Skip to content

Commit

Permalink
chore(update): 1280 - rollback logging
Browse files Browse the repository at this point in the history
  • Loading branch information
ds-mwesener committed Jul 24, 2024
1 parent 6fca6aa commit 1389634
Showing 1 changed file with 2 additions and 23 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -44,38 +44,17 @@
public class FeignDiscoveryRepositoryImpl implements DiscoveryRepository {
private final EdcProperties edcProperties;
private final DiscoveryFinderClient discoveryFinderClient;
private final ObjectMapper objectMapper;
private final String BPN = "bpn";
private static final String BPN = "bpn";

@Override
public Optional<Discovery> retrieveDiscoveryByFinderAndEdcDiscoveryService(String bpn) {
DiscoveryFinderRequest request = new DiscoveryFinderRequest(List.of(BPN));
DiscoveryResponse discoveryEndpoints = discoveryFinderClient.findDiscoveryEndpoints(request);
try {
log.info("discoveryEndpoints");
log.warn(objectMapper.writeValueAsString(discoveryEndpoints));
} catch (JsonProcessingException e) {
log.warn("Could not write value as string");
}
List<EdcDiscoveryResult> discoveryResults = new ArrayList<>();
discoveryEndpoints.endpoints().forEach(discoveryEndpoint -> {
String endPointAddress = discoveryEndpoint.endpointAddress();
log.info("endPointAddress {}", endPointAddress);
List<EdcDiscoveryResult> connectorEndpoints = discoveryFinderClient.findConnectorEndpoints(endPointAddress, List.of(bpn));
try {
log.info("connectorEndpoints");
log.warn(objectMapper.writeValueAsString(connectorEndpoints));
} catch (JsonProcessingException e) {
log.warn("Could not write value as string");
}
discoveryResults.addAll(connectorEndpoints);
discoveryResults.addAll(discoveryFinderClient.findConnectorEndpoints(endPointAddress, List.of(bpn)));
});
try {
log.info("DiscoveryResult");
log.warn(objectMapper.writeValueAsString(discoveryResults));
} catch (JsonProcessingException e) {
log.warn("Could not write value as string");
}
List<EdcDiscoveryResult> discoveryResultByBPN
= discoveryResults.stream().filter(edcDiscoveryResult -> edcDiscoveryResult.bpn().equals(bpn)).toList();

Expand Down

0 comments on commit 1389634

Please sign in to comment.