pre-shutdown-checklist.js

Go to the documentation of this file.

#!/usr/bin/env node
/**
 * Pre-Shutdown Verification Checklist
 * Verifies all critical data has been migrated from WHM/WHMCS before server shutdown
 */
 
const mysql = require('mysql2/promise');
const { Pool } = require('pg');
const { exec } = require('child_process');
const util = require('util');
const execPromise = util.promisify(exec);
 
const MYSQL_CONFIG = {
  host: 'localhost',
  port: 3307, // SSH tunnel
  user: 'precisewebhostin_migration',
  password: 'Zrepowfg1-cFS,TP',
  database: 'precisewebhostin_whmcs'
};
 
const PG_CONFIG = {
  host: 'rmm-psa-db-do-user-28531160-0.i.db.ondigitalocean.com',
  port: 25060,
  database: 'defaultdb',
  user: 'doadmin',
  password: 'AVNS_J8RJAmsEwsHFG52_-F2',
  ssl: { rejectUnauthorized: false }
};
 
const tenantId = '00000000-0000-0000-0000-000000000001';
 
/**
 *
 * @param description
 * @param checkFunction
 */
async function checkItem(description, checkFunction) {
  process.stdout.write(`${description.padEnd(60)}`);
  try {
    const result = await checkFunction();
    if (result.status === 'ok') {
      console.log(`✓ ${result.message || 'OK'}`);
      return { passed: true, ...result };
    } else if (result.status === 'warning') {
      console.log(`⚠ ${result.message}`);
      return { passed: true, warning: true, ...result };
    } else {
      console.log(`✗ ${result.message}`);
      return { passed: false, ...result };
    }
  } catch (error) {
    console.log(`✗ ${error.message}`);
    return { passed: false, error: error.message };
  }
}
 
/**
 *
 */
