Chat from Anywhere

// server.js
import express from "express";
import { execFile } from "child_process";

const app = express();
app.use(express.json());

app.post("/chat", (req, res) => {
  const message = req.body.message ?? "";
  const agent = req.body.agent ?? ""; // optional: specific sub-agent

  const args = [
    "-w", process.env.CRAFT_MCP_URL,
    "-p", message,
    "--output-format", "text"
  ];

  if (agent) {
    args.push("-a", agent);
  }

  execFile("craft", args, { timeout: 120000 }, (err, stdout, stderr) => {
    if (err) {
      console.error("Agent error:", err, stderr);
      return res.status(500).json({ error: "agent_failed" });
    }
    res.json({ reply: stdout.trim() });
  });
});

const port = process.env.PORT || 3000;
app.listen(port, () => console.log(`Agent server on :${port}`));

import fetch from "node-fetch";

const SLACK_BOT_TOKEN = process.env.SLACK_BOT_TOKEN;

app.post("/slack/events", async (req, res) => {
  // Slack URL verification
  if (req.body.type === "url_verification") {
    return res.json({ challenge: req.body.challenge });
  }

  const event = req.body.event;

  // Ignore bot messages to prevent loops
  if (event.bot_id || event.subtype === "bot_message") {
    return res.sendStatus(200);
  }

  // Acknowledge immediately (Slack times out after 3s)
  res.sendStatus(200);

  // Process message async
  const message = event.text;
  const channel = event.channel;

  try {
    // Call your /chat endpoint
    const response = await fetch("http://localhost:3000/chat", {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ message })
    });

    const { reply } = await response.json();

    // Send reply to Slack
    await fetch("https://slack.com/api/chat.postMessage", {
      method: "POST",
      headers: {
        "Authorization": `Bearer ${SLACK_BOT_TOKEN}`,
        "Content-Type": "application/json"
      },
      body: JSON.stringify({ channel, text: reply })
    });
  } catch (err) {
    console.error("Slack handler error:", err);
  }
});

const TELEGRAM_TOKEN = process.env.TELEGRAM_TOKEN;

app.post("/telegram/webhook", async (req, res) => {
  const message = req.body.message;
  if (!message?.text) return res.sendStatus(200);

  const chatId = message.chat.id;
  const text = message.text;

  res.sendStatus(200);

  try {
    const response = await fetch("http://localhost:3000/chat", {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ message: text })
    });

    const { reply } = await response.json();

    await fetch(`https://api.telegram.org/bot${TELEGRAM_TOKEN}/sendMessage`, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ chat_id: chatId, text: reply })
    });
  } catch (err) {
    console.error("Telegram handler error:", err);
  }
});