cwa-pos-api.ts

Go to the documentation of this file.

/**
 * CWA Fieldpine POS API Integration
 * Based on real POS API analysis from murwillumbah.cwanz.online/openapi/
 * This handles actual POS operations like product search, sales processing, etc.
 */
 
export interface POSApiResponse<T = any> {
  data?: T;
  error?: string;
  status?: string;
}
 
export interface ProductSearchResult {
  id: string;
  name: string;
  barcode?: string;
  price: number;
  stock?: number;
}
 
export interface RetailConfig {
  settings?: Record<string, any>;
  version?: string;
  store?: {
    name?: string;
    id?: string;
  };
}
 
export class CWAPosApi {
  private baseUrl: string;
  private apiKey?: string;
 
  constructor(storeBaseUrl?: string) {
    // POS API uses /openapi/ endpoint
    this.baseUrl = storeBaseUrl ? `${storeBaseUrl}/openapi` : 'https://murwillumbah.cwanz.online/openapi';
  }
 
  /**
   * Set the API key for authenticated requests
   */
  setApiKey(apiKey: string) {
    this.apiKey = apiKey;
  }
 
  /**
   * Make a request to the POS API
   */
  private async posRequest(endpoint: string, params: Record<string, string | number> = {}): Promise<POSApiResponse> {
    let url: string;
    
    if (endpoint.startsWith('BUCK?')) {
      // For BUCK requests, use base store URL directly
      const baseStoreUrl = this.baseUrl.replace('/openapi', '');
      url = new URL(endpoint, baseStoreUrl).toString();
    } else {
      url = new URL(endpoint, this.baseUrl).toString();
    }
 
    // Add parameters for non-BUCK requests
    if (!endpoint.startsWith('BUCK?') && Object.keys(params).length > 0) {
      const urlObj = new URL(url);
      Object.entries(params).forEach(([key, value]) => {
        urlObj.searchParams.set(key, String(value));
      });
      url = urlObj.toString();
    }
 
    const headers: HeadersInit = {
      'Accept': '*/*',
      'Cache-Control': 'no-cache',
    };
 
    // Add authentication if available
    if (this.apiKey) {
      headers['Cookie'] = `FieldpineApiKey=${this.apiKey}`;
    }
 
    try {
      console.log('POS API Request:', url);
      
      const response = await fetch(url, {
        method: 'GET',
        headers,
      });
 
      if (!response.ok) {
        return {
          error: `HTTP ${response.status}: ${response.statusText}`,
          status: 'error'
        };
      }
 
      // Try to parse as JSON, fallback to text
      const contentType = response.headers.get('content-type');
      let data: any;
      
      if (contentType && contentType.includes('application/json')) {
        data = await response.json();
      } else {
        data = await response.text();
      }
 
      return {
        data,
        status: 'success'
      };
    } catch (error) {
      return {
        error: error instanceof Error ? error.message : 'Unknown error',
        status: 'error'
      };
    }
  }
 
  // POS-specific API methods based on discovered endpoints
 
  /**
   * Get retail configuration
   * /openapi/retailconfig
   */
  async getRetailConfig(): Promise<POSApiResponse<RetailConfig>> {
    return this.posRequest('retailconfig');
  }
 
  /**
   * Get a specific page
   * /openapi/page?key=/report/rr/sell5.htm
   */
  async getPage(pageKey: string): Promise<POSApiResponse> {
    return this.posRequest(`page?key=${encodeURIComponent(pageKey)}`);
  }
 
  /**
   * Get sale list template
   * /openapi/salelist1.htm
   */
  async getSaleListTemplate(): Promise<POSApiResponse> {
    return this.posRequest('salelist1.htm');
  }
 
  /**
   * Get sale header template
   * /openapi/saleheader1.htm
   */
  async getSaleHeaderTemplate(): Promise<POSApiResponse> {
    return this.posRequest('saleheader1.htm');
  }
 
  /**
   * Get payment single template
   * /openapi/paymentsingle.htm
   */
  async getPaymentSingleTemplate(): Promise<POSApiResponse> {
    return this.posRequest('paymentsingle.htm');
  }
 
  /**
   * Get payment types
   * /openapi/PaymentTypes
   */
  async getPaymentTypes(): Promise<POSApiResponse> {
    return this.posRequest('PaymentTypes');
  }
 
  /**
   * Search products using BUCK API
   * BUCK?3=retailmax.elink.products.list&8=30&9=f506,8,searchterm
   */
  async searchProducts(searchTerm: string, limit = 30): Promise<POSApiResponse<ProductSearchResult[]>> {
    const query = `BUCK?3=retailmax.elink.products.list&8=${limit}&9=f506,8,${encodeURIComponent(searchTerm)}`;
    return this.posRequest(query);
  }
 
  /**
   * Get product by ID or barcode
   */
  async getProduct(idOrBarcode: string): Promise<POSApiResponse<ProductSearchResult>> {
    // Try exact match first
    const result = await this.searchProducts(idOrBarcode, 1);
    
    if (result.data && Array.isArray(result.data) && result.data.length > 0) {
      return {
        data: result.data[0],
        status: 'success'
      };
    }
    
    return {
      error: 'Product not found',
      status: 'error'
    };
  }
 
  /**
   * Get all products with pagination
   */
  async getAllProducts(limit = 100, offset = 0): Promise<POSApiResponse<ProductSearchResult[]>> {
    // Use empty search to get all products
    return this.searchProducts('', limit);
  }
 
  /**
   * Submit a sale (this would need to be implemented based on actual POS API)
   */
  async submitSale(saleData: {
    items: Array<{
      productId: string;
      quantity: number;
      price: number;
    }>;
    payment: {
      type: string;
      amount: number;
    };
    customer?: {
      id?: string;
      name?: string;
    };
  }): Promise<POSApiResponse> {
    // This is a placeholder - would need to discover the actual sale submission endpoint
    console.log('Sale submission not yet implemented. Sale data:', saleData);
    return {
      error: 'Sale submission endpoint not yet discovered',
      status: 'error'
    };
  }
 
  /**
   * Get specific item by ID (for barcode scanning)
   */
  async getItem(itemId: string): Promise<POSApiResponse> {
    return this.posRequest(itemId);
  }
}
 
// Store-specific API instances
export const cwaPosMurwillumbah = new CWAPosApi('https://murwillumbah.cwanz.online');
export const cwaPosIig = new CWAPosApi('https://iig.cwanz.online');
export const cwaPosCowra = new CWAPosApi('https://cowra.cwanz.online');
 
// Default POS API instance (Murwillumbah)
export const cwaPosApi = cwaPosMurwillumbah;
 
// Helper function to set API key for all POS instances
export function setCWAPosApiKey(apiKey: string) {
  cwaPosMurwillumbah.setApiKey(apiKey);
  cwaPosIig.setApiKey(apiKey);
  cwaPosCowra.setApiKey(apiKey);
}
 
// Helper function to get POS API for specific store
export function getCWAPosApi(storeUrl: string): CWAPosApi {
  switch (storeUrl) {
    case 'https://murwillumbah.cwanz.online':
      return cwaPosMurwillumbah;
    case 'https://iig.cwanz.online':
      return cwaPosIig;
    case 'https://cowra.cwanz.online':
      return cwaPosCowra;
    default:
      return new CWAPosApi(storeUrl);
  }
}