fix!: reportMessageValidationResult to accept peer id string (#432)

fix: reportMessageValidationResult to accept peer id string

Author: twoeths

src/index.ts

@@ -2139,7 +2139,7 @@ export class GossipSub extends EventEmitter<GossipsubEvents> implements PubSub<G
    *
    * This should only be called once per message.
    */
-  reportMessageValidationResult(msgId: MsgIdStr, propagationSource: PeerId, acceptance: TopicValidatorResult): void {
+  reportMessageValidationResult(msgId: MsgIdStr, propagationSource: PeerIdStr, acceptance: TopicValidatorResult): void {
     let cacheEntry: MessageCacheRecord | null
 
     if (acceptance === TopicValidatorResult.Accept) {
@@ -2148,9 +2148,9 @@ export class GossipSub extends EventEmitter<GossipsubEvents> implements PubSub<G
       if (cacheEntry != null) {
         const { message: rawMsg, originatingPeers } = cacheEntry
         // message is fully validated inform peer_score
-        this.score.deliverMessage(propagationSource.toString(), msgId, rawMsg.topic)
+        this.score.deliverMessage(propagationSource, msgId, rawMsg.topic)
 
-        this.forwardMessage(msgId, cacheEntry.message, propagationSource.toString(), originatingPeers)
+        this.forwardMessage(msgId, cacheEntry.message, propagationSource, originatingPeers)
       }
       // else, Message not in cache. Ignoring forwarding
     }
@@ -2165,7 +2165,7 @@ export class GossipSub extends EventEmitter<GossipsubEvents> implements PubSub<G
 
         // Tell peer_score about reject
         // Reject the original source, and any duplicates we've seen from other peers.
-        this.score.rejectMessage(propagationSource.toString(), msgId, rawMsg.topic, rejectReason)
+        this.score.rejectMessage(propagationSource, msgId, rawMsg.topic, rejectReason)
         for (const peer of originatingPeers) {
           this.score.rejectMessage(peer, msgId, rawMsg.topic, rejectReason)
         }