fix: EventEmmiter

decentralized-identity · Dec 12, 2019 · dc52b55 · dc52b55
1 parent f23263b
commit dc52b55
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 6 deletions.
diff --git a/packages/daf-cli/src/services.ts b/packages/daf-cli/src/services.ts
@@ -19,6 +19,7 @@ export const listen = async (pollSeconds?: number) => {
   })
 
   await core.setupServices()
+  await core.listen()
   await core.getMessagesSince(await dataStore.latestMessageTimestamps())
 
   if (pollSeconds) {

diff --git a/packages/daf-core/src/core.ts b/packages/daf-core/src/core.ts
@@ -65,8 +65,8 @@ export class Core extends EventEmitter {
   }
 
   async listen() {
-    debug('Listening...')
-    this.serviceManager.on(ServiceEventTypes.NewMessages, this.validateMessages)
+    debug('Listening for new messages')
+    this.serviceManager.on(ServiceEventTypes.NewMessages, this.validateMessages.bind(this))
     this.serviceManager.listen()
   }
 
@@ -76,7 +76,6 @@ export class Core extends EventEmitter {
   }
 
   public async validateMessages(messages: Message[]): Promise<Message[]> {
-    debug('validateMessages %O', messages)
     const result: Message[] = []
     for (const message of messages) {
       try {

diff --git a/packages/daf-core/src/service/service-manager.ts b/packages/daf-core/src/service/service-manager.ts
@@ -39,14 +39,13 @@ export class ServiceManager extends EventEmitter {
       for (const controller of this.controllers) {
         const instance = new controller(issuer, this.didResolver)
         await instance.ready
-        instance.on(ServiceEventTypes.NewMessages, this.onNewMessages)
+        instance.on(ServiceEventTypes.NewMessages, this.onNewMessages.bind(this))
         this.controllerInstances.push(instance)
       }
     }
   }
 
   private onNewMessages(messages: Message[]) {
-    debug('onNewMessage kakakaka %O', messages)
     this.emit(ServiceEventTypes.NewMessages, messages)
   }
 

diff --git a/packages/daf-data-store/src/graphql.ts b/packages/daf-data-store/src/graphql.ts
@@ -10,7 +10,6 @@ export const resolvers = {
     metaData: async (message: any, {}, { dataStore }: Context) => dataStore.messageMetaData(message.id),
     thread: async (message: any, {}, { dataStore }: Context) => {
       const messages = await dataStore.findMessages({ threadId: message.threadId })
-      console.log('AAAA', messages)
       return messages.filter((item: any) => item.id !== message.id)
     },
   },