feat(impl):[#244] Show infected supply chain on first tier level + feat(impl):[#246] Show hops number for impacted supply chain

CHANGELOG.md

@@ -5,6 +5,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
+### Changed
+- ESS
+  - Added 'hops' parameter to SupplyChainImpacted Aspect model - contains relative distance in the supply chain
+  - Added `impactedSuppliersOnFirstTier` parameter to Supply SupplyChainImpacted Aspect model - contains information of first level supply chain impacted
 
 ## [4.0.0] - 2023-10-27
 ### Added

DEPENDENCIES

@@ -170,7 +170,7 @@ maven/mavencentral/io.rest-assured/xml-path/5.3.0, Apache-2.0, approved, #9267
 maven/mavencentral/io.rest-assured/xml-path/5.3.2, Apache-2.0, approved, #9267
 maven/mavencentral/io.suzaku/boopickle_2.13/1.3.3, Apache-2.0, approved, clearlydefined
 maven/mavencentral/io.swagger.core.v3/swagger-annotations-jakarta/2.2.15, Apache-2.0, approved, #5947
-maven/mavencentral/io.swagger.core.v3/swagger-annotations/2.2.16, Apache-2.0, approved, clearlydefined
+maven/mavencentral/io.swagger.core.v3/swagger-annotations/2.2.16, Apache-2.0, approved, #11362
 maven/mavencentral/io.swagger.core.v3/swagger-core-jakarta/2.2.15, Apache-2.0, approved, #5929
 maven/mavencentral/io.swagger.core.v3/swagger-models-jakarta/2.2.15, Apache-2.0, approved, #5919
 maven/mavencentral/jakarta.activation/jakarta.activation-api/2.1.2, EPL-2.0 OR BSD-3-Clause OR GPL-2.0-only with Classpath-exception-2.0, approved, ee4j.jaf

docs/src/api/irs-api.yaml

@@ -2521,6 +2521,11 @@ components:
       type: object
       additionalProperties: false
       properties:
+        hops:
+          type: integer
+          format: int32
+        parentBpn:
+          type: string
         result:
           type: string
     SemanticId:
@@ -2563,10 +2568,10 @@ components:
           items:
             $ref: '#/components/schemas/Endpoint'
           maxItems: 2147483647
-        idShort:
-          type: string
         id:
           type: string
+        idShort:
+          type: string
         semanticId:
           $ref: '#/components/schemas/Reference'
     Summary:

irs-api/src/main/java/org/eclipse/tractusx/irs/ess/service/BpnInvestigationJob.java

@@ -27,18 +27,23 @@
 import java.time.ZonedDateTime;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.Comparator;
 import java.util.List;
-import java.util.Map;
 import java.util.Optional;
+import java.util.Set;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import org.eclipse.tractusx.irs.component.Job;
 import org.eclipse.tractusx.irs.component.Jobs;
+import org.eclipse.tractusx.irs.component.Notification;
 import org.eclipse.tractusx.irs.component.Submodel;
 import org.eclipse.tractusx.irs.component.Summary;
 import org.eclipse.tractusx.irs.component.enums.JobState;
+import org.eclipse.tractusx.irs.edc.client.model.notification.EdcNotification;
+import org.eclipse.tractusx.irs.edc.client.model.notification.ResponseNotificationContent;
+import org.eclipse.tractusx.irs.util.JsonUtil;
 
 /**
  * Object to store in cache
@@ -51,45 +56,61 @@ public class BpnInvestigationJob {
 
     private Jobs jobSnapshot;
     private List<String> incidentBpns;
-    private List<String> unansweredNotifications;
-    private List<String> answeredNotifications;
+    private List<Notification> unansweredNotifications;
+    private List<EdcNotification<ResponseNotificationContent>> answeredNotifications;
     private JobState state;
 
     public BpnInvestigationJob(final Jobs jobSnapshot, final List<String> incidentBpns) {
         this(jobSnapshot, incidentBpns, new ArrayList<>(), new ArrayList<>(), JobState.RUNNING);
     }
 
-    private static Jobs extendJobWithSupplyChainSubmodel(final Jobs irsJob,
-            final SupplyChainImpacted supplyChainImpacted) {
-        final Submodel supplyChainImpactedSubmodel = Submodel.builder()
-                                                             .aspectType(SUPPLY_CHAIN_ASPECT_TYPE)
-                                                             .payload(Map.of("supplyChainImpacted",
-                                                                     supplyChainImpacted.getDescription()))
-                                                             .build();
-
-        return irsJob.toBuilder()
-                     .clearSubmodels()
-                     .submodels(Collections.singletonList(supplyChainImpactedSubmodel))
-                     .build();
-    }
-
-    private static Jobs updateLastModified(final Jobs irsJob, final ZonedDateTime lastModifiedOn) {
-        final Job job = irsJob.getJob().toBuilder().completedOn(lastModifiedOn).lastModifiedOn(lastModifiedOn).build();
-        return irsJob.toBuilder().job(job).build();
-    }
-
-    public BpnInvestigationJob update(final Jobs jobSnapshot, final SupplyChainImpacted newSupplyChain) {
+    public BpnInvestigationJob update(final Jobs jobSnapshot, final SupplyChainImpacted newSupplyChain,
+            final String bpn) {
         final Optional<SupplyChainImpacted> previousSupplyChain = getSupplyChainImpacted();
 
         final SupplyChainImpacted supplyChainImpacted = previousSupplyChain.map(
                 prevSupplyChain -> prevSupplyChain.or(newSupplyChain)).orElse(newSupplyChain);
 
-        this.jobSnapshot = extendJobWithSupplyChainSubmodel(jobSnapshot, supplyChainImpacted);
+        this.jobSnapshot = extendJobWithSupplyChainSubmodel(jobSnapshot, supplyChainImpacted, bpn);
         this.jobSnapshot = extendSummary(this.jobSnapshot);
         this.jobSnapshot = updateLastModified(this.jobSnapshot, ZonedDateTime.now(ZoneOffset.UTC));
         return this;
     }
 
+    public BpnInvestigationJob withUnansweredNotifications(final List<Notification> notifications) {
+        this.unansweredNotifications.addAll(notifications);
+        return this;
+    }
+
+    public BpnInvestigationJob withAnsweredNotification(
+            final EdcNotification<ResponseNotificationContent> notification) {
+        final Optional<String> parentBpn = getParentBpn(notification);
+        removeFromUnansweredNotification(notification);
+        notification.getContent().setParentBpn(parentBpn.orElse(null));
+        notification.getContent().incrementHops();
+        this.answeredNotifications.add(notification);
+
+        return this;
+    }
+
+    private Optional<String> getParentBpn(final EdcNotification<ResponseNotificationContent> notification) {
+        return this.unansweredNotifications.stream()
+                                           .filter(unansweredNotification -> unansweredNotification.notificationId()
+                                                                                                   .equals(notification.getHeader().getOriginalNotificationId()))
+                                           .map(Notification::bpn)
+                                           .findAny();
+    }
+
+    private void removeFromUnansweredNotification(final EdcNotification<ResponseNotificationContent> notification) {
+        this.unansweredNotifications.removeIf(unansweredNotification -> unansweredNotification.notificationId()
+                                                                                              .equals(notification.getHeader().getOriginalNotificationId()));
+    }
+
+    public BpnInvestigationJob complete() {
+        this.state = JobState.COMPLETED;
+        return this;
+    }
+
     /* package */ Optional<SupplyChainImpacted> getSupplyChainImpacted() {
         return this.getJobSnapshot()
                    .getSubmodels()
@@ -101,6 +122,43 @@ public BpnInvestigationJob update(final Jobs jobSnapshot, final SupplyChainImpac
                    .findFirst();
     }
 
+    private Jobs extendJobWithSupplyChainSubmodel(final Jobs irsJob, final SupplyChainImpacted supplyChainImpacted,
+            final String bpn) {
+        final SupplyChainImpactedAspect.SupplyChainImpactedAspectBuilder supplyChainImpactedAspectBuilder = SupplyChainImpactedAspect.builder()
+                                                                                                                                     .supplyChainImpacted(
+                                                                                                                                             supplyChainImpacted);
+
+        if (getUnansweredNotifications().isEmpty()) {
+            final Optional<ResponseNotificationContent> incidentWithMinHopsValue = getAnsweredNotifications().stream()
+                                                                                                             .map(EdcNotification::getContent)
+                                                                                                             .filter(ResponseNotificationContent::thereIsIncident)
+                                                                                                             .min(Comparator.comparing(
+                                                                                                                     ResponseNotificationContent::getHops));
+
+            final List<SupplyChainImpactedAspect.ImpactedSupplierFirstLevel> suppliersFirstLevel = incidentWithMinHopsValue.map(
+                                                                                                                                   min -> new SupplyChainImpactedAspect.ImpactedSupplierFirstLevel(bpn, min.getHops()))
+                                                                                                                           .stream()
+                                                                                                                           .toList();
+            supplyChainImpactedAspectBuilder.impactedSuppliersOnFirstTier(Set.copyOf(suppliersFirstLevel));
+        }
+
+        final Submodel supplyChainImpactedSubmodel = Submodel.builder()
+                                                             .aspectType(SUPPLY_CHAIN_ASPECT_TYPE)
+                                                             .payload(new JsonUtil().asMap(
+                                                                     supplyChainImpactedAspectBuilder.build()))
+                                                             .build();
+
+        return irsJob.toBuilder()
+                     .clearSubmodels()
+                     .submodels(Collections.singletonList(supplyChainImpactedSubmodel))
+                     .build();
+    }
+
+    private Jobs updateLastModified(final Jobs irsJob, final ZonedDateTime lastModifiedOn) {
+        final Job job = irsJob.getJob().toBuilder().completedOn(lastModifiedOn).lastModifiedOn(lastModifiedOn).build();
+        return irsJob.toBuilder().job(job).build();
+    }
+
     private Jobs extendSummary(final Jobs irsJob) {
         final Summary oldSummary = Optional.ofNullable(irsJob.getJob().getSummary()).orElse(Summary.builder().build());
         final NotificationSummary newSummary = new NotificationSummary(oldSummary.getAsyncFetchedItems(),
@@ -111,19 +169,4 @@ private Jobs extendSummary(final Jobs irsJob) {
         return irsJob.toBuilder().job(job).build();
     }
 
-    public BpnInvestigationJob withNotifications(final List<String> notifications) {
-        this.unansweredNotifications.addAll(notifications);
-        return this;
-    }
-
-    public BpnInvestigationJob withAnsweredNotification(final String notificationId) {
-        this.unansweredNotifications.remove(notificationId);
-        this.answeredNotifications.add(notificationId);
-        return this;
-    }
-
-    public BpnInvestigationJob complete() {
-        this.state = JobState.COMPLETED;
-        return this;
-    }
 }

irs-api/src/main/java/org/eclipse/tractusx/irs/ess/service/EdcNotificationSender.java

@@ -60,7 +60,7 @@ public EdcNotificationSender(final EdcSubmodelFacade edcSubmodelFacade,
     }
 
     public void sendEdcNotification(final EdcNotification<InvestigationNotificationContent> originalEdcNotification,
-            final SupplyChainImpacted supplyChainImpacted) {
+            final SupplyChainImpacted supplyChainImpacted, final Integer hops, final String bpn) {
         final String notificationId = UUID.randomUUID().toString();
         final String originalNotificationId = originalEdcNotification.getHeader().getNotificationId();
         final String recipientBpn = originalEdcNotification.getHeader().getSenderBpn();
@@ -69,6 +69,8 @@ public void sendEdcNotification(final EdcNotification<InvestigationNotificationC
                 log.info("Edc Notification will be send to connector endpoint: {}", connectorEndpoint);
                 final NotificationContent notificationContent = ResponseNotificationContent.builder()
                                                                                            .result(supplyChainImpacted.getDescription())
+                                                                                           .hops(hops)
+                                                                                           .parentBpn(bpn)
                                                                                            .build();
                 final EdcNotification<NotificationContent> responseNotification = edcRequest(notificationId,
                         originalNotificationId, essLocalEdcEndpoint, localBpn, recipientBpn, notificationContent);

irs-api/src/main/java/org/eclipse/tractusx/irs/ess/service/EssRecursiveNotificationHandler.java

@@ -23,12 +23,15 @@
  ********************************************************************************/
 package org.eclipse.tractusx.irs.ess.service;
 
+import java.util.Comparator;
 import java.util.List;
 import java.util.Optional;
 import java.util.UUID;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.eclipse.tractusx.irs.edc.client.model.notification.EdcNotification;
+import org.eclipse.tractusx.irs.edc.client.model.notification.ResponseNotificationContent;
 import org.springframework.stereotype.Service;
 
 /**
@@ -39,31 +42,34 @@
 @Slf4j
 public class EssRecursiveNotificationHandler {
 
+    private static final Integer FIRST_HOP = 0;
+
     private final RelatedInvestigationJobsCache relatedInvestigationJobsCache;
     private final BpnInvestigationJobCache bpnInvestigationJobCache;
     private final EdcNotificationSender edcNotificationSender;
 
-    /* package */ void handleNotification(final UUID finishedJobId, final SupplyChainImpacted supplyChainImpacted) {
+    /* package */ void handleNotification(final UUID finishedJobId, final SupplyChainImpacted supplyChainImpacted, final String bpn) {
 
         final Optional<RelatedInvestigationJobs> relatedJobsId = relatedInvestigationJobsCache.findByRecursiveRelatedJobId(
                 finishedJobId);
 
         relatedJobsId.ifPresentOrElse(relatedJobs -> {
             if (SupplyChainImpacted.YES.equals(supplyChainImpacted)) {
                 log.debug("SupplyChain is impacted. Sending notification back to requestor.");
-                edcNotificationSender.sendEdcNotification(relatedJobs.originalNotification(), supplyChainImpacted);
+                edcNotificationSender.sendEdcNotification(relatedJobs.originalNotification(), supplyChainImpacted, FIRST_HOP, bpn);
                 relatedInvestigationJobsCache.remove(
                         relatedJobs.originalNotification().getHeader().getNotificationId());
             } else {
                 log.debug(
                         "SupplyChainImpacted in state '{}'. Waiting for Jobs to complete to send notification back to requestor.",
                         supplyChainImpacted);
-                sendNotificationAfterAllCompleted(relatedJobs);
+                sendNotificationAfterAllCompleted(relatedJobs, bpn);
             }
         }, () -> log.debug("No RelatedInvestigationJob found for id '{}'.", finishedJobId));
     }
 
-    private void sendNotificationAfterAllCompleted(final RelatedInvestigationJobs relatedInvestigationJobs) {
+    private void sendNotificationAfterAllCompleted(final RelatedInvestigationJobs relatedInvestigationJobs,
+            final String bpn) {
         final List<BpnInvestigationJob> allInvestigationJobs = relatedInvestigationJobs.recursiveRelatedJobIds()
                                                                                        .stream()
                                                                                        .map(bpnInvestigationJobCache::findByJobId)
@@ -75,9 +81,20 @@ private void sendNotificationAfterAllCompleted(final RelatedInvestigationJobs re
                                                                         .flatMap(Optional::stream)
                                                                         .reduce(SupplyChainImpacted.NO,
                                                                                 SupplyChainImpacted::or);
-            edcNotificationSender.sendEdcNotification(relatedInvestigationJobs.originalNotification(), finalResult);
+
+            edcNotificationSender.sendEdcNotification(relatedInvestigationJobs.originalNotification(), finalResult, getMinHops(allInvestigationJobs), bpn);
         }
+    }
 
+    private Integer getMinHops(final List<BpnInvestigationJob> allInvestigationJobs) {
+        return allInvestigationJobs
+                .stream()
+                .flatMap(investigationJobs -> investigationJobs.getAnsweredNotifications().stream())
+                .map(EdcNotification::getContent)
+                .filter(ResponseNotificationContent::thereIsIncident)
+                .min(Comparator.comparing(ResponseNotificationContent::getHops))
+                .map(ResponseNotificationContent::getHops)
+                .orElse(FIRST_HOP);
     }
 
     private boolean checkAllFinished(final List<BpnInvestigationJob> allInvestigationJobs) {

irs-api/src/main/java/org/eclipse/tractusx/irs/ess/service/EssRecursiveService.java

@@ -43,6 +43,8 @@
 @Slf4j
 public class EssRecursiveService {
 
+    private static final Integer FIRST_HOP = 0;
+
     private final EssService essService;
     private final RelatedInvestigationJobsCache relatedInvestigationJobsCache;
     private final String localBpn;
@@ -65,7 +67,7 @@ public void handleNotification(final EdcNotification<InvestigationNotificationCo
                 notification.getContent().getConcernedCatenaXIds());
 
         if (incidentBPNSs.isPresent() && incidentBPNSs.get().contains(localBpn)) {
-            edcNotificationSender.sendEdcNotification(notification, SupplyChainImpacted.YES);
+            edcNotificationSender.sendEdcNotification(notification, SupplyChainImpacted.YES, FIRST_HOP, localBpn);
         } else if (concernedCatenaXIdsNotification.isPresent() && incidentBPNSs.isPresent()) {
             final List<String> bpns = incidentBPNSs.get();
             final List<String> concernedCatenaXIds = concernedCatenaXIdsNotification.get();