[INJICERT-1116] Add the Ledger search api. (mosip#368)

* Adding the Ledger search api.

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>

* updated the PR with validation changes.

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>

* Changed the key names in the CredentialLedgerSearchRequest as per specs.

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>

* Resolved the comments by modified the service code and adding the testcases.

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>

* Removed unused dependency and print statements.

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>

* Resolved the comments by modifying the LedgerIssuanceTableCustomRepositoryImpl file.

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>

* fix: resolve ApplicationContext failure in RenderingCredentialTemplateRepositoryTest by providing ObjectMapper bean

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>

---------

Signed-off-by: Nandeesh <nandeeshv0001@gmail.com>
Signed-off-by: Vishwa <visu.vs1@gmail.com>
Signed-off-by: Piyush7034 <piyushshukla2100@gmail.com>

Author: Nandeesh778

certify-core/src/main/java/io/mosip/certify/core/dto/CredentialLedgerSearchRequest.java

@@ -0,0 +1,18 @@
+package io.mosip.certify.core.dto;
+
+import java.util.Map;
+import lombok.Data;
+import jakarta.validation.constraints.NotBlank;
+
+@Data
+public class CredentialLedgerSearchRequest {
+    private String credentialId;
+
+    @NotBlank(message = "issuerId is mandatory")
+    private String issuerId;
+
+    @NotBlank(message = "credentialType is mandatory")
+    private String credentialType;
+
+    private Map<String, String> indexedAttributesEquals;
+}

certify-core/src/main/java/io/mosip/certify/core/dto/CredentialStatusResponse.java

@@ -2,8 +2,6 @@
 
 import lombok.Data;
 import java.time.LocalDateTime;
-import java.util.List;
-import java.util.Map;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
 
@@ -25,6 +23,4 @@ public class CredentialStatusResponse {
 
     @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss")
     private LocalDateTime statusTimestamp;
-
-    private List<Map<String, Object>> credentialStatusDetails;
 }

certify-core/src/main/java/io/mosip/certify/core/spi/VCIssuanceService.java

@@ -5,12 +5,14 @@
  */
 package io.mosip.certify.core.spi;
 
+import io.mosip.certify.core.dto.CredentialLedgerSearchRequest;
 import io.mosip.certify.core.dto.CredentialRequest;
 import io.mosip.certify.core.dto.CredentialResponse;
 import io.mosip.certify.core.dto.CredentialStatusResponse;
 import io.mosip.certify.core.dto.UpdateCredentialStatusRequest;
 
 import java.util.Map;
+import java.util.List;
 
 public interface VCIssuanceService {
 
@@ -26,4 +28,6 @@ public interface VCIssuanceService {
     Map<String, Object> getDIDDocument();
 
     CredentialStatusResponse updateCredential(UpdateCredentialStatusRequest updateCredentialStatusRequest);
+
+    List<CredentialStatusResponse> searchCredentials(CredentialLedgerSearchRequest request);
 }

certify-service/src/main/java/io/mosip/certify/controller/VCIssuanceController.java

@@ -22,6 +22,7 @@
 import org.springframework.web.bind.annotation.ResponseStatus;
 import org.springframework.web.bind.annotation.RestController;
 
+import io.mosip.certify.core.dto.CredentialLedgerSearchRequest;
 import io.mosip.certify.core.dto.CredentialRequest;
 import io.mosip.certify.core.dto.CredentialResponse;
 import io.mosip.certify.core.dto.UpdateCredentialStatusRequest;
@@ -33,6 +34,8 @@
 import jakarta.validation.Valid;
 import lombok.extern.slf4j.Slf4j;
 
+import java.util.List;
+
 @Slf4j
 @RestController
 @RequestMapping("/issuance")
@@ -65,6 +68,16 @@ public ResponseEntity<CredentialStatusResponse> updateCredential(
         return ResponseEntity.ok(result);
     }
 
+    @PostMapping("/ledger-search")
+    public ResponseEntity<List<CredentialStatusResponse>> searchCredentials(
+            @Valid @RequestBody CredentialLedgerSearchRequest request) {
+        List<CredentialStatusResponse> result = vcIssuanceService.searchCredentials(request);
+        if (result.isEmpty()) {
+            return ResponseEntity.noContent().build();
+        }
+        return ResponseEntity.ok(result);
+    }
+
     /**
      * 1. The credential Endpoint MUST accept Access Tokens
      * @param credentialRequest VC credential request

certify-service/src/main/java/io/mosip/certify/repository/LedgerIssuanceTableCustomRepository.java

@@ -0,0 +1,10 @@
+package io.mosip.certify.repository;
+
+import io.mosip.certify.core.dto.CredentialLedgerSearchRequest;
+import io.mosip.certify.entity.Ledger;
+
+import java.util.List;
+
+public interface LedgerIssuanceTableCustomRepository {
+    List<Ledger> findBySearchRequest(CredentialLedgerSearchRequest request);
+}

certify-service/src/main/java/io/mosip/certify/repository/LedgerIssuanceTableCustomRepositoryImpl.java

@@ -0,0 +1,66 @@
+package io.mosip.certify.repository;
+
+import io.mosip.certify.core.dto.CredentialLedgerSearchRequest;
+import io.mosip.certify.entity.Ledger;
+
+import jakarta.persistence.EntityManager;
+import jakarta.persistence.PersistenceContext;
+import org.springframework.stereotype.Repository;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Repository
+public class LedgerIssuanceTableCustomRepositoryImpl implements LedgerIssuanceTableCustomRepository {
+
+    @PersistenceContext
+    private EntityManager entityManager;
+
+    private final ObjectMapper objectMapper;
+
+    public LedgerIssuanceTableCustomRepositoryImpl(ObjectMapper objectMapper) {
+        this.objectMapper = objectMapper;
+    }
+
+    @Override
+    public List<Ledger> findBySearchRequest(CredentialLedgerSearchRequest request) {
+        try {
+            StringBuilder sql = new StringBuilder("SELECT * FROM ledger WHERE issuer_id = :issuerId AND credential_type = :credentialType ");
+            Map<String, Object> params = new HashMap<>();
+            params.put("issuerId", request.getIssuerId());
+            params.put("credentialType", request.getCredentialType());
+
+            if (request.getCredentialId() != null) {
+                sql.append(" AND credential_id = :credentialId ");
+                params.put("credentialId", request.getCredentialId());
+            }
+
+            if (request.getIndexedAttributesEquals() != null && !request.getIndexedAttributesEquals().isEmpty()) {
+                int i = 0;
+                for (Map.Entry<String, String> entry : request.getIndexedAttributesEquals().entrySet()) {
+                    String key = entry.getKey();
+                    String value = entry.getValue();
+                    if (key == null || key.isBlank() || value == null || value.isBlank()) continue;
+
+                    String paramName = "indexedAttr" + i;
+                    sql.append(" AND indexed_attributes @> cast(:" + paramName + " AS jsonb) ");
+                    params.put(paramName, objectMapper.writeValueAsString(Map.of(key, value)));
+                    i++;
+                }
+            }
+
+            var query = entityManager.createNativeQuery(sql.toString(), Ledger.class);
+
+            for (Map.Entry<String, Object> entry : params.entrySet()) {
+                query.setParameter(entry.getKey(), entry.getValue());
+            }
+
+            return query.getResultList();
+        } catch (Exception e) {
+            throw new RuntimeException("Failed to search LedgerIssuanceTable", e);
+        }
+    }
+}

certify-service/src/main/java/io/mosip/certify/repository/LedgerRepository.java

@@ -13,7 +13,7 @@
 import java.util.Optional;
 
 @Repository
-public interface LedgerRepository extends JpaRepository<Ledger, Long> {
+public interface LedgerRepository extends JpaRepository<Ledger, Long>, LedgerIssuanceTableCustomRepository {
 
 
     /**

certify-service/src/main/java/io/mosip/certify/services/CertifyIssuanceServiceImpl.java

@@ -8,6 +8,7 @@
 import java.text.ParseException;
 import java.time.OffsetDateTime;
 import java.util.*;
+import java.util.stream.Collectors;
 
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -552,4 +553,76 @@ public CredentialStatusResponse updateCredential(UpdateCredentialStatusRequest r
         dto.setStatusTimestamp(savedTransaction.getCreatedDtimes());
         return dto;        
     }
+
+    @Override
+    public List<CredentialStatusResponse> searchCredentials(CredentialLedgerSearchRequest request) {
+        validateSearchRequest(request);
+        try {
+            List<Ledger> records = ledgerRepository.findBySearchRequest(request);
+
+            if (records.isEmpty()) {
+                return Collections.emptyList();
+            }
+
+            return records.stream()
+                    .map(this::mapToSearchResponse)
+                    .collect(Collectors.toList());
+
+        } catch (Exception e) {
+            throw new CertifyException("SEARCH_CREDENTIALS_FAILED");
+        }
+    }
+
+    private CredentialStatusResponse mapToSearchResponse(Ledger record) {
+        CredentialStatusResponse response = new CredentialStatusResponse();
+        response.setCredentialId(record.getCredentialId());
+        response.setIssuerId(record.getIssuerId());
+        response.setIssueDate(record.getIssueDate().toLocalDateTime());
+        response.setExpirationDate(record.getExpirationDate() != null ? record.getExpirationDate().toLocalDateTime() : null);
+        response.setCredentialType(record.getCredentialType());
+        List<Map<String, Object>> statusDetails = record.getCredentialStatusDetails();
+        if (statusDetails != null && !statusDetails.isEmpty()) {
+            Map<String, Object> latestStatus = statusDetails.get(0);
+            Object statusListCredentialId = latestStatus.get("status_list_credential_id");
+            Object statusListIndex = latestStatus.get("status_list_index");
+            Object statusPurpose = latestStatus.get("status_purpose");
+            Object createdDtimes = latestStatus.get("cr_dtimes");
+
+            if (statusListCredentialId != null) {
+                response.setStatusListCredentialUrl(statusListCredentialId.toString());
+            }
+        
+            if (statusListIndex instanceof Number) {
+                Long index = ((Number) statusListIndex).longValue();
+                response.setStatusListIndex(index);
+            }
+        
+            if (statusPurpose != null) {
+                response.setStatusPurpose(statusPurpose.toString());
+            }
+
+            if (createdDtimes instanceof Number) {
+                long timestampMillis = ((Number) createdDtimes).longValue();
+                OffsetDateTime createdDateTime = OffsetDateTime.ofInstant(
+                    java.time.Instant.ofEpochMilli(timestampMillis),
+                    java.time.ZoneOffset.UTC
+                );
+                response.setStatusTimestamp(createdDateTime.toLocalDateTime());
+            }
+        }
+        return response;
+    }
+
+    private void validateSearchRequest(CredentialLedgerSearchRequest request) {
+        Map<String, String> indexedAttrs = request.getIndexedAttributesEquals();
+    
+        boolean hasValid = indexedAttrs != null && !indexedAttrs.isEmpty() &&
+                indexedAttrs.entrySet().stream()
+                        .anyMatch(e -> e.getKey() != null && !e.getKey().isBlank()
+                                && e.getValue() != null && !e.getValue().isBlank());
+    
+        if (!hasValid) {
+            throw new CertifyException("INVALID_SEARCH_CRITERIA");
+        }
+    }
 }

certify-service/src/main/java/io/mosip/certify/services/VCIssuanceServiceImpl.java

@@ -15,6 +15,7 @@
 import io.mosip.certify.api.util.Action;
 import io.mosip.certify.api.util.ActionStatus;
 import io.mosip.certify.core.constants.VCFormats;
+import io.mosip.certify.core.dto.CredentialLedgerSearchRequest;
 import io.mosip.certify.core.dto.CredentialMetadata;
 import io.mosip.certify.core.dto.CredentialRequest;
 import io.mosip.certify.core.dto.CredentialResponse;
@@ -201,4 +202,9 @@ public CredentialStatusResponse updateCredential(UpdateCredentialStatusRequest r
         throw new CertifyException("This method is not supported in VCIssuanceServiceImpl");
     }
 
+    @Override
+    public List<CredentialStatusResponse> searchCredentials(CredentialLedgerSearchRequest request) {
+        throw new CertifyException("This method is not supported in VCIssuanceServiceImpl");
+    }
+
 }

certify-service/src/test/java/io/mosip/certify/TestVCIssuanceServiceImpl.java

@@ -1,6 +1,7 @@
 package io.mosip.certify;
 
 import io.mosip.certify.core.constants.ErrorConstants;
+import io.mosip.certify.core.dto.CredentialLedgerSearchRequest;
 import io.mosip.certify.core.dto.CredentialRequest;
 import io.mosip.certify.core.dto.CredentialResponse;
 import io.mosip.certify.core.dto.CredentialStatusResponse;
@@ -10,6 +11,8 @@
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 
 import java.util.Map;
+import java.util.Collections;
+import java.util.List;
 
 @ConditionalOnProperty(value = "mosip.certify.plugin-mode", havingValue = "VCIssuance")
 public class TestVCIssuanceServiceImpl implements VCIssuanceService {
@@ -36,7 +39,11 @@ public Map<String, Object> getDIDDocument() {
 
     @Override
     public CredentialStatusResponse updateCredential(UpdateCredentialStatusRequest request) {
-        System.out.println("updateCredential called with: " + request);
         throw new UnsupportedOperationException("updateCredential is not implemented yet");
     }
+
+    @Override
+    public List<CredentialStatusResponse> searchCredentials(CredentialLedgerSearchRequest request) {
+        return Collections.emptyList();
+    }
 }