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

const credential = new DefaultAzureCredential();

await runResponsesServer({
  port: Number.parseInt(process.env.PORT ?? "8088", 10),
  store: new FoundryStorageProvider({
    credential,
  }),
  async handler(request: CreateResponse, context: ResponseContext) {
    const text = await context.getInputText();
    const history = await context.getHistory();
    return new TextResponse(context, request, {
      text: `Echo: ${text}\nHistory items available: ${history.length}`,
    });
  },
});