add event listener to the ioc

Author: hirsch88

src/api/controllers/UserController.ts

@@ -1,4 +1,4 @@
-import { injectable, inject, named } from 'inversify';
+import { inject, named } from 'inversify';
 import { Controller, Get, Post, Put, Delete, RequestParam, RequestBody, Response, Request } from 'inversify-express-utils';
 import { my } from 'my-express';
 import { UserService } from '../services/UserService';
@@ -17,7 +17,6 @@ const populateUser = ioc.Container.getNamed<PopulateUserMiddleware>(Types.Middle
  * UserController is in charge of the user resource and should
  * provide all crud actions.
  */
-@injectable()
 @Controller('/user', authenticate.use)
 export class UserController {
 

src/api/controllers/auth/AuthController.ts

@@ -1,9 +1,7 @@
-import { injectable } from 'inversify';
 
 
 export namespace auth {
 
-    @injectable()
     export class AuthController {
 
     }

src/api/listeners/UserAuthenticatedListener.ts

@@ -0,0 +1,24 @@
+import { inject, named } from 'inversify';
+import { Types } from '../../constants/Types';
+import { Core } from '../../constants/Targets';
+import { events } from '../../core/api/events';
+import { Log } from '../../core/log/';
+
+
+export class UserAuthenticatedListener {
+
+    static Event = Symbol('UserAuthenticatedListener');
+
+    public log: Log;
+
+    constructor(
+        @inject(Types.Core) @named(Core.Log) Logger: typeof Log
+    ) {
+        this.log = new Logger('api:listeners:UserAuthenticatedListener');
+    }
+
+    public async run(user: any): Promise<void> {
+        this.log.info('Receive event UserAuthenticatedListener', user);
+    }
+
+}

src/api/listeners/UserCreatedListener.ts

@@ -1,3 +1,6 @@
+import { inject, named } from 'inversify';
+import { Types } from '../../constants/Types';
+import { Core } from '../../constants/Targets';
 import { events } from '../../core/api/events';
 import { Log } from '../../core/log/';
 
@@ -8,8 +11,17 @@ export class UserCreatedListener {
 
     static Event = Symbol('UserCreated');
 
+    public log: Log;
+
+    constructor(
+        @inject(Types.Core) @named(Core.Log) Logger: typeof Log
+    ) {
+        this.log = new Logger('api:listeners:UserCreatedListener');
+    }
+
     public async run(user: any): Promise<void> {
         log.info('Receive event UserCreated', user);
     }
 
 }
+

src/api/middlewares/AuthenticateMiddleware.ts

@@ -1,12 +1,13 @@
-import { injectable, inject, named } from 'inversify';
+import { inject, named } from 'inversify';
 import * as Request from 'request';
 import { my } from 'my-express';
 import { Log } from '../../core/log';
 import { Types } from '../../constants/Types';
 import { Lib, Core } from '../../constants/Targets';
+import { events } from '../../core/api/events';
+import { UserAuthenticatedListener } from '../listeners/UserAuthenticatedListener';
 
 
-@injectable()
 export class AuthenticateMiddleware {
 
     public log: Log;
@@ -20,8 +21,6 @@ export class AuthenticateMiddleware {
 
 
     public use = (req: my.Request, res: my.Response, next: my.NextFunction): void => {
-        // console.log(this.request());
-        // return next();
         const token = this.getToken(req);
 
         if (token === null) {
@@ -43,6 +42,7 @@ export class AuthenticateMiddleware {
             if (!error && response.statusCode === 200) {
                 req.tokeninfo = JSON.parse(body);
                 this.log.info(`Retrieved user ${req.tokeninfo.email}`);
+                events.emit(UserAuthenticatedListener.Event, req.tokeninfo);
                 return next();
             }
 

src/api/middlewares/PopulateUserMiddleware.ts

@@ -1,4 +1,4 @@
-import { injectable, inject, named } from 'inversify';
+import { inject, named } from 'inversify';
 import * as Request from 'request';
 import { my } from 'my-express';
 import { Log } from '../../core/log';
@@ -7,7 +7,6 @@ import { Types } from '../../constants/Types';
 import { Service, Core } from '../../constants/Targets';
 
 
-@injectable()
 export class PopulateUserMiddleware {
 
     public log: Log;

src/api/models/User.ts

@@ -1,4 +1,3 @@
-import { injectable } from 'inversify';
 import { Bookshelf } from '../../config/Database';
 import { Tables } from '../../constants/Tables';
 
@@ -9,7 +8,6 @@ import { Tables } from '../../constants/Tables';
  * @class User
  * @extends {Bookshelf.Model<User>}
  */
-@injectable()
 export class User extends Bookshelf.Model<User> {
 
     public static async fetchById(id: number): Promise<User> {

src/api/repositories/UserRepository.ts

@@ -1,5 +1,5 @@
 import * as Bookshelf from 'bookshelf';
-import { injectable, inject, named } from 'inversify';
+import { inject, named } from 'inversify';
 import { Types } from '../../constants/Types';
 import { Model } from '../../constants/Targets';
 import { User } from '../models/User';
@@ -12,7 +12,6 @@ import { NotFoundException } from '../exceptions/NotFoundException';
  * @export
  * @class UserRepository
  */
-@injectable()
 export class UserRepository {
 
     constructor(

src/api/services/UserService.ts

@@ -1,5 +1,5 @@
 import * as Bookshelf from 'bookshelf';
-import { injectable, inject, named } from 'inversify';
+import { inject, named } from 'inversify';
 import { Core, Repository } from '../../constants/Targets';
 import { Types } from '../../constants/Types';
 import { Log } from '../../core/log';
@@ -23,7 +23,6 @@ import { UserCreatedListener } from '../listeners/UserCreatedListener';
  * @export
  * @class UserService
  */
-@injectable()
 export class UserService {
 
     public log: Log;

src/constants/Targets.ts

@@ -15,17 +15,6 @@ export const Core = {
     Log: 'Log'
 };
 
-export const Controller = {
-    UserController: 'UserController',
-    auth: {
-        AuthController: 'auth.AuthController'
-    }
-};
-
-export const Service = {
-    UserService: 'UserService'
-};
-
 export const Model = {
     User: 'User'
 };
@@ -34,7 +23,23 @@ export const Repository = {
     UserRepository: 'UserRepository'
 };
 
+export const Service = {
+    UserService: 'UserService'
+};
+
 export const Middleware = {
     AuthenticateMiddleware: 'AuthenticateMiddleware',
     PopulateUserMiddleware: 'PopulateUserMiddleware'
 };
+
+export const Listener = {
+    UserAuthenticatedListener: 'UserAuthenticatedListener',
+    UserCreatedListener: 'UserCreatedListener'
+};
+
+export const Controller = {
+    UserController: 'UserController',
+    auth: {
+        AuthController: 'auth.AuthController'
+    }
+};