import {
  ResponseContext,
  TextResponse,
  runResponsesServer,
  type CreateResponse,
} from "@cuylabs/agent-foundry-agentserver-responses";

await runResponsesServer({
  port: Number.parseInt(process.env.PORT ?? "8088", 10),
  async handler(request: CreateResponse, context: ResponseContext) {
    const text = await context.getInputText();
    return new TextResponse(context, request, {
      text: streamTokens(`Streaming echo: ${text}`),
    });
  },
});

async function* streamTokens(text: string): AsyncGenerator<string> {
  for (const token of text.split(/(\s+)/u)) {
    await new Promise((resolve) => setTimeout(resolve, 25));
    yield token;
  }
}