require('dotenv').config(); // Loads env variables from .env
const { Connection } = require('@solana/web3.js');
const axios = require('axios');

// ------------------------------
// 1. Define the endpoints
// ------------------------------
const GS_NODE_RPC = 'https://rpc.gsnode.io';  // Replace with real GS Node RPC
const PUMP_FUN_API_URL = 'https://api.pumpfun.io/v1/price'; // Hypothetical endpoint

// ------------------------------
// 2. Create a Solana connection
// ------------------------------
const connection = new Connection(GS_NODE_RPC);

// ------------------------------
// 3. Fetch single token price
// ------------------------------
async function getPumpFunPrice(tokenSymbol = 'PumpFun') {
  try {
    const response = await axios.get(PUMP_FUN_API_URL, {
      headers: {
        Authorization: `Bearer ${process.env.PUMP_FUN_API_KEY}`
      },
      params: {
        token: tokenSymbol
      }
    });

    if (response.data) {
      console.log(`Token: ${response.data.token}`);
      console.log(`Current Price (USD): ${response.data.price_usd}`);
      console.log(`24h Change: ${response.data.price_change_24h}`);
      console.log(`Timestamp: ${response.data.timestamp}`);
    } else {
      console.error('No valid data returned by the API.');
    }
  } catch (error) {
    console.error('Error fetching token price:', error.message);
  }
}

// ------------------------------
// 4. Check on-chain data
// ------------------------------
async function checkOnChainData() {
  try {
    const slot = await connection.getSlot();
    console.log('Current Solana slot:', slot);

    const epochInfo = await connection.getEpochInfo();
    console.log('Epoch Info:', epochInfo);

    // Additional queries: token account, supply, etc.
    // ...
  } catch (error) {
    console.error('Error querying Solana RPC:', error.message);
  }
}

// ------------------------------
// 5. Main function
// ------------------------------
async function main() {
  // Pass your desired token symbol here if needed
  await getPumpFunPrice('PumpFun');
  await checkOnChainData();
}

// Execute
main();