agent.js

import "dotenv/config";
import axios from "axios";
import { StateGraph } from "@langchain/langgraph";

const API_KEY = process.env.CRYPTORANK_API_KEY;

if (!API_KEY) {
  throw new Error("Missing CRYPTORANK_API_KEY");
}

/**
 * CryptoRank API client
 * Docs: https://cryptorank.io/api
 */
const client = axios.create({
  baseURL: "https://api.cryptorank.io/v1",
  headers: {
    "X-Api-Key": API_KEY,
    "Accept": "application/json"
  },
  timeout: 10000
});

/**
 * Free fallback: CoinGecko daily market trends
 * No API key required
 */
const fetchDailyMarketTrends = async () => {
  const res = await axios.get(
    "https://api.coingecko.com/api/v3/search/trending"
  );

  return res.data?.coins?.slice(0, 5) || [];
};

/**
 * Fetch daily Web3 intelligence:
 * - ICOs (CryptoRank)
 * - Funding rounds (CryptoRank)
 * - Market trends (CoinGecko fallback)
 */
const fetchWeb3Intel = async () => {
  let ico = [];
  let funding = [];
  let marketTrends = [];

  try {
    const icoRes = await client.get("/ico");
    ico = icoRes.data?.data?.slice(0, 3) || [];
  } catch (err) {
    console.error("ICO fetch failed");
  }

  try {
    const fundingRes = await client.get("/funding-rounds");
    funding = fundingRes.data?.data?.slice(0, 3) || [];
  } catch (err) {
    console.error("Funding fetch failed");
  }

  try {
    marketTrends = await fetchDailyMarketTrends();
  } catch (err) {
    console.error("Market trends fetch failed");
  }

  return {
    result: {
      ico,
      funding,
      market_trends: marketTrends
    }
  };
};

/**
 * LangGraph definition
 */
const graph = new StateGraph({
  channels: {
    result: {}
  }
});

graph.addNode("fetch_web3_intel", fetchWeb3Intel);
graph.setEntryPoint("fetch_web3_intel");
graph.setFinishPoint("fetch_web3_intel");

export const agent = graph.compile();