alfred-channel-delivery

name	alfred-channel-delivery
description	How to deliver a message to Sir on a specific channel (Slack DM, Telegram, SMS, voice call, email) using cached contact IDs from KNOWN_CONTACTS.md instead of walking workspace directories. Read this whenever Sir says "send/text/call/email me…".
triggers	deliver, send to me, text me, slack me, telegram me, dm me, call me, email me, ping me, post to slack, send sms, drop me an email

Channel Delivery — Use the Cached IDs

When Sir says "send this to me on Slack", "text me when it's done", "drop me an email", "call me at 5", your job is to put a message in front of him on the channel he named. The wrong way is to walk Slack's user directory looking for "Jane Doe", page through Telegram updates trying to find his chat, or scan email contacts. That path costs 25+ turns and usually fails.

The right way: read KNOWN_CONTACTS.md once, then call self() with the cached ID.

Step 1 — Load the contact

Every tenant ships with ~/.openclaw/workspace/KNOWN_CONTACTS.md containing Sir's known channel identifiers. Read it from the qmd memory backend or directly:

self({ endpoint: "/api/v1/admin/workspace/KNOWN_CONTACTS.md" })

Returns { filename, content } where content is the markdown. The bottom of the file has a Machine-readable JSON block — parse that for programmatic use. Schema:

{
  "sir": {
    "displayName": "...",
    "email": "...",
    "channels": {
      "slack":      { "userId": "U…", "dmChannelId": "D…" },
      "telegram":   { "chatId": "…", "botAccount": "default" },
      "agentmail":  { "address": "…@…" },
      "agentphone": { "e164": "+…" }
    }
  }
}

If a channel sub-object is missing or its values are empty strings, that channel hasn't been paired yet — see "Fallback: pair-then-cache" below.

Step 1.5 — Cross-session memory: AUDIT every outbound delivery

This is the most important rule in this skill. Read it twice.

Sessions on Alfred are isolated. When you send a Slack DM at 15:27 in session A, session B at 15:35 cannot see your prior session — at all. If Sir asks "what did you just send me?" in a new session, you have no memory of the send unless you wrote it somewhere a future session can read.

This has actually happened on a tenant: Alfred sent a Slack DM at 15:27 UTC; eight minutes later in a fresh session, when Sir asked Alfred to quote what he'd sent, Alfred replied "I have reviewed my logs and do not have a record of sending a Slack message to you, Sir." — the send happened, but only inside one session jsonl that the next session never opened.

Mandate: after EVERY successful outbound delivery (Slack DM, Telegram, voice call init, email send/reply/forward), you MUST also POST to /api/v1/streams/ingest to write a tiny audit record. SMS is the only exception — /api/v1/phone/sms already auto-ingests to sms-outbound. For everything else, you do it.

self({
  endpoint: "/api/v1/streams/ingest",
  method: "POST",
  body: {
    stream_id: "outbound-deliveries",
    stream_type: "outbound-delivery",
    source_ref: "<channel>:<recipient_id>:<unix_ms>",   // dedup key
    summary: "<channel> to <recipient>: <first 80 chars of message>",
    raw: {
      channel: "slack",                  // "slack" | "telegram" | "email" | "voice"
      to: "D0123456789",                 // the same `to` you sent on
      message: "Sir, the weekly report is ready.",
      session_id: "<your current session id, if known>",
      direction: "outbound"
    }
  }
})

The next session bootstrap reads outbound-deliveries events through /api/v1/streams/:id/events and surfaces recent sends, so a fresh session can answer "what did you just send me on Slack?" without amnesia.

Worked example — full Slack DM with audit:

// 1. Send the message.
const send = await self({
  endpoint: "/api/v1/notifications",
  method: "POST",
  body: {
    channel: "slack",
    to: "D0123456789",
    message: "Sir, the weekly report is ready.",
    urgency: "normal"
  }
});

// 2. Audit it. Do this synchronously in the same turn — no exceptions.
await self({
  endpoint: "/api/v1/streams/ingest",
  method: "POST",
  body: {
    stream_id: "outbound-deliveries",
    stream_type: "outbound-delivery",
    source_ref: `slack:D0123456789:${Date.now()}`,
    summary: "slack DM to Sir: Sir, the weekly report is ready.",
    raw: {
      channel: "slack",
      to: "D0123456789",
      message: "Sir, the weekly report is ready.",
      direction: "outbound"
    }
  }
});

If the audit POST fails, retry it once. Don't drop it silently.

Step 1.7 — When you discover a NEW channel id by searching, write it back

