small change for lorre not quiting after encountering an error (#961)

conseil-common/src/main/resources/reference.conf

@@ -207,6 +207,10 @@ akka {
  # give more room for async response in head-of-line blocking on the same connection or other slow responses
  response-entity-subscription-timeout: 60 seconds
  }
+
+ # fixes the issue when lorre does not quit after system.shutdown()
+ coordinated-shutdown.run-by-actor-system-terminate = off
+
 }
 
 # Custom libSodium settings

conseil-lorre/src/main/scala/tech/cryptonomic/conseil/indexer/tezos/TezosIndexer.scala

@@ -231,12 +231,18 @@ class TezosIndexer private (
 
  override def start(): Unit = {
  checkTezosConnection()
- val accountResetsToHandle =
- Await.result(
- accountsResetHandler.unprocessedResetRequestLevels(lorreConf.chainEvents),
- atMost = 5.seconds
- )
- mainLoop(0, accountResetsToHandle)
+ Await.result(
+ accountsResetHandler
+ .unprocessedResetRequestLevels(lorreConf.chainEvents)
+ .transform(
+ accountResets => mainLoop(0, accountResets),
+ error => {
+ logger.error("Could not get the unprocessed events block levels for this chain network", error)
+ error
+ }
+ ),
+ Duration.Inf
+ )
  }
 
  override def stop(): Future[ShutdownComplete] = terminationSequence()

project/Dependencies.scala

@@ -7,7 +7,7 @@ object Dependencies {
  val pureConfig = "0.10.2"
  val scopt = "4.0.0-RC2"
 
- val akka = "2.6.3"
+ val akka = "2.6.11"
  val akkaHttp = "10.2.1"
  val akkaHttpJson = "1.35.2"
  val akkaHttpCors = "1.1.0"