Weather

import dotenv from "dotenv";
import chalk from "chalk";
import path from "path";
import { ChatOpenAI } from "@langchain/openai";
import HyperAgent from "@hyperbrowser/agent";

dotenv.config();

const TASK = `Search bing for the most populated state in the USA currently. Then list 3 weather alerts for that state.`;

async function run() {
  console.log(chalk.cyan.bold("\n===== Running Task ====="));
  console.log(chalk.white(`Task: ${TASK}`));
  console.log(chalk.cyan.bold("=======================\n"));

  const llm = new ChatOpenAI({
    apiKey: process.env.OPENAI_API_KEY,
    model: "gpt-4o",
  });

  const mcpServerPath = path.join(__dirname, "/servers/weather-server.js");

  console.log(chalk.yellow("Creating Hyperbrowser Agent..."));

  try {
    const agent = new HyperAgent({
      llm: llm,
      debug: true,
    });

    await agent.initializeMCPClient({
      servers: [
        {
          command: "node",
          args: [mcpServerPath],
        },
      ],
    });

    const result = await agent.executeTask(TASK, {
      debugOnAgentOutput: (agentOutput) => {
        console.log("\n" + chalk.cyan.bold("===== AGENT OUTPUT ====="));
        console.dir(agentOutput, { depth: null, colors: true });
        console.log(chalk.cyan.bold("===============") + "\n");
      },
      onStep: (step) => {
        console.log("\n" + chalk.cyan.bold(`===== STEP ${step.idx} =====`));
        console.dir(step, { depth: null, colors: true });
        console.log(chalk.cyan.bold("===============") + "\n");
      },
    });

    await agent.closeAgent();
    console.log(chalk.green.bold("\nResult:"));
    console.log(chalk.white(result.output));
    return result;
  } catch (error) {
    console.error(chalk.red("Error creating agent or executing task:"));
    console.error(
      chalk.red(error instanceof Error ? error.stack : String(error))
    );
  }
}

(async () => {
  try {
    await run();
  } catch (error) {
    console.error(chalk.red("Error:"), error);
    process.exit(1);
  }
})();