feat(slack): allow receiving file/audio/video/image (#573)

* add files support for slack v1 * feat(slack): allow receiving file/audio/video/image
botpress · Jul 31, 2023 · 167a9c3 · 167a9c3
1 parent 89db5ac
commit 167a9c3
Show file tree

Hide file tree

Showing 4 changed files with 80 additions and 261 deletions.
diff --git a/packages/channels/src/slack/README.md b/packages/channels/src/slack/README.md
@@ -17,15 +17,15 @@
 
 ### Receiving
 
-| Channels      | Slack | Details |
-| ------------- | :---: | :------ |
-| Text          |  ✅   |         |
-| Quick Reply   |  ✅   |         |
-| Postback      |  ✅   |         |
-| Say Something |  ✅   |         |
-| Voice         |  ❌   |         |
-| Image         |  ❌   |         |
-| File          |  ❌   |         |
-| Audio         |  ❌   |         |
-| Video         |  ❌   |         |
-| Location      |  ❌   |         |
+| Channels      | Slack | Details     |
+| ------------- | :---: | :---------- |
+| Text          |  ✅   |             |
+| Quick Reply   |  ✅   |             |
+| Postback      |  ✅   |             |
+| Say Something |  ✅   |             |
+| Voice         |  ✅   | Private URL |
+| Image         |  ✅   | Private URL |
+| File          |  ✅   | Private URL |
+| Audio         |  ✅   | Private URL |
+| Video         |  ✅   | Private URL |
+| Location      |  ❌   |             |
diff --git a/packages/channels/src/slack/api.ts b/packages/channels/src/slack/api.ts
@@ -111,11 +111,23 @@ export class SlackApi extends ChannelApi<SlackService> {
     }
 
     if ('user' in message) {
-      await this.service.receive(
-        scope,
-        { identity: '*', sender: message.user, thread: message.channel },
-        { type: 'text', text: message.text }
-      )
+      if ('files' in message && message.files?.length) {
+        for (const file of message.files) {
+          await this.service.receive(
+            scope,
+            { identity: '*', sender: message.user, thread: message.channel },
+            { type: this.mapMimeTypeToStandardType(file.mimetype), url: file.url_private, title: file.title }
+          )
+        }
+      }
+
+      if (message.text?.length) {
+        await this.service.receive(
+          scope,
+          { identity: '*', sender: message.user, thread: message.channel },
+          { type: 'text', text: message.text }
+        )
+      }
     }
   }
 
@@ -163,6 +175,18 @@ export class SlackApi extends ChannelApi<SlackService> {
       payload: action.selected_option.value
     })
   }
+
+  private mapMimeTypeToStandardType(mimeType: string) {
+    if (mimeType?.startsWith('image/')) {
+      return 'image'
+    } else if (mimeType?.startsWith('video/')) {
+      return 'video'
+    } else if (mimeType?.startsWith('audio/')) {
+      return 'audio'
+    } else {
+      return 'file'
+    }
+  }
 }
 
 interface SlackActionHandler<T> {

diff --git a/packages/engine/package.json b/packages/engine/package.json
@@ -39,7 +39,7 @@
     "pg": "^8.7.1",
     "redlock": "^4.2.0",
     "semver": "^7.3.5",
-    "sqlite3": "^5.0.2",
+    "sqlite3": "^5.0.8",
     "uuid": "^8.3.2",
     "yn": "^4.0.0"
   }