create_precise_pcs_tenant.js

Go to the documentation of this file.

#!/usr/bin/env node
 
/**
 * Create "Precise PCs" Tenant in PostgreSQL
 * 
 * This script creates a new tenant for Precise PCs customers
 * being migrated from WHMCS.
 */
 
require('dotenv').config();
const { Pool } = require('pg');
const { v4: uuidv4 } = require('uuid');
 
// PostgreSQL connection
const pool = new Pool({
  host: process.env.DB_HOST,
  port: process.env.DB_PORT,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  database: process.env.DB_NAME,
  ssl: process.env.DB_HOST.includes('digitalocean') ? { rejectUnauthorized: false } : false
});
 
/**
 *
 */
async function createPrecisePCsTenant() {
  console.log('========================================');
  console.log('Creating Precise PCs Tenant');
  console.log('========================================');
  console.log('');
 
  try {
    // Check if tenant already exists
    const existingCheck = await pool.query(
      "SELECT tenant_id, name, subdomain FROM tenants WHERE name ILIKE '%Precise%' OR subdomain ILIKE '%precise%'"
    );
 
    if (existingCheck.rows.length > 0) {
      const existing = existingCheck.rows[0];
      console.log('⚠️  Tenant already exists:');
      console.log(`   ID: ${existing.tenant_id}`);
      console.log(`   Name: ${existing.name}`);
      console.log(`   Subdomain: ${existing.subdomain || 'N/A'}`);
      console.log('');
      console.log('Using existing tenant for import...');
      
      // Save to file
      const fs = require('fs');
      const path = require('path');
      const exportDir = path.join(__dirname, '..', 'exports');
      
      if (!fs.existsSync(exportDir)) {
        fs.mkdirSync(exportDir, { recursive: true });
      }
 
      fs.writeFileSync(
        path.join(exportDir, 'precise_pcs_tenant.json'),
        JSON.stringify({
          tenant_id: existing.tenant_id,
          name: existing.name,
          subdomain: existing.subdomain
        }, null, 2)
      );
      
      return existing.tenant_id;
    }
 
    // Create new tenant
    const tenantId = uuidv4();
    const tenantData = {
      tenant_id: tenantId,
      name: 'Precise PCs',
      subdomain: 'precisepcs',
      status: 'active',
      is_msp: false,
      email_automation: JSON.stringify({
        migrated_from: 'WHMCS',
        migration_date: new Date().toISOString(),
        original_whmcs_url: 'https://clientarea.precisewebhosting.com.au',
        original_domain: 'precisewebhosting.com.au',
        features: {
          billing: true,
          support_tickets: true,
          domain_management: true,
          wordpress_hosting: true
        }
      })
    };
 
    const insertQuery = `
      INSERT INTO tenants (
        tenant_id, name, subdomain, status, is_msp,
        email_automation, created_at, updated_at
      ) VALUES (
        $1, $2, $3, $4, $5, $6, NOW(), NOW()
      )
      RETURNING tenant_id, name, subdomain, status, is_msp, created_at
    `;
 
    const result = await pool.query(insertQuery, [
      tenantData.tenant_id,
      tenantData.name,
      tenantData.subdomain,
      tenantData.status,
      tenantData.is_msp,
      tenantData.email_automation
    ]);
 
    const tenant = result.rows[0];
 
    console.log('✅ Tenant created successfully!');
    console.log('');
    console.log('Tenant Details:');
    console.log('─────────────────────────────────────');
    console.log(`ID:          ${tenant.tenant_id}`);
    console.log(`Name:        ${tenant.name}`);
    console.log(`Subdomain:   ${tenant.subdomain}`);
    console.log(`Status:      ${tenant.status}`);
    console.log(`Is MSP:      ${tenant.is_msp}`);
    console.log(`Created:     ${tenant.created_at}`);
    console.log('─────────────────────────────────────');
    console.log('');
 
    // Save tenant ID to file for import script
    const fs = require('fs');
    const path = require('path');
    const exportDir = path.join(__dirname, '..', 'exports');
    
    if (!fs.existsSync(exportDir)) {
      fs.mkdirSync(exportDir, { recursive: true });
    }
 
    fs.writeFileSync(
      path.join(exportDir, 'precise_pcs_tenant.json'),
      JSON.stringify({
        tenant_id: tenant.tenant_id,
        name: tenant.name,
        subdomain: tenant.subdomain,
        created_at: tenant.created_at
      }, null, 2)
    );
 
    console.log('💾 Tenant ID saved to: exports/precise_pcs_tenant.json');
    console.log('');
 
    return tenant.tenant_id;
 
  } catch (error) {
    console.error('❌ Error creating tenant:', error.message);
    throw error;
  } finally {
    await pool.end();
  }
}
 
// Run if executed directly
if (require.main === module) {
  createPrecisePCsTenant()
    .then(() => {
      console.log('✅ Tenant creation complete');
      process.exit(0);
    })
    .catch((error) => {
      console.error('❌ Tenant creation failed:', error);
      process.exit(1);
    });
}
 
module.exports = { createPrecisePCsTenant };