diff --git a/src/message/rpc.proto.js b/src/message/rpc.proto.js index 50eb9506dc..6f917bfcef 100644 --- a/src/message/rpc.proto.js +++ b/src/message/rpc.proto.js @@ -6,7 +6,7 @@ message RPC { message SubOpts { optional bool subscribe = 1; // subscribe or unsubcribe - optional string topicCID = 2; + optional string topicID = 2; } message Message { diff --git a/src/peer.js b/src/peer.js index c0af044273..45c4573222 100644 --- a/src/peer.js +++ b/src/peer.js @@ -105,7 +105,7 @@ class Peer extends EventEmitter { topics.forEach((topic) => { subs.push({ subscribe: subscribe, - topicCID: topic + topicID: topic }) }) @@ -153,9 +153,9 @@ class Peer extends EventEmitter { updateSubscriptions (changes) { changes.forEach((subopt) => { if (subopt.subscribe) { - this.topics.add(subopt.topicCID) + this.topics.add(subopt.topicID) } else { - this.topics.delete(subopt.topicCID) + this.topics.delete(subopt.topicID) } }) }