chore: normalize msg before emit

libp2p · Aug 19, 2020 · e905864 · e905864
1 parent c9cc4ec
commit e905864
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/pubsub/index.js b/src/pubsub/index.js
@@ -576,12 +576,13 @@ class PubsubBaseProtocol extends EventEmitter {
       topicIDs: [topic]
     }
 
+    // ensure that any operations performed on the message will include the signature
+    const outMsg = await this._buildMessage(msgObject)
+    msgObject = utils.normalizeInRpcMessage(outMsg)
+
     // Emit to self if I'm interested and emitSelf enabled
     this.emitSelf && this._emitMessage(msgObject)
 
-    // ensure that any operations performed on the message will include the signature
-    msgObject = await this._buildMessage(msgObject)
-
     // send to all the other peers
     await this._publish(msgObject)
   }