index.js

require('dotenv').config();
const config = require('./config');
const { getConnection } = require('./src/core/connection');
const { getWallet } = require('./src/core/wallet');
const { startScheduler } = require('./src/strategy/scheduler');
const { startDashboard, updateAgentStatus, addEquityHistory } = require('./src/monitoring/dashboard');
const { sendStartup } = require('./src/monitoring/telegram');
const logger = require('./src/monitoring/logger');

async function main() {
  try {
    logger.log('INFO', 'Starting Gtrade Agent...');
    
    // Test koneksi
    const connection = getConnection();
    await connection.getSlot();
    logger.log('INFO', 'RPC connection OK');
    
    // Load wallet
    const wallet = getWallet();
    const walletAddress = wallet.publicKey.toBase58();
    logger.log('INFO', `Wallet loaded: ${walletAddress}`);
    
    // Hitung initial capital (default $40 = $20 SOL + $20 USDC)
    // Ini bisa disesuaikan dengan membaca dari config nantinya
    const initialCapital = config.trading.initial_capital || 40;
    
    // Start dashboard with initial data
    const dashboardPort = config.monitoring.dashboard_port || 3000;
    startDashboard(dashboardPort, {
      initialCapital: initialCapital,
      status: 'RUNNING',
      startTime: Date.now()
    });
    
    // Update agent status di dashboard
    updateAgentStatus({
      status: 'RUNNING',
      startTime: Date.now(),
      initialCapital: initialCapital,
      currentBalance: initialCapital,
      marketTrend: 'SIDEWAYS',
      totalFeeCollected: 0,
      lastUpdate: Date.now()
    });
    
    // Add initial equity history point
    addEquityHistory(initialCapital);
    
    // Start scheduler
    await startScheduler();
    
    // Kirim notifikasi startup
    await sendStartup(walletAddress, 'Helius (primary)');
    
    logger.log('INFO', 'Gtrade Agent is running...');
    logger.log('INFO', `Dashboard available at http://localhost:${dashboardPort}`);
    
    // Keep process alive
    process.on('SIGINT', () => {
      logger.log('INFO', 'Shutting down Gtrade Agent...');
      updateAgentStatus({ status: 'STOPPED' });
      process.exit(0);
    });
    
  } catch (error) {
    logger.log('ERROR', `Fatal error: ${error.message}`);
    updateAgentStatus({ status: 'STOPPED' });
    process.exit(1);
  }
}

main();