Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

pass up userId

This commit is contained in:
dal 2025-07-16 13:22:43 -06:00
parent 6b01f2f97a
commit a20c8dad56
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/server/src/api/v2/slack/events.ts
View File

@ -90,9 +90,10 @@ export async function findOrCreateSlackChat({
/**
* Queue slack agent task for processing
*/
export async function queueSlackAgentTask(chatId: string): Promise<void> {
export async function queueSlackAgentTask(chatId: string, userId: string): Promise<void> {
await tasks.trigger('slack-agent-task', {
chatId,
userId,
});
}
@ -168,7 +169,7 @@ export async function eventsHandler(payload: SlackWebhookPayload): Promise<Slack
});
// Queue the task
await queueSlackAgentTask(chatId);
await queueSlackAgentTask(chatId, userId);
}
return { success: true };

1
apps/trigger/src/tasks/slack-agent-task/slack-agent-task.ts
View File

@ -3,6 +3,7 @@ import { z } from 'zod';
const SlackAgentTaskInputSchema = z.object({
chatId: z.string().uuid(),
userId: z.string().uuid(),
});
const SlackAgentTaskOutputSchema = z.object({});