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

tweak to the default_channel arg

This commit is contained in:
dal 2025-07-03 15:46:37 -06:00
parent 46a3331f36
commit 40e0146fd7
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
1 changed files with 7 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
apps/server/src/api/v2/slack/handler.ts
View File

@ -1,11 +1,11 @@
import { getUserOrganizationId } from '@buster/database';
import { SlackChannelService } from '@buster/slack';
import type { Context } from 'hono';
import { HTTPException } from 'hono/http-exception';
import { z } from 'zod';
import { getActiveIntegration, updateDefaultChannel } from './services/slack-helpers';
import { type SlackOAuthService, createSlackOAuthService } from './services/slack-oauth-service';
import { SlackChannelService } from '@buster/slack';
import * as slackHelpers from './services/slack-helpers';
import { type SlackOAuthService, createSlackOAuthService } from './services/slack-oauth-service';
// Request schemas
const InitiateOAuthSchema = z.object({
@ -24,7 +24,7 @@ const OAuthCallbackSchema = z.object({
});
const UpdateIntegrationSchema = z.object({
defaultChannel: z
default_channel: z
.object({
name: z.string().min(1),
id: z.string().min(1),
@ -375,8 +375,8 @@ export class SlackHandler {
}
// Update integration settings
if (parsed.data.defaultChannel) {
await updateDefaultChannel(integration.id, parsed.data.defaultChannel);
if (parsed.data.default_channel) {
await updateDefaultChannel(integration.id, parsed.data.default_channel);
}
return c.json({
@ -431,9 +431,7 @@ export class SlackHandler {
}
// Get active integration
const integration = await slackHelpers.getActiveIntegration(
organizationGrant.organizationId
);
const integration = await slackHelpers.getActiveIntegration(organizationGrant.organizationId);
if (!integration) {
return c.json(
@ -483,11 +481,7 @@ export class SlackHandler {
}
if (error instanceof Error && error.message.includes('Rate limit exceeded')) {
throw new SlackError(
'Rate limit exceeded. Please try again later.',
429,
'RATE_LIMITED'
);
throw new SlackError('Rate limit exceeded. Please try again later.', 429, 'RATE_LIMITED');
}
throw new SlackError(