fix(server): add Discord notification debouncing and rate limit handling

- Pre-filter notifiable statuses in EventService to avoid unnecessary getAgent
  DB lookups and notification calls for non-actionable statuses (working, starting, etc.)
- Add 60s per-agent+status debounce in NotificationService to prevent spam
  when agents rapidly cycle through the same status
- Respect Discord's Retry-After header on 429 responses instead of blind
  exponential backoff
- Demote noisy logger.info calls to logger.debug for skipped/debounced events
- Bump version to v1.3.9

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: yarin-mag

apps/server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "marionette-server",
-  "version": "1.3.8",
+  "version": "1.3.9",
   "private": true,
   "type": "module",
   "bin": {

apps/server/src/services/event.service.ts

@@ -11,6 +11,10 @@ const VALID_AGENT_STATUSES = new Set<string>([
   'finished', 'crashed', 'disconnected', 'awaiting_input', 'delegating'
 ]);
 
+const NOTIFIABLE_STATUSES = new Set<string>([
+  'idle', 'finished', 'crashed', 'error', 'awaiting_input',
+]);
+
 export interface BatchResult {
   processed: MarionetteEvent[];
   failed: Array<{ event: MarionetteEvent; error: string }>;
@@ -73,7 +77,7 @@ export class EventService {
     await this.repository.insert({ ...effectiveEvent, ts });
 
     // Fire Discord notification for terminal statuses (fire-and-forget).
-    if (effectiveEvent.agent_id && effectiveEvent.status) {
+    if (effectiveEvent.agent_id && effectiveEvent.status && NOTIFIABLE_STATUSES.has(effectiveEvent.status)) {
       this.agentService.getAgent(effectiveEvent.agent_id).then((agent) => {
         if (agent && !agent.is_subagent && !agent.parent_agent_id) {
           this.notificationService.notifyAgentStatus(agent, effectiveEvent);

apps/server/src/services/notification.service.ts

@@ -17,23 +17,31 @@ function formatDuration(ms: number): string {
   return `${s}s`;
 }
 
+// How long to suppress repeat notifications for the same agent+status (ms).
+const DEBOUNCE_MS = 60_000;
+
 export class NotificationService {
   private prefsRepo = new PreferencesRepository();
+  // key: `${agentId}:${status}` → timestamp of last successful send
+  private readonly sentAt = new Map<string, number>();
 
   async notifyAgentStatus(agent: AgentSnapshot, event: MarionetteEvent): Promise<void> {
     const status = event.status;
-    logger.info(`[discord] called — status=${status} agent=${agent.agent_id.slice(0, 12)}`);
 
     const isDone = status === "idle" || status === "finished";
     const isError = status === "crashed" || status === "error";
     const isAwaitingInput = status === "awaiting_input";
-    if (!isDone && !isError && !isAwaitingInput) {
-      logger.info(`[discord] skipping — status not actionable`);
+    if (!isDone && !isError && !isAwaitingInput) return;
+
+    // Debounce: skip if the same agent+status was sent recently.
+    const debounceKey = `${agent.agent_id}:${status}`;
+    const lastSent = this.sentAt.get(debounceKey) ?? 0;
+    if (Date.now() - lastSent < DEBOUNCE_MS) {
+      logger.debug(`[discord] debounced — status=${status} agent=${agent.agent_id.slice(0, 12)}`);
       return;
     }
 
     const webhookUrl = await this.getWebhookUrl();
-    logger.info(`[discord] webhookUrl=${webhookUrl ? "SET" : "NOT SET"}`);
     if (!webhookUrl) return;
 
     const embed = isDone
@@ -42,7 +50,8 @@ export class NotificationService {
         ? this.buildAwaitingInputEmbed(agent)
         : this.buildErrorEmbed(agent, event);
 
-    logger.info(`[discord] firing POST`);
+    this.sentAt.set(debounceKey, Date.now());
+    logger.info(`[discord] firing POST — status=${status} agent=${agent.agent_id.slice(0, 12)}`);
     withRetry(() => this.post(webhookUrl, embed), `discord-webhook agent=${agent.agent_id.slice(0, 12)}`);
   }
 
@@ -115,6 +124,12 @@ export class NotificationService {
       body: JSON.stringify({ embeds: [embed] }),
     });
     if (!res.ok) {
+      if (res.status === 429) {
+        const retryAfter = res.headers.get("retry-after");
+        const waitMs = retryAfter ? parseFloat(retryAfter) * 1000 : 5_000;
+        logger.warn(`[discord] rate limited, waiting ${waitMs}ms before retry`);
+        await new Promise<void>((resolve) => setTimeout(resolve, waitMs));
+      }
       throw new Error(`Discord webhook responded with ${res.status}`);
     }
   }

package.json

@@ -1,7 +1,7 @@
 {
   "name": "marionette",
   "private": true,
-  "version": "1.3.8",
+  "version": "1.3.9",
   "packageManager": "pnpm@9.0.0",
   "workspaces": [
     "apps/*",

packages/cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@marionette-app/cli",
-  "version": "1.3.8",
+  "version": "1.3.9",
   "description": "Real-time monitoring for Claude Code sessions",
   "bin": {
     "marionette": "./bin/marionette.js"