base con front

public/main.js

@@ -0,0 +1,224 @@
+// main.js
+// Express server for: Ops UI (static) + SSE stream + Local WhatsApp Simulator + simple in-memory stores
+// Run: npm i express cors  &&  node main.js
+// Open: http://localhost:3000
+
+import express from "express";
+import cors from "cors";
+import crypto from "crypto";
+import path from "path";
+import { fileURLToPath } from "url";
+
+const app = express();
+app.use(cors());
+app.use(express.json({ limit: "1mb" }));
+
+// Serve /public as static (UI + webcomponents)
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = path.dirname(__filename);
+const publicDir = path.join(__dirname, "public");
+app.use(express.static(publicDir));
+
+/**
+ * In-memory store (MVP). Replace with Postgres later.
+ */
+const conversations = new Map(); // chat_id -> conversation snapshot
+const runs = new Map(); // run_id -> run object
+
+/**
+ * SSE clients (Server-Sent Events)
+ */
+const sseClients = new Set();
+
+function sseSend(event, data) {
+  const payload = `event: ${event}\ndata: ${JSON.stringify(data)}\n\n`;
+  for (const res of sseClients) res.write(payload);
+}
+
+function nowIso() {
+  return new Date().toISOString();
+}
+
+function newId(prefix = "run") {
+  return `${prefix}_${crypto.randomUUID()}`;
+}
+
+function upsertConversation(chat_id, patch) {
+  const prev = conversations.get(chat_id) || {
+    chat_id,
+    from: patch.from || chat_id,
+    state: "IDLE",
+    intent: "other",
+    last_activity: nowIso(),
+    status: "ok",
+    last_run_id: null,
+  };
+
+  const next = {
+    ...prev,
+    ...patch,
+    last_activity: nowIso(),
+  };
+
+  conversations.set(chat_id, next);
+  return next;
+}
+
+/**
+ * TODO: Replace this with your real pipeline later:
+ * - loadState from Postgres
+ * - call LLM (structured output)
+ * - product search (LIMITED) + resolve ids
+ * - create/update Woo order
+ * - create MercadoPago link
+ * - save state
+ */
+async function processMessage({ chat_id, from, text }) {
+  const prevConv = conversations.get(chat_id) || null;
+
+  const run_id = newId("run");
+  const started_at = Date.now();
+
+  // Minimal simulated LLM output (replace later)
+  const plan = {
+    reply: `Recibido: "${text}". ¿Querés retiro o envío?`,
+    next_state: "BUILDING_ORDER",
+    intent: "create_order",
+    missing_fields: ["delivery_or_pickup"],
+    order_action: "none",
+    basket_resolved: { items: [] },
+  };
+
+  const invariants = {
+    ok: true,
+    checks: [
+      { name: "required_keys_present", ok: true },
+      { name: "no_checkout_without_payment_link", ok: true },
+      { name: "no_order_action_without_items", ok: true },
+    ],
+  };
+
+  const run = {
+    run_id,
+    ts: nowIso(),
+    chat_id,
+    from,
+    status: "ok", // ok|warn|error
+    prev_state: prevConv?.state || "IDLE",
+    input: { text },
+    llm_output: plan,
+    tools: [], // later: [{name, ok, ms, input_summary, output_summary}]
+    invariants,
+    final_reply: plan.reply,
+    order_id: null,
+    payment_link: null,
+    latency_ms: Date.now() - started_at,
+  };
+
+  runs.set(run_id, run);
+
+  const conv = upsertConversation(chat_id, {
+    from,
+    state: plan.next_state,
+    intent: plan.intent,
+    status: run.status,
+    last_run_id: run_id,
+  });
+
+  // Push realtime events to UI
+  sseSend("conversation.upsert", conv);
+  sseSend("run.created", run);
+
+  return run;
+}
+
+/**
+ * SSE endpoint (UI connects here)
+ */
+app.get("/stream", (req, res) => {
+  res.setHeader("Content-Type", "text/event-stream");
+  res.setHeader("Cache-Control", "no-cache");
+  res.setHeader("Connection", "keep-alive");
+
+  // If compression middleware ever added, you'd need res.flushHeaders()
+  res.flushHeaders?.();
+
+  // hello event
+  res.write(`event: hello\ndata: ${JSON.stringify({ ts: nowIso() })}\n\n`);
+
+  sseClients.add(res);
+
+  req.on("close", () => {
+    sseClients.delete(res);
+    res.end();
+  });
+});
+
+/**
+ * Local WhatsApp Simulator:
+ * POST /sim/send  { chat_id, from_phone, text }
+ */
+app.post("/sim/send", async (req, res) => {
+  const { chat_id, from_phone, text } = req.body || {};
+  if (!chat_id || !from_phone || !text) {
+    return res.status(400).json({ ok: false, error: "chat_id, from_phone, text are required" });
+  }
+  try {
+    const run = await processMessage({ chat_id, from: from_phone, text });
+    res.json({ ok: true, run_id: run.run_id, reply: run.final_reply });
+  } catch (err) {
+    res.status(500).json({ ok: false, error: "internal_error", detail: String(err?.message || err) });
+  }
+});
+
+/**
+ * List conversations
+ * GET /conversations?q=&status=&state=
+ */
+app.get("/conversations", (req, res) => {
+  const { q = "", status = "", state = "" } = req.query;
+
+  const items = [...conversations.values()]
+    .filter(c => (q ? (String(c.chat_id).includes(q) || String(c.from).includes(q)) : true))
+    .filter(c => (status ? c.status === status : true))
+    .filter(c => (state ? c.state === state : true))
+    .sort((a, b) => (a.last_activity < b.last_activity ? 1 : -1));
+
+  res.json({ items });
+});
+
+/**
+ * List runs (optionally by chat_id)
+ * GET /runs?chat_id=&limit=50
+ */
+app.get("/runs", (req, res) => {
+  const { chat_id, limit = "50" } = req.query;
+  const lim = Math.max(1, Math.min(200, parseInt(limit, 10) || 50));
+
+  let items = [...runs.values()].sort((a, b) => (a.ts < b.ts ? 1 : -1));
+  if (chat_id) items = items.filter(r => r.chat_id === chat_id);
+
+  res.json({ items: items.slice(0, lim) });
+});
+
+/**
+ * Run detail
+ * GET /runs/:run_id
+ */
+app.get("/runs/:run_id", (req, res) => {
+  const run = runs.get(req.params.run_id);
+  if (!run) return res.status(404).json({ ok: false, error: "not_found" });
+  res.json(run);
+});
+
+/**
+ * Root: serve UI
+ */
+app.get("/", (req, res) => {
+  res.sendFile(path.join(publicDir, "index.html"));
+});
+
+const port = process.env.PORT || 3000;
+app.listen(port, () => {
+  console.log(`UI: http://localhost:${port}`);
+});