Skip to content

Commit

Permalink
Merge branch '07-show-new-offer-with-pending-status' into 08-handle-e…
Browse files Browse the repository at this point in the history
…xtradata-in-editoffer
  • Loading branch information
ghubstan committed Aug 16, 2021
2 parents 1c096d0 + 524a586 commit 859a5ab
Showing 1 changed file with 8 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ public void onAdded(Offer offer, P2PDataStorage.ByteArray hashOfPayload, int seq
boolean hasSameOffer = offerBookListItems.stream().anyMatch(item -> item.getOffer().equals(offer));
if (!hasSameOffer) {
OfferBookListItem newOfferBookListItem = new OfferBookListItem(offer, hashOfPayload, sequenceNumber);
removeAnyOldOfferBookListItemsBeforeAddingReplacement(newOfferBookListItem);
removeDuplicateItem(newOfferBookListItem);
offerBookListItems.add(newOfferBookListItem); // Add replacement.
if (log.isDebugEnabled()) {
log.debug("onAdded: Added new offer {}\n"
Expand All @@ -116,7 +116,7 @@ public void onRemoved(Offer offer, P2PDataStorage.ByteArray hashOfPayload, int s
});
}

private void removeAnyOldOfferBookListItemsBeforeAddingReplacement(OfferBookListItem newOfferBookListItem) {
private void removeDuplicateItem(OfferBookListItem newOfferBookListItem) {
String offerId = newOfferBookListItem.getOffer().getId();
List<OfferBookListItem> offerItemsWithSameIdAndDifferentHash = offerBookListItems.stream()
.filter(item -> item.getOffer().getId().equals(offerId) && (
Expand Down Expand Up @@ -247,8 +247,7 @@ public void fillOfferBookListItems() {
// Investigate why....
offerBookListItems.clear();
offerBookListItems.addAll(offerBookService.getOffers().stream()
.filter(o -> !isOfferIdBanned(o))
.filter(o -> isV3NodeAddressCompliant(o))
.filter(o -> isOfferAllowed(o))
.map(OfferBookListItem::new)
.collect(Collectors.toList()));

Expand Down Expand Up @@ -288,21 +287,16 @@ private Optional<OfferBookListItem> getOfferBookListItem(Offer offer) {
.findFirst();
}

private boolean isOfferIdBanned(Offer offer) {
return filterManager.isOfferIdBanned(offer.getId());
}

private boolean isV3NodeAddressCompliant(Offer offer) {
return !OfferRestrictions.requiresNodeAddressUpdate()
private boolean isOfferAllowed(Offer offer) {
boolean isBanned = filterManager.isOfferIdBanned(offer.getId());
boolean isV3NodeAddressCompliant = !OfferRestrictions.requiresNodeAddressUpdate()
|| Utils.isV3Address(offer.getMakerNodeAddress().getHostName());
return !isBanned && isV3NodeAddressCompliant;
}

private boolean isStoredLocally(Offer offer) {
return offerBookService.getOffers().stream()
.anyMatch(o -> o.getId().equals(offer.getId())
&& !isOfferIdBanned(o)
&& isV3NodeAddressCompliant(o)
);
.anyMatch(o -> o.getId().equals(offer.getId()) && isOfferAllowed(o));
}

private void fillOfferCountMaps() {
Expand Down

0 comments on commit 859a5ab

Please sign in to comment.