feat: add IcebergConfigurationService

Author: nryanov

.gitignore

@@ -7,3 +7,4 @@ target/
 *.iml
 .bsp
 .DS_Store
+stash/

modules/catalog/catalog-iceberg/src/main/java/kasanari/catalog/iceberg/IcebergCatalogConfigurationService.java

@@ -0,0 +1,51 @@
+package kasanari.catalog.iceberg;
+
+import org.apache.iceberg.rest.Endpoint;
+import org.apache.iceberg.rest.responses.ConfigResponse;
+
+import java.util.List;
+
+public class IcebergCatalogConfigurationService {
+    private final List<Endpoint> endpoints;
+
+    public IcebergCatalogConfigurationService() {
+        endpoints = List.of(
+                // namespace
+                Endpoint.V1_CREATE_NAMESPACE,
+                Endpoint.V1_DELETE_NAMESPACE,
+                Endpoint.V1_LIST_NAMESPACES,
+                Endpoint.V1_LOAD_NAMESPACE,
+                Endpoint.V1_NAMESPACE_EXISTS,
+                Endpoint.V1_UPDATE_NAMESPACE,
+                // table
+                Endpoint.V1_CREATE_TABLE,
+                Endpoint.V1_DELETE_TABLE,
+                Endpoint.V1_LIST_TABLES,
+                Endpoint.V1_LOAD_TABLE,
+                Endpoint.V1_REGISTER_TABLE,
+                Endpoint.V1_RENAME_TABLE,
+                Endpoint.V1_UPDATE_TABLE,
+                Endpoint.V1_TABLE_EXISTS,
+                // view
+                Endpoint.V1_CREATE_VIEW,
+                Endpoint.V1_DELETE_VIEW,
+                Endpoint.V1_LIST_VIEWS,
+                Endpoint.V1_LOAD_VIEW,
+                Endpoint.V1_UPDATE_VIEW,
+                Endpoint.V1_RENAME_VIEW,
+                Endpoint.V1_VIEW_EXISTS,
+                // transactions
+                Endpoint.V1_COMMIT_TRANSACTION,
+                // other
+                Endpoint.V1_REPORT_METRICS
+        );
+    }
+
+    public ConfigResponse getConfig(String warehouse) {
+        return ConfigResponse
+                .builder()
+                .withEndpoints(endpoints)
+                .withOverride("prefix", warehouse)
+                .build();
+    }
+}

modules/catalog/catalog-lance/build.gradle.kts

@@ -27,6 +27,8 @@ dependencies {
         exclude(group = "org.apache.hive", module = "hive-service")
         exclude(group = "org.apache.hive", module = "hive-llap-server")
         exclude(group = "org.apache.hive", module = "hive-exec")
+        exclude(group = "asm")
+        exclude(group = "org.ow2.asm", module = "asm-all")
     }
 
     // test

modules/server/build.gradle.kts

@@ -19,6 +19,7 @@ dependencies {
     implementation(project(":modules:catalog:catalog-paimon"))
     // lance
     implementation(project(":modules:api:api-lance"))
+    implementation(project(":modules:catalog:catalog-lance"))
     // management
     implementation(project(":modules:api:api-management"))
     implementation(project(":modules:management:management-catalog"))

modules/server/src/main/java/kasanari/server/bootstrap/IcebergCatalogBeans.java

@@ -0,0 +1,15 @@
+package kasanari.server.bootstrap;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.inject.Produces;
+import jakarta.inject.Singleton;
+import kasanari.catalog.iceberg.IcebergCatalogConfigurationService;
+
+@ApplicationScoped
+public class IcebergCatalogBeans {
+    @Singleton
+    @Produces
+    IcebergCatalogConfigurationService icebergCatalogConfigurationService() {
+        return new IcebergCatalogConfigurationService();
+    }
+}

modules/server/src/main/java/kasanari/server/bootstrap/LanceCatalogBeans.java

@@ -0,0 +1,4 @@
+package kasanari.server.bootstrap;
+
+public class LanceCatalogBeans {
+}

modules/server/src/main/java/kasanari/server/bootstrap/PaimonCatalogBeans.java

@@ -0,0 +1,4 @@
+package kasanari.server.bootstrap;
+
+public class PaimonCatalogBeans {
+}

modules/server/src/main/java/kasanari/server/infrastructure/iceberg/IcebergConfigurationServiceHandler.java

@@ -3,13 +3,19 @@
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.ws.rs.core.Response;
 import jakarta.ws.rs.core.SecurityContext;
+import kasanari.catalog.iceberg.IcebergCatalogConfigurationService;
 import kasanari.catalog.iceberg.api.IcebergRestConfigurationApiService;
-import kasanari.server.infrastructure.http.ApiFallbacks;
 
 @ApplicationScoped
 public class IcebergConfigurationServiceHandler implements IcebergRestConfigurationApiService {
+    private final IcebergCatalogConfigurationService configurationService;
+
+    public IcebergConfigurationServiceHandler(IcebergCatalogConfigurationService configurationService) {
+        this.configurationService = configurationService;
+    }
+
     @Override
     public Response getConfig(String warehouse, SecurityContext securityContext) {
-        return ApiFallbacks.notImplemented("IcebergConfigurationService.getConfig");
+        return Response.ok().entity(configurationService.getConfig(warehouse)).build();
     }
 }