#!/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

Get Started

Product Support

Page Not Found