pax8_sync_standalone.js

Go to the documentation of this file.

#!/usr/bin/env node
// Standalone Pax8 product sync - direct database and API access
const { Pool } = require('pg');
const axios = require('axios');
 
const PAX8_API_BASE = 'https://api.pax8.com/v1';
const PAX8_AUTH_URL = 'https://api.pax8.com/v1/oauth/token';
const PAX8_CLIENT_ID = 'Kc57c2kDnwisVNia0m3yKOQGoiglaq3d';
const PAX8_CLIENT_SECRET = 'kFQarde_yooSLBnF-y6ZXohOr_6lZT87GX_SrL7taji-LTaaCmSopvo6nSLodF_M';
const TENANT_ID = '00000000-0000-0000-0000-000000000001';
const VENDOR = 'Microsoft';
 
// Database connection
const pool = new Pool({
  host: 'rmm-psa-db-do-user-28531160-0.i.db.ondigitalocean.com',
  port: 25060,
  user: 'doadmin',
  password: 'AVNS_J8RJAmsEwsHFG52_-F2',
  database: 'defaultdb',
  ssl: { rejectUnauthorized: false }
});
 
console.log('🚀 Pax8 Product Sync - Standalone');
console.log(`Tenant: ${TENANT_ID}`);
console.log(`Vendor: ${VENDOR}\n`);
 
/**
 *
 */
async function getAccessToken() {
  console.log('🔐 Getting Pax8 access token...');
  
  try {
    const response = await axios.post(PAX8_AUTH_URL, {
      grant_type: 'client_credentials',
      client_id: PAX8_CLIENT_ID,
      client_secret: PAX8_CLIENT_SECRET
    }, {
      headers: { 'Content-Type': 'application/json' }
    });
 
    console.log('✓ Access token acquired\n');
    return response.data.access_token;
  } catch (error) {
    console.error('✗ OAuth2 authentication failed:', error.response?.data || error.message);
    throw error;
  }
}
 
/**
 *
 * @param accessToken
 * @param vendor
 */
async function listProducts(accessToken, vendor) {
  console.log(`📦 Fetching ${vendor} products from Pax8...`);
  
  try {
    const response = await axios.get(`${PAX8_API_BASE}/products`, {
      headers: {
        'Authorization': `Bearer ${accessToken}`,
        'Content-Type': 'application/json'
      },
      params: { vendor }
    });
 
    const products = response.data.content || response.data.products || response.data;
    console.log(`✓ Found ${products.length} products\n`);
    return products;
  } catch (error) {
    console.error('✗ Failed to fetch products:', error.response?.data || error.message);
    throw error;
  }
}
 
/**
 *
 */
async function syncProducts() {
  try {
    const accessToken = await getAccessToken();
    const products = await listProducts(accessToken, VENDOR);
 
    if (!products || products.length === 0) {
      console.log('No products to sync');
      return;
    }
 
    console.log('💾 Syncing products to database...\n');
 
    let synced = 0;
    let updated = 0;
    let errors = 0;
 
    for (const product of products) {
      try {
        const pax8ProductId = product.id || product.productId;
        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);
 
        // Check if exists
        const existingResult = await pool.query(
          'SELECT product_id FROM products WHERE pax8_product_id = $1',
          [pax8ProductId]
        );
 
        if (existingResult.rows.length > 0) {
          // Update
          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, pax8ProductId]
          );
          updated++;
          console.log(`  ↻ Updated: ${name}`);
        } else {
          // Insert
          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()
            )`,
            [TENANT_ID, name, description, 'Pax8', priceRetail, priceExTax,
             true, true, false, pax8ProductId, pax8Vendor, pax8Category, pax8Subcategory,
             pax8Sku, billingTerm, isAutoRenew, pax8Metadata, true]
          );
          synced++;
          console.log(`  + Added: ${name}`);
        }
 
      } catch (productErr) {
        errors++;
        console.error(`  ✗ Error: ${product.name}:`, productErr.message);
      }
    }
 
    console.log('\n✅ Sync Complete!');
    console.log(`  Total: ${products.length}`);
    console.log(`  Added: ${synced}`);
    console.log(`  Updated: ${updated}`);
    console.log(`  Errors: ${errors}`);
 
  } catch (error) {
    console.error('\n❌ Sync failed:', error.message);
    throw error;
  } finally {
    await pool.end();
  }
}
 
// Run
syncProducts()
  .then(() => process.exit(0))
  .catch(err => {
    console.error(err);
    process.exit(1);
  });