Set assistant status to provide the user with waiting message

Author: spastorelli

integrations/slack/src/actions/inferUserIntent.ts

@@ -45,6 +45,38 @@ export async function inferUserIntentAndTriggerAction(
 
     logger.debug('Infering user intent from message', userMessage);
 
+    const installation = await getIntegrationInstallationForTeam(context, teamId);
+    if (!installation) {
+        throw new Error('Installation not found');
+    }
+    const installationConfiguration = installation.configuration as SlackInstallationConfiguration;
+    const accessToken = installationConfiguration.oauth_credentials?.access_token;
+    const accessTokenScopes = installationConfiguration.oauth_credentials?.requested_scopes || [];
+
+    // Installations created before the Docs Agents feature was released may not have a token with the
+    // required scope to call this API. Since this is non-blocking, we skip the API call if the token lacks
+    // the necessary permission.
+    if (accessTokenScopes.includes('assistant:write')) {
+        await slackAPI(
+            context,
+            {
+                method: 'POST',
+                path: 'assistant.threads.setStatus',
+                payload: {
+                    channel_id: channelId,
+                    thread_ts: threadTs,
+                    status: 'is working on your request...',
+                    loading_messages: [
+                        'Reading your message…',
+                        'Understanding your request…',
+                        'Determining the best action…',
+                    ],
+                },
+            },
+            { accessToken },
+        );
+    }
+
     const result = await generateText({
         model: openai('gpt-5-nano'),
         messages: [
@@ -104,13 +136,6 @@ You are a Slack assistant designed to help users with their product documentatio
             .filter((content) => content && content.type === 'text');
         const lastAssistantMessage = assistantMessages.pop();
 
-        const installation = await getIntegrationInstallationForTeam(context, teamId);
-        if (!installation) {
-            throw new Error('Installation not found');
-        }
-        const accessToken = (installation.configuration as SlackInstallationConfiguration)
-            .oauth_credentials?.access_token;
-
         await slackAPI(
             context,
             {

integrations/slack/src/configuration.ts

@@ -3,6 +3,7 @@ import { RuntimeContext, RuntimeEnvironment } from '@gitbook/runtime';
 export interface SlackInstallationConfiguration {
     oauth_credentials?: {
         access_token: string;
+        requested_scopes?: string[];
     };
 
     default_channel?: string;

integrations/slack/src/handlers/handlers.ts

@@ -80,19 +80,20 @@ export async function messageEventHandler(eventPayload: any, context: SlackRunti
  */
 export async function appMentionEventHandler(eventPayload: any, context: SlackRuntimeContext) {
     // pull out required params from the slashEvent for queryAskAI
-    const { type, text, thread_ts, channel, user, team, response_url } = eventPayload.event;
+    const { type, text, channel, ts, thread_ts, user, team } = eventPayload.event;
 
     // check for bot_id so that the bot doesn't trigger itself
     if (['message', 'app_mention'].includes(type) && isAllowedToRespond(eventPayload)) {
         // strip out the bot-name in the mention and account for user mentions within the query
         // @ts-ignore
         const parsedMessage = stripBotName(text, eventPayload.authorizations[0]?.user_id);
+        logger.info('Received payload', JSON.stringify(eventPayload));
 
         context.waitUntil(
             inferUserIntentAndTriggerAction(
                 {
                     channelId: channel,
-                    threadTs: thread_ts,
+                    threadTs: thread_ts ?? ts,
                     userId: user,
                     teamId: team,
                     userMessage: parsedMessage,

integrations/slack/src/router.ts

@@ -40,21 +40,6 @@ export const handleFetchEvent: FetchEventCallback = async (request, context) =>
         ).pathname,
     });
 
-    const encodedScopes = encodeURIComponent(
-        [
-            'app_mentions:read',
-            'chat:write',
-            'channels:join',
-            'channels:read',
-            'groups:read',
-            'links:read',
-            'links:write',
-            'commands',
-            'channels:history',
-            'im:history',
-        ].join(' '),
-    );
-
     /**
      * Handle integration tasks
      */
@@ -88,6 +73,21 @@ export const handleFetchEvent: FetchEventCallback = async (request, context) =>
         });
     });
 
+    const requestedScopes = [
+        'app_mentions:read',
+        'chat:write',
+        'channels:join',
+        'channels:read',
+        'groups:read',
+        'links:read',
+        'links:write',
+        'commands',
+        'channels:history',
+        'im:history',
+        'assistant:write',
+    ];
+    const encodedScopes = encodeURIComponent(requestedScopes.join(' '));
+
     /*
      * Authenticate the user using OAuth.
      */
@@ -115,7 +115,10 @@ export const handleFetchEvent: FetchEventCallback = async (request, context) =>
                 return {
                     externalIds: [response.team.id],
                     configuration: {
-                        oauth_credentials: { access_token: response.access_token },
+                        oauth_credentials: {
+                            access_token: response.access_token,
+                            requested_scopes: requestedScopes,
+                        },
                     },
                 };
             },