Add sllpa in compute facade

Author: IoannisPanagiotas

algorithms-compute-facade/build.gradle

@@ -9,14 +9,17 @@ dependencies {
     implementation project(':algo')
     implementation project(':algo-common')
     implementation project(':collections')
+    implementation project(":community-configs")
     implementation project(':community-params')
+    implementation project(":config-api")
     implementation project(':core')
     implementation project(':core-api')
     implementation project(':logging')
     implementation project(':ml-core')
     implementation project(':node-embeddings-params')
     implementation project(':path-finding-algorithms')
     implementation project(':path-finding-params')
+    implementation project(":pregel")
     implementation project(':progress-tracking')
     implementation project(':termination')
 

algorithms-compute-facade/src/main/java/org/neo4j/gds/community/CommunityComputeFacade.java

@@ -27,6 +27,8 @@
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutParameters;
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutResult;
 import org.neo4j.gds.async.AsyncAlgorithmCaller;
+import org.neo4j.gds.beta.pregel.ImmutablePregelResult;
+import org.neo4j.gds.beta.pregel.PregelResult;
 import org.neo4j.gds.cliqueCounting.CliqueCounting;
 import org.neo4j.gds.cliqueCounting.CliqueCountingResult;
 import org.neo4j.gds.cliquecounting.CliqueCountingParameters;
@@ -71,6 +73,8 @@
 import org.neo4j.gds.result.TimedAlgorithmResult;
 import org.neo4j.gds.scc.Scc;
 import org.neo4j.gds.scc.SccParameters;
+import org.neo4j.gds.sllpa.SpeakerListenerLPA;
+import org.neo4j.gds.sllpa.SpeakerListenerLPAConfig;
 import org.neo4j.gds.termination.TerminationFlag;
 import org.neo4j.gds.triangle.IntersectingTriangleCount;
 import org.neo4j.gds.triangle.LocalClusteringCoefficient;
@@ -600,7 +604,7 @@ CompletableFuture<TimedAlgorithmResult<DisjointSetStruct>> wcc(
     ) {
 
         if (graph.isEmpty()) {
-            return CompletableFuture.completedFuture(TimedAlgorithmResult.empty( new HugeAtomicDisjointSetStruct(0 , new Concurrency(1))));
+            return CompletableFuture.completedFuture(TimedAlgorithmResult.empty(new HugeAtomicDisjointSetStruct(0, new Concurrency(1))));
         }
 
         var progressTracker = progressTrackerFactory.create(
@@ -624,5 +628,36 @@ CompletableFuture<TimedAlgorithmResult<DisjointSetStruct>> wcc(
             jobId
         );
     }
+    CompletableFuture<TimedAlgorithmResult<PregelResult>> sllpa(
+        Graph graph,
+        SpeakerListenerLPAConfig configuration,
+        JobId jobId,
+        boolean logProgress
+    ) {
+
+        if (graph.isEmpty()) {
+            return CompletableFuture.completedFuture(TimedAlgorithmResult.empty(ImmutablePregelResult.of(null, 0, false)));
+        }
+
+        var progressTracker = progressTrackerFactory.create(
+            tasks.speakerListenerLPA(graph,configuration),
+            jobId,
+            configuration.concurrency(),
+            logProgress
+        );
+
+        var algorithm = new SpeakerListenerLPA(
+            graph,
+            configuration,
+            DefaultPool.INSTANCE,
+            progressTracker,
+            Optional.empty()
+        );
+
+        return algorithmCaller.run(
+            algorithm::compute,
+            jobId
+        );
+    }
 
 }

algorithms-compute-facade/src/test/java/org/neo4j/gds/community/CommunityComputeFacadeEmptyGraphTest.java

@@ -52,6 +52,7 @@
 import org.neo4j.gds.modularityoptimization.ModularityOptimizationParameters;
 import org.neo4j.gds.modularityoptimization.ModularityOptimizationResult;
 import org.neo4j.gds.scc.SccParameters;
+import org.neo4j.gds.sllpa.SpeakerListenerLPAConfig;
 import org.neo4j.gds.termination.TerminationFlag;
 import org.neo4j.gds.triangle.LocalClusteringCoefficientParameters;
 import org.neo4j.gds.triangle.LocalClusteringCoefficientResult;
@@ -361,4 +362,21 @@ void wcc(){
         verifyNoInteractions(algorithmCallerMock);
     }
 
+    @Test
+    void sllpa(){
+
+        var future = facade.sllpa(
+            graph,
+            mock(SpeakerListenerLPAConfig.class),
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result().ranIterations()).isEqualTo(0L);
+        verifyNoInteractions(progressTrackerFactoryMock);
+        verifyNoInteractions(algorithmCallerMock);
+    }
+
 }

algorithms-compute-facade/src/test/java/org/neo4j/gds/community/CommunityComputeFacadeTest.java

@@ -51,6 +51,7 @@
 import org.neo4j.gds.modularity.ModularityParameters;
 import org.neo4j.gds.modularityoptimization.ModularityOptimizationParameters;
 import org.neo4j.gds.scc.SccParameters;
+import org.neo4j.gds.sllpa.SpeakerListenerLPAConfigImpl;
 import org.neo4j.gds.termination.TerminationFlag;
 import org.neo4j.gds.triangle.LocalClusteringCoefficientParameters;
 import org.neo4j.gds.triangle.TriangleCountParameters;
@@ -434,4 +435,22 @@ void wcc(){
         assertThat(results.computeMillis()).isNotNegative();
     }
 
+    @Test
+    void sllpa(){
+
+        var config = SpeakerListenerLPAConfigImpl.builder().concurrency(4).minAssociationStrength(0.00).maxIterations(10).build();
+
+        var future = facade.sllpa(
+            graph,
+            config,
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result().ranIterations()).isGreaterThan(0);
+        assertThat(results.computeMillis()).isNotNegative();
+    }
+
 }