Connection Event Waker (services/connection-event-wake.ts)

paperclipai/paperclip · server/src/services/connection-event-wake.ts · typescript · MIT
realtime, infra, tag:events

Manages process-local event wake signals for durable connections. Use this to trigger callbacks when external events require attention in a persistent system.

// Source: https://github.com/paperclipai/paperclip | License: MIT | Copyright 2025 Paperclip AI
// Provided via justclaw.it.com; keep this notice with the code.
/** Process-local hint only; Cloud retains the durable target until event acknowledgment. */
const receivers = new WeakMap<object, () => void>();
export function registerConnectionEventWake(owner: object, wake: () => void) {
  receivers.set(owner, wake);
  return () => { if (receivers.get(owner) === wake) receivers.delete(owner); };
}
export function wakeConnectionEvents(owner: object): boolean {
  const wake = receivers.get(owner);
  if (!wake) return false;
  wake();
  return true;
}

/** Inspection never emits a wake or polls the broker. */
export const hasConnectionEventWakeReceiver = (owner: object): boolean => receivers.has(

... (truncated -- full source via MCP)

See the full source, get the GitHub permalink, and search for more like it.

Get a free API key