feat(pr-shepherd): org-wide PR staleness watcher with Slack escalation

inbox-buddy/lib/slack.ts

@@ -1,124 +1,18 @@
 /**
  * Slack chat transport for inbox-buddy.
  *
- * The human talks to inbox-buddy in a dedicated Slack channel (the relay inbox
- * is agent-to-agent; the human-facing channel is Slack). This mirrors the
- * proven, in-production `linear-slack` pattern: a `slack` trigger watches one
- * channel, the handler replies with `slackClient()`, and the bot ignores its
- * own/bot messages to avoid a reply loop.
+ * The canonical implementations live in `shared/slack.ts` (agents repo stopgap)
+ * and will move to `@agentworkforce/delivery` once that package is bumped.
+ * This file is a re-export shim so inbox-buddy's internal imports don't break.
  */
-import type { WorkforceCtx } from '@agentworkforce/runtime';
-import { slackClient } from '@relayfile/relay-helpers';
-
-export interface SlackMessage {
-  channel: string;
-  ts: string;
-  threadTs?: string;
-  text: string;
-  user?: string;
-  isBot: boolean;
-  subtype?: string;
-}
-
-/** The slice of slackClient() the handler uses (injectable for tests). */
-export interface SlackPoster {
-  post(channel: string, text: string): Promise<{ channel: string; ts: string }>;
-  reply(channel: string, threadTs: string, text: string): Promise<{ channel: string; ts: string }>;
-}
-
-const WRITEBACK_TIMEOUT_MS = 15_000;
-
-export function defaultSlack(): SlackPoster {
-  return slackClient({ writebackTimeoutMs: WRITEBACK_TIMEOUT_MS });
-}
-
-// ── payload parsing ─────────────────────────────────────────────────────────
-
-function asRecord(value: unknown): Record<string, unknown> | null {
-  return value && typeof value === 'object' && !Array.isArray(value) ? (value as Record<string, unknown>) : null;
-}
-function str(value: unknown): string | undefined {
-  return typeof value === 'string' && value.length > 0 ? value : undefined;
-}
-function unwrapRecord(payload: unknown): Record<string, unknown> | null {
-  const rec = asRecord(payload);
-  if (!rec) return null;
-  return asRecord(rec.data) ?? rec;
-}
-
-/** Read a Slack message envelope into a normalized shape (or null if unusable). */
-export function readSlackMessage(payload: unknown): SlackMessage | null {
-  const rec = unwrapRecord(payload);
-  if (!rec) return null;
-  const raw = asRecord(rec.raw_event) ?? rec;
-
-  const channel = str(rec.channel) ?? str(raw.channel);
-  if (!channel) return null;
-  const ts = str(rec.ts) ?? str(raw.ts) ?? str(rec.event_ts) ?? str(raw.event_ts);
-  if (!ts) return null;
-
-  return {
-    channel,
-    ts,
-    threadTs: str(rec.thread_ts) ?? str(rec.threadTs) ?? str(raw.thread_ts),
-    text: str(rec.text) ?? str(raw.text) ?? '',
-    user: str(rec.user) ?? str(raw.user),
-    isBot: Boolean(rec.is_bot ?? raw.is_bot) || Boolean(str(rec.bot_id) ?? str(raw.bot_id)),
-    subtype: str(rec.subtype) ?? str(raw.subtype)
-  };
-}
-
-/** Strip a leading `<@U…>`/`@name` mention so the question text is clean. */
-export function stripLeadingMention(text: string): string {
-  return text.replace(/^\s*<@[^>]+>\s*/, '').replace(/^\s*@\S+\s*/, '');
-}
-
-/**
- * Strip the `__name` suffix the platform appends to channel ids in some payloads
- * (e.g. `/slack/channels/{id__name}/**`). Bare Slack ids never contain `__`, so
- * this is a safe no-op when the id is already bare. Use it before comparing
- * channels, keying memory, or calling the Slack API.
- */
-export function bareChannelId(channel: string): string {
-  return channel.split('__')[0];
-}
-
-/**
- * Conversation key for continuity. A threaded message keys on its thread; a
- * top-level message keys on the CHANNEL itself, so consecutive top-level
- * messages in a dedicated chat channel form one continuous conversation.
- */
-export function conversationKeyForSlack(msg: SlackMessage): string {
-  const chanId = bareChannelId(msg.channel);
-  return msg.threadTs ? `${chanId}:${msg.threadTs}` : chanId;
-}
-
-/**
- * Reason this message should be skipped, or null to handle it. Skips the bot's
- * own/other bot messages (loop guard), edits/joins (subtype), the wrong channel,
- * and empty text.
- */
-export function skipReason(msg: SlackMessage, boardChannel: string | undefined): string | null {
-  if (msg.isBot) return 'bot message';
-  if (msg.subtype) return `slack subtype ${msg.subtype}`;
-  if (!boardChannel || bareChannelId(msg.channel) !== bareChannelId(boardChannel)) return 'not the chat channel';
-  if (!stripLeadingMention(msg.text).trim()) return 'empty message text';
-  return null;
-}
-
-/** Post the reply (threaded if the incoming message was in a thread). Loud-ish:
- *  a missing receipt is logged (cloud writeback often outruns the wait). */
-export async function postReply(
-  ctx: WorkforceCtx,
-  slack: SlackPoster,
-  msg: SlackMessage,
-  text: string
-): Promise<void> {
-  const chanId = bareChannelId(msg.channel);
-  const result = msg.threadTs
-    ? await slack.reply(chanId, msg.threadTs, text)
-    : await slack.post(chanId, text);
-  if (!result?.ts) {
-    ctx.log?.('warn', 'inbox-buddy.reply.no-receipt', { channel: chanId, threaded: Boolean(msg.threadTs) });
-  }
-}
+export {
+  type SlackMessage,
+  type SlackPoster,
+  defaultSlack,
+  readSlackMessage,
+  stripLeadingMention,
+  bareChannelId,
+  conversationKeyForSlack,
+  skipReason,
+  postReply
+} from '../../shared/slack.js';