pax8Service.js

Go to the documentation of this file.

/**
 * Pax8 API Service
 * Handles OAuth2 authentication and API interactions with Pax8
 * Multi-tenant aware - each instance is bound to a specific tenant
 */
 
const axios = require('axios');
const pool = require('./db');
 
const PAX8_API_BASE = process.env.PAX8_API_BASE || 'https://api.pax8.com/v1';
const PAX8_AUTH_URL = process.env.PAX8_AUTH_URL || 'https://api.pax8.com/v1/oauth/token';
 
/**
 *
 */
class Pax8Service {
  /**
   *
   * @param tenantId
   */
  constructor(tenantId) {
    this.tenantId = tenantId;
    this.config = null;
    this.accessToken = null;
    this.tokenExpiry = null;
  }
 
  /**
   * Load Pax8 configuration for the tenant
   */
  async loadConfig() {
    const result = await pool.query(
      'SELECT * FROM pax8_config WHERE tenant_id = $1 AND is_active = true',
      [this.tenantId]
    );
    
    if (result.rows.length === 0) {
      throw new Error('Pax8 configuration not found for this tenant. Please configure Pax8 API credentials first.');
    }
    
    this.config = result.rows[0];
    return this.config;
  }
 
  /**
   * Get OAuth2 access token (cached for performance)
   * Automatically refreshes when expired
   */
  async getAccessToken() {
    // Return cached token if still valid (with 60s buffer)
    if (this.accessToken && this.tokenExpiry && Date.now() < this.tokenExpiry) {
      return this.accessToken;
    }
 
    if (!this.config) {
      await this.loadConfig();
    }
 
    console.log(`[Pax8] Requesting new access token for tenant ${this.tenantId}`);
 
    try {
      // TODO: Decrypt client_secret before using
      const clientSecret = this.config.client_secret_encrypted; // Implement decryption
 
      const response = await axios.post(PAX8_AUTH_URL, 
        {
          grant_type: 'client_credentials',
          client_id: this.config.client_id,
          client_secret: clientSecret
        },
        {
          headers: {
            'Content-Type': 'application/json'
          }
        }
      );
 
      this.accessToken = response.data.access_token;
      // Set expiry with 60 second buffer
      this.tokenExpiry = Date.now() + (response.data.expires_in * 1000) - 60000;
 
      console.log(`[Pax8] Access token acquired, expires in ${response.data.expires_in}s`);
 
      return this.accessToken;
    } catch (error) {
      console.error('[Pax8] OAuth2 authentication failed:', error.response?.data || error.message);
      throw new Error(`Pax8 authentication failed: ${error.response?.data?.error_description || error.message}`);
    }
  }
 
  /**
   * Make authenticated API request to Pax8
   * @param {string} method - HTTP method (GET, POST, PATCH, DELETE)
   * @param {string} endpoint - API endpoint (e.g., '/companies')
   * @param {object} data - Request body data (for POST/PATCH)
   * @param {object} params - Query parameters
   */
  async apiRequest(method, endpoint, data = null, params = null) {
    const token = await this.getAccessToken();
    
    const config = {
      method,
      url: `${PAX8_API_BASE}${endpoint}`,
      headers: {
        'Authorization': `Bearer ${token}`,
        'Content-Type': 'application/json'
      }
    };
 
    if (data) {
      config.data = data;
    }
 
    if (params) {
      config.params = params;
    }
 
    try {
      const response = await axios(config);
      return response.data;
    } catch (error) {
      const errorDetail = error.response?.data || error.message;
      console.error(`[Pax8] API Error (${method} ${endpoint}):`, errorDetail);
      
      // Throw with more context
      throw new Error(`Pax8 API error: ${JSON.stringify(errorDetail)}`);
    }
  }
 
  // ========================================
  // Company (Customer) Management
  // ========================================
 
  /**
   * List all companies (customers) in Pax8
   * @param {object} filters - Optional filters (page, size, etc.)
   */
  async listCompanies(filters = {}) {
    return this.apiRequest('GET', '/companies', null, filters);
  }
 
