backfill_domain_notifications.js

Go to the documentation of this file.

// Backfill notifications for existing domain registration requests
// Run with: node scripts/backfill_domain_notifications.js
 
const pool = require('../services/db');
 
/**
 *
 */
async function backfillNotifications() {
  const client = await pool.connect();
  
  try {
    console.log('Starting notification backfill for domain requests...');
    
    // Get root tenant
    const rootTenantResult = await client.query(
      `SELECT tenant_id FROM tenants WHERE subdomain = 'admin' OR is_msp = true LIMIT 1`
    );
    
    if (rootTenantResult.rows.length === 0) {
      console.error('Root tenant not found');
      return;
    }
    
    const rootTenantId = rootTenantResult.rows[0].tenant_id;
    console.log(`Root tenant ID: ${rootTenantId}`);
    
    // Get all domain requests that don't have notifications
    const requestsResult = await client.query(`
      SELECT dr.request_id, dr.domain_name, dr.customer_id, dr.requested_at,
             dr.registrant_contact
      FROM domain_registration_requests dr
      WHERE NOT EXISTS (
        SELECT 1 FROM notifications n 
        WHERE n.message LIKE '%' || dr.domain_name || '%'
      )
      ORDER BY dr.requested_at DESC
    `);
    
    console.log(`Found ${requestsResult.rows.length} requests without notifications`);
    
    // Create notifications for each request
    let created = 0;
    for (const request of requestsResult.rows) {
      const registrant = request.registrant_contact;
      const fullName = `${registrant.firstName || ''} ${registrant.lastName || ''}`.trim() || 'Unknown';
      
      await client.query(
        `INSERT INTO notifications (tenant_id, title, message, type, customer_id, created_at)
         VALUES ($1, $2, $3, $4, $5, $6)`,
        [
          rootTenantId,
          'New Domain Registration Request',
          `${request.domain_name} registration requested by ${fullName}`,
          'info',
          request.customer_id,
          request.requested_at
        ]
      );
      
      created++;
      console.log(`Created notification for ${request.domain_name}`);
    }
    
    console.log(`\n✅ Successfully created ${created} notifications`);
    
  } catch (err) {
    console.error('Error backfilling notifications:', err);
    throw err;
  } finally {
    client.release();
    await pool.end();
  }
}
 
backfillNotifications()
  .then(() => {
    console.log('Backfill complete');
    process.exit(0);
  })
  .catch(err => {
    console.error('Backfill failed:', err);
    process.exit(1);
  });