Add clique counting in compute facade

Author: IoannisPanagiotas

algo/src/main/java/org/neo4j/gds/cliqueCounting/CliqueCountingResult.java

@@ -25,4 +25,7 @@ public record CliqueCountingResult(
     long[] globalCount,
     HugeObjectArray<long[]> perNodeCount,
     long[][] perSubcliqueCount
-){}
+){
+
+    public static CliqueCountingResult EMPTY = new CliqueCountingResult(new long[0], HugeObjectArray.newArray(long[].class,0), new long[0][0]);
+}

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

@@ -26,6 +26,9 @@
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutParameters;
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutResult;
 import org.neo4j.gds.async.AsyncAlgorithmCaller;
+import org.neo4j.gds.cliqueCounting.CliqueCounting;
+import org.neo4j.gds.cliqueCounting.CliqueCountingResult;
+import org.neo4j.gds.cliquecounting.CliqueCountingParameters;
 import org.neo4j.gds.core.concurrency.DefaultPool;
 import org.neo4j.gds.core.utils.progress.JobId;
 import org.neo4j.gds.result.TimedAlgorithmResult;
@@ -90,6 +93,37 @@ public CompletableFuture<TimedAlgorithmResult<ApproxMaxKCutResult>> approxMaxKCu
         );
     }
 
+    CompletableFuture<TimedAlgorithmResult<CliqueCountingResult>> cliqueCounting(
+        Graph graph,
+        CliqueCountingParameters parameters,
+        JobId jobId,
+        boolean logProgress
+    ) {
+
+        if (graph.isEmpty()) {
+            return CompletableFuture.completedFuture(TimedAlgorithmResult.empty(CliqueCountingResult.EMPTY));
+        }
+
+        var progressTracker = progressTrackerFactory.create(
+            tasks.cliqueCounting(graph, parameters),
+            jobId,
+            parameters.concurrency(),
+            logProgress
+        );
 
+        var algorithm = CliqueCounting.create(
+            graph,
+            parameters,
+            DefaultPool.INSTANCE,
+            progressTracker,
+            terminationFlag
+        );
+
+        return algorithmCaller.run(
+            algorithm::compute,
+            jobId
+        );
+
+    }
 
 }

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

@@ -29,9 +29,15 @@
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutParameters;
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutResult;
 import org.neo4j.gds.async.AsyncAlgorithmCaller;
+import org.neo4j.gds.cliqueCounting.CliqueCountingResult;
+import org.neo4j.gds.cliquecounting.CliqueCountingMode;
+import org.neo4j.gds.cliquecounting.CliqueCountingParameters;
+import org.neo4j.gds.core.concurrency.Concurrency;
 import org.neo4j.gds.core.utils.progress.JobId;
 import org.neo4j.gds.termination.TerminationFlag;
 
+import java.util.List;
+
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verifyNoInteractions;
@@ -78,5 +84,25 @@ void maxKCut() {
         verifyNoInteractions(algorithmCallerMock);
     }
 
+    @Test
+    void cliqueCounting(){
+        var future = facade.cliqueCounting(
+            graph,
+            new CliqueCountingParameters(
+                CliqueCountingMode.GloballyOnly,
+                List.of(),
+                new Concurrency(4)
+            ),
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result()).isEqualTo(CliqueCountingResult.EMPTY);
+        verifyNoInteractions(progressTrackerFactoryMock);
+        verifyNoInteractions(algorithmCallerMock);
+    }
+
 
 }

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

@@ -28,6 +28,8 @@
 import org.neo4j.gds.ProgressTrackerFactory;
 import org.neo4j.gds.approxmaxkcut.ApproxMaxKCutParameters;
 import org.neo4j.gds.async.AsyncAlgorithmCaller;
+import org.neo4j.gds.cliquecounting.CliqueCountingMode;
+import org.neo4j.gds.cliquecounting.CliqueCountingParameters;
 import org.neo4j.gds.core.concurrency.Concurrency;
 import org.neo4j.gds.core.utils.progress.JobId;
 import org.neo4j.gds.core.utils.progress.tasks.ProgressTracker;
@@ -116,4 +118,23 @@ void maxKCut() {
         assertThat(results.computeMillis()).isNotNegative();
 
     }
+
+    @Test
+    void cliqueCounting(){
+        var future = facade.cliqueCounting(
+            graph,
+            new CliqueCountingParameters(
+              CliqueCountingMode.GloballyOnly,
+                List.of(),
+                new Concurrency(4)
+            ),
+            jobIdMock,
+            false
+        );
+
+        var results = future.join();
+
+        assertThat(results.result().globalCount()).containsExactly(1);
+        assertThat(results.computeMillis()).isNotNegative();
+    }
 }