  /**
   * Get company by ID
   * @param {string} pax8CompanyId - Pax8 company ID
   */
  async getCompany(pax8CompanyId) {
    return this.apiRequest('GET', `/companies/${pax8CompanyId}`);
  }
 
  /**
   * Create a new company in Pax8
   * @param {object} companyData - Company details
   */
  async createCompany(companyData) {
    return this.apiRequest('POST', '/companies', companyData);
  }
 
  /**
   * Update company information
   * @param {string} pax8CompanyId - Pax8 company ID
   * @param {object} updates - Updated company data
   */
  async updateCompany(pax8CompanyId, updates) {
    return this.apiRequest('PATCH', `/companies/${pax8CompanyId}`, updates);
  }
 
  // ========================================
  // Product Management
  // ========================================
 
  /**
   * List available products (SKUs)
   * @param {object} filters - Filters like vendor, category, etc.
   */
  async listProducts(filters = {}) {
    return this.apiRequest('GET', '/products', null, filters);
  }
 
  /**
   * Get product details by ID
   * @param {string} productId - Pax8 product ID
   */
  async getProduct(productId) {
    return this.apiRequest('GET', `/products/${productId}`);
  }
 
  /**
   * Search products
   * @param {string} searchTerm - Search term
   */
  async searchProducts(searchTerm) {
    return this.apiRequest('GET', '/products', null, { search: searchTerm });
  }
 
  // ========================================
  // Subscription Management
  // ========================================
 
  /**
   * List subscriptions
   * @param {object} filters - Optional filters (companyId, status, etc.)
   */
  async listSubscriptions(filters = {}) {
    return this.apiRequest('GET', '/subscriptions', null, filters);
  }
 
  /**
   * Get subscriptions for a specific company
   * @param {string} pax8CompanyId - Pax8 company ID
   */
  async getCompanySubscriptions(pax8CompanyId) {
    return this.apiRequest('GET', '/subscriptions', null, { companyId: pax8CompanyId });
  }
 
  /**
   * Get subscription by ID
   * @param {string} pax8SubscriptionId - Pax8 subscription ID
   */
  async getSubscription(pax8SubscriptionId) {
    return this.apiRequest('GET', `/subscriptions/${pax8SubscriptionId}`);
  }
 
  /**
   * Create a new subscription (purchase licenses)
   * @param {object} subscriptionData - Subscription details
   * @example
   * {
   *   companyId: 'company-id',
   *   productId: 'product-id',
   *   quantity: 5,
   *   billingTerm: 'monthly'
   * }
   */
  async createSubscription(subscriptionData) {
    return this.apiRequest('POST', '/subscriptions', subscriptionData);
  }
 
  /**
   * Update subscription (change quantity, billing term, etc.)
   * @param {string} pax8SubscriptionId - Pax8 subscription ID
   * @param {object} updates - Updates to apply
   */
  async updateSubscription(pax8SubscriptionId, updates) {
    return this.apiRequest('PATCH', `/subscriptions/${pax8SubscriptionId}`, updates);
  }
 
  /**
   * Cancel subscription
   * @param {string} pax8SubscriptionId - Pax8 subscription ID
   */
  async cancelSubscription(pax8SubscriptionId) {
    return this.apiRequest('DELETE', `/subscriptions/${pax8SubscriptionId}`);
  }
 
  // ========================================
  // Utility Methods
  // ========================================
 
  /**
   * Test API connection
   * @returns {boolean} True if connection successful
   */
  async testConnection() {
    try {
      await this.getAccessToken();
      // Try to list companies to verify access
      await this.listCompanies({ size: 1 });
      return true;
    } catch (error) {
      console.error('[Pax8] Connection test failed:', error.message);
      return false;
    }
  }
 
  /**
   * Update last sync status in database
   * @param {string} status - 'success', 'failed', 'in_progress'
   * @param {string} error - Error message (if failed)
   */
  async updateSyncStatus(status, error = null) {
    await pool.query(
      `UPDATE pax8_config 
       SET last_sync_at = NOW(), last_sync_status = $1, sync_error = $2
       WHERE tenant_id = $3`,
      [status, error, this.tenantId]
    );
  }
}
 
module.exports = Pax8Service;