Skip to content

Commit 2234bfa

Browse files
authored
fix: deliver message when publish (#526)
* fix: deliver message when publish * fix: lint --------- Co-authored-by: Tuyen Nguyen <[email protected]>
1 parent 60b5dad commit 2234bfa

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/index.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2268,6 +2268,8 @@ export class GossipSub extends TypedEventEmitter<GossipsubEvents> implements Pub
22682268
this.seenCache.put(msgIdStr)
22692269
// all published messages are valid
22702270
this.mcache.put({ msgId, msgIdStr }, rawMsg, true)
2271+
// Consider the message as delivered for gossip promises.
2272+
this.gossipTracer.deliverMessage(msgIdStr)
22712273

22722274
// If the message is anonymous or has a random author add it to the published message ids cache.
22732275
this.publishedMessageIds.put(msgIdStr)

0 commit comments

Comments
 (0)