WhatsApp integration

export class WhatsAppChannel implements Channel {
  name = 'whatsapp';
  
  async connect(): Promise<void> {
    // Connects to WhatsApp using Baileys
  }
  
  async sendMessage(jid: string, text: string): Promise<void> {
    // Sends messages with assistant name prefix
  }
  
  async setTyping(jid: string, isTyping: boolean): Promise<void> {
    // Shows typing indicator
  }
}

WhatsApp (Baileys) → SQLite → Polling loop → Container (Claude Agent SDK) → Response

claude
/setup

export const ASSISTANT_HAS_OWN_NUMBER = false; // Default: shared number

export const ASSISTANT_NAME = 'Andy';

Andy: Your scheduled task completed successfully.

const { version } = await fetchLatestWaWebVersion({});
this.sock = makeWASocket({
  version,
  auth: { creds: state.creds, keys: makeCacheableSignalKeyStore(state.keys, logger) },
  printQRInTerminal: false,
  logger,
  browser: Browsers.macOS('Chrome'),
});

const isBotMessage = ASSISTANT_HAS_OWN_NUMBER
  ? fromMe
  : content.startsWith(`${ASSISTANT_NAME}:`);

const prefixed = ASSISTANT_HAS_OWN_NUMBER
  ? text
  : `${ASSISTANT_NAME}: ${text}`;

async syncGroupMetadata(force = false): Promise<void> {
  const groups = await this.sock.groupFetchAllParticipating();
  for (const [jid, metadata] of Object.entries(groups)) {
    if (metadata.subject) {
      updateChatName(jid, metadata.subject);
    }
  }
}

registerGroup("<your-number>@s.whatsapp.net", {
  name: "Main",
  folder: "main",
  trigger: `@${ASSISTANT_NAME}`,
  added_at: new Date().toISOString(),
  requiresTrigger: false,
});

registerGroup("<group-jid>@g.us", {
  name: "Family Chat",
  folder: "family-chat",
  trigger: `@${ASSISTANT_NAME}`,
  added_at: new Date().toISOString(),
  requiresTrigger: true, // Only responds when mentioned
});

claude
/setup

if (connection === 'close') {
  const shouldReconnect = reason !== DisconnectReason.loggedOut;
  if (shouldReconnect) {
    logger.info('Reconnecting...');
    this.connectInternal().catch(...);
  }
}

sqlite3 store/messages.db "SELECT * FROM registered_groups"

/add-telegram  # Keeps WhatsApp, adds Telegram

TELEGRAM_ONLY=true  # in .env

private async flushOutgoingQueue(): Promise<void> {
  while (this.outgoingQueue.length > 0) {
    const item = this.outgoingQueue.shift()!;
    await this.sock.sendMessage(item.jid, { text: item.text });
  }
}

this.sock.sendPresenceUpdate('available').catch(...);

async setTyping(jid: string, isTyping: boolean): Promise<void> {
  const status = isTyping ? 'composing' : 'paused';
  await this.sock.sendPresenceUpdate(status, jid);
}