Merge pull request #620 from automatisch/refactor/restructure-slack

refactor: Use beforeRequest hook with slack app

packages/backend/src/apps/slack/actions/find-message/find-message.ts

@@ -8,10 +8,6 @@ type FindMessageOptions = {
 };
 
 const findMessage = async ($: IGlobalVariable, options: FindMessageOptions) => {
-  const headers = {
-    Authorization: `Bearer ${$.auth.data.accessToken}`,
-  };
-
   const params = {
     query: options.query,
     sort: options.sortBy,
@@ -20,7 +16,6 @@ const findMessage = async ($: IGlobalVariable, options: FindMessageOptions) => {
   };
 
   const response = await $.http.get('/search.messages', {
-    headers,
     params,
   });
 

packages/backend/src/apps/slack/actions/send-a-message-to-channel/post-message.ts

@@ -5,16 +5,12 @@ const postMessage = async (
   channelId: string,
   text: string
 ) => {
-  const headers = {
-    Authorization: `Bearer ${$.auth.data.accessToken}`,
-  };
-
   const params = {
     channel: channelId,
     text,
   };
 
-  const response = await $.http.post('/chat.postMessage', params, { headers });
+  const response = await $.http.post('/chat.postMessage', params);
 
   const message: IActionOutput = {
     data: {

packages/backend/src/apps/slack/auth/is-still-verified.ts

@@ -1,6 +1,7 @@
+import { IGlobalVariable } from '@automatisch/types';
 import verifyCredentials from './verify-credentials';
 
-const isStillVerified = async ($: any) => {
+const isStillVerified = async ($: IGlobalVariable) => {
   try {
     await verifyCredentials($);
     return true;

packages/backend/src/apps/slack/common/add-auth-header.ts

@@ -0,0 +1,11 @@
+import { TBeforeRequest } from '@automatisch/types';
+
+const addAuthHeader: TBeforeRequest = ($, requestConfig) => {
+  if (requestConfig.headers && $.auth.data?.accessToken) {
+    requestConfig.headers.Authorization = `Bearer ${$.auth.data.accessToken}`;
+  }
+
+  return requestConfig;
+};
+
+export default addAuthHeader;

packages/backend/src/apps/slack/data/list-channels/index.ts

@@ -13,19 +13,15 @@ export default {
       error: null,
     };
 
-    const response = await $.http.get('/conversations.list', {
+    const response = await $.http.get('/conversations.list');
-      headers: {
-        Authorization: `Bearer ${$.auth.data.accessToken}`,
-      },
-    });
 
     if (response.integrationError) {
       channels.error = response.integrationError;
       return channels;
     }
 
-    if (response.data.ok === 'false') {
+    if (response.data.ok === false) {
-      channels.error = response.data.error;
+      channels.error = response.data;
       return channels;
     }
 

packages/backend/src/apps/slack/index.ts

@@ -1,4 +1,7 @@
-export default {
+import defineApp from '../../helpers/define-app';
+import addAuthHeader from './common/add-auth-header';
+
+export default defineApp({
   name: 'Slack',
   key: 'slack',
   iconUrl: '{BASE_URL}/apps/slack/assets/favicon.svg',
@@ -6,4 +9,6 @@ export default {
   supportsConnections: true,
   baseUrl: 'https://slack.com',
   apiBaseUrl: 'https://slack.com/api',
-};
+  primaryColor: '4a154b',
+  beforeRequest: [addAuthHeader],
+});