admin-retry-registration.js

Go to the documentation of this file.

#!/usr/bin/env node
/**
 * Administrative Script: Retry Failed Domain Registration
 * 
 * This script manually processes a pending domain registration request
 * by calling the Cloudflare Registrar API directly and updating the database.
 * 
 * Usage: node admin-retry-registration.js
 */
 
require('dotenv').config();
const { Pool } = require('pg');
const cloudflare = require('./services/cloudflare');
 
const REQUEST_ID = '3d647ee7-c6af-4e49-af84-fb8e2d103551';
 
// Handle DigitalOcean's self-signed certificates
const dbUrl = process.env.DATABASE_URL.replace('sslmode=require', 'sslmode=no-verify');
 
const pool = new Pool({
  connectionString: dbUrl,
  ssl: { rejectUnauthorized: false }
});
 
async function retryRegistration() {
  const client = await pool.connect();
  
  try {
    console.log('🔄 Starting administrative domain registration retry...\n');
    
    // Get request details
    console.log('1. Fetching registration request...');
    const requestResult = await client.query(
      'SELECT * FROM domain_registration_requests WHERE request_id = $1',
      [REQUEST_ID]
    );
    
    if (requestResult.rows.length === 0) {
      throw new Error('Registration request not found');
    }
    
    const request = requestResult.rows[0];
    console.log('   Domain:', request.domain_name);
    console.log('   Status:', request.status);
    console.log('   Registrar:', request.registrar);
    
    if (request.status !== 'pending') {
      console.warn(`   ⚠️  Warning: Status is '${request.status}', expected 'pending'`);
    }
    
    // Update to approved status
    console.log('\n2. Marking as approved...');
    await client.query(
      `UPDATE domain_registration_requests 
       SET status = 'approved', reviewed_at = NOW(), approval_notes = $1, updated_at = NOW()
       WHERE request_id = $2`,
      ['Administrative retry after adding Cloudflare Account ID', REQUEST_ID]
    );
    console.log('   ✓ Status updated to: approved');
    
    // Prepare contact information (Cloudflare requires specific field names)
    if (!request.registrant_contact) {
      throw new Error('No registrant contact information found in request');
    }
    
    const contact = {
      organization: request.registrant_contact.organization || '',
      first_name: request.registrant_contact.firstName,
      last_name: request.registrant_contact.lastName,
      email: request.registrant_contact.email,
      phone: request.registrant_contact.phone,
      address: request.registrant_contact.address,
      city: request.registrant_contact.city,
      state: request.registrant_contact.state,
      zip: request.registrant_contact.postalCode,
      country: request.registrant_contact.country.toUpperCase()
    };
    
    console.log('\n3. Registering domain with Cloudflare Registrar...');
    console.log('   Contact:', `${contact.first_name} ${contact.last_name} (${contact.email})`);
    console.log('   Contact object:', JSON.stringify(contact, null, 2));
    console.log('   This may take 30-60 seconds...');
    
    const registrationResult = await cloudflare.registerDomain({
      domain: request.domain_name,
      years: request.years || 1,
      privacy: true,
      auto_renew: true,
      registrant_contact: contact
    });
    
    if (registrationResult.code === 'API_NOT_AVAILABLE') {
      throw new Error(`Cloudflare API error: ${registrationResult.message}`);
    }
    
    console.log('   ✓ Registration successful!');
    console.log('   Domain:', registrationResult.domain);
    console.log('   Status:', registrationResult.status);
    console.log('   Expiration:', registrationResult.expiration_date);
    
    // Create DNS zone in Cloudflare
    console.log('\n4. Creating Cloudflare DNS zone...');
    const zone = await cloudflare.createZone(request.domain_name, request.tenant_id);
    console.log('   ✓ Zone created!');
    console.log('   Zone ID:', zone.id);
    console.log('   Nameservers:', zone.name_servers?.join(', '));
    
    // Insert domain into domains table
    console.log('\n5. Adding domain to database...');
    const domainResult = await client.query(
      `INSERT INTO domains (
        tenant_id, domain_name, cloudflare_zone_id, 
        nameservers, status, registrar
      ) VALUES ($1, $2, $3, $4, 'active', 'cloudflare-registrar')
      ON CONFLICT (domain_name) DO UPDATE 
      SET cloudflare_zone_id = $3, nameservers = $4, status = 'active'
      RETURNING domain_id`,
      [request.tenant_id, request.domain_name, zone.id, zone.name_servers]
    );
    
    const domainId = domainResult.rows[0].domain_id;
    console.log('   ✓ Domain ID:', domainId);
    
    // Update registration request to completed
    console.log('\n6. Finalizing registration request...');
    await client.query(
      `UPDATE domain_registration_requests 
       SET status = 'registered', 
           domain_id = $1,
           cloudflare_zone_id = $2,
           registration_completed_at = NOW(),
           updated_at = NOW()
       WHERE request_id = $3`,
      [domainId, zone.id, REQUEST_ID]
    );
    console.log('   ✓ Request marked as registered');
    
    console.log('\n✅ Registration completed successfully!');
    console.log('\nSummary:');
    console.log('  Domain:', request.domain_name);
    console.log('  Domain ID:', domainId);
    console.log('  Zone ID:', zone.id);
    console.log('  Nameservers:', zone.name_servers?.join(', '));
    console.log('  Expiration:', registrationResult.expiration_date);
    
  } catch (error) {
    console.error('\n❌ Registration failed:', error.message);
    
    if (error.details) {
      console.error('Details:', JSON.stringify(error.details, null, 2));
    }
    
    // Update request to failed status
    try {
      await client.query(
        `UPDATE domain_registration_requests 
         SET status = 'failed', 
             registration_error = $1,
             updated_at = NOW()
         WHERE request_id = $2`,
        [error.message, REQUEST_ID]
      );
      console.error('   Request marked as failed in database');
    } catch (updateError) {
      console.error('   Failed to update database:', updateError.message);
    }
    
    process.exit(1);
  } finally {
    client.release();
    await pool.end();
  }
}
 
// Run the script
retryRegistration().catch(err => {
  console.error('Unhandled error:', err);
  process.exit(1);
});