How to Build an AI Agent with Replit

1// Generated by Replit Agent from the prompts in steps 3-4 and 6; shown here
2// so you can see exactly what it wrote. Re-prompt to change it rather than
3// hand-editing, so the app and this file stay in sync.
4import express from "express";
5import { pool } from "../db.js";
6
7const router = express.Router();
8const lastDraftAt = new Map();
9
10router.post("/tickets/:id/draft", async (req, res) => {
11  const { id } = req.params;
12  const last = lastDraftAt.get(id);
13  if (last && Date.now() - last < 5 * 60 * 1000) {
14    return res.status(429).json({ error: "rate_limited" });
15  }
16
17  const { rows } = await pool.query("SELECT * FROM tickets WHERE id = $1", [id]);
18  const ticket = rows[0];
19  if (!ticket) return res.status(404).json({ error: "not_found" });
20
21  const claudeRes = await fetch("https://api.anthropic.com/v1/messages", {
22    method: "POST",
23    headers: {
24      "content-type": "application/json",
25      "x-api-key": process.env.ANTHROPIC_API_KEY,
26      "anthropic-version": "2023-06-01",
27    },
28    body: JSON.stringify({
29      model: "claude-sonnet-5-5",
30      max_tokens: 400,
31      messages: [{
32        role: "user",
33        content: `Ticket: ${ticket.subject}\n${ticket.body}\n\nSuggest a resolution and a priority (low/medium/high). Return JSON: {"resolution": "...", "priority": "..."}.`,
34      }],
35    }),
36  });
37  const data = await claudeRes.json();
38  const parsed = JSON.parse(data.content[0].text);
39
40  await pool.query(
41    "UPDATE tickets SET draft_resolution = $1, priority = $2, status = 'open_draft' WHERE id = $3",
42    [parsed.resolution, parsed.priority, id]
43  );
44  lastDraftAt.set(id, Date.now());
45  res.json({ drafted: true });
46});
47
48router.post("/tickets/:id/escalate", async (req, res) => {
49  const { id } = req.params;
50  const { rows } = await pool.query("SELECT * FROM tickets WHERE id = $1", [id]);
51  const ticket = rows[0];
52  if (!ticket) return res.status(404).json({ error: "not_found" });
53
54  await fetch(process.env.SLACK_WEBHOOK_URL, {
55    method: "POST",
56    headers: { "content-type": "application/json" },
57    body: JSON.stringify({
58      text: `Escalated: ${ticket.subject}\nSuggested resolution: ${ticket.draft_resolution}`,
59    }),
60  });
61
62  await pool.query("UPDATE tickets SET status = 'escalated' WHERE id = $1", [id]);
63  res.json({ escalated: true });
64});
65
66export default router;
67