#1398 Use a dedicated threadpool for MISP synchronization

thehive-misp/app/connectors/misp/MispSynchro.scala

@@ -35,12 +35,18 @@ class MispSynchro @Inject()(
     tempSrv: TempSrv,
     lifecycle: ApplicationLifecycle,
     system: ActorSystem,
-    implicit val ec: ExecutionContext,
     implicit val mat: Materializer
 ) {
 
   private[misp] lazy val logger   = Logger(getClass)
   private[misp] lazy val alertSrv = alertSrvProvider.get
+  implicit val ec: ExecutionContext = try {
+    system.dispatchers.lookup("misp-thread-pools")
+  } catch {
+    case e: Throwable =>
+      logger.warn(s"Unable to use MISP specific dispatcher ($e). Fallback  to default dispatcher")
+      system.dispatcher
+  }
 
   private[misp] def initScheduler(): Unit = {
     val task = system.scheduler.scheduleWithFixedDelay(0.seconds, mispConfig.interval) {() =>

thehive-misp/conf/reference.conf

@@ -25,3 +25,14 @@ misp {
   # Interval between two MISP event import
   interval = 1h
 }
+
+misp-thread-pool {
+  fork-join-executor {
+    # Min number of threads available for MISP synchronization
+    parallelism-min = 2
+    # Parallelism (threads) ... ceil(available processors * factor)
+    parallelism-factor = 2.0
+    # Max number of threads available for MISP synchronization
+    parallelism-max = 4
+  }
+}