Event related fixes (#159)

* Add events() method to CredentialsModule
* Add events for createInvitation & receiveInvitation

src/lib/modules/CredentialsModule.ts

@@ -9,6 +9,7 @@ import logger from '../logger';
 import { CredentialOfferMessage } from '../protocols/credentials/messages/CredentialOfferMessage';
 import { JsonEncoder } from '../utils/JsonEncoder';
 import { JsonTransformer } from '../utils/JsonTransformer';
+import { EventEmitter } from 'events';
 
 export class CredentialsModule {
   private connectionService: ConnectionService;
@@ -73,4 +74,8 @@ export class CredentialsModule {
   public async find(id: string) {
     return this.credentialService.find(id);
   }
+
+  public events(): EventEmitter {
+    return this.credentialService;
+  }
 }

src/lib/protocols/connections/ConnectionService.ts

@@ -68,7 +68,13 @@ class ConnectionService extends EventEmitter {
     });
 
     connectionRecord.invitation = invitation;
-    this.connectionRepository.update(connectionRecord);
+
+    await this.connectionRepository.update(connectionRecord);
+
+    this.emit(EventType.StateChanged, {
+      connection: connectionRecord,
+      prevState: null,
+    });
 
     return connectionRecord;
   }
@@ -100,6 +106,13 @@ class ConnectionService extends EventEmitter {
       },
     });
 
+    await this.connectionRepository.update(connectionRecord);
+
+    this.emit(EventType.StateChanged, {
+      connection: connectionRecord,
+      prevState: null,
+    });
+
     return connectionRecord;
   }