sync_pax8_direct.js

Go to the documentation of this file.

// Direct Pax8 product sync test (no Redis)
// Override DB config to use production BEFORE loading modules
delete require.cache[require.resolve('../services/db')];
process.env.DATABASE_URL = '';
process.env.DB_HOST = 'rmm-psa-db-do-user-28531160-0.i.db.ondigitalocean.com';
process.env.DB_PORT = '25060';
process.env.DB_USER = 'doadmin';
process.env.DB_PASSWORD = 'AVNS_J8RJAmsEwsHFG52_-F2';
process.env.DB_NAME = 'defaultdb';
process.env.DB_SSL = 'true';
 
const pool = require('../services/db');
const Pax8Service = require('../services/pax8Service');
 
const tenantId = '00000000-0000-0000-0000-000000000001'; // Independent Business Group
const vendor = 'Microsoft';
 
console.log('Starting direct Pax8 product sync...');
console.log(`Tenant: ${tenantId}`);
console.log(`Vendor: ${vendor}\n`);
 
/**
 *
 */
async function syncProducts() {
  try {
    const pax8 = new Pax8Service(tenantId);
    
    console.log('Fetching products from Pax8 API...');
    const products = await pax8.listProducts({ vendor });
 
    if (!products || products.length === 0) {
      console.log('No products found');
      process.exit(0);
    }
 
    console.log(`Found ${products.length} products\n`);
 
    let synced = 0;
    let updated = 0;
    let skipped = 0;
    let errors = 0;
 
    for (const product of products) {
      try {
        const existingResult = await pool.query(
          'SELECT product_id, last_synced_at FROM products WHERE pax8_product_id = $1',
          [product.id]
        );
 
        const name = product.name || product.productName || 'Unknown Product';
        const description = product.description || product.productDescription || '';
        const priceRetail = product.pricing?.retail || product.price || 0;
        const priceExTax = product.pricing?.cost || priceRetail;
        const pax8Vendor = product.vendor || vendor;
        const pax8Category = product.category || null;
        const pax8Subcategory = product.subcategory || product.subCategory || null;
        const pax8Sku = product.sku || product.productSku || null;
        const billingTerm = product.billingTerm || product.billing?.term || 'monthly';
        const isAutoRenew = product.autoRenew !== false;
        const pax8Metadata = JSON.stringify(product);
 
        if (existingResult.rows.length > 0) {
          await pool.query(
            `UPDATE products SET
              name = $1, description = $2, price_retail = $3, price_ex_tax = $4,
              pax8_vendor = $5, pax8_category = $6, pax8_subcategory = $7, pax8_sku = $8,
              billing_term = $9, is_auto_renew = $10, pax8_metadata = $11,
              last_synced_at = NOW(), updated_at = NOW()
            WHERE pax8_product_id = $12`,
            [name, description, priceRetail, priceExTax, pax8Vendor, pax8Category, pax8Subcategory, pax8Sku,
             billingTerm, isAutoRenew, pax8Metadata, product.id]
          );
          updated++;
          console.log(`✓ Updated: ${name}`);
        } else {
          await pool.query(
            `INSERT INTO products (
              tenant_id, name, description, supplier, price_retail, price_ex_tax,
              is_service, divisible, is_stock,
              pax8_product_id, pax8_vendor, pax8_category, pax8_subcategory,
              pax8_sku, billing_term, is_auto_renew, pax8_metadata,
              is_active, last_synced_at, created_at, updated_at
            ) VALUES (
              $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, NOW(), NOW(), NOW()
            )`,
            [tenantId, name, description, 'Pax8', priceRetail, priceExTax,
             true, true, false, product.id, pax8Vendor, pax8Category, pax8Subcategory,
             pax8Sku, billingTerm, isAutoRenew, pax8Metadata, true]
          );
          synced++;
          console.log(`✓ Added: ${name}`);
        }
 
      } catch (productErr) {
        errors++;
        console.error(`✗ Error processing product ${product.id}:`, productErr.message);
      }
    }
 
    console.log('\n=== Sync Complete ===');
    console.log(`Total: ${products.length}`);
    console.log(`Synced: ${synced}`);
    console.log(`Updated: ${updated}`);
    console.log(`Skipped: ${skipped}`);
    console.log(`Errors: ${errors}`);
 
    await pool.end();
    process.exit(0);
 
  } catch (err) {
    console.error('Sync failed:', err.message);
    console.error(err.stack);
    await pool.end();
    process.exit(1);
  }
}
 
syncProducts();