diff --git a/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts b/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts index ef490827..bec4ae56 100644 --- a/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts +++ b/services/discord-gateway/src/modules/ai-moderation/aiAnalyzer.ts @@ -166,12 +166,14 @@ export function startPendingAIAnalysisWorker( // Only revert stuck processing messages if there's active processing. // Avoids a DB query every recovery interval when the pipeline is idle. if (conversationProcessing.size > 0) { - messageStore.revertStuckProcessingMessages(300000).catch((err: unknown) => { - logger.error( - { error: String(err) }, - "Failed to run stuck processing recovery", - ); - }); + messageStore + .revertStuckProcessingMessages(300000) + .catch((err: unknown) => { + logger.error( + { error: String(err) }, + "Failed to run stuck processing recovery", + ); + }); } Promise.all([ diff --git a/services/discord-gateway/src/modules/ai-moderation/autoDeleteManager.ts b/services/discord-gateway/src/modules/ai-moderation/autoDeleteManager.ts index 23b637cc..29d9bee7 100644 --- a/services/discord-gateway/src/modules/ai-moderation/autoDeleteManager.ts +++ b/services/discord-gateway/src/modules/ai-moderation/autoDeleteManager.ts @@ -146,7 +146,11 @@ function isAlreadyDeletedError(error: unknown): boolean { return true; // Fallback: check the message text for the Discord "Unknown Message" string const msg = - error instanceof Error ? error.message : typeof error === "string" ? error : ""; + error instanceof Error + ? error.message + : typeof error === "string" + ? error + : ""; return msg.includes("Unknown Message") || msg.includes("Unknown Channel"); } diff --git a/services/discord-gateway/src/modules/ai-moderation/llmCaller.ts b/services/discord-gateway/src/modules/ai-moderation/llmCaller.ts index e60e18f0..6839ddaa 100644 --- a/services/discord-gateway/src/modules/ai-moderation/llmCaller.ts +++ b/services/discord-gateway/src/modules/ai-moderation/llmCaller.ts @@ -80,7 +80,8 @@ export async function callModerationLLM( ]; const completion = await llmChat({ messages, - max_tokens: maxTokens ?? config.AI_LLM_MAX_COMPLETION_TOKENS ?? 16384, + max_tokens: + maxTokens ?? config.AI_LLM_MAX_COMPLETION_TOKENS ?? 16384, jsonResponse: { type: "json_object" }, retries: 0, signal, diff --git a/services/discord-gateway/src/shared/config/index.ts b/services/discord-gateway/src/shared/config/index.ts index b7c31d34..2ad0b285 100644 --- a/services/discord-gateway/src/shared/config/index.ts +++ b/services/discord-gateway/src/shared/config/index.ts @@ -197,7 +197,11 @@ export const configSchema = z .positive() .default(1024), AI_LLM_TEXT_BATCH_SIZE: z.coerce.number().int().positive().default(60), - AI_LLM_MAX_COMPLETION_TOKENS: z.coerce.number().int().positive().default(16384), + AI_LLM_MAX_COMPLETION_TOKENS: z.coerce + .number() + .int() + .positive() + .default(16384), AI_LLM_MEDIA_ANALYSIS_TIMEOUT_MS: z.coerce .number() .int()