CST-12744 if Announce received, NotifyRequestsStatus won't give the element

This commit is contained in:
frabacche
2023-11-24 10:53:27 +01:00
parent 5bb75512b0
commit 37227c10c4

View File

@@ -299,8 +299,7 @@ public class LDNMessageServiceImpl implements LDNMessageService {
offer.setStatus(NotifyRequestStatusEnum.REQUESTED); offer.setStatus(NotifyRequestStatusEnum.REQUESTED);
} else if (acks.stream() } else if (acks.stream()
.filter(c -> (c.getActivityStreamType().equalsIgnoreCase("TentativeAccept") || .filter(c -> (c.getActivityStreamType().equalsIgnoreCase("TentativeAccept") ||
c.getActivityStreamType().equalsIgnoreCase("Accept") || c.getActivityStreamType().equalsIgnoreCase("Accept")))
c.getActivityStreamType().equalsIgnoreCase("Announce")))
.findAny().isPresent()) { .findAny().isPresent()) {
offer.setStatus(NotifyRequestStatusEnum.ACCEPTED); offer.setStatus(NotifyRequestStatusEnum.ACCEPTED);
} else if (acks.stream() } else if (acks.stream()
@@ -308,9 +307,13 @@ public class LDNMessageServiceImpl implements LDNMessageService {
.findAny().isPresent()) { .findAny().isPresent()) {
offer.setStatus(NotifyRequestStatusEnum.REJECTED); offer.setStatus(NotifyRequestStatusEnum.REJECTED);
} }
if (acks.stream().filter(
c -> c.getActivityStreamType().equalsIgnoreCase("Announce"))
.findAny().isEmpty()) {
result.addRequestStatus(offer); result.addRequestStatus(offer);
} }
} }
}
return result; return result;
} }