add executeBotPostRoomCreate

src/definition/metadata/AppMethod.ts

@@ -58,6 +58,7 @@ export enum AppMethod {
     EXECUTEPREROOMCREATEMODIFY = 'executePreRoomCreateModify',
     CHECKPOSTROOMCREATE = 'checkPostRoomCreate',
     EXECUTEPOSTROOMCREATE = 'executePostRoomCreate',
+    EXECUTEBOTPOSTROOMCREATE = 'executeBotPostRoomCreate',
     CHECKPREROOMDELETEPREVENT = 'checkPreRoomDeletePrevent',
     EXECUTEPREROOMDELETEPREVENT = 'executePreRoomDeletePrevent',
     CHECKPOSTROOMDELETED = 'checkPostRoomDeleted',

src/definition/rooms/IPostBotRoomCreate.ts

@@ -0,0 +1,15 @@
+import { IHttp, IModify, IPersistence, IRead } from '../accessors';
+import { IRoom } from './IRoom';
+
+/** Handler for after a dm room with Bot is created. */
+export interface IPostBotRoomCreate {
+    /**
+     * Method called *after* the room has been created.
+     *
+     * @param room The room which was created
+     * @param read An accessor to the environment
+     * @param http An accessor to the outside world
+     * @param persistence An accessor to the App's persistence
+     */
+    executePostBotRoomCreate(room: IRoom, read: IRead, http: IHttp, persistence: IPersistence, modify: IModify): Promise<void>;
+}

src/server/managers/AppListenerManager.ts

@@ -842,6 +842,35 @@ export class AppListenerManager {
         for (const appId of this.listeners.get(AppInterface.IPostRoomCreate)) {
             const app = this.manager.getOneById(appId);
 
+            // Check if the dm belongs to the app
+
+            if (data.type === RoomType.DIRECT_MESSAGE && data.userIds.length > 1) {
+                for (const appId of this.listeners.get(AppInterface.IPostMessageSentToBot)) {
+                    const app = this.manager.getOneById(appId);
+                    if (app.hasMethod(AppMethod.EXECUTEPOSTMESSAGESENTTOBOT)) {
+                        const reader = this.am.getReader(appId);
+                        const bot = await reader.getUserReader().getAppUser();
+                        if (!bot) {
+                            continue;
+                        }
+
+                        if (!data.userIds.includes(bot.id)) {
+                            continue;
+                        }
+
+                        await app.call(
+                            AppMethod.EXECUTEBOTPOSTROOMCREATE,
+                            cfRoom,
+                            this.am.getReader(appId),
+                            this.am.getHttp(appId),
+                            this.am.getPersistence(appId),
+                            this.am.getModifier(appId),
+                        );
+                    }
+                }
+            }
+
+            // executePostBotRoomCreate
             let continueOn = true;
             if (app.hasMethod(AppMethod.CHECKPOSTROOMCREATE)) {
                 continueOn = (await app.call(AppMethod.CHECKPOSTROOMCREATE, cfRoom, this.am.getReader(appId), this.am.getHttp(appId))) as boolean;