fix: add missing JsonObjectToCriterionTransformer (#267)

* fix: add missing JsonObjectToCriterionTransformer

* test(e2e): verify catalog with QuerySpec.filterExpression

Author: thomasrutger

core/federated-catalog-core/src/main/java/org/eclipse/edc/catalog/cache/FederatedCatalogCacheExtension.java

@@ -50,6 +50,7 @@
 import org.eclipse.edc.spi.system.health.HealthCheckService;
 import org.eclipse.edc.spi.types.TypeManager;
 import org.eclipse.edc.transform.spi.TypeTransformerRegistry;
+import org.eclipse.edc.transform.transformer.edc.to.JsonObjectToCriterionTransformer;
 import org.eclipse.edc.transform.transformer.edc.to.JsonObjectToQuerySpecTransformer;
 import org.eclipse.edc.transform.transformer.edc.to.JsonValueToGenericTypeTransformer;
 
@@ -156,6 +157,7 @@ private void registerTransformers(ServiceExtensionContext context) {
         transformerRegistry.register(new JsonObjectToDataServiceTransformer());
         transformerRegistry.register(new JsonObjectToDistributionTransformer());
         transformerRegistry.register(new JsonObjectToQuerySpecTransformer());
+        transformerRegistry.register(new JsonObjectToCriterionTransformer());
 
         var jsonFactory = Json.createBuilderFactory(Map.of());
         var mapper = context.getService(TypeManager.class).getMapper(JSON_LD);

system-tests/end2end-test/e2e-junit-runner/src/test/java/org/eclipse/edc/end2end/CatalogApiClient.java

@@ -67,8 +67,8 @@ Result<String> postContractDefinition(JsonObject definition) {
         return postObjectWithId(createPostRequest(definition, managementBaseUrl + "/v3/contractdefinitions"));
     }
 
-    List<Catalog> getContractOffers() {
-        var rq = createPostRequest(TestFunctions.createEmptyQuery(), catalog("/v1alpha/catalog/query"));
+    List<Catalog> getCatalogs(JsonObject querySpec) {
+        var rq = createPostRequest(querySpec, catalog("/v1alpha/catalog/query"));
 
         try (var response = getClient().newCall(rq).execute()) {
             if (response.isSuccessful()) {

system-tests/end2end-test/e2e-junit-runner/src/test/java/org/eclipse/edc/end2end/FederatedCatalogTest.java

@@ -23,6 +23,7 @@
 import org.eclipse.edc.catalog.transform.JsonObjectToDataServiceTransformer;
 import org.eclipse.edc.catalog.transform.JsonObjectToDatasetTransformer;
 import org.eclipse.edc.catalog.transform.JsonObjectToDistributionTransformer;
+import org.eclipse.edc.connector.controlplane.catalog.spi.Catalog;
 import org.eclipse.edc.connector.controlplane.transform.odrl.from.JsonObjectFromPolicyTransformer;
 import org.eclipse.edc.connector.core.agent.NoOpParticipantIdMapper;
 import org.eclipse.edc.crawler.spi.TargetNode;
@@ -182,19 +183,31 @@ void crawl_whenOfferAvailable_shouldContainOffer(TestInfo testInfo) {
                 .pollInterval(ofSeconds(1))
                 .atMost(TIMEOUT)
                 .untilAsserted(() -> {
-                    var catalogs = apiClient.getContractOffers();
 
-                    assertThat(catalogs).hasSizeGreaterThanOrEqualTo(1);
-                    assertThat(catalogs).anySatisfy(catalog -> assertThat(catalog.getDatasets())
-                            .anySatisfy(dataset -> {
-                                assertThat(dataset.getOffers()).hasSizeGreaterThanOrEqualTo(1);
-                                assertThat(dataset.getOffers().keySet()).anyMatch(key -> key.contains(assetIdBase64));
-                            }));
+                    // With empty query
+                    var emptyQuery = TestFunctions.createEmptyQuery();
+                    var catalogs = apiClient.getCatalogs(emptyQuery);
 
+                    assertCatalogContainsOffer(assetIdBase64, catalogs);
+
+                    // With query containing a filter expression for existing asset.
+                    var queryWithExistingAssetId = TestFunctions.createQuerySpecWithFilterExpressionForAssetId(id);
+                    catalogs = apiClient.getCatalogs(queryWithExistingAssetId);
+
+                    assertCatalogContainsOffer(assetIdBase64, catalogs);
                 });
     }
 
     private String getError(Result<String> r) {
         return ofNullable(r.getFailureDetail()).orElse("No error");
     }
+
+    private void assertCatalogContainsOffer(String assetIdBase64, List<Catalog> catalogs) {
+        assertThat(catalogs).hasSizeGreaterThanOrEqualTo(1);
+        assertThat(catalogs).anySatisfy(catalog -> assertThat(catalog.getDatasets())
+                .anySatisfy(dataset -> {
+                    assertThat(dataset.getOffers()).hasSizeGreaterThanOrEqualTo(1);
+                    assertThat(dataset.getOffers().keySet()).anyMatch(key -> key.contains(assetIdBase64));
+                }));
+    }
 }

system-tests/end2end-test/e2e-junit-runner/src/test/java/org/eclipse/edc/end2end/TestFunctions.java

@@ -35,6 +35,7 @@
 import static org.eclipse.edc.junit.testfixtures.TestUtils.getResourceFileContentAsString;
 import static org.eclipse.edc.spi.constants.CoreConstants.EDC_NAMESPACE;
 import static org.eclipse.edc.spi.constants.CoreConstants.EDC_PREFIX;
+import static org.eclipse.edc.spi.query.QuerySpec.EDC_QUERY_SPEC_FILTER_EXPRESSION;
 
 public class TestFunctions {
 
@@ -60,7 +61,7 @@ public static JsonObject createContractDef(String id, String accessPolicyId, Str
                 .add(ID, id)
                 .add(CONTRACT_DEFINITION_ACCESSPOLICY_ID, accessPolicyId)
                 .add(CONTRACT_DEFINITION_CONTRACTPOLICY_ID, contractPolicyId)
-                .add(CONTRACT_DEFINITION_ASSETS_SELECTOR, createCriterionBuilder(assetId).build())
+                .add(CONTRACT_DEFINITION_ASSETS_SELECTOR, createCriterionBuilder(Asset.PROPERTY_ID, "=", assetId).build())
                 .build();
     }
 
@@ -70,13 +71,21 @@ public static JsonObject createEmptyQuery() {
                 .build();
     }
 
-    private static JsonArrayBuilder createCriterionBuilder(String assetId) {
+    public static JsonObject createQuerySpecWithFilterExpressionForAssetId(String id) {
+        return Json.createObjectBuilder()
+                .add(TYPE, QuerySpec.EDC_QUERY_SPEC_TYPE)
+                .add(EDC_QUERY_SPEC_FILTER_EXPRESSION, createCriterionBuilder("datasets.id", "=", id))
+                .build();
+    }
+
+
+    private static JsonArrayBuilder createCriterionBuilder(String operandLeft, String operator, String operandRight) {
         return Json.createArrayBuilder()
                 .add(Json.createObjectBuilder()
-                        .add(TYPE, EDC_NAMESPACE + "CriterionDto")
-                        .add(EDC_NAMESPACE + "operandLeft", Asset.PROPERTY_ID)
-                        .add(EDC_NAMESPACE + "operator", "=")
-                        .add(EDC_NAMESPACE + "operandRight", assetId)
+                        .add(TYPE, EDC_NAMESPACE + "Criterion")
+                        .add(EDC_NAMESPACE + "operandLeft", operandLeft)
+                        .add(EDC_NAMESPACE + "operator", operator)
+                        .add(EDC_NAMESPACE + "operandRight", operandRight)
                 );
     }