romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: resolve channel delay per-message for Discord channel ID support

Browse Source 
The channelDelayMs was being resolved once at handler creation with
'discord' as the key, but configs use Discord channel IDs (e.g.,
'1465655303121928265'). This caused the peer reply check to never run
since channelDelayMs was always 0.

Now channelDelayMs is resolved per-message using the actual Discord
channel ID from the incoming message, enabling per-channel delay
configuration to work correctly.
This commit is contained in:
Sol 2026-01-29 13:23:48 -08:00
parent b99ad70b46
commit 65446b0c48
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/discord/monitor/message-handler.ts
View File

@ -43,7 +43,7 @@ export function createDiscordMessageHandler(params: {
const groupPolicy = params.discordConfig?.groupPolicy ?? "open"; const groupPolicy = params.discordConfig?.groupPolicy ?? "open";
const ackReactionScope = params.cfg.messages?.ackReactionScope ?? "group-mentions"; const ackReactionScope = params.cfg.messages?.ackReactionScope ?? "group-mentions";
const debounceMs = resolveInboundDebounceMs({ cfg: params.cfg, channel: "discord" }); const debounceMs = resolveInboundDebounceMs({ cfg: params.cfg, channel: "discord" });
const channelDelayMs = resolveChannelDelayMs({ cfg: params.cfg, channel: "discord" }); // Note: channelDelayMs is resolved per-message below to support per-channel overrides
const skipIfPeerRepliedMs = resolveSkipIfPeerRepliedMs({ cfg: params.cfg }); const skipIfPeerRepliedMs = resolveSkipIfPeerRepliedMs({ cfg: params.cfg });
const debouncer = createInboundDebouncer<{ data: DiscordMessageEvent; client: Client }>({ const debouncer = createInboundDebouncer<{ data: DiscordMessageEvent; client: Client }>({
@ -168,6 +168,10 @@ export function createDiscordMessageHandler(params: {
return async (data, client) => { return async (data, client) => {
try { try {
// Resolve channel delay per-message to support per-channel overrides via Discord channel ID
const discordChannelId = data.message?.channelId ?? "discord";
const channelDelayMs = resolveChannelDelayMs({ cfg: params.cfg, channel: discordChannelId });
// Apply channel delay for multi-bot coordination // Apply channel delay for multi-bot coordination
if (channelDelayMs > 0) { if (channelDelayMs > 0) {
await sleep(channelDelayMs); await sleep(channelDelayMs);