Skip to content
This repository has been archived by the owner on Oct 31, 2024. It is now read-only.

Commit

Permalink
(feat): Add loggers around IDAM calls. (#460)
Browse files Browse the repository at this point in the history
* (feat): Add loggers around IDAM calls.

* (feat): Add loggers around IDAM calls.

* (feat): Add loggers around IDAM calls.

* (feat): Add loggers around IDAM calls.

* (feat): Add loggers around IDAM calls.

* (feat): Add loggers around IDAM calls.
  • Loading branch information
nitishsingla1234 authored Jan 26, 2021
1 parent 35e0bbb commit 823fe70
Showing 1 changed file with 26 additions and 12 deletions.
Original file line number Diff line number Diff line change
@@ -1,26 +1,16 @@
package uk.gov.hmcts.reform.profilesync.service.impl;

import com.fasterxml.jackson.core.type.TypeReference;

import feign.Response;

import java.util.Base64;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

import lombok.AllArgsConstructor;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;

import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;

import uk.gov.hmcts.reform.authorisation.generators.AuthTokenGenerator;
import uk.gov.hmcts.reform.profilesync.advice.UserProfileSyncException;
import uk.gov.hmcts.reform.profilesync.client.IdamClient;
Expand All @@ -31,6 +21,13 @@
import uk.gov.hmcts.reform.profilesync.service.ProfileUpdateService;
import uk.gov.hmcts.reform.profilesync.util.JsonFeignResponseUtil;

import java.util.Base64;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

@Service
@NoArgsConstructor
@AllArgsConstructor
Expand Down Expand Up @@ -82,7 +79,12 @@ public String getBearerToken() throws UserProfileSyncException {
}

public String getS2sToken() {
return tokenGenerator.generate();
log.info("generating S2S Token from updateUserProfileFeed method");
String s2sToken = tokenGenerator.generate();
if (StringUtils.isNotEmpty(s2sToken)) {
log.info("The length of S2S token is: {}", s2sToken.length());
}
return s2sToken;
}


Expand All @@ -98,6 +100,8 @@ public Set<IdamClient.User> getSyncFeed(String bearerToken, String searchQuery)t
do {
formParams.put("page", String.valueOf(counter));
Response response = idamClient.getUserFeed(bearerToken, formParams);
logIdamResponse(response);

ResponseEntity<Object> responseEntity = JsonFeignResponseUtil.toResponseEntity(response,
new TypeReference<Set<IdamClient.User>>() {
});
Expand Down Expand Up @@ -131,6 +135,16 @@ public Set<IdamClient.User> getSyncFeed(String bearerToken, String searchQuery)t
return updatedUsers;
}

private void logIdamResponse(Response response) {
log.info("Logging Response from IDAM");
if (response != null) {
log.info("Response code from idamClient.getUserFeed {}", response.status());
if (response.status() != 200 && response.body() != null) {
log.info("Response body from idamClient.getUserFeed {}", response.body().toString());
}
}
}

public ProfileSyncAudit updateUserProfileFeed(String searchQuery, ProfileSyncAudit syncAudit)
throws UserProfileSyncException {
log.info("{}:: Inside updateUserProfileFeed ::{}", loggingComponentName);
Expand Down

0 comments on commit 823fe70

Please sign in to comment.