[NEW] Add new events after user has been created, updated and deleted

src/definition/metadata/AppInterface.ts

@@ -43,4 +43,7 @@ export enum AppInterface {
     IPreFileUpload = 'IPreFileUpload',
     // Email
     IPreEmailSent = 'IPreEmailSent',
+    IPostUserCreated = 'IPostUserCreated',
+    IPostUserUpdated = 'IPostUserUpdated',
+    IPostUserDeleted = 'IPostUserDeleted',
 }

src/definition/metadata/AppMethod.ts

@@ -76,4 +76,8 @@ export enum AppMethod {
     EXECUTE_PRE_FILE_UPLOAD = 'executePreFileUpload',
     // Email
     EXECUTE_PRE_EMAIL_SENT = 'executePreEmailSent',
+    // User
+    EXECUTE_POST_USER_CREATED = 'executePostUserCreated',
+    EXECUTE_POST_USER_UPDATED = 'executePostUserUpdated',
+    EXECUTE_POST_USER_DELETED = 'executePostUserDeleted',
 }

src/definition/users/IPostUserCreated.ts

@@ -0,0 +1,21 @@
+import { IHttp, IModify, IPersistence, IRead } from '../accessors';
+import { AppMethod } from '../metadata';
+import { IUserContext } from './IUserContext';
+
+/**
+ * Event interface that allows an app to
+ * register as a handler of the `IPostUserCreated`
+ * event
+ *
+ * This event is triggered *after* the
+ * user has been saved to the database.
+ */
+export interface IPostUserCreated {
+    [AppMethod.EXECUTE_POST_USER_CREATED](
+        context: IUserContext,
+        read: IRead,
+        http: IHttp,
+        persis: IPersistence,
+        modify: IModify,
+    ): Promise<void>;
+}

src/definition/users/IPostUserDeleted.ts

@@ -0,0 +1,21 @@
+import { IHttp, IModify, IPersistence, IRead } from '../accessors';
+import { AppMethod } from '../metadata';
+import { IUserContext } from './IUserContext';
+
+/**
+ * Event interface that allows an app to
+ * register as a handler of the `IPostUserDeleted`
+ * event
+ *
+ * This event is triggered *after* the
+ * user has been removed from the database.
+ */
+export interface IPostUserDeleted {
+    [AppMethod.EXECUTE_POST_USER_DELETED](
+        context: IUserContext,
+        read: IRead,
+        http: IHttp,
+        persis: IPersistence,
+        modify: IModify,
+    ): Promise<void>;
+}

src/definition/users/IPostUserUpdated.ts

@@ -0,0 +1,21 @@
+import { IHttp, IModify, IPersistence, IRead } from '../accessors';
+import { AppMethod } from '../metadata';
+import { IUserUpdateContext } from './IUserUpdateContext';
+
+/**
+ * Event interface that allows an app to
+ * register as a handler of the `IPostUserUpdated`
+ * event
+ *
+ * This event is triggered *after* the
+ * user has been saved to the database.
+ */
+export interface IPostUserUpdated {
+    [AppMethod.EXECUTE_POST_USER_UPDATED](
+        context: IUserUpdateContext,
+        read: IRead,
+        http: IHttp,
+        persis: IPersistence,
+        modify: IModify,
+    ): Promise<void>;
+}

src/definition/users/IUserContext.ts

@@ -0,0 +1,19 @@
+import { IUser } from './IUser';
+
+/**
+ * The context of execution for the following events:
+ * - IPostUserCreated
+ * - IPostUserDeleted
+ */
+export interface IUserContext {
+    /**
+     * The user who has been affected
+     * by the action
+     */
+    user: IUser;
+    /**
+     * The user who performed the
+     * action. Null if it's the user himself
+     */
+    performedBy?: IUser;
+}

src/definition/users/IUserUpdateContext.ts

@@ -0,0 +1,24 @@
+import { IUser } from './IUser';
+
+/**
+ * The context of execution for the
+ * IPostUserUpdated event
+ */
+export interface IUserUpdateContext {
+    /**
+     * The user who has been affected
+     * by the action
+     */
+    user: IUser;
+
+    /**
+     * The user who performed the
+     * update. Null if it's the user himself
+     */
+    performedBy?: IUser;
+
+    /**
+     * The user data before the update
+     */
+    previousData?: IUser;
+}

