feat(channels): add conversation.started event (#266)

* feat(channels): conversation.started * fix
botpress · Dec 3, 2021 · 67906da · 67906da
1 parent 8417ec0
commit 67906da
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 5 deletions.
diff --git a/packages/server/src/channels/base/conduit.ts b/packages/server/src/channels/base/conduit.ts
@@ -78,8 +78,9 @@ export abstract class ConduitInstance<TConfig, TContext extends ChannelContext<a
     }
   }
 
-  async receive<T>(payload: T) {
+  async receive<T>(payload: T, started?: boolean) {
     const conduit = (await this.app.conduits.get(this.conduitId))!
+    const channel = this.app.channels.getById(conduit!.channelId)
     const provider = (await this.app.providers.getById(conduit.providerId))!
     const endpoint = await this.extractEndpoint(payload)
 
@@ -96,9 +97,22 @@ export abstract class ConduitInstance<TConfig, TContext extends ChannelContext<a
     }
 
     const { userId, conversationId } = await this.app.mapping.getMapping(clientId, conduit.channelId, endpoint)
-    return this.app.messages.create(conversationId, userId, endpoint.content, {
-      conduit: { id: this.conduitId, endpoint: _.omit(endpoint, 'content') }
-    })
+
+    if (started) {
+      await this.app.stream.stream(
+        'conversation.started',
+        { conversationId, channel: channel.name },
+        clientId,
+        userId,
+        {
+          conduit: { id: this.conduitId, endpoint }
+        }
+      )
+    } else {
+      return this.app.messages.create(conversationId, userId, endpoint.content, {
+        conduit: { id: this.conduitId, endpoint: _.omit(endpoint, 'content') }
+      })
+    }
   }
 
   async initialize() {}

diff --git a/packages/server/src/channels/teams/conduit.ts b/packages/server/src/channels/teams/conduit.ts
@@ -72,6 +72,8 @@ export class TeamsConduit extends ConduitInstance<TeamsConfig, TeamsContext> {
         await turnContext.sendActivity(message)
       })
     }
+
+    await this.receive(turnContext, true)
   }
 
   protected async getContext(base: ChannelContext<any>): Promise<TeamsContext> {

diff --git a/packages/server/src/stream/service.ts b/packages/server/src/stream/service.ts
@@ -115,7 +115,7 @@ export class StreamService extends Service {
     }
   }
 
-  private async stream(type: string, data: any, clientId: uuid, userId?: uuid, source?: ActionSource) {
+  async stream(type: string, data: any, clientId: uuid, userId?: uuid, source?: ActionSource) {
     const payload = {
       type,
       data: {