* feat(whatsapp): add debounceMs for batching rapid messages
Add a `debounceMs` configuration option to WhatsApp channel settings
that batches rapid consecutive messages from the same sender into a
single response. This prevents triggering separate agent runs for
each message when a user sends multiple short messages in quick
succession (e.g., "Hey!", "how are you?", "I was wondering...").
Changes:
- Add `debounceMs` config to WhatsAppConfig and WhatsAppAccountConfig
- Implement message buffering in `monitorWebInbox` with:
- Map-based buffer keyed by sender (DM) or chat ID (groups)
- Debounce timer that resets on each new message
- Message combination with newline separator
- Single message optimization (no modification if only one message)
- Wire `debounceMs` through account resolution and monitor tuning
- Add UI hints and schema documentation
Usage example:
{
"channels": {
"whatsapp": {
"debounceMs": 5000 // 5 second window
}
}
}
Default behavior: `debounceMs: 0` (disabled by default)
Verified: All existing tests pass (3204 tests), TypeScript compilation
succeeds with no errors.
Implemented with assistance from AI coding tools.
Closes #967
* chore: wip inbound debounce
* fix: debounce inbound messages across channels (#971) (thanks @juanpablodlc)
---------
Co-authored-by: Peter Steinberger <steipete@gmail.com>
139 lines
5.0 KiB
TypeScript
139 lines
5.0 KiB
TypeScript
import type { BlockStreamingCoalesceConfig, DmPolicy, GroupPolicy } from "./types.base.js";
|
|
import type { DmConfig } from "./types.messages.js";
|
|
|
|
export type WhatsAppActionConfig = {
|
|
reactions?: boolean;
|
|
sendMessage?: boolean;
|
|
polls?: boolean;
|
|
};
|
|
|
|
export type WhatsAppConfig = {
|
|
/** Optional per-account WhatsApp configuration (multi-account). */
|
|
accounts?: Record<string, WhatsAppAccountConfig>;
|
|
/** Optional provider capability tags used for agent/runtime guidance. */
|
|
capabilities?: string[];
|
|
/** Allow channel-initiated config writes (default: true). */
|
|
configWrites?: boolean;
|
|
/** Send read receipts for incoming messages (default true). */
|
|
sendReadReceipts?: boolean;
|
|
/**
|
|
* Inbound message prefix (WhatsApp only).
|
|
* Default: `[{agents.list[].identity.name}]` (or `[clawdbot]`) when allowFrom is empty, else `""`.
|
|
*/
|
|
messagePrefix?: string;
|
|
/** Direct message access policy (default: pairing). */
|
|
dmPolicy?: DmPolicy;
|
|
/**
|
|
* Same-phone setup (bot uses your personal WhatsApp number).
|
|
*/
|
|
selfChatMode?: boolean;
|
|
/** Optional allowlist for WhatsApp direct chats (E.164). */
|
|
allowFrom?: string[];
|
|
/** Optional allowlist for WhatsApp group senders (E.164). */
|
|
groupAllowFrom?: string[];
|
|
/**
|
|
* Controls how group messages are handled:
|
|
* - "open": groups bypass allowFrom, only mention-gating applies
|
|
* - "disabled": block all group messages entirely
|
|
* - "allowlist": only allow group messages from senders in groupAllowFrom/allowFrom
|
|
*/
|
|
groupPolicy?: GroupPolicy;
|
|
/** Max group messages to keep as history context (0 disables). */
|
|
historyLimit?: number;
|
|
/** Max DM turns to keep as history context. */
|
|
dmHistoryLimit?: number;
|
|
/** Per-DM config overrides keyed by user ID. */
|
|
dms?: Record<string, DmConfig>;
|
|
/** Outbound text chunk size (chars). Default: 4000. */
|
|
textChunkLimit?: number;
|
|
/** Maximum media file size in MB. Default: 50. */
|
|
mediaMaxMb?: number;
|
|
/** Disable block streaming for this account. */
|
|
blockStreaming?: boolean;
|
|
/** Merge streamed block replies before sending. */
|
|
blockStreamingCoalesce?: BlockStreamingCoalesceConfig;
|
|
/** Per-action tool gating (default: true for all). */
|
|
actions?: WhatsAppActionConfig;
|
|
groups?: Record<
|
|
string,
|
|
{
|
|
requireMention?: boolean;
|
|
}
|
|
>;
|
|
/** Acknowledgment reaction sent immediately upon message receipt. */
|
|
ackReaction?: {
|
|
/** Emoji to use for acknowledgment (e.g., "👀"). Empty = disabled. */
|
|
emoji?: string;
|
|
/** Send reactions in direct chats. Default: true. */
|
|
direct?: boolean;
|
|
/**
|
|
* Send reactions in group chats:
|
|
* - "always": react to all group messages
|
|
* - "mentions": react only when bot is mentioned
|
|
* - "never": never react in groups
|
|
* Default: "mentions"
|
|
*/
|
|
group?: "always" | "mentions" | "never";
|
|
};
|
|
/** Debounce window (ms) for batching rapid consecutive messages from the same sender (0 to disable). */
|
|
debounceMs?: number;
|
|
};
|
|
|
|
export type WhatsAppAccountConfig = {
|
|
/** Optional display name for this account (used in CLI/UI lists). */
|
|
name?: string;
|
|
/** Optional provider capability tags used for agent/runtime guidance. */
|
|
capabilities?: string[];
|
|
/** Allow channel-initiated config writes (default: true). */
|
|
configWrites?: boolean;
|
|
/** If false, do not start this WhatsApp account provider. Default: true. */
|
|
enabled?: boolean;
|
|
/** Send read receipts for incoming messages (default true). */
|
|
sendReadReceipts?: boolean;
|
|
/** Inbound message prefix override for this account (WhatsApp only). */
|
|
messagePrefix?: string;
|
|
/** Override auth directory (Baileys multi-file auth state). */
|
|
authDir?: string;
|
|
/** Direct message access policy (default: pairing). */
|
|
dmPolicy?: DmPolicy;
|
|
/** Same-phone setup for this account (bot uses your personal WhatsApp number). */
|
|
selfChatMode?: boolean;
|
|
allowFrom?: string[];
|
|
groupAllowFrom?: string[];
|
|
groupPolicy?: GroupPolicy;
|
|
/** Max group messages to keep as history context (0 disables). */
|
|
historyLimit?: number;
|
|
/** Max DM turns to keep as history context. */
|
|
dmHistoryLimit?: number;
|
|
/** Per-DM config overrides keyed by user ID. */
|
|
dms?: Record<string, DmConfig>;
|
|
textChunkLimit?: number;
|
|
mediaMaxMb?: number;
|
|
blockStreaming?: boolean;
|
|
/** Merge streamed block replies before sending. */
|
|
blockStreamingCoalesce?: BlockStreamingCoalesceConfig;
|
|
groups?: Record<
|
|
string,
|
|
{
|
|
requireMention?: boolean;
|
|
}
|
|
>;
|
|
/** Acknowledgment reaction sent immediately upon message receipt. */
|
|
ackReaction?: {
|
|
/** Emoji to use for acknowledgment (e.g., "👀"). Empty = disabled. */
|
|
emoji?: string;
|
|
/** Send reactions in direct chats. Default: true. */
|
|
direct?: boolean;
|
|
/**
|
|
* Send reactions in group chats:
|
|
* - "always": react to all group messages
|
|
* - "mentions": react only when bot is mentioned
|
|
* - "never": never react in groups
|
|
* Default: "mentions"
|
|
*/
|
|
group?: "always" | "mentions" | "never";
|
|
};
|
|
/** Debounce window (ms) for batching rapid consecutive messages from the same sender (0 to disable). */
|
|
debounceMs?: number;
|
|
};
|