Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
Check out our upcoming events and meetups! View events →
new AgentHttpServer<Creates the HTTP transport over an existing socket server. RPC overTState>(server:AgentSocketServer<TState>):AgentHttpServer<TState>
POST …/rpc/<method> and the SSE streams use that server’s authorization and dispatch, so one policy covers both transports.
import { Agent, type Env } from "@telnyx/edge-runtime";
import { AgentSocketServer } from "@telnyx/edge-runtime/agent-socket";
import { AgentHttpServer } from "@telnyx/edge-runtime/agent-http";
export class Conversation extends Agent<Env> {
private desk = new AgentSocketServer<Record<string, unknown>>(this, {
getState: () => this.getState(),
authorize: (token) => (token === undefined ? ["read"] : ["read", "rpc"]),
});
private door = new AgentHttpServer(this.desk);
override fetch(req: Request): Promise<Response> {
return this.door.fetch(req);
}
}
| Parameter | Type | Meaning |
|---|---|---|
server | AgentSocketServer<TState> | The instance’s socket server. |
| Parameter | Default | Meaning |
|---|---|---|
TState | Record<string, unknown> | The agent’s persistent state shape, as served by the socket server. |
Was this page helpful?