test_pax8_sync.js

Go to the documentation of this file.

// Test script to trigger Pax8 product sync via Redis
const Redis = require("ioredis");
const { v4: uuidv4 } = require('uuid');
 
const redisConfig = require('../config/redis');
const redisSub = new Redis(redisConfig);
const redisPub = new Redis(redisConfig);
 
const tenantId = '00000000-0000-0000-0000-000000000001'; // Independent Business Group
const vendor = 'Microsoft';
const force = true; // Force re-sync
const jobId = uuidv4();
 
console.log(`Triggering Pax8 sync job ${jobId}...`);
console.log(`Tenant: ${tenantId}`);
console.log(`Vendor: ${vendor}`);
console.log(`Force: ${force}`);
 
// Subscribe to results
redisSub.subscribe('pax8:sync:result', (err) => {
  if (err) {
    console.error('Failed to subscribe to results:', err);
    process.exit(1);
  }
  console.log('Listening for sync results...\n');
});
 
redisSub.on('message', (channel, message) => {
  if (channel === 'pax8:sync:result') {
    const result = JSON.parse(message);
    if (result.jobId === jobId) {
      console.log('\n=== Sync Result ===');
      console.log('Success:', result.success);
      console.log('Message:', result.message);
      if (result.stats) {
        console.log('Stats:', result.stats);
      }
      if (result.error) {
        console.error('Error:', result.error);
      }
      redisSub.disconnect();
      redisPub.disconnect();
      process.exit(result.success ? 0 : 1);
    }
  }
});
 
// Publish sync request
setTimeout(() => {
  redisPub.publish('pax8:sync:request', JSON.stringify({
    jobId,
    tenantId,
    vendor,
    force
  }));
  console.log('Sync request published, waiting for worker to process...');
}, 500);