Initialise single node cluster if there are configured seed nodes

misp/connector/src/main/scala/org/thp/thehive/connector/misp/services/MispActor.scala

@@ -1,15 +1,13 @@
 package org.thp.thehive.connector.misp.services
 
-import scala.concurrent.Future
-import scala.util.{Failure, Success, Try}
-
-import play.api.Logger
-
 import akka.actor.{Actor, ActorRef, ActorSystem, Cancellable}
-import akka.cluster.Cluster
 import akka.cluster.singleton.{ClusterSingletonProxy, ClusterSingletonProxySettings}
 import javax.inject.{Inject, Named, Provider}
 import org.thp.scalligraph.auth.UserSrv
+import play.api.Logger
+
+import scala.concurrent.Future
+import scala.util.{Failure, Success, Try}
 
 object MispActor {
   case object Synchro
@@ -61,17 +59,11 @@ class MispActor @Inject() (
 }
 
 class MispActorProvider @Inject() (system: ActorSystem, @Named("misp-actor-singleton") mispActorSingleton: ActorRef) extends Provider[ActorRef] {
-  lazy val logger: Logger = Logger(getClass)
-  override def get(): ActorRef = {
-    val cluster = Cluster(system)
-    logger.info("Initialising cluster")
-    cluster.join(mispActorSingleton.path.address)
-    logger.info(s"cluster members are ${cluster.state.members}")
+  override def get(): ActorRef =
     system.actorOf(
       ClusterSingletonProxy.props(
         singletonManagerPath = mispActorSingleton.path.toStringWithoutAddress,
         settings = ClusterSingletonProxySettings(system)
       )
     )
-  }
 }

thehive/app/org/thp/thehive/ClusterSetup.scala

@@ -1,3 +1,15 @@
-package org.thp.thehive class ClusterSetup {
+package org.thp.thehive
 
+import akka.actor.ActorSystem
+import akka.cluster.Cluster
+import javax.inject.Inject
+import play.api.{Configuration, Logger}
+
+class ClusterSetup @Inject() (configuration: Configuration, system: ActorSystem) {
+  lazy val logger: Logger = Logger(getClass)
+  if (configuration.get[Seq[String]]("akka.cluster.seed-nodes").isEmpty) {
+    val cluster = Cluster(system)
+    logger.info("Initialising cluster")
+    cluster.join(cluster.system.provider.getDefaultAddress)
+  }
 }

thehive/app/org/thp/thehive/TheHiveModule.scala

@@ -87,6 +87,7 @@ class TheHiveModule(environment: Environment, configuration: Configuration) exte
     bindActor[NotificationActor]("notification-actor")
 
     bind[SchemaUpdater].asEagerSingleton()
+    bind[ClusterSetup].asEagerSingleton()
     ()
   }
 }