Rozwiązania,
które napędzają Twój biznes

// api-connect.js — Mateflow Integration Module import axios from 'axios'; import { logger } from './utils/logger'; const API_BASE = 'https://api.example.com/v1'; const TIMEOUT = 5000; const MAX_RETRY = 3; /** * Core connector — handles auth, retries & error mapping */ async function connectAPI(endpoint, payload, retries = 0) { const headers = { 'Content-Type': 'application/json', 'Authorization': `Bearer ${process.env.API_KEY}`, 'X-Client-ID': 'mateflow-integration', 'X-Request-ID': crypto.randomUUID(), }; try { const { data, status } = await axios.post( `${API_BASE}/${endpoint}`, payload, { headers, timeout: TIMEOUT } ); logger.info(`[API] ${endpoint} → ${status}`); return { success: true, data }; } catch (err) { if (err.response?.status >= 500 && retries < MAX_RETRY) { await sleep(300 * (2 ** retries)); return connectAPI(endpoint, payload, retries + 1); } logger.error(`[API] Failed: ${err.message}`); return { success: false, error: err.message }; } } // ── WooCommerce order sync ────────────────────────── async function syncOrder(orderId) { const order = await fetchOrder(orderId); const result = await connectAPI('orders/sync', { id: order.id, status: order.status, items: order.line_items.map(i => ({ sku: i.sku, qty: i.quantity, price: i.price, })), }); if (result.success) { await updateLocalCache(orderId, result.data); } return result; } // ── Webhook dispatcher ────────────────────────────── const webhookHandler = async (req, res) => { const { event, data } = req.body; const handlers = { 'order.created': () => syncOrder(data.id), 'product.updated': () => updateInventory(data.sku, data.stock), 'customer.signup': () => enrollCRM(data.email, data.name), 'invoice.paid': () => triggerFulfillment(data.invoice_id), }; const fn = handlers[event]; if (fn) { await fn(); logger.info(`[Webhook] ${event} handled`); } else { logger.warn(`[Webhook] Unknown event: ${event}`); } res.status(200).json({ received: true, event }); }; // ── Inventory bridge ──────────────────────────────── async function updateInventory(sku, stock) { const [woo, erp] = await Promise.all([ connectAPI('inventory/woo', { sku, stock }), connectAPI('inventory/erp', { sku, qty: stock }), ]); return { woo: woo.success, erp: erp.success }; } module.exports = { connectAPI, syncOrder, webhookHandler, updateInventory, }; // ─────────────────────────────────────────────────── // api-connect.js — Mateflow Integration Module import axios from 'axios'; import { logger } from './utils/logger'; const API_BASE = 'https://api.example.com/v1'; const TIMEOUT = 5000; const MAX_RETRY = 3; async function connectAPI(endpoint, payload, retries = 0) { const headers = { 'Content-Type': 'application/json', 'Authorization': `Bearer ${process.env.API_KEY}`, 'X-Client-ID': 'mateflow-integration', 'X-Request-ID': crypto.randomUUID(), }; try { const { data, status } = await axios.post( `${API_BASE}/${endpoint}`, payload, { headers, timeout: TIMEOUT } ); return { success: true, data }; } catch (err) { return { success: false, error: err.message }; } }