wip

Author: phearnot

.github/workflows/check-pr.yml

@@ -50,14 +50,14 @@ jobs:
       - name: Run tests
         run: |
           forge --version
-          sbt --batch "scalafmtCheck;test;docker;consensus-client-it/test"
+          sbt --no-colors --batch "scalafmtCheck;test;docker;consensus-client-it/test"
         env:
           RUN_ID: ${{ github.head_ref }}-${{ github.run_number }}-${{ github.run_attempt }}
       - uses: scacap/action-surefire-report@5609ce4db72c09db044803b344a8968fd1f315da
         if: always()
         with:
           report_paths: '**/target/test-reports/*.xml'
-          create_check: false
+          create_check: true
           check_name: 'Check PR'
       - name: Archive logs
         uses: actions/upload-artifact@v4

build.sbt

@@ -1,7 +1,29 @@
 import com.github.sbt.git.SbtGit.GitKeys.gitCurrentBranch
+import sbt.Def
+import sbt.internal.RelayAppender
+import sbt.util.Level
 
 enablePlugins(UniversalDeployPlugin, GitVersioning, sbtdocker.DockerPlugin, VersionObject)
 
+extraAppenders := {
+  extraAppenders.value
+
+  (s: Def.ScopedKey[?]) =>
+    new RelayAppender("RELAY") {
+      override def appendLog(level: Level.Value, message: => String): Unit = {
+        if (level >= Level.Warn) {
+          println(s)
+          val lines = message.split("\n")
+          if (lines.length > 1)
+            println(s"::$level file=,title=${lines(0)}::${lines.tail.mkString("%0A")}")
+          else
+            println(s"::$level::$message")
+        }
+        super.appendLog(level, message)
+      }
+    } +: extraAppenders.value(s)
+}
+
 git.useGitDescribe       := true
 git.baseVersion          := "1.1.0"
 git.uncommittedSignifier := Some("DIRTY")

src/main/scala/units/ELUpdater.scala

@@ -71,7 +71,7 @@ class ELUpdater(
   def executionBlockReceived(block: NetworkL2Block, ch: Channel): Unit = scheduler.execute { () =>
     logger.debug(s"New block ${block.hash}->${block.parentHash} (timestamp=${block.timestamp}, height=${block.height}) appeared")
 
-    val now = time.correctedTime() / 1000
+    val now = time.correctedTime() /\ 1000
     if (block.timestamp - now <= MaxTimeDrift) {
       state match {
         case WaitingForSyncHead(target, _) if block.hash == target.hash =>