Implemented HIU Discovery

src/main/java/com/nha/abdm/wrapper/common/RequestManager.java

@@ -45,4 +45,16 @@ public <T> ResponseEntity<GenericResponse> fetchResponseFromGateway(String uri,
         .toEntity(GenericResponse.class)
         .block();
   }
+
+  public ResponseEntity<Object> fetchResponseForPHR(
+      String uri, Object request, String xAuthToken, String path) {
+    return hiuWebClient
+        .post()
+        .uri(uri + path)
+        .headers(headers -> headers.add("X-AUTH-TOKEN", xAuthToken))
+        .body(BodyInserters.fromValue(request))
+        .retrieve()
+        .toEntity(Object.class)
+        .block();
+  }
 }

src/main/java/com/nha/abdm/wrapper/hip/hrp/dataTransfer/encryption/EncryptionResponse.java

@@ -2,13 +2,12 @@
 package com.nha.abdm.wrapper.hip.hrp.dataTransfer.encryption;
 
 import com.nha.abdm.wrapper.hip.hrp.dataTransfer.requests.helpers.HealthInformationBundle;
+import java.util.List;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
-import java.util.List;
-
 @Data
 @Builder
 @AllArgsConstructor

src/main/java/com/nha/abdm/wrapper/hip/hrp/database/mongo/services/PatientService.java

@@ -16,6 +16,10 @@
 import com.nha.abdm.wrapper.hip.hrp.link.hipInitiated.requests.LinkRecordsRequest;
 import com.nha.abdm.wrapper.hip.hrp.link.userInitiated.responses.InitResponse;
 import com.nha.abdm.wrapper.hiu.hrp.consent.requests.ConsentCareContexts;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.bson.Document;
