-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.ts
More file actions
70 lines (61 loc) · 2.01 KB
/
server.ts
File metadata and controls
70 lines (61 loc) · 2.01 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
/**
* cancel — server.
*
* Hosts a "slow-walk" agent that emits a metric per tick and checks its
* cancellation signal between ticks. When the client sends `job.cancel`,
* the runtime aborts `ctx.signal`; the agent observes it and throws,
* yielding a terminal `job.error` with `final_status: "cancelled"`.
*/
import {
ARCPServer,
CancelledError,
StaticBearerVerifier,
startWebSocketServer,
} from "@arcp/sdk";
const PORT = Number(process.env.ARCP_DEMO_PORT ?? 7883);
const TOKEN = process.env.ARCP_DEMO_TOKEN ?? "demo-token";
async function main(): Promise<void> {
const server = new ARCPServer({
runtime: { name: "cancel-demo", version: "1.0.0" },
capabilities: { encodings: ["json"], agents: ["slow-walk"] },
bearer: new StaticBearerVerifier(new Map([[TOKEN, { principal: "demo" }]])),
});
server.registerAgent("slow-walk", async (input, ctx) => {
const opts = (input ?? {}) as { steps?: number; tickMs?: number };
const steps = opts.steps ?? 60;
const tickMs = opts.tickMs ?? 100;
await ctx.status("walking");
for (let i = 1; i <= steps; i++) {
if (ctx.signal.aborted) {
throw new CancelledError("cancellation observed by agent");
}
await ctx.metric({ name: "step", value: i, unit: "count" });
await sleep(tickMs);
}
return { steps };
});
const wss = await startWebSocketServer({
host: "127.0.0.1",
port: PORT,
onTransport: (t) => {
server.accept(t);
},
});
console.log(`ARCP runtime listening on ${wss.url}`);
console.log(`Token: ${TOKEN}`);
console.log("Press Ctrl+C to stop.");
const shutdown = async (): Promise<void> => {
console.log("\nshutting down...");
await wss.close();
await server.close();
process.exit(0);
};
process.on("SIGINT", () => void shutdown());
process.on("SIGTERM", () => void shutdown());
}
const sleep = (ms: number): Promise<void> =>
new Promise((resolve) => setTimeout(resolve, ms));
void main().catch((err) => {
console.error(err);
process.exit(1);
});