#!/usr/bin/env node /** * Supplyline DAM Client * * Fetches parsed documents and images from the DAM (Digital Asset Management) system. * * Usage: * node scripts/dam-client.js fetch [--local] * node scripts/dam-client.js lookup [--local] * node scripts/dam-client.js metadata [--local] * node scripts/dam-client.js status [--local] * * Environment: * DAM_BASE_URL - Override the DAM base URL */ const fs = require('fs'); const path = require('path'); const https = require('https'); const http = require('http'); // Load config const CONFIG_PATH = path.join(__dirname, '..', 'dam.config.json'); let config = {}; try { config = JSON.parse(fs.readFileSync(CONFIG_PATH, 'utf-8')); } catch (err) { console.error('Warning: Could not load dam.config.json:', err.message); } /** * DAM API Client */ class DAMClient { constructor(baseUrl, apiKey) { this.baseUrl = baseUrl || process.env.DAM_BASE_URL || config.dam?.baseUrl; this.apiKey = apiKey || process.env.DAM_API_KEY || config.dam?.apiKey; if (!this.baseUrl) { throw new Error('DAM base URL not configured. Set DAM_BASE_URL or update dam.config.json'); } // Note: API key not required yet but will be needed for production } /** * Make an HTTP request to the DAM API */ async request(method, endpoint, options = {}) { const url = new URL(endpoint, this.baseUrl); const isHttps = url.protocol === 'https:'; const httpModule = isHttps ? https : http; // Build headers, including API key if configured const headers = { ...options.headers }; if (this.apiKey) { headers['Authorization'] = `Bearer ${this.apiKey}`; } return new Promise((resolve, reject) => { const req = httpModule.request(url, { method, headers, }, (res) => { const chunks = []; res.on('data', chunk => chunks.push(chunk)); res.on('end', () => { const body = Buffer.concat(chunks); if (options.raw) { resolve({ status: res.statusCode, headers: res.headers, body }); } else { try { const json = JSON.parse(body.toString()); resolve({ status: res.statusCode, data: json }); } catch { resolve({ status: res.statusCode, body: body.toString() }); } } }); }); req.on('error', reject); if (options.body) { req.write(options.body); } req.end(); }); } /** * Get asset details by SHA-256 hash */ async getAsset(sha256) { const res = await this.request('GET', `/assets/${sha256}`); if (res.status !== 200) { throw new Error(`Failed to get asset: ${res.data?.error || res.status}`); } return res.data.asset; } /** * Get a specific derivative (markdown or image) * @param {string} sha256 - Asset hash * @param {string} kind - Derivative kind (doc_md, doc_image, etc.) * @param {string} [pipelineVersion] - Pipeline version * @param {string} [imagePath] - For doc_image, the specific image path from manifest */ async getDerivative(sha256, kind, pipelineVersion, imagePath) { // supplyline-sync uses /derivative/ (singular), old DAM used /derivatives/ let endpoint = `/assets/${sha256}/derivative/${kind}`; const params = []; if (pipelineVersion) { params.push(`v=${pipelineVersion}`); } if (imagePath) { params.push(`path=${encodeURIComponent(imagePath)}`); } if (params.length > 0) { endpoint += `?${params.join('&')}`; } const res = await this.request('GET', endpoint, { raw: true }); if (res.status !== 200) { throw new Error(`Failed to get derivative: ${res.status}`); } return { contentType: res.headers['content-type'], body: res.body }; } /** * Get markdown content via the /content endpoint (supplyline-sync) * This is a higher-level endpoint that returns parsed markdown */ async getContent(sha256, section) { let endpoint = `/assets/${sha256}/content`; if (section) { endpoint += `?section=${section}`; } const res = await this.request('GET', endpoint); if (res.status !== 200) { throw new Error(`Failed to get content: ${res.data?.error || res.status}`); } return res.data; } /** * Get job status */ async getJobStatus(runId) { const res = await this.request('GET', `/jobs/${runId}`); if (res.status !== 200) { throw new Error(`Failed to get job status: ${res.data?.error || res.status}`); } return res.data.job; } /** * Trigger document processing */ async processJob(runId) { const res = await this.request('POST', `/jobs/${runId}/process`); if (res.status !== 200) { throw new Error(`Failed to process job: ${res.data?.error || res.status}`); } return res.data.job; } /** * Get the manifest for a specific pipeline version * The manifest contains the authoritative list of derivatives with their paths */ async getManifest(sha256, pipelineVersion) { const res = await this.request('GET', `/assets/${sha256}/manifest?v=${pipelineVersion}`); if (res.status === 404) { // Manifest endpoint doesn't exist for this asset return null; } if (res.status !== 200) { throw new Error(`Failed to get manifest: ${res.data?.error || res.status}`); } return res.data; } /** * Lookup asset by external source ID (e.g., Plytix) * @param {string} sourceType - Source system type (e.g., 'plytix') * @param {string} sourceId - ID in the source system * @returns {Promise<{sha256: string, asset: object}>} */ async lookupBySource(sourceType, sourceId) { const res = await this.request('GET', `/assets/by-source?source_type=${sourceType}&source_id=${sourceId}`); if (res.status !== 200) { throw new Error(`Asset not found for ${sourceType}:${sourceId}`); } return res.data; } /** * Get AI-extracted metadata for an asset * @param {string} sha256 - Asset hash * @returns {Promise

Problem	Possible Cause	Solution
Pump won’t prime	Air leak in suction line	Check all connections
Low output	Worn diaphragm	Replace diaphragm
Erratic flow	Debris in valves	Clean valve cartridges

Get Started

Product Support

​TD Series Troubleshooting

​Common Issues

TD Series Troubleshooting

Common Issues