Test Fixes

treeverse · Feb 26, 2024 · d589250 · d589250
1 parent f86dcad
commit d589250
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/src/main/java/io/lakefs/iceberg/rest/LakeFSCatalog.java b/src/main/java/io/lakefs/iceberg/rest/LakeFSCatalog.java
@@ -75,6 +75,7 @@ public void initialize(String name, Map<String, String> properties) {
         catalogName = name;
         warehouseLocation = WAREHOUSE_LOCATION;
         suppressPermissionError = Boolean.parseBoolean(properties.get(HADOOP_SUPPRESS_PERMISSION_ERROR));
+        // TODO (niro): Future - create a caching mechanism for FileSystem Initialization per repo
     }
 
     @Override

diff --git a/src/test/java/io/lakefs/iceberg/rest/TestLakeFSFileIO.java b/src/test/java/io/lakefs/iceberg/rest/TestLakeFSFileIO.java
@@ -5,6 +5,10 @@
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
+import org.mockserver.matchers.Times;
+import static org.mockserver.model.HttpResponse.response;
+
+import io.lakefs.clients.sdk.model.StorageConfig;
 
 public class TestLakeFSFileIO extends FSTestBase {
 
@@ -15,6 +19,21 @@ public class TestLakeFSFileIO extends FSTestBase {
 
     @Before
     public void setUp(){
+        // lakeFSFS initialization requires a blockstore.
+        mockServerClient.when(request()
+                                .withMethod("GET")
+                                .withPath("/config/storage"), 
+                        Times.unlimited())
+                .respond(response()
+                        .withStatusCode(200)
+                        .withBody(gson.toJson(new StorageConfig()
+                                .blockstoreType("s3")
+                                .blockstoreNamespaceExample("/not/really")
+                                .blockstoreNamespaceValidityRegex(".*")
+                                .preSignSupport(false)
+                                .preSignSupportUi(false)
+                                .importSupport(false)
+                                .importValidityRegex(".*"))));
         lakeFSFileIO = new LakeFSFileIO(lakeFSRepo, lakeFSRef, conf);
     }