Add k1coloring in compute facade

Author: IoannisPanagiotas

algo/src/main/java/org/neo4j/gds/CommunityAlgorithmTasks.java

@@ -28,7 +28,7 @@
 import org.neo4j.gds.core.utils.progress.tasks.Task;
 import org.neo4j.gds.core.utils.progress.tasks.Tasks;
 import org.neo4j.gds.hdbscan.HDBScanProgressTrackerCreator;
-import org.neo4j.gds.k1coloring.K1ColoringBaseConfig;
+import org.neo4j.gds.k1coloring.K1ColoringParameters;
 import org.neo4j.gds.k1coloring.K1ColoringProgressTrackerTaskCreator;
 import org.neo4j.gds.kmeans.KMeansTaskFactory;
 import org.neo4j.gds.kmeans.KmeansParameters;
@@ -70,10 +70,10 @@ public Task hdbscan(Graph graph) {
         return HDBScanProgressTrackerCreator.hdbscanTask(AlgorithmLabel.HDBScan.asString(), graph.nodeCount());
     }
 
-    public Task k1Coloring(Graph graph, K1ColoringBaseConfig configuration) {
+    public Task k1Coloring(Graph graph, K1ColoringParameters parameters) {
         return K1ColoringProgressTrackerTaskCreator.progressTask(
             graph.nodeCount(),
-            configuration.maxIterations()
+            parameters.maxIterations()
         );
     }
 

algo/src/main/java/org/neo4j/gds/k1coloring/K1ColoringResult.java

@@ -39,4 +39,6 @@ public BitSet usedColors() {
         return usedColors;
     }
 
+    public static  K1ColoringResult EMPTY = new K1ColoringResult(HugeLongArray.newArray(0),0, false);
+
 }

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

@@ -37,6 +37,9 @@
 import org.neo4j.gds.hdbscan.HDBScan;
 import org.neo4j.gds.hdbscan.HDBScanParameters;
 import org.neo4j.gds.hdbscan.Labels;
+import org.neo4j.gds.k1coloring.K1Coloring;
+import org.neo4j.gds.k1coloring.K1ColoringParameters;
+import org.neo4j.gds.k1coloring.K1ColoringResult;
 import org.neo4j.gds.result.TimedAlgorithmResult;
 import org.neo4j.gds.termination.TerminationFlag;
 
@@ -196,4 +199,36 @@ CompletableFuture<TimedAlgorithmResult<Labels>> hdbscan(
             jobId
         );
     }
+
+    CompletableFuture<TimedAlgorithmResult<K1ColoringResult>> k1Coloring(
+        Graph graph,
+        K1ColoringParameters parameters,
+        JobId jobId,
+        boolean logProgress
+    ) {
+
+        if (graph.isEmpty()) {
+            return CompletableFuture.completedFuture(TimedAlgorithmResult.empty(K1ColoringResult.EMPTY));
+        }
+
+        var progressTracker = progressTrackerFactory.create(
+            tasks.k1Coloring(graph, parameters),
+            jobId,
+            parameters.concurrency(),
+            logProgress
+        );
+
+        var algorithm = new K1Coloring(
+            graph,
+            parameters,
+            DefaultPool.INSTANCE,
+            progressTracker,
+            terminationFlag
+        );
+
+        return algorithmCaller.run(
+            algorithm::compute,
+            jobId
+        );
+    }
 }

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

@@ -36,6 +36,8 @@
 import org.neo4j.gds.core.utils.progress.JobId;
 import org.neo4j.gds.hdbscan.HDBScanParameters;
 import org.neo4j.gds.hdbscan.Labels;
+import org.neo4j.gds.k1coloring.K1ColoringParameters;
+import org.neo4j.gds.k1coloring.K1ColoringResult;
 import org.neo4j.gds.termination.TerminationFlag;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -133,4 +135,21 @@ void hdbscan(){
         verifyNoInteractions(algorithmCallerMock);
     }
 
+    @Test
+    void k1Coloring(){
+
+        var future = facade.k1Coloring(
+            graph,
+            mock(K1ColoringParameters.class),
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result()).isEqualTo(K1ColoringResult.EMPTY);
+        verifyNoInteractions(progressTrackerFactoryMock);
+        verifyNoInteractions(algorithmCallerMock);
+    }
+
 }

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

@@ -40,6 +40,7 @@
 import org.neo4j.gds.extension.Inject;
 import org.neo4j.gds.extension.TestGraph;
 import org.neo4j.gds.hdbscan.HDBScanParameters;
+import org.neo4j.gds.k1coloring.K1ColoringParameters;
 import org.neo4j.gds.logging.Log;
 import org.neo4j.gds.termination.TerminationFlag;
 
@@ -180,4 +181,23 @@ void hdbscan(){
         assertThat(results.result().labels().toArray()).hasSize(3);
         assertThat(results.computeMillis()).isNotNegative();
     }
+
+    @Test
+    void k1Coloring(){
+        var future = facade.k1Coloring(
+            graph,
+            new K1ColoringParameters(
+                new Concurrency(4),
+                1,
+                10_000
+            ),
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result().ranIterations()).isGreaterThan(0);
+        assertThat(results.computeMillis()).isNotNegative();
+    }
 }

applications/algorithms/community/src/main/java/org/neo4j/gds/applications/algorithms/community/CommunityAlgorithmsBusinessFacade.java

@@ -124,10 +124,11 @@ public Labels hdbscan(Graph graph, HDBScanBaseConfig configuration) {
     }
 
     public K1ColoringResult k1Coloring(Graph graph, K1ColoringBaseConfig configuration) {
-        var task = tasks.k1Coloring(graph, configuration);
-        var progressTracker = progressTrackerCreator.createProgressTracker(task, configuration);
         var params = configuration.toParameters();
 
+        var task = tasks.k1Coloring(graph, params);
+        var progressTracker = progressTrackerCreator.createProgressTracker(task, configuration);
+
         return algorithmMachinery.getResult(
             () -> algorithms.k1Coloring(graph, params, progressTracker),
             progressTracker,