If KNOWN_CONTACTS.md did NOT have the value (so you had to do the pair-then-cache flow OR you searched the channel directory to find Sir's id), you MUST patch KNOWN_CONTACTS.md so the next session doesn't re-discover. See "Fallback: pair-then-cache" below for the PUT shape — but the rule is: search-then-send always ends with a KNOWN_CONTACTS.md update, not just the send. Otherwise every fresh session pays the discovery cost again.

Step 2 — Send via /api/v1/notifications (preferred)

The unified delivery endpoint puts the message on the named channel via a native Hermes main-profile cron job (deliver=<channel>:<to>) — ctrl-api creates the job, triggers it for immediate execution, waits for the run, and returns delivered: true only when Hermes confirms the channel send. A delivery failure comes back as a real 502 with an error, never a silent no-op. Pass the cached to value explicitly so the endpoint doesn't have to guess.

Slack DM

self({
  endpoint: "/api/v1/notifications",
  method: "POST",
  body: {
    channel: "slack",
    to: "<knownContacts.sir.channels.slack.dmChannelId>",   // e.g. "D0123456789"
    message: "Sir, the weekly report is ready.",
    urgency: "normal"
  }
})

The dmChannelId (starts with D) is what chat.postMessage wants. Do NOT pass the userId (U…) — that requires Slack to open a new DM channel and may fail if the bot doesn't have im:write for an unpaired user.

Telegram

self({
  endpoint: "/api/v1/notifications",
  method: "POST",
  body: {
    channel: "telegram",
    to: "<knownContacts.sir.channels.telegram.chatId>",     // e.g. "100000000"
    message: "Sir — quick heads-up: …",
    urgency: "normal"
  }
})

The chatId is the integer Telegram returns from getUpdates, but stringified.

Email

Email goes through the dedicated AgentMail endpoints, not /notifications. See the alfred-email-channel skill for reply/forward shapes. To send a fresh outbound:

self({
  endpoint: "/api/v1/email/send",
  method: "POST",
  body: {
    to: ["<knownContacts.sir.channels.agentmail.address>"],   // or .email if different
    subject: "Weekly report",
    text: "Sir, please find this week's summary below…",
    // html / attachments optional
  }
})

SMS

self({
  endpoint: "/api/v1/phone/sms",
  method: "POST",
  body: {
    to: "<knownContacts.sir.channels.agentphone.e164>",     // e.g. "[phone]"
    body: "Sir — heads-up, your two o'clock just moved."
  }
})

Voice call (TTS one-shot)

self({
  endpoint: "/api/v1/phone/call",
  method: "POST",
  body: {
    to: "<knownContacts.sir.channels.agentphone.e164>",
    message: "Sir, your two o'clock is starting in five minutes.",
    mode: "tts"      // or "realtime" to open a live Voice Bridge session
  }
})

Fallback: pair-then-cache

If the cached value for a channel is missing/empty AND Sir explicitly asks for that channel:

1. Slack: ask Sir to send you a one-line DM ("hi alfred"). When the inbound arrives, the session payload contains chat_id: "user:U..." and the channel ID. Capture both.
2. Telegram: ask Sir to send /start (or any message) to the bot. The next inbound contains from.id (= chat ID).
3. AgentMail: usually known at provision time. If empty, read process.env.AGENTMAIL_INBOX_ADDRESS via self({ endpoint: "/api/v1/admin/env/AGENTMAIL_INBOX_ADDRESS" }) if available, or ask Sir.
4. AgentPhone: read self({ endpoint: "/api/v1/phone/config" }) — returns { phoneNumber: "+1…" } if a number was provisioned.

Once you have the value, persist it back to KNOWN_CONTACTS.md so the next delivery is instant:

self({
  endpoint: "/api/v1/admin/workspace/KNOWN_CONTACTS.md",
  method: "PUT",
  body: { content: "<full updated markdown>" }
})

Read the file first, edit the relevant cell + the JSON block, then PUT the whole new content. Keep the prose sections unchanged — only the channel table and the Machine-readable JSON should change.

Don't

• Don't search Slack's user directory. No users.list, no fuzzy name matching on the principal's name. The cached dmChannelId is the answer.
• Don't assume auto channel selection. When Sir names a channel, pass it explicitly (channel: "slack"). Auto-pick is for system-initiated notifications, not user requests.
• Don't invent IDs. If KNOWN_CONTACTS.md has an empty value, do the pair-then-cache flow above. Never fill in a guess.
• Don't post the same message on two channels unless Sir asked you to. Pick one.

A sanity-check ritual

Before you call /api/v1/notifications, mentally check:

"Did I read KNOWN_CONTACTS.md in this turn?" "Is my to value copied verbatim from the file (or derived via pair-then-cache)?" "Am I passing channel: explicitly?"

If yes to all three, send.

After the send returns successfully, mentally check:

"Did I POST the audit record to outbound-deliveries?" "If I just discovered Sir's id by searching, did I patch KNOWN_CONTACTS.md?"

If yes to both, the turn is complete. If you skip these, the next session goes blind and Sir is right to be annoyed.