Agentic Chat

import { Agent, run, Runner, setDefaultOpenAIClient, setOpenAIAPI, tool } from "@openai/agents";
import { OpenAI } from "openai";
import * as undici from "undici";

export function createOpenAIAgenticChatAgent() {
  let proxyAgent = undefined;
  if (process.env.http_proxy) {
    proxyAgent = new undici.ProxyAgent(process.env.http_proxy!);
  }
  const openai = new OpenAI({
    apiKey: process.env.OPENAI_API_KEY,
    baseURL: process.env.OPENAI_BASE_URL,
    fetchOptions: {
      dispatcher: proxyAgent,
    }
  });
  setDefaultOpenAIClient(openai);
  setOpenAIAPI('chat_completions');


  const getCurrentTimeTool = tool({
    name: 'get_current_time',
    description: 'Get the current time',
    parameters: {
      type: 'object',
      properties: {},
      required: [],
    },
    execute: async () => {
      const d = new Date();
      return `${d.toString()} ${d.toISOString()}`;
    }
  });
  const agent = new Agent({
    name: 'Agent',
    model: process.env.OPENAI_MODEL!,
    instructions: 'You are a helpful assistant.',
    tools: [getCurrentTimeTool],
  });

  const runner = new Runner({
    tracingDisabled: true,
  })
  return {
    agent,
    runner,
  }
  // const stream = await runner.run(agent, 'What is the current time?', {

  //   stream: true,
  // });
  // const types = new Set<string>();
  // for await (const event of stream) {
  //   console.log(event);
  //   types.add(event.type);
  // }
  // console.log(Array.from(types).join(', '));
}

// main().catch(console.error);