async function main() {
  console.log('╔══════════════════════════════════════════════════════════╗');
  console.log('║   WHM/WHMCS Pre-Shutdown Verification Checklist         ║');
  console.log('╚══════════════════════════════════════════════════════════╝\n');
 
  let mysqlConn;
  let pgPool;
  const results = [];
 
  try {
    // Setup SSH tunnel first
    console.log('Setting up SSH tunnel to WHMCS database...');
    try {
      await execPromise('ssh -i ~/PreciseITServices.pem -L 3307:precisewebhosting.com.au:3306 -fN centos@54.253.193.6 -o StrictHostKeyChecking=no');
      await new Promise(resolve => setTimeout(resolve, 2000)); // Wait for tunnel
      console.log('✓ SSH tunnel established\n');
    } catch (e) {
      console.log('⚠ SSH tunnel may already exist\n');
    }
 
    mysqlConn = await mysql.createConnection(MYSQL_CONFIG);
    pgPool = new Pool(PG_CONFIG);
 
    console.log('DATA MIGRATION VERIFICATION');
    console.log('===========================\n');
 
    // 1. Customer count verification
    results.push(await checkItem('1. Customer records migrated', async () => {
      const [whmcsCount] = await mysqlConn.query('SELECT COUNT(*) as count FROM tblclients');
      const pgCount = await pgPool.query('SELECT COUNT(*) as count FROM customers WHERE tenant_id = $1', [tenantId]);
      
      if (pgCount.rows[0].count >= whmcsCount[0].count) {
        return { status: 'ok', message: `${pgCount.rows[0].count} of ${whmcsCount[0].count}` };
      } else {
        return { status: 'error', message: `Only ${pgCount.rows[0].count} of ${whmcsCount[0].count} migrated` };
      }
    }));
 
    // 2. Active services/contracts
    results.push(await checkItem('2. Active service contracts migrated', async () => {
      const [whmcsServices] = await mysqlConn.query(
        'SELECT COUNT(*) as count FROM tblhosting WHERE domainstatus IN ("Active", "Suspended")'
      );
      const pgContracts = await pgPool.query(
        'SELECT COUNT(*) as count FROM contracts WHERE tenant_id = $1 AND status IN ($2, $3)',
        [tenantId, 'active', 'suspended']
      );
      
      if (pgContracts.rows[0].count >= whmcsServices[0].count * 0.9) { // Allow 10% variance
        return { status: 'ok', message: `${pgContracts.rows[0].count} contracts (${whmcsServices[0].count} services)` };
      } else {
        return { status: 'warning', message: `${pgContracts.rows[0].count} contracts vs ${whmcsServices[0].count} services` };
      }
    }));
 
    // 3. Invoice records
    results.push(await checkItem('3. Invoice history migrated', async () => {
      const [whmcsInvoices] = await mysqlConn.query('SELECT COUNT(*) as count FROM tblinvoices');
      const pgInvoices = await pgPool.query('SELECT COUNT(*) as count FROM invoices WHERE tenant_id = $1', [tenantId]);
      
      const percentage = (pgInvoices.rows[0].count / whmcsInvoices[0].count) * 100;
      return { status: 'ok', message: `${pgInvoices.rows[0].count} of ${whmcsInvoices[0].count} (${percentage.toFixed(0)}%)` };
    }));
 
    // 4. Products catalog
    results.push(await checkItem('4. Product catalog migrated', async () => {
      const [whmcsProducts] = await mysqlConn.query('SELECT COUNT(*) as count FROM tblproducts WHERE hidden = 0');
      const pgProducts = await pgPool.query('SELECT COUNT(*) as count FROM products WHERE tenant_id = $1', [tenantId]);
      
      if (pgProducts.rows[0].count >= whmcsProducts[0].count) {
        return { status: 'ok', message: `${pgProducts.rows[0].count} products` };
      } else {
        return { status: 'warning', message: `${pgProducts.rows[0].count} of ${whmcsProducts[0].count}` };
      }
    }));
 
    // 5. Product pricing
    results.push(await checkItem('5. Product pricing populated', async () => {
      const pgPriced = await pgPool.query(
        'SELECT COUNT(*) as count FROM products WHERE tenant_id = $1 AND price_retail > 0',
        [tenantId]
      );
      const pgTotal = await pgPool.query(
        'SELECT COUNT(*) as count FROM products WHERE tenant_id = $1',
        [tenantId]
      );
      
      if (pgPriced.rows[0].count > 0) {
        return { status: 'ok', message: `${pgPriced.rows[0].count} of ${pgTotal.rows[0].count} have pricing` };
      } else {
        return { status: 'error', message: 'No products have pricing!' };
      }
    }));
 
    console.log('\nDNS & DOMAINS');
    console.log('=============\n');
 
    // 6. DNS zones migrated
    results.push(await checkItem('6. DNS zones on BIND server', async () => {
      const { stdout } = await execPromise('sshpass -p "vocjecXqFIzwe8dbPoTv4Lhd4O8WbVg4" ssh root@209.38.80.86 "ls /etc/bind/zones/ | wc -l"');
      const zoneCount = parseInt(stdout.trim());
      
      if (zoneCount > 60) {
        return { status: 'ok', message: `${zoneCount} zones on BIND` };
      } else {
        return { status: 'warning', message: `Only ${zoneCount} zones found` };
      }
    }));
 
    // 7. BIND service status
    results.push(await checkItem('7. BIND DNS service running', async () => {
      const { stdout } = await execPromise('sshpass -p "vocjecXqFIzwe8dbPoTv4Lhd4O8WbVg4" ssh root@209.38.80.86 "systemctl is-active named"');
      
      if (stdout.trim() === 'active') {
        return { status: 'ok', message: 'Active' };
      } else {
        return { status: 'error', message: 'Not active!' };
      }
    }));
 
    console.log('\nWORDPRESS SITES');
    console.log('===============\n');
 
    // 8. WordPress sites migrated
    results.push(await checkItem('8. WordPress sites on new droplet', async () => {
      const { stdout } = await execPromise('ssh -i ~/.ssh/wordpress_hosting_rsa root@209.38.90.228 "ls /var/www/wordpress-sites/ | wc -l"');
      const siteCount = parseInt(stdout.trim());
      
      if (siteCount >= 14) {
        return { status: 'ok', message: `${siteCount} sites` };
      } else {
        return { status: 'warning', message: `Only ${siteCount} sites found` };
      }
    }));
 
    // 9. WordPress Apache configs
    results.push(await checkItem('9. Apache vhosts configured', async () => {
      const { stdout } = await execPromise('ssh -i ~/.ssh/wordpress_hosting_rsa root@209.38.90.228 "ls /etc/apache2/sites-enabled/ | grep -v 000-default | wc -l"');
      const vhostCount = parseInt(stdout.trim());
      
      if (vhostCount >= 14) {
        return { status: 'ok', message: `${vhostCount} vhosts` };
      } else {
        return { status: 'warning', message: `Only ${vhostCount} vhosts` };
      }
    }));
 
    console.log('\nCRITICAL DATA CHECKS');
    console.log('====================\n');
 
    // 10. Domain-to-client mapping
    results.push(await checkItem('10. Client domain associations', async () => {
      const [domains] = await mysqlConn.query(`
        SELECT COUNT(DISTINCT domain) as count 
        FROM tblhosting 
        WHERE domainstatus NOT IN ('Cancelled', 'Terminated')
      `);
      
      return { 
        status: 'warning', 
        message: `${domains[0].count} domains in WHMCS (review needed)`,
        data: { domainCount: domains[0].count }
      };
    }));
 
    // 11. Client custom fields
    results.push(await checkItem('11. Client custom fields/notes', async () => {
      const [notes] = await mysqlConn.query('SELECT COUNT(*) as count FROM tblclients WHERE notes != ""');
      
      if (notes[0].count > 0) {
        return { 
          status: 'warning', 
          message: `${notes[0].count} clients have notes (may need manual review)`,
          data: { notesCount: notes[0].count }
        };
      } else {
        return { status: 'ok', message: 'No critical notes' };
      }
    }));
 
    // 12. Unpaid invoices
    results.push(await checkItem('12. Outstanding invoices', async () => {
      const [unpaid] = await mysqlConn.query(`
        SELECT COUNT(*) as count, SUM(total) as total 
        FROM tblinvoices 
        WHERE status = 'Unpaid'
      `);
      
      return { 
        status: 'ok', 
        message: `${unpaid[0].count} unpaid ($${parseFloat(unpaid[0].total || 0).toFixed(2)})`,
        data: { unpaidCount: unpaid[0].count, unpaidTotal: unpaid[0].total }
      };
    }));
 
    // 13. Email/support tickets
    results.push(await checkItem('13. Support tickets', async () => {
      try {
        const [tickets] = await mysqlConn.query('SELECT COUNT(*) as count FROM tbltickets WHERE status != "Closed"');
        
        if (tickets[0].count > 0) {
          return { 
            status: 'warning', 
            message: `${tickets[0].count} open tickets (export recommended)`,
            data: { openTickets: tickets[0].count }
          };
        } else {
          return { status: 'ok', message: 'No open tickets' };
        }
      } catch (e) {
        return { status: 'ok', message: 'Tickets table not accessible' };
      }
    }));
 
    console.log('\nBACKUP RECOMMENDATIONS');
    console.log('======================\n');
 
    // 14. Final database backup
    results.push(await checkItem('14. Create final WHMCS DB backup', async () => {
      return { 
        status: 'warning', 
        message: 'Manual action required',
        action: 'Run: mysqldump precisewebhostin_whmcs > whmcs_final_backup.sql'
      };
    }));
 
    // 15. WHM backup
    results.push(await checkItem('15. Create final WHM backup', async () => {
      return { 
        status: 'warning', 
        message: 'Manual action required',
        action: 'WHM > Backup > Generate Full Backup'
      };
    }));
 
    console.log('\n\n╔══════════════════════════════════════════════════════════╗');
    console.log('║   VERIFICATION SUMMARY                                   ║');
    console.log('╚══════════════════════════════════════════════════════════╝\n');
 
    const passed = results.filter(r => r.passed && !r.warning).length;
    const warnings = results.filter(r => r.warning).length;
    const failed = results.filter(r => !r.passed).length;
    const total = results.length;
 
    console.log(`Total Checks:     ${total}`);
    console.log(`Passed:           ${passed} ✓`);
    console.log(`Warnings:         ${warnings} ⚠`);
    console.log(`Failed:           ${failed} ✗`);
 
    if (failed > 0) {
      console.log('\n⚠ CRITICAL ISSUES FOUND - DO NOT SHUTDOWN SERVER YET\n');
      console.log('Failed checks:');
      results.filter(r => !r.passed).forEach((r, i) => {
        console.log(`  ${i + 1}. ${r.error || 'Unknown error'}`);
      });
    } else if (warnings > 0) {
      console.log('\n⚠ WARNINGS FOUND - REVIEW BEFORE SHUTDOWN\n');
      console.log('Items requiring attention:');
      results.filter(r => r.warning).forEach((r, i) => {
        console.log(`  ${i + 1}. ${r.message}`);
        if (r.action) console.log(`     Action: ${r.action}`);
      });
    } else {
      console.log('\n✓ ALL CHECKS PASSED - SERVER CAN BE SAFELY SHUTDOWN\n');
    }
 
    // Additional recommendations
    console.log('\nFINAL CHECKLIST BEFORE SHUTDOWN:');
    console.log('================================');
    console.log('[ ] Export any remaining cPanel email accounts to new provider');
    console.log('[ ] Update all domain nameservers to Cloudflare (if not done)');
    console.log('[ ] Verify SSL certificates are in place on new WordPress droplet');
    console.log('[ ] Download final backup of /home/ directories from WHM');
    console.log('[ ] Export WHMCS database: mysqldump precisewebhostin_whmcs > final_backup.sql');
    console.log('[ ] Test all critical domains resolve correctly from new servers');
    console.log('[ ] Notify clients of any planned downtime (if applicable)');
    console.log('[ ] Keep WHM server running for 30 days minimum as fallback\n');
 
  } catch (error) {
    console.error('\n❌ VERIFICATION FAILED:', error.message);
    process.exit(1);
  } finally {
    if (mysqlConn) await mysqlConn.end();
    if (pgPool) await pgPool.end();
    
    // Clean up SSH tunnel
    try {
      await execPromise('pkill -f "ssh.*3307:precisewebhosting"');
    } catch (e) {
      // Ignore errors
    }
  }
}
 
main();