@@ -28,11 +32,6 @@
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Set;
-import java.util.stream.Collectors;
-
 @Service
 public class PatientService {
   private static final Logger log = LogManager.getLogger(PatientService.class);

src/main/java/com/nha/abdm/wrapper/hiu/facade/discovery/HIUFacadeDiscoveryController.java

@@ -0,0 +1,21 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.facade.discovery;
+
+import com.nha.abdm.wrapper.hiu.hrp.discovery.HIUFacadeDiscoverControllerInterface;
+import com.nha.abdm.wrapper.hiu.hrp.discovery.requests.HIUDiscoverRequest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping(path = "/v1/care-contexts")
+public class HIUFacadeDiscoveryController {
+  @Autowired HIUFacadeDiscoverControllerInterface hiuFacadeDiscoverControllerInterface;
+
+  @PostMapping("/discover")
+  public ResponseEntity<Object> hiuDiscoverResponse(
+      @RequestHeader(value = "X-AUTH-TOKEN") String xAuthToken,
+      @RequestBody HIUDiscoverRequest discoverRequest) {
+    return hiuFacadeDiscoverControllerInterface.initiateDiscover(discoverRequest, xAuthToken);
+  }
+}

src/main/java/com/nha/abdm/wrapper/hiu/facade/link/HIUFacadeLinkController.java

@@ -0,0 +1,29 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.facade.link;
+
+import com.nha.abdm.wrapper.hiu.hrp.link.HIUFacadeLinkControllerInterface;
+import com.nha.abdm.wrapper.hiu.hrp.link.requests.HIUConfirmRequest;
+import com.nha.abdm.wrapper.hiu.hrp.link.requests.HIUInitRequest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping(path = "/v1/care-contexts/link")
+public class HIUFacadeLinkController {
+  @Autowired HIUFacadeLinkControllerInterface hiuFacadeLinkControllerInterface;
+
+  @PostMapping("/init")
+  public ResponseEntity<Object> hiuInitResponse(
+      @RequestHeader(value = "X-AUTH-TOKEN") String xAuthToken,
+      @RequestBody HIUInitRequest hiuInitRequest) {
+    return hiuFacadeLinkControllerInterface.initiateLinkInit(hiuInitRequest, xAuthToken);
+  }
+
+  @PostMapping("/confirm")
+  public ResponseEntity<Object> hiuConfirmResponse(
+      @RequestHeader(value = "X-AUTH-TOKEN") String xAuthToken,
+      @RequestBody HIUConfirmRequest hiuConfirmRequest) {
+    return hiuFacadeLinkControllerInterface.initiateLinkConfirm(hiuConfirmRequest, xAuthToken);
+  }
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/HIUFacadeDiscoverControllerInterface.java

@@ -0,0 +1,10 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery;
+
+import com.nha.abdm.wrapper.hiu.hrp.discovery.requests.HIUDiscoverRequest;
+import org.springframework.http.ResponseEntity;
+
+public interface HIUFacadeDiscoverControllerInterface {
+
+  ResponseEntity<Object> initiateDiscover(HIUDiscoverRequest hiuDiscoverRequest, String xAuthToken);
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/HIUFacadeDiscoverControllerService.java

@@ -0,0 +1,49 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery;
+
+import com.nha.abdm.wrapper.common.RequestManager;
+import com.nha.abdm.wrapper.hiu.hrp.discovery.requests.HIUDiscoverRequest;
+import com.nha.abdm.wrapper.hiu.hrp.discovery.responses.DiscoverResponse;
+import java.util.Objects;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+@Service
+public class HIUFacadeDiscoverControllerService implements HIUFacadeDiscoverControllerInterface {
+  @Value("${hiuDiscoverPath}")
+  public String hiuDiscoverPath;
+
+  private final RequestManager requestManager;
+
+  private static final Logger log = LogManager.getLogger(HIUFacadeDiscoverControllerService.class);
+
+  public HIUFacadeDiscoverControllerService(RequestManager requestManager) {
+    this.requestManager = requestManager;
+  }
+
+  @Override
+  public ResponseEntity<Object> initiateDiscover(
+      HIUDiscoverRequest hiuDiscoverRequest, String xAuthToken) {
+    log.info(hiuDiscoverRequest.toString());
+    if (Objects.nonNull(hiuDiscoverRequest)
+        && Objects.nonNull(hiuDiscoverRequest.getHip())
+        && Objects.nonNull(hiuDiscoverRequest.getRequestId())
+        && Objects.nonNull(xAuthToken)) {
+      try {
+        ResponseEntity<Object> response =
+            requestManager.fetchResponseForPHR(hiuDiscoverPath, hiuDiscoverRequest, xAuthToken, "");
+
+        log.info(response.getBody().toString());
+        return response;
+
+      } catch (Exception e) {
+        throw new RuntimeException("unable to make post request from discover " + e);
+      }
+    }
+    return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(new DiscoverResponse());
+  }
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/requests/HIUDiscoverRequest.java

@@ -0,0 +1,20 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery.requests;
+
+import com.nha.abdm.wrapper.hiu.hrp.discovery.requests.helpers.HIPId;
+import com.nha.abdm.wrapper.hiu.hrp.discovery.requests.helpers.HIUPatientUnverifiedIdentifiers;
+import java.util.List;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class HIUDiscoverRequest {
+  public HIPId hip;
+  public String requestId;
+  public List<HIUPatientUnverifiedIdentifiers> unverifiedIdentifiers;
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/requests/helpers/HIPId.java

@@ -0,0 +1,15 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery.requests.helpers;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class HIPId {
+  public String id;
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/requests/helpers/HIUPatientUnverifiedIdentifiers.java

@@ -0,0 +1,16 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery.requests.helpers;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class HIUPatientUnverifiedIdentifiers {
+  public String type;
+  public String value;
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/responses/DiscoverResponse.java

@@ -0,0 +1,21 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery.responses;
+
+import com.nha.abdm.wrapper.common.responses.ErrorResponse;
+import com.nha.abdm.wrapper.hiu.hrp.discovery.responses.helpers.HIUPatient;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class DiscoverResponse {
+  private static final long serialVersionUID = 165269402517398406L;
+  public String transactionId;
+  public HIUPatient patient;
+  public String createdAt;
+  public ErrorResponse error;
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/responses/helpers/CareContextRequest.java

@@ -0,0 +1,6 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery.responses.helpers;
+
+public class CareContextRequest {
+  private String referenceNumber;
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/discovery/responses/helpers/HIUPatient.java

@@ -0,0 +1,19 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.discovery.responses.helpers;
+
+import com.nha.abdm.wrapper.common.models.CareContext;
+import java.util.List;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class HIUPatient {
+  public String referenceNumber;
+  public String display;
+  public List<CareContext> careContexts;
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/link/HIUFacadeLinkControllerInterface.java

@@ -0,0 +1,13 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.link;
+
+import com.nha.abdm.wrapper.hiu.hrp.link.requests.HIUConfirmRequest;
+import com.nha.abdm.wrapper.hiu.hrp.link.requests.HIUInitRequest;
+import org.springframework.http.ResponseEntity;
+
+public interface HIUFacadeLinkControllerInterface {
+  ResponseEntity<Object> initiateLinkInit(HIUInitRequest hiuInitRequest, String xAuthToken);
+
+  ResponseEntity<Object> initiateLinkConfirm(
+      HIUConfirmRequest hiuConfirmRequest, String xAuthToken);
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/link/HIUFacadeLinkControllerService.java

@@ -0,0 +1,77 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.link;
+
+import com.nha.abdm.wrapper.common.RequestManager;
+import com.nha.abdm.wrapper.hiu.hrp.link.requests.HIUConfirmRequest;
+import com.nha.abdm.wrapper.hiu.hrp.link.requests.HIUInitRequest;
+import com.nha.abdm.wrapper.hiu.hrp.link.responses.ConfirmResponse;
+import com.nha.abdm.wrapper.hiu.hrp.link.responses.InitResponse;
+import java.util.Objects;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+@Service
+public class HIUFacadeLinkControllerService implements HIUFacadeLinkControllerInterface {
+  private static final Logger log = LogManager.getLogger(HIUFacadeLinkControllerInterface.class);
+
+  private final RequestManager requestManager;
+
+  @Value("${hiuInitPath}")
+  public String hiuInitPath;
+
+  @Value("${hiuLinkConfirmPath}")
+  public String hiuLinkConfirmPath;
+
+  public HIUFacadeLinkControllerService(RequestManager requestManager) {
+    this.requestManager = requestManager;
+  }
+
+  @Override
+  public ResponseEntity<Object> initiateLinkInit(HIUInitRequest hiuInitRequest, String xAuthToken) {
+    log.info(hiuInitRequest.toString());
+
+    if (Objects.nonNull(hiuInitRequest)
+        && Objects.nonNull(hiuInitRequest.getRequestId())
+        && Objects.nonNull(hiuInitRequest.getTransactionId())
+        && Objects.nonNull(hiuInitRequest.getPatient())
+        && Objects.nonNull(xAuthToken)) {
+      try {
+        ResponseEntity<Object> response =
+            requestManager.fetchResponseForPHR(hiuInitPath, hiuInitRequest, xAuthToken, "");
+        return response;
+
+      } catch (Exception e) {
+        throw new RuntimeException("unable to make post request from linkint " + e);
+      }
+    }
+    return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(new InitResponse());
+  }
+
+  @Override
+  public ResponseEntity<Object> initiateLinkConfirm(
+      HIUConfirmRequest hiuConfirmRequest, String xAuthToken) {
+    log.info(hiuConfirmRequest.toString());
+    if (Objects.nonNull(hiuConfirmRequest)
+        && Objects.nonNull(hiuConfirmRequest.getReferenceNumber())
+        && Objects.nonNull(hiuConfirmRequest.getToken())
+        && Objects.nonNull(xAuthToken)) {
+      try {
+        ResponseEntity<Object> response =
+            requestManager.fetchResponseForPHR(
+                hiuLinkConfirmPath,
+                hiuConfirmRequest,
+                xAuthToken,
+                "/" + hiuConfirmRequest.getReferenceNumber());
+        return response;
+
+      } catch (Exception e) {
+        throw new RuntimeException("unable to make post request from linkconfirm " + e);
+      }
+    }
+    return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(new ConfirmResponse());
+  }
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/link/requests/HIUConfirmRequest.java

@@ -0,0 +1,16 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.link.requests;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class HIUConfirmRequest {
+  public String token;
+  public String referenceNumber;
+}

src/main/java/com/nha/abdm/wrapper/hiu/hrp/link/requests/HIUInitRequest.java

@@ -0,0 +1,18 @@
+/* (C) 2024 */
+package com.nha.abdm.wrapper.hiu.hrp.link.requests;
+
+import com.nha.abdm.wrapper.hiu.hrp.link.requests.helpers.PatientWithReferenceNumber;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class HIUInitRequest {
+  public String requestId;
+  public String transactionId;
+  public PatientWithReferenceNumber patient;
+}