interanl subscribe

Author: nullagent

src/topics/host-topic.js

@@ -2,9 +2,12 @@
 
 const Path = require('path')
 const debug = require('debug')('dataparty.topics.host-topic')
+const EventEmitter = require('eventemitter3')
 
-class HostTopic {
+
+class HostTopic extends EventEmitter {
   constructor(path, type){
+    super()
     this.path = Path.normalize(path)
     this.type = type
     this.created = Date.now()
@@ -95,6 +98,12 @@ class HostTopic {
       sends.push(node[1].send(this, this.lastMessage, sender))
     }
 
+    this.emit('publish', {
+      topic: this,
+      data: this.lastMessage,
+      sender: sender
+    })
+
     if(sends.length > 0){
       debug('publishing', this.path)
       this.sending = true

src/topics/local-topic-host.js

@@ -18,8 +18,8 @@ class LocalTopicHost {
    */
   constructor(){
     debug('constructor')
-    this.nodesByUuid = new Map()
-    this.topicsByPath = new Map()
+    this.nodesByUuid = new Map()    // <string, PeerNode>
+    this.topicsByPath = new Map()   // <string, HostTopic>
     this.party = null
   }
 
@@ -146,6 +146,18 @@ class LocalTopicHost {
 
   }
 
+  async subscribeInternal(path, cb, create=false){
+    const topic = this.getTopic(path, create)
+
+    debug('subscribeInternal', path)
+
+    if(topic){
+
+      topic.on('publish', cb)
+    }
+
+  }
+
   async destroyNode(peer){
     const node = this.getNodeByPeer(peer)