Bazel migration for service module

service/BUILD.bazel

@@ -0,0 +1,63 @@
+vertx_deps = [
+    maven_artifact("io.vertx:vertx-core"),
+    maven_artifact("io.vertx:vertx-web"),
+    maven_artifact("io.vertx:vertx-web-client"),
+    maven_artifact("io.vertx:vertx-config"),
+    maven_artifact("io.vertx:vertx-micrometer-metrics"),
+]
+
+vertx_test_deps = [
+    # Libraries
+    maven_artifact("io.vertx:vertx-core"),
+    maven_artifact("io.vertx:vertx-web"),
+    maven_artifact("io.vertx:vertx-web-client"),
+    # Testing
+    maven_artifact("io.vertx:vertx-junit5"),
+    maven_artifact("io.vertx:vertx-unit"),
+]
+
+java_library(
+    name = "lib",
+    srcs = glob(["src/main/**/*.java"]),
+    visibility = ["//visibility:public"],
+    deps = _SCALA_DEPS + vertx_deps + [
+        "//online:lib",
+        "//service_commons:lib",
+        maven_artifact("ch.qos.logback:logback-classic"),
+        maven_artifact("com.typesafe:config"),
+        maven_artifact("io.netty:netty-all"),
+        maven_artifact("io.micrometer:micrometer-registry-statsd"),
+        maven_artifact("io.micrometer:micrometer-core"),
+        maven_artifact("com.fasterxml.jackson.core:jackson-annotations"),
+        maven_artifact("com.fasterxml.jackson.core:jackson-core"),
+        maven_artifact("com.fasterxml.jackson.core:jackson-databind"),
+        maven_artifact("org.slf4j:slf4j-api"),
+        scala_artifact("org.json4s:json4s-core"),
+    ],
+)
+
+test_deps = vertx_test_deps + [
+    ":lib",
+    "//online:lib",
+    "//service_commons:lib",
+    maven_artifact("org.mockito:mockito-core"),
+    maven_artifact("org.junit.jupiter:junit-jupiter-api"),
+    maven_artifact("junit:junit"),
+    maven_artifact("org.junit.platform:junit-platform-launcher"),
+    maven_artifact("org.junit.platform:junit-platform-reporting"),
+]
+
+java_library(
+    name = "test-lib",
+    srcs = glob(["src/test/**/*.java"]),
+    visibility = ["//visibility:public"],
+    deps = test_deps,
+)
+
+java_test_suite(
+    name = "test",
+    srcs = glob(["src/test/**/*.java"]),
+    visibility = ["//visibility:public"],
+    runner = "junit5",
+    deps = test_deps + [":test-lib"],
+)

service/src/test/java/ai/chronon/service/handlers/FetchHandlerTest.java

