Update blox.go

functionland · Nov 6, 2023 · 0a6ccd9 · 0a6ccd9
1 parent 13b693a
commit 0a6ccd9
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/blox/blox.go b/blox/blox.go
@@ -98,7 +98,12 @@ func (p *Blox) validateAnnouncement(ctx context.Context, id peer.ID, msg *pubsub
 			log.Errorw("peer is not an approved member", "peer", id)
 			return false
 		}
-	case PoolJoinRequestAnnouncementType, PoolJoinApproveAnnouncementType, IExistAnnouncementType:
+	case PoolJoinRequestAnnouncementType:
+		if status != blockchain.Unknown {
+			log.Errorw("peer is no longer permitted to send this message type", "peer", id)
+			return false
+		}
+	case PoolJoinApproveAnnouncementType, IExistAnnouncementType:
 		// Any member status is valid for a pool join announcement
 	default:
 		return false