src/definition/users/index.ts

@@ -1,7 +1,23 @@
+import { IPostUserCreated } from './IPostUserCreated';
+import { IPostUserDeleted } from './IPostUserDeleted';
+import { IPostUserUpdated } from './IPostUserUpdated';
 import { IUser } from './IUser';
+import { IUserContext } from './IUserContext';
 import { IUserCreationOptions } from './IUserCreationOptions';
 import { IUserEmail } from './IUserEmail';
+import { IUserUpdateContext } from './IUserUpdateContext';
 import { UserStatusConnection } from './UserStatusConnection';
 import { UserType } from './UserType';
 
-export { IUser, IUserEmail, IUserCreationOptions, UserStatusConnection, UserType };
+export {
+    IUser,
+    IUserEmail,
+    IUserCreationOptions,
+    UserStatusConnection,
+    UserType,
+    IPostUserCreated,
+    IPostUserUpdated,
+    IPostUserDeleted,
+    IUserContext,
+    IUserUpdateContext,
+};

src/server/managers/AppListenerManager.ts

@@ -16,7 +16,7 @@ import {
     UIKitViewSubmitInteractionContext,
 } from '../../definition/uikit/UIKitInteractionContext';
 import { IFileUploadContext } from '../../definition/uploads/IFileUploadContext';
-import { IUser } from '../../definition/users';
+import { IUser, IUserContext, IUserUpdateContext } from '../../definition/users';
 import { MessageBuilder, MessageExtender, RoomBuilder, RoomExtender } from '../accessors';
 import { AppManager } from '../AppManager';
 import { Message } from '../messages/Message';
@@ -234,6 +234,13 @@ export class AppListenerManager {
             // Email
             case AppInterface.IPreEmailSent:
                 return this.executePreEmailSent(data as IPreEmailSentContext);
+            // User
+            case AppInterface.IPostUserCreated:
+                return this.executePostUserCreated(data as IUserContext);
+            case AppInterface.IPostUserUpdated:
+                return this.executePostUserUpdated(data as IUserContext);
+            case AppInterface.IPostUserDeleted:
+                return this.executePostUserDeleted(data as IUserContext);
             default:
                 console.warn('An invalid listener was called');
                 return;
@@ -1196,4 +1203,58 @@ export class AppListenerManager {
 
         return descriptor;
     }
+
+    private async executePostUserCreated(data: IUserContext): Promise<void> {
+        const context = Utilities.deepFreeze(data);
+
+        for (const appId of this.listeners.get(AppInterface.IPostUserCreated)) {
+            const app = this.manager.getOneById(appId);
+
+            if (app.hasMethod(AppMethod.EXECUTE_POST_USER_CREATED)) {
+                await app.call(AppMethod.EXECUTE_POST_USER_CREATED,
+                    context,
+                    this.am.getReader(appId),
+                    this.am.getHttp(appId),
+                    this.am.getPersistence(appId),
+                    this.am.getModifier(appId),
+                );
+            }
+        }
+    }
+
+    private async executePostUserUpdated(data: IUserUpdateContext): Promise<void> {
+        const context = Utilities.deepFreeze(data);
+
+        for (const appId of this.listeners.get(AppInterface.IPostUserUpdated)) {
+            const app = this.manager.getOneById(appId);
+
+            if (app.hasMethod(AppMethod.EXECUTE_POST_USER_UPDATED)) {
+                await app.call(AppMethod.EXECUTE_POST_USER_UPDATED,
+                    context,
+                    this.am.getReader(appId),
+                    this.am.getHttp(appId),
+                    this.am.getPersistence(appId),
+                    this.am.getModifier(appId),
+                );
+            }
+        }
+    }
+
+    private async executePostUserDeleted(data: IUserContext): Promise<void> {
+        const context = Utilities.deepFreeze(data);
+
+        for (const appId of this.listeners.get(AppInterface.IPostUserDeleted)) {
+            const app = this.manager.getOneById(appId);
+
+            if (app.hasMethod(AppMethod.EXECUTE_POST_USER_DELETED)) {
+                await app.call(AppMethod.EXECUTE_POST_USER_DELETED,
+                    context,
+                    this.am.getReader(appId),
+                    this.am.getHttp(appId),
+                    this.am.getPersistence(appId),
+                    this.am.getModifier(appId),
+                );
+            }
+        }
+    }
 }