validate-setup.js

#!/usr/bin/env node

// Setup Validation Script
// Run this before starting the oracle to verify configuration

import dotenv from 'dotenv';
import { existsSync } from 'fs';
import { createClient } from '@supabase/supabase-js';
import { JsonRpcProvider, Wallet } from 'ethers';

dotenv.config();

const errors = [];
const warnings = [];

console.log('\n🔍 Validating Arbitrum YouTube Oracle Setup\n');
console.log('━'.repeat(60));

// Check environment file
if (!existsSync('.env')) {
  errors.push('.env file not found');
} else {
  console.log('✅ .env file found');
}

// Check required environment variables
const requiredVars = [
  'PRIVATE_KEY',
  'CONTRACT_ADDRESS', 
  'YOUTUBE_API_KEY',
  'CHANNEL_ID',
  'SUPABASE_ANON_KEY'
];

console.log('\n📝 Checking environment variables:');
for (const varName of requiredVars) {
  if (!process.env[varName]) {
    errors.push(`Missing ${varName} in .env`);
    console.log(`❌ ${varName} - MISSING`);
  } else if (process.env[varName].includes('Your') || process.env[varName].includes('your_')) {
    warnings.push(`${varName} appears to be a placeholder`);
    console.log(`⚠️  ${varName} - PLACEHOLDER (needs to be updated)`);
  } else {
    const maskedValue = varName.includes('KEY') || varName.includes('PRIVATE') 
      ? process.env[varName].substring(0, 10) + '...' 
      : process.env[varName].substring(0, 20) + '...';
    console.log(`✅ ${varName} - ${maskedValue}`);
  }
}

// Check optional but important variables
console.log('\n⚙️  Optional configuration:');
const optionalVars = {
  'VIDEO_ID': process.env.VIDEO_ID || 'LQAFm01IOT0',
  'CHECK_INTERVAL_MINUTES': process.env.CHECK_INTERVAL_MINUTES || '45',
  'RPC_URL': process.env.RPC_URL || 'https://arb1.arbitrum.io/rpc'
};

for (const [key, value] of Object.entries(optionalVars)) {
  console.log(`   ${key}: ${value}`);
}

// Check directories
console.log('\n📁 Checking directories:');
const dirs = ['logs', 'thumbnails', 'dist'];
for (const dir of dirs) {
  if (existsSync(dir)) {
    console.log(`✅ ${dir}/ exists`);
  } else {
    warnings.push(`${dir}/ directory not found`);
    console.log(`⚠️  ${dir}/ not found (will be created)`);
  }
}

// Check compiled files
console.log('\n🔨 Checking build:');
if (existsSync('dist/youtube-oracle.js')) {
  console.log('✅ Compiled JavaScript found');
} else {
  errors.push('Compiled JavaScript not found - run: npm run build');
  console.log('❌ dist/youtube-oracle.js not found');
}

// Test Supabase connection
console.log('\n💾 Testing Supabase connection:');
if (process.env.SUPABASE_URL && process.env.SUPABASE_ANON_KEY) {
  try {
    const supabase = createClient(
      process.env.SUPABASE_URL,
      process.env.SUPABASE_ANON_KEY
    );
    
    // Try a simple query
    const { data, error } = await supabase
      .from('oracle_state')
      .select('*')
      .limit(1);
    
    if (error) {
      if (error.message.includes('relation') || error.message.includes('does not exist')) {
        errors.push('Supabase tables not created - run supabase-schema.sql');
        console.log('❌ Tables not found - run SQL schema in Supabase');
      } else {
        errors.push(`Supabase error: ${error.message}`);
        console.log(`❌ Connection error: ${error.message}`);
      }
    } else {
      console.log('✅ Supabase connected and tables exist');
    }
  } catch (err) {
    errors.push(`Failed to connect to Supabase: ${err.message}`);
    console.log(`❌ Connection failed: ${err.message}`);
  }
} else {
  errors.push('Supabase credentials missing');
  console.log('❌ Supabase credentials not configured');
}

// Test RPC connection
console.log('\n⛓️  Testing Arbitrum RPC:');
if (process.env.RPC_URL || true) {
  try {
    const rpcUrl = process.env.RPC_URL || 'https://arb1.arbitrum.io/rpc';
    const provider = new JsonRpcProvider(rpcUrl);
    
    const network = await provider.getNetwork();
    const blockNumber = await provider.getBlockNumber();
    
    if (network.chainId === 42161n) {
      console.log(`✅ Connected to Arbitrum One (Chain ID: ${network.chainId})`);
      console.log(`   Latest block: ${blockNumber}`);
    } else {
      warnings.push(`Connected to chain ${network.chainId}, expected 42161 (Arbitrum One)`);
      console.log(`⚠️  Connected to chain ${network.chainId} (expected 42161)`);
    }
  } catch (err) {
    errors.push(`Failed to connect to RPC: ${err.message}`);
    console.log(`❌ RPC connection failed: ${err.message}`);
  }
}

// Test wallet
console.log('\n💼 Testing wallet:');
if (process.env.PRIVATE_KEY) {
  try {
    const wallet = new Wallet(process.env.PRIVATE_KEY);
    console.log(`✅ Wallet address: ${wallet.address}`);
    
    // Check balance if RPC is available
    if (process.env.RPC_URL || true) {
      const rpcUrl = process.env.RPC_URL || 'https://arb1.arbitrum.io/rpc';
      const provider = new JsonRpcProvider(rpcUrl);
      const walletWithProvider = wallet.connect(provider);
      const balance = await walletWithProvider.provider.getBalance(wallet.address);
      const ethBalance = parseFloat(balance.toString()) / 1e18;
      
      if (ethBalance < 0.001) {
        warnings.push('Wallet ETH balance is low');
        console.log(`⚠️  Balance: ${ethBalance.toFixed(6)} ETH (may need more for gas)`);
      } else {
        console.log(`✅ Balance: ${ethBalance.toFixed(6)} ETH`);
      }
    }
  } catch (err) {
    errors.push(`Invalid private key: ${err.message}`);
    console.log(`❌ Invalid private key`);
  }
}

// Summary
console.log('\n' + '━'.repeat(60));
console.log('\n📊 VALIDATION SUMMARY:\n');

if (errors.length === 0 && warnings.length === 0) {
  console.log('🎉 All checks passed! You\'re ready to start the oracle.\n');
  console.log('To start:');
  console.log('  npm start           # Test run');
  console.log('  pm2 start pm2.config.js  # Production deployment');
  process.exit(0);
} else {
  if (errors.length > 0) {
    console.log(`❌ ${errors.length} ERROR(S) found:\n`);
    errors.forEach((err, i) => {
      console.log(`   ${i + 1}. ${err}`);
    });
    console.log('');
  }
  
  if (warnings.length > 0) {
    console.log(`⚠️  ${warnings.length} WARNING(S):\n`);
    warnings.forEach((warn, i) => {
      console.log(`   ${i + 1}. ${warn}`);
    });
    console.log('');
  }
  
  if (errors.length > 0) {
    console.log('❌ Please fix the errors before starting the oracle.\n');
    console.log('See SETUP_GUIDE.md for detailed instructions.');
    process.exit(1);
  } else {
    console.log('⚠️  Warnings found, but oracle can still run.');
    console.log('Consider addressing warnings for optimal performance.\n');
    process.exit(0);
  }
}