fetch_whm_data.js

Go to the documentation of this file.

#!/usr/bin/env node
/**
 * Fetch WHMCS data via WHM API (no MySQL connection needed)
 * Uses WHM API to list accounts and export data
 */
 
require('dotenv').config();
const https = require('https');
const fs = require('fs');
const path = require('path');
 
const WHM_HOST = 'precisewebhosting.com.au';
const WHM_PORT = 2087;
const WHM_TOKEN = process.env.WHM_TOKEN;
const EXPORT_DIR = path.join(__dirname, '../exports');
 
// Ensure export directory exists
if (!fs.existsSync(EXPORT_DIR)) {
  fs.mkdirSync(EXPORT_DIR, { recursive: true });
}
 
/**
 * Make WHM API request
 * @param endpoint
 * @param params
 */
function whmApiRequest(endpoint, params = {}) {
  return new Promise((resolve, reject) => {
    const queryString = new URLSearchParams(params).toString();
    const url = `https://${WHM_HOST}:${WHM_PORT}/json-api/${endpoint}?${queryString}`;
    
    const options = {
      hostname: WHM_HOST,
      port: WHM_PORT,
      path: `/json-api/${endpoint}?${queryString}`,
      method: 'GET',
      headers: {
        'Authorization': `WHM root:${WHM_TOKEN}`
      },
      rejectUnauthorized: false // Skip SSL verification
    };
 
    console.log(`[WHM API] ${endpoint}`);
    
    const req = https.request(options, (res) => {
      let data = '';
      
      res.on('data', (chunk) => {
        data += chunk;
      });
      
      res.on('end', () => {
        try {
          const json = JSON.parse(data);
          if (json.metadata && json.metadata.result === 0) {
            reject(new Error(json.metadata.reason || 'WHM API error'));
          } else {
            resolve(json);
          }
        } catch (err) {
          reject(new Error(`Failed to parse WHM response: ${err.message}`));
        }
      });
    });
    
    req.on('error', (err) => {
      reject(err);
    });
    
    req.end();
  });
}
 
/**
 * Main export function
 */
async function exportFromWHM() {
  try {
    console.log('========================================');
    console.log('WHM Data Export (Direct API Access)');
    console.log('========================================\n');
    
    if (!WHM_TOKEN) {
      throw new Error('WHM_TOKEN not configured in .env');
    }
    
    console.log(`Connecting to WHM: ${WHM_HOST}:${WHM_PORT}\n`);
    
    // List all accounts
    console.log('Fetching cPanel accounts...');
    const accounts = await whmApiRequest('listaccts');
    
    if (!accounts.data || !accounts.data.acct) {
      throw new Error('No accounts found in WHM');
    }
    
    console.log(`Found ${accounts.data.acct.length} cPanel accounts\n`);
    
    // Get domains
    console.log('Extracting domain information...');
    const domains = accounts.data.acct.map(acct => ({
      username: acct.user,
      domain: acct.domain,
      email: acct.email,
      plan: acct.plan,
      created: acct.startdate,
      suspended: acct.suspended,
      disk_used: acct.diskused,
      disk_limit: acct.disklimit
    }));
    
    // Save accounts export
    const accountsPath = path.join(EXPORT_DIR, 'whm_accounts.json');
    fs.writeFileSync(accountsPath, JSON.stringify(accounts.data.acct, null, 2));
    console.log(`✅ Accounts saved: ${accountsPath}`);
    
    // Save domains CSV
    const domainsCsv = [
      'username,domain,email,plan,created,suspended,disk_used,disk_limit',
      ...domains.map(d => `"${d.username}","${d.domain}","${d.email}","${d.plan}",${d.created},${d.suspended},"${d.disk_used}","${d.disk_limit}"`)
    ].join('\n');
    
    const domainsPath = path.join(EXPORT_DIR, 'whm_domains.csv');
    fs.writeFileSync(domainsPath, domainsCsv);
    console.log(`✅ Domains CSV saved: ${domainsPath}`);
    
    // Summary
    console.log('\n========================================');
    console.log('Export Summary');
    console.log('========================================');
    console.log(`Total Accounts: ${accounts.data.acct.length}`);
    console.log(`Active Domains: ${domains.filter(d => !d.suspended).length}`);
    console.log(`Suspended: ${domains.filter(d => d.suspended).length}`);
    console.log('========================================\n');
    
    // Show sample
    console.log('Sample Domains (first 5):');
    domains.slice(0, 5).forEach(d => {
      console.log(`  ${d.domain} (${d.email}) - ${d.suspended ? 'SUSPENDED' : 'Active'}`);
    });
    console.log('\n');
    
    console.log('✅ Export complete!');
    console.log('\nNote: This exported cPanel/WHM accounts.');
    console.log('To get WHMCS customer data, you still need MySQL access.');
    console.log('Options:');
    console.log('  1. Add IP 210.56.255.66 to MySQL remote access in WHM');
    console.log('  2. Or export WHMCS data directly on the server\n');
    
  } catch (error) {
    console.error('\n❌ Export failed:', error.message);
    console.error(error.stack);
    process.exit(1);
  }
}
 
// Run if called directly
if (require.main === module) {
  exportFromWHM();
}
 
module.exports = { exportFromWHM };