@@ -75,11 +75,11 @@ public void testSuccessfulSingleRequest(TestContext context) {
 
         Map<String, Object> keys = Collections.singletonMap("user_id", "123");
         JavaRequest request = new JavaRequest(TEST_GROUP_BY, keys);
-        Map<String, Object> featureMap = new HashMap<String, Object>() {{
-            put("feature_1", 12);
-            put("feature_2", 23.3);
-            put("feature_3", "USD");
-        }};
+        Map<String, Object> featureMap = Map.of(
+            "feature_1", 12,
+            "feature_2", 23.3,
+            "feature_3", "USD"
+        );
         JTry<Map<String, Object>> values = JTry.success(featureMap);
         JavaResponse mockResponse = new JavaResponse(request, values);
 
@@ -177,27 +177,27 @@ public void testSuccessfulMultipleRequests(TestContext context) {
         Map<String, Object> keys2 = Collections.singletonMap("user_id", "456");
         JavaRequest request2 = new JavaRequest(TEST_GROUP_BY, keys2);
 
-        Map<String, Object> featureMap1 = new HashMap<String, Object>() {{
-            put("feature_1", 12);
-            put("feature_2", 23.3);
-            put("feature_3", "USD");
-        }};
+        Map<String, Object> featureMap1 = Map.of(
+            "feature_1", 12,
+            "feature_2", 23.3,
+            "feature_3", "USD"
+        );
 
-        Map<String, Object> featureMap2 = new HashMap<String, Object>() {{
-            put("feature_1", 24);
-            put("feature_2", 26.3);
-            put("feature_3", "CAD");
-        }};
+        Map<String, Object> featureMap2 = Map.of(
+            "feature_1", 24,
+            "feature_2", 26.3,
+            "feature_3", "CAD"
+        );
 
         JTry<Map<String, Object>> values1 = JTry.success(featureMap1);
         JTry<Map<String, Object>> values2 = JTry.success(featureMap2);
         JavaResponse mockResponse1 = new JavaResponse(request1, values1);
         JavaResponse mockResponse2 = new JavaResponse(request2, values2);
 
-        List<JavaResponse> mockResponseList = new ArrayList<JavaResponse>() {{
-            add(mockResponse1);
-            add(mockResponse2);
-        }};
+        List<JavaResponse> mockResponseList = List.of(
+            mockResponse1,
+            mockResponse2
+        );
         CompletableFuture<List<JavaResponse>> futureResponse =
                 CompletableFuture.completedFuture(mockResponseList);
         when(mockFetcher.fetchJoin(anyList())).thenReturn(futureResponse);
@@ -219,10 +219,10 @@ public void testSuccessfulMultipleRequests(TestContext context) {
             GetFeaturesResponse.Result expectedResult1 = GetFeaturesResponse.Result.builder().status(Success).entityKeys(keys1).features(featureMap1).build();
             GetFeaturesResponse.Result expectedResult2 = GetFeaturesResponse.Result.builder().status(Success).entityKeys(keys2).features(featureMap2).build();
 
-            List<GetFeaturesResponse.Result> expectedResultList = new ArrayList<GetFeaturesResponse.Result>() {{
-                add(expectedResult1);
-                add(expectedResult2);
-            }};
+            List<GetFeaturesResponse.Result> expectedResultList = List.of(
+                expectedResult1,
+                expectedResult2
+            );
             validateSuccessfulResponse(actualResponse, expectedResultList, context);
             async.complete();
         });
@@ -242,21 +242,21 @@ public void testPartialSuccessfulRequests(TestContext context) {
         Map<String, Object> keys2 = Collections.singletonMap("user_id", "456");
         JavaRequest request2 = new JavaRequest(TEST_GROUP_BY, keys2);
 
-        Map<String, Object> featureMap = new HashMap<String, Object>() {{
-            put("feature_1", 12);
-            put("feature_2", 23.3);
-            put("feature_3", "USD");
-        }};
+        Map<String, Object> featureMap = Map.of(
+            "feature_1", 12,
+            "feature_2", 23.3,
+            "feature_3", "USD"
+        );
 
         JTry<Map<String, Object>> values1 = JTry.success(featureMap);
         JTry<Map<String, Object>> values2 = JTry.failure(new RuntimeException("some failure!"));
         JavaResponse mockResponse1 = new JavaResponse(request1, values1);
         JavaResponse mockResponse2 = new JavaResponse(request2, values2);
 
-        List<JavaResponse> mockResponseList = new ArrayList<JavaResponse>() {{
-            add(mockResponse1);
-            add(mockResponse2);
-        }};
+        List<JavaResponse> mockResponseList = List.of(
+                mockResponse1,
+                mockResponse2
+        );
         CompletableFuture<List<JavaResponse>> futureResponse =
                 CompletableFuture.completedFuture(mockResponseList);
         when(mockFetcher.fetchJoin(anyList())).thenReturn(futureResponse);
@@ -277,10 +277,10 @@ public void testPartialSuccessfulRequests(TestContext context) {
             JsonObject actualResponse = new JsonObject(responseCaptor.getValue());
             GetFeaturesResponse.Result expectedResult1 = GetFeaturesResponse.Result.builder().status(Success).entityKeys(keys1).features(featureMap).build();
             GetFeaturesResponse.Result expectedResult2 = GetFeaturesResponse.Result.builder().status(Failure).entityKeys(keys2).error("some failure!").build();
-            List<GetFeaturesResponse.Result> expectedResultList = new ArrayList<GetFeaturesResponse.Result>() {{
-               add(expectedResult1);
-               add(expectedResult2);
-            }};
+            List<GetFeaturesResponse.Result> expectedResultList = List.of(
+                    expectedResult1,
+                    expectedResult2
+            );
             validateSuccessfulResponse(actualResponse, expectedResultList, context);
             async.complete();;
         });

tools/build_rules/dependencies/maven_repository.bzl

@@ -89,6 +89,7 @@ maven_repository = repository(
         "io.vertx:vertx-config:4.5.10",
         "io.vertx:vertx-micrometer-metrics:4.5.10",
         "io.vertx:vertx-junit5:4.5.10",
+        "io.vertx:vertx-unit:4.5.10",
     ],
     overrides = {
     },