Slack Adapter: Connect Heypi in Socket or HTTP Mode

slack({
  // ...tokens and mode
  allow: {
    teams: ["T123"],       // Slack workspace/team IDs
    channels: ["C123"],    // Channel IDs (non-DM channels only)
    users: ["U123"],       // Restrict to specific users
    dms: true,             // Allow direct messages
  },
  trigger: "mention",        // Only respond when @mentioned
  threadTrigger: "message",  // In existing threads, respond to any message
});

slack({
  // ...
  streaming: true,

  // Or fine-tuned:
  streaming: {
    intervalMs: 1000,   // How often to update the draft message (default: 1000 ms)
    minChars: 40,       // Minimum characters before first update (default: 40)
    maxFailures: 3,     // Stop streaming after this many edit errors (default: 3)
  },
});

slack({
  // ...
  progress: {
    reaction: "hourglass",  // Emoji reaction on the original message (default: "eyes"); set false to disable
    message: "On it...",    // Placeholder message text (default: "Working..."); set false to disable
    delayMs: 1000,          // Delay before showing the placeholder (default: 750 ms)
  },
  // Or disable entirely:
  // progress: false,
});

slack({
  // ...
  reply: "thread",   // Default: reply in a new thread (or existing thread)
  // reply: "same",  // Reply in the same thread the message was in
  // reply: "channel", // Reply directly to the channel (no thread)
});

import { existsSync } from "node:fs";
import { loadEnvFile } from "node:process";
import { agentFrom, consoleLogger, coreTools, createHeypi, runHeypi, slack, workspace } from "@hunvreus/heypi";
import { createHostContext, createHostTools } from "./tools/host.js";
import { createRunbookTools } from "./tools/runbook.js";

loadEnv(".env");

function loadEnv(path: string): void {
  if (existsSync(path)) loadEnvFile(path);
}

function required(name: string): string {
  const value = process.env[name];
  if (!value) throw new Error(`Missing env var: ${name}`);
  return value;
}

function optional(name: string): string | undefined {
  return process.env[name]?.trim() || undefined;
}

function list(name: string): string[] {
  return (process.env[name] ?? "")
    .split(",")
    .map((value) => value.trim())
    .filter(Boolean);
}

const stateRoot = "./state";
const log = consoleLogger({ level: "debug", format: "pretty" });
const jobChannel = optional("HEYPI_SLACK_JOB_CHANNEL");

const app = createHeypi({
  state: { root: stateRoot },
  logger: log,
  admin: true,
  adapters: [
    slack({
      botToken: required("SLACK_BOT_TOKEN"),
      mode: "socket",
      appToken: required("SLACK_APP_TOKEN"),
      allow: {
        teams: list("HEYPI_SLACK_TEAMS"),
        channels: list("HEYPI_SLACK_CHANNELS"),
        users: list("HEYPI_SLACK_USERS"),
      },
      trigger: "mention",
      reply: "thread",
      streaming: true,
    }),
  ],
  agent: agentFrom("./agent", {
    id: "slack-devops",
    model: "openai/gpt-5-mini",
    context: [createHostContext({ root: stateRoot })],
    tools: [
      ...coreTools({ bash: true }),
      ...createRunbookTools({ root: "./agent/runbooks" }),
      ...createHostTools({ root: stateRoot, timeoutMs: 60_000 }),
    ],
  }),
  approval: {
    approvers: list("HEYPI_APPROVERS"),
    expiresInMs: 10 * 60 * 1000,
  },
  jobs: jobChannel
    ? [
        {
          id: "daily-health-check",
          schedule: { cron: "0 9 * * *", timezone: "UTC" },
          targets: { slack: { channels: [jobChannel] } },
          prompt: "Run a daily infrastructure health check and summarize anything that needs attention.",
          state: "active",
        },
        {
          id: "idle-incident-follow-up",
          kind: "heartbeat",
          everyMs: 6 * 60 * 60 * 1000,
          idleMs: 30 * 60 * 1000,
          scope: { slack: { channels: [jobChannel] } },
          prompt: "If an incident thread has gone quiet, ask whether follow-up is still needed.",
          state: "paused",
        },
      ]
    : [],
  runtime: {
    root: workspace("./workspace"),
    scope: "channel",
  },
});

await runHeypi(app);