check-migration-status.js

Go to the documentation of this file.

#!/usr/bin/env node
const { Pool } = require('pg');
 
const pool = new Pool({
  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 }
});
 
/**
 *
 */
async function checkStats() {
  const tenantId = '00000000-0000-0000-0000-000000000001';
  
  const result = await pool.query(`
    SELECT 
      (SELECT COUNT(*) FROM customers WHERE tenant_id = $1) as customers,
      (SELECT COUNT(*) FROM products WHERE tenant_id = $1) as products,
      (SELECT COUNT(*) FROM invoices WHERE tenant_id = $1) as invoices,
      (SELECT COUNT(*) FROM contracts WHERE tenant_id = $1) as contracts,
      (SELECT COUNT(*) FROM contract_line_items cli 
       JOIN contracts c ON cli.contract_id = c.contract_id 
       WHERE c.tenant_id = $1) as line_items
  `, [tenantId]);
  
  console.log('Current Migration Statistics:');
  console.log('==============================');
  console.log(`Customers:      ${result.rows[0].customers}`);
  console.log(`Products:       ${result.rows[0].products}`);
  console.log(`Invoices:       ${result.rows[0].invoices}`);
  console.log(`Contracts:      ${result.rows[0].contracts}`);
  console.log(`Line Items:     ${result.rows[0].line_items}`);
  
  await pool.end();
}
 
checkStats().catch(console.error);