cannaiq/backend/archive/sync-dispensaries-to-dutchie.ts

import { Pool } from 'pg';

async function syncDispensaries() {
  // Source: sail database
  const sailPool = new Pool({
    connectionString: 'postgresql://sail:password@localhost:5432/dutchie_menus'
  });

  // Destination: dutchie database
  const dutchiePool = new Pool({
    connectionString: 'postgresql://dutchie:dutchie_local_pass@localhost:54320/dutchie_menus'
  });

  try {
    console.log('🔄 Syncing enriched dispensary data from sail → dutchie database\n');

    // Get all enriched dispensaries from sail
    const result = await sailPool.query(`
      SELECT id, name, company_name, slug, address, city, state, zip, phone, email,
             website, dba_name, google_rating, google_review_count, status_line,
             azdhs_url, latitude, longitude
      FROM azdhs_list
      WHERE website IS NOT NULL AND website != ''
    `);

    console.log(`📋 Found ${result.rows.length} enriched dispensaries to sync\n`);

    let synced = 0;
    for (const disp of result.rows) {
      await dutchiePool.query(`
        UPDATE azdhs_list
        SET
          website = $1,
          dba_name = $2,
          google_rating = $3,
          google_review_count = $4,
          updated_at = CURRENT_TIMESTAMP
        WHERE id = $5
      `, [
        disp.website,
        disp.dba_name,
        disp.google_rating,
        disp.google_review_count,
        disp.id
      ]);
      synced++;
      if (synced % 20 === 0) {
        console.log(`   Synced ${synced}/${result.rows.length}...`);
      }
    }

    console.log(`\n✅ Successfully synced ${synced} dispensaries!`);

  } finally {
    await sailPool.end();
    await dutchiePool.end();
  }
}

syncDispensaries().catch(console.error);