[ES-869] (#1215)

* [ES-869] Signed-off-by: Venkata Saidurga Polamraju <[email protected]> * reviewed changes Signed-off-by: Venkata Saidurga Polamraju <[email protected]> * reviewed changes Signed-off-by: Venkata Saidurga Polamraju <[email protected]> --------- Signed-off-by: Venkata Saidurga Polamraju <[email protected]>
mosip · Mar 12, 2024 · d367b28 · d367b28
1 parent b4f9446
commit d367b28
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 9 deletions.
diff --git a/...va/io/mosip/authentication/common/service/websub/impl/OndemandTemplateEventPublisher.java b/...va/io/mosip/authentication/common/service/websub/impl/OndemandTemplateEventPublisher.java
@@ -135,9 +135,9 @@ private void sendEvents(BaseRequestDTO baserequestdto, String headerSignature, O
 			eventData.put(REQUESTDATETIME, DateUtils.formatToISOString(DateUtils.getUTCCurrentDateTime()));
 			eventData.put(INDIVIDUAL_ID,
 					encryptIndividualId(baserequestdto.getIndividualId(), partnerDataCert.get().getCertificateData()));
-			eventData.put(AUTH_PARTNER_ID, partner.get().getPartnerId());
+			eventData.put(AUTH_PARTNER_ID, partner.map(PartnerDTO::getPartnerId).orElse(null));
 			eventData.put(INDIVIDUAL_ID_TYPE, baserequestdto.getIndividualIdType());
-			eventData.put(ENTITY_NAME, partner.get().getPartnerName());
+			eventData.put(ENTITY_NAME, partner.map(PartnerDTO::getPartnerName).orElse(null));
 			eventData.put(REQUEST_SIGNATURE, headerSignature);
 			EventModel eventModel = createEventModel(onDemadTemplateExtractionTopic, eventData);
 			publishEvent(eventModel);

diff --git a/...impl/src/main/java/io/mosip/authentication/esignet/integration/service/HelperService.java b/...impl/src/main/java/io/mosip/authentication/esignet/integration/service/HelperService.java
@@ -160,7 +160,8 @@ protected SendOtpResult sendOTP(String partnerId, String clientId, IdaSendOtpReq
         ResponseEntity<IdaSendOtpResponse> responseEntity = restTemplate.exchange(requestEntity, IdaSendOtpResponse.class);
         if(responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
             IdaSendOtpResponse idaSendOtpResponse = responseEntity.getBody();
-            if(idaSendOtpRequest.getTransactionID().equals(idaSendOtpResponse.getTransactionID()) && idaSendOtpResponse.getResponse() != null){
+            if (idaSendOtpResponse != null && idaSendOtpRequest.getTransactionID().equals(idaSendOtpResponse.getTransactionID()) &&
+                    idaSendOtpResponse.getResponse() != null) {
                 return new SendOtpResult(idaSendOtpResponse.getTransactionID(),
                         idaSendOtpResponse.getResponse().getMaskedEmail(),
                         idaSendOtpResponse.getResponse().getMaskedMobile());

diff --git a/...src/main/java/io/mosip/authentication/esignet/integration/service/IdaAuditPluginImpl.java b/...src/main/java/io/mosip/authentication/esignet/integration/service/IdaAuditPluginImpl.java
@@ -104,7 +104,7 @@ private void audit(String username, Action action, ActionStatus status, AuditDTO
 
 			if (responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
 				ResponseWrapper<AuditResponse> responseWrapper = responseEntity.getBody();
-				if (responseWrapper.getErrors() != null && !responseWrapper.getErrors().isEmpty()) {
+				if (responseWrapper != null && responseWrapper.getErrors() != null && !responseWrapper.getErrors().isEmpty()) {
 					log.error("Error response received from audit service with errors: {}",
 							responseWrapper.getErrors());
 				}

diff --git a/...c/main/java/io/mosip/authentication/esignet/integration/service/IdaAuthenticatorImpl.java b/...c/main/java/io/mosip/authentication/esignet/integration/service/IdaAuthenticatorImpl.java
@@ -135,7 +135,7 @@ public KycAuthResult doKycAuth(String relyingPartyId, String clientId, KycAuthDt
 
             if(responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
                 IdaResponseWrapper<IdaKycAuthResponse> responseWrapper = responseEntity.getBody();
-                if(responseWrapper.getResponse() != null && responseWrapper.getResponse().isKycStatus() && responseWrapper.getResponse().getKycToken() != null) {
+                if(responseWrapper != null && responseWrapper.getResponse() != null && responseWrapper.getResponse().isKycStatus() && responseWrapper.getResponse().getKycToken() != null) {
                     return new KycAuthResult(responseEntity.getBody().getResponse().getKycToken(),
                             responseEntity.getBody().getResponse().getAuthToken());
                 }
@@ -188,7 +188,7 @@ public KycExchangeResult doKycExchange(String relyingPartyId, String clientId, K
 
             if(responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
                 IdaResponseWrapper<IdaKycExchangeResponse> responseWrapper = responseEntity.getBody();
-                if(responseWrapper.getResponse() != null && responseWrapper.getResponse().getEncryptedKyc() != null) {
+                if(responseWrapper != null && responseWrapper.getResponse() != null && responseWrapper.getResponse().getEncryptedKyc() != null) {
                     return new KycExchangeResult(responseWrapper.getResponse().getEncryptedKyc());
                 }
                 log.error("Errors in response received from IDA Kyc Exchange: {}", responseWrapper.getErrors());
@@ -241,7 +241,7 @@ public List<KycSigningCertificateData> getAllKycSigningCertificates() throws Kyc
 
             if(responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
             	ResponseWrapper<GetAllCertificatesResponse> responseWrapper = responseEntity.getBody();
-                if(responseWrapper.getResponse() != null && responseWrapper.getResponse().getAllCertificates() != null) {
+                if(responseWrapper != null && responseWrapper.getResponse() != null && responseWrapper.getResponse().getAllCertificates() != null) {
                     return responseWrapper.getResponse().getAllCertificates();
                 }
                 log.error("Error response received from getAllSigningCertificates with errors: {}",

diff --git a/...l/src/main/java/io/mosip/authentication/esignet/integration/service/IdaKeyBinderImpl.java b/...l/src/main/java/io/mosip/authentication/esignet/integration/service/IdaKeyBinderImpl.java
@@ -142,7 +142,7 @@ public KeyBindingResult doKeyBinding(String individualId, List<AuthChallenge> ch
 
             if(responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
                 IdaResponseWrapper<KeyBindingResponse> responseWrapper = responseEntity.getBody();
-                if(responseWrapper.getResponse() == null) {
+                if(responseWrapper == null || responseWrapper.getResponse() == null) {
                     log.error("Error response received from IDA (Key-binding) Errors: {}", responseWrapper.getErrors());
                     throw new KeyBindingException(CollectionUtils.isEmpty(responseWrapper.getErrors()) ?
                             ErrorConstants.KEY_BINDING_FAILED : responseWrapper.getErrors().get(0).getErrorCode());

diff --git a/...ain/java/io/mosip/authentication/esignet/integration/service/IdaVCIssuancePluginImpl.java b/...ain/java/io/mosip/authentication/esignet/integration/service/IdaVCIssuancePluginImpl.java
@@ -132,7 +132,7 @@ public VCResult<JsonLDObject> getVerifiableCredentialWithLinkedDataProof(VCReque
 					requestEntity, new ParameterizedTypeReference<IdaResponseWrapper<IdaVcExchangeResponse<JsonLDObject>>>() {});
 			if (responseEntity.getStatusCode().is2xxSuccessful() && responseEntity.getBody() != null) {
 				IdaResponseWrapper<IdaVcExchangeResponse<JsonLDObject>> responseWrapper = responseEntity.getBody();
-				if (responseWrapper.getResponse() != null) {
+				if (responseWrapper != null || responseWrapper.getResponse() != null) {
 					VCResult vCResult = new VCResult();
 					vCResult.setCredential(responseWrapper.getResponse().getVerifiableCredentials());
 					vCResult.setFormat(vcRequestDto.getFormat());