chore: fix after upstream changes on state filtering (#605)

Author: wolf4ood

core/common-core/src/main/java/org/eclipse/edc/identityhub/defaults/store/InMemoryHolderCredentialRequestStore.java

@@ -15,6 +15,7 @@
 package org.eclipse.edc.identityhub.defaults.store;
 
 import org.eclipse.edc.identityhub.spi.credential.request.model.HolderCredentialRequest;
+import org.eclipse.edc.identityhub.spi.credential.request.model.HolderRequestState;
 import org.eclipse.edc.identityhub.spi.credential.request.store.HolderCredentialRequestStore;
 import org.eclipse.edc.spi.query.CriterionOperatorRegistry;
 import org.eclipse.edc.spi.query.QuerySpec;
@@ -30,7 +31,7 @@ public InMemoryHolderCredentialRequestStore(Clock clock, CriterionOperatorRegist
     }
 
     public InMemoryHolderCredentialRequestStore(String leaserId, Clock clock, CriterionOperatorRegistry criterionOperatorRegistry) {
-        super(HolderCredentialRequest.class, leaserId, clock, criterionOperatorRegistry);
+        super(HolderCredentialRequest.class, leaserId, clock, criterionOperatorRegistry, state -> HolderRequestState.valueOf(state).code());
     }
 
     @Override

core/issuerservice/issuerservice-core/src/main/java/org/eclipse/edc/issuerservice/defaults/store/InMemoryIssuanceProcessStore.java

@@ -15,6 +15,7 @@
 package org.eclipse.edc.issuerservice.defaults.store;
 
 import org.eclipse.edc.issuerservice.spi.issuance.model.IssuanceProcess;
+import org.eclipse.edc.issuerservice.spi.issuance.model.IssuanceProcessStates;
 import org.eclipse.edc.issuerservice.spi.issuance.process.store.IssuanceProcessStore;
 import org.eclipse.edc.spi.query.CriterionOperatorRegistry;
 import org.eclipse.edc.spi.query.QuerySpec;
@@ -31,7 +32,7 @@ public InMemoryIssuanceProcessStore(Clock clock, CriterionOperatorRegistry crite
     }
 
     public InMemoryIssuanceProcessStore(String leaserId, Clock clock, CriterionOperatorRegistry criterionOperatorRegistry) {
-        super(IssuanceProcess.class, leaserId, clock, criterionOperatorRegistry);
+        super(IssuanceProcess.class, leaserId, clock, criterionOperatorRegistry, state -> IssuanceProcessStates.valueOf(state).code());
     }
 
     @Override

extensions/store/sql/holder-credential-request-store-sql/src/main/java/org/eclipse/edc/identityhub/store/sql/credentialrequest/schema/schema/postgres/HolderCredentialRequestMapping.java

@@ -14,6 +14,7 @@
 
 package org.eclipse.edc.identityhub.store.sql.credentialrequest.schema.schema.postgres;
 
+import org.eclipse.edc.identityhub.spi.credential.request.model.HolderRequestState;
 import org.eclipse.edc.identityhub.store.sql.credentialrequest.schema.HolderCredentialRequestStoreStatements;
 import org.eclipse.edc.sql.lease.StatefulEntityMapping;
 import org.eclipse.edc.sql.translation.JsonFieldTranslator;
@@ -31,7 +32,7 @@ public class HolderCredentialRequestMapping extends StatefulEntityMapping {
     public static final String FIELD_PENDING_ISSUANCE = "pending";
 
     public HolderCredentialRequestMapping(HolderCredentialRequestStoreStatements statements) {
-        super(statements);
+        super(statements, state -> HolderRequestState.valueOf(state).code());
         add(FIELD_PARTICIPANT_ID, statements.getParticipantIdColumn());
         add(FIELD_ISSUER_DID, statements.getIssuerDidColumn());
         add(FIELD_CREDENTIAL_TYPES, new JsonFieldTranslator(statements.getCredentialTypesColumn()));

extensions/store/sql/issuance-process-store-sql/src/main/java/org/eclipse/edc/issuerservice/store/sql/issuanceprocess/schema/postgres/IssuanceProcessMapping.java

@@ -14,6 +14,7 @@
 
 package org.eclipse.edc.issuerservice.store.sql.issuanceprocess.schema.postgres;
 
+import org.eclipse.edc.issuerservice.spi.issuance.model.IssuanceProcessStates;
 import org.eclipse.edc.issuerservice.store.sql.issuanceprocess.IssuanceProcessStoreStatements;
 import org.eclipse.edc.sql.lease.StatefulEntityMapping;
 import org.eclipse.edc.sql.translation.JsonArrayTranslator;
@@ -34,7 +35,7 @@ public class IssuanceProcessMapping extends StatefulEntityMapping {
     private static final String FIELD_PENDING = "pending";
 
     public IssuanceProcessMapping(IssuanceProcessStoreStatements statements) {
-        super(statements);
+        super(statements, state -> IssuanceProcessStates.valueOf(state).code());
         add(FIELD_ID, statements.getIdColumn());
         add(FIELD_PARTICIPANT_ID, statements.getParticipantIdColumn());
         add(FIELD_ISSUER_CONTEXT_ID, statements.getIssuerContextIdColumn());

spi/holder-credential-request-spi/src/testFixtures/java/org/eclipse/edc/identityhub/credential/request/test/HolderCredentialRequestStoreTestBase.java

@@ -404,6 +404,19 @@ void queryByState() {
             assertThat(result).hasSize(1).usingRecursiveFieldByFieldElementComparator().containsExactly(request);
         }
 
+        @Test
+        void queryByStateAsString() {
+            var request = createHolderRequest("testprocess1");
+            getStore().save(request);
+
+            var query = QuerySpec.Builder.newInstance()
+                    .filter(List.of(new Criterion("state", "=", HolderRequestState.from(request.getState()).name())))
+                    .build();
+
+            var result = getStore().query(query);
+            assertThat(result).hasSize(1).usingRecursiveFieldByFieldElementComparator().containsExactly(request);
+        }
+
         @Test
         void queryByIssuerDid() {
 

spi/issuerservice/issuerservice-issuance-spi/src/testFixtures/java/org/eclipse/edc/issuerservice/spi/issuance/process/store/IssuanceProcessStoreTestBase.java

@@ -403,6 +403,19 @@ void queryByState() {
             assertThat(result).hasSize(1).usingRecursiveFieldByFieldElementComparator().containsExactly(issuanceProcess);
         }
 
+        @Test
+        void queryByStateAsString() {
+            var issuanceProcess = createIssuanceProcess("testprocess1");
+            getStore().save(issuanceProcess);
+
+            var query = QuerySpec.Builder.newInstance()
+                    .filter(List.of(new Criterion("state", "=", IssuanceProcessStates.from(issuanceProcess.getState()).name())))
+                    .build();
+
+            var result = getStore().query(query).toList();
+            assertThat(result).hasSize(1).usingRecursiveFieldByFieldElementComparator().containsExactly(issuanceProcess);
+        }
+
         @Test
         void queryByParticipantId() {