/** * @node image * @name Image * @category image * @version 1.0.0 * @description Extract image information, metadata, and EXIF data using ImageMagick * @icon image */ const configSchema = { type: 'object', properties: { operation: { type: 'string', title: 'Operation', enum: ['info', 'resize', 'crop', 'rotate', 'filter', 'convert'], enumLabels: ['Info', 'Resize', 'Crop', 'Rotate', 'Filter', 'Convert Format'], default: 'info', description: 'Image operation to perform' }, inputSource: { type: 'string', title: 'Input Source', enum: ['auto', 'base64', 'filePath', 'url', 'storage'], enumLabels: ['Auto-detect', 'Base64 Data', 'File Path', 'URL', 'Storage Reference'], default: 'auto', description: 'Source type for the input image' }, base64Data: { type: 'string', title: 'Base64 Image Data', description: 'Base64-encoded image data. Supports {{variable}} interpolation.', showWhen: { field: 'inputSource', value: 'base64' } }, filePath: { type: 'string', title: 'File Path', description: 'Path to image file on runner filesystem. Supports {{variable}} interpolation.', showWhen: { field: 'inputSource', value: 'filePath' } }, url: { type: 'string', title: 'Image URL', description: 'URL to download image from. Supports {{variable}} interpolation.', showWhen: { field: 'inputSource', value: 'url' } }, storageCollection: { type: 'string', title: 'Storage Collection', description: 'Collection name for stored image', showWhen: { field: 'inputSource', value: 'storage' } }, storageId: { type: 'string', title: 'Storage Document ID', description: 'Document ID in storage collection. Supports {{variable}} interpolation.', showWhen: { field: 'inputSource', value: 'storage' } }, includeExif: { type: 'boolean', title: 'Include EXIF Metadata', default: true, description: 'Extract EXIF metadata (camera info, GPS, date taken, etc.)', showWhen: { field: 'operation', value: 'info' } }, timeout: { type: 'number', title: 'Timeout (ms)', default: 30000, minimum: 1000, maximum: 120000, description: 'Maximum time to wait for image processing' } }, required: ['operation'] }; const inputSchema = { type: 'object', properties: { data: { type: 'any', description: 'Input data. Can be base64 string, file path, URL, or binary object from another node.' }, file: { type: 'object', description: 'Binary file object with type, data (base64), mimeType, filename' }, storage: { type: 'object', description: 'Storage reference with collection and id' }, base64: { type: 'string', description: 'Base64-encoded image data' }, filePath: { type: 'string', description: 'Override file path from input' }, url: { type: 'string', description: 'Override URL from input' } } }; const outputSchema = { type: 'object', properties: { width: { type: 'number', description: 'Image width in pixels' }, height: { type: 'number', description: 'Image height in pixels' }, format: { type: 'string', description: 'Image format (JPEG, PNG, GIF, etc.)' }, colorSpace: { type: 'string', description: 'Color space (sRGB, CMYK, Grayscale, etc.)' }, depth: { type: 'number', description: 'Bit depth per channel' }, fileSize: { type: 'number', description: 'File size in bytes' }, dpi: { type: 'object', description: 'DPI/resolution information', properties: { x: { type: 'number' }, y: { type: 'number' }, unit: { type: 'string' } } }, hasAlpha: { type: 'boolean', description: 'Whether image has alpha/transparency channel' }, compression: { type: 'string', description: 'Compression type used' }, exif: { type: 'object', description: 'EXIF metadata (if available)', properties: { camera: { type: 'object', properties: { make: { type: 'string' }, model: { type: 'string' }, software: { type: 'string' } } }, datetime: { type: 'object', properties: { original: { type: 'string' }, digitized: { type: 'string' }, modified: { type: 'string' } } }, gps: { type: 'object', properties: { latitude: { type: 'number' }, longitude: { type: 'number' }, altitude: { type: 'number' }, latitudeRef: { type: 'string' }, longitudeRef: { type: 'string' } } }, exposure: { type: 'object', properties: { time: { type: 'string' }, fNumber: { type: 'number' }, iso: { type: 'number' }, program: { type: 'string' }, bias: { type: 'string' } } }, lens: { type: 'object', properties: { focalLength: { type: 'string' }, focalLength35mm: { type: 'number' }, aperture: { type: 'number' }, make: { type: 'string' }, model: { type: 'string' } } }, orientation: { type: 'number' }, flash: { type: 'string' }, whiteBalance: { type: 'string' }, meteringMode: { type: 'string' } } }, sourceType: { type: 'string', description: 'Source type used (base64, filePath, url, storage)' }, sourcePath: { type: 'string', description: 'Temporary file path used for processing' } } }; function interpolate(template, data) { if (typeof template !== 'string') return template; return template.replace(/\{\{([^}]+)\}\}/g, function(match, key) { var keys = key.trim().split('.'); var value = data; for (var i = 0; i < keys.length; i++) { if (value && typeof value === 'object' && keys[i] in value) { value = value[keys[i]]; } else { return match; } } return value !== undefined ? String(value) : match; }); } function generateTempPath(extension) { var uuid = smartbotic.utils.uuid(); return '/tmp/smartbotic-image-' + uuid + (extension ? '.' + extension : ''); } function detectImageFormat(base64Data) { if (!base64Data || base64Data.length < 8) return null; var header = smartbotic.utils.base64Decode(base64Data.substring(0, 16)); if (!header) return null; if (header.charCodeAt(0) === 0xFF && header.charCodeAt(1) === 0xD8 && header.charCodeAt(2) === 0xFF) { return 'jpg'; } if (header.substring(0, 8) === '\x89PNG\r\n\x1a\n') { return 'png'; } if (header.substring(0, 6) === 'GIF87a' || header.substring(0, 6) === 'GIF89a') { return 'gif'; } if (header.substring(0, 4) === 'RIFF' && header.substring(8, 12) === 'WEBP') { return 'webp'; } if (header.substring(0, 2) === 'BM') { return 'bmp'; } if (header.substring(0, 4) === 'II*\x00' || header.substring(0, 4) === 'MM\x00*') { return 'tiff'; } return null; } function resolveImageInput(config, input) { var inputSource = config.inputSource || 'auto'; var result = { type: null, data: null, path: null, tempPath: null }; if (inputSource === 'filePath' || (inputSource === 'auto' && input.filePath)) { var filePath = input.filePath || interpolate(config.filePath, input); if (filePath && smartbotic.fs.exists(filePath)) { result.type = 'filePath'; result.path = filePath; return result; } } if (inputSource === 'base64' || (inputSource === 'auto' && (input.base64 || config.base64Data))) { var base64 = input.base64 || interpolate(config.base64Data, input); if (base64) { result.type = 'base64'; result.data = base64; return result; } } if (inputSource === 'url' || (inputSource === 'auto' && (input.url || config.url))) { var url = input.url || interpolate(config.url, input); if (url) { result.type = 'url'; result.data = url; return result; } } if (inputSource === 'storage' || (inputSource === 'auto' && input.storage)) { var collection = input.storage ? input.storage.collection : config.storageCollection; var id = input.storage ? input.storage.id : interpolate(config.storageId, input); if (collection && id) { result.type = 'storage'; result.data = { collection: collection, id: id }; return result; } } if (inputSource === 'auto') { if (input.file && input.file.type === 'binary' && input.file.data) { result.type = 'base64'; result.data = input.file.data; return result; } if (typeof input.data === 'string') { if (input.data.match(/^[A-Za-z0-9+/]+=*$/) && input.data.length > 100) { result.type = 'base64'; result.data = input.data; return result; } if (input.data.startsWith('http://') || input.data.startsWith('https://')) { result.type = 'url'; result.data = input.data; return result; } if (smartbotic.fs.exists(input.data)) { result.type = 'filePath'; result.path = input.data; return result; } } if (input.data && typeof input.data === 'object') { if (input.data.type === 'binary' && input.data.data) { result.type = 'base64'; result.data = input.data.data; return result; } if (input.data.collection && input.data.id) { result.type = 'storage'; result.data = input.data; return result; } } } return result; } function prepareImageFile(imageInput, timeout) { var tempPath = null; if (imageInput.type === 'filePath') { return { path: imageInput.path, tempPath: null }; } if (imageInput.type === 'base64') { var ext = detectImageFormat(imageInput.data) || 'img'; tempPath = generateTempPath(ext); var writeResult = smartbotic.fs.writeFile(tempPath, imageInput.data, 'base64'); if (!writeResult.success) { throw new Error('Failed to write temp file: ' + (writeResult.error || 'Unknown error')); } return { path: tempPath, tempPath: tempPath }; } if (imageInput.type === 'url') { smartbotic.log.info('Downloading image from URL: ' + imageInput.data); var response = smartbotic.http.request({ method: 'GET', url: imageInput.data, timeout: timeout }); if (response.status < 200 || response.status >= 300) { throw new Error('Failed to download image: HTTP ' + response.status); } var contentType = response.headers['content-type'] || ''; var ext = 'img'; if (contentType.includes('jpeg') || contentType.includes('jpg')) ext = 'jpg'; else if (contentType.includes('png')) ext = 'png'; else if (contentType.includes('gif')) ext = 'gif'; else if (contentType.includes('webp')) ext = 'webp'; tempPath = generateTempPath(ext); var base64Data = smartbotic.utils.base64Encode(response.data); var writeResult = smartbotic.fs.writeFile(tempPath, base64Data, 'base64'); if (!writeResult.success) { throw new Error('Failed to write downloaded image: ' + (writeResult.error || 'Unknown error')); } return { path: tempPath, tempPath: tempPath }; } if (imageInput.type === 'storage') { var storageResult = smartbotic.storage.get(imageInput.data.collection, imageInput.data.id); if (!storageResult.found) { throw new Error('Image not found in storage: ' + imageInput.data.collection + '/' + imageInput.data.id); } var doc = storageResult.document; var base64Data = doc.data || doc.content || doc.base64; if (!base64Data) { throw new Error('Storage document does not contain image data'); } var ext = detectImageFormat(base64Data) || 'img'; tempPath = generateTempPath(ext); var writeResult = smartbotic.fs.writeFile(tempPath, base64Data, 'base64'); if (!writeResult.success) { throw new Error('Failed to write storage image: ' + (writeResult.error || 'Unknown error')); } return { path: tempPath, tempPath: tempPath }; } throw new Error('No valid image input found'); } function cleanupTempFile(tempPath) { if (tempPath) { try { smartbotic.fs.unlink(tempPath); } catch (e) { smartbotic.log.warn('Failed to cleanup temp file: ' + tempPath); } } } function parseImageMagickInfo(output) { var info = {}; var lines = output.split('\n'); for (var i = 0; i < lines.length; i++) { var line = lines[i].trim(); if (!line) continue; var colonIdx = line.indexOf(':'); if (colonIdx > 0) { var key = line.substring(0, colonIdx).trim().toLowerCase(); var value = line.substring(colonIdx + 1).trim(); if (key === 'image' || key === 'format') { var formatMatch = value.match(/^(\w+)/); if (formatMatch) info.format = formatMatch[1].toUpperCase(); } else if (key === 'geometry' || key === 'page geometry') { var geomMatch = value.match(/(\d+)x(\d+)/); if (geomMatch) { info.width = parseInt(geomMatch[1], 10); info.height = parseInt(geomMatch[2], 10); } } else if (key === 'colorspace') { info.colorSpace = value; } else if (key === 'depth') { var depthMatch = value.match(/(\d+)/); if (depthMatch) info.depth = parseInt(depthMatch[1], 10); } else if (key === 'channel depth' || key === 'channels') { if (value.toLowerCase().includes('alpha')) { info.hasAlpha = true; } } else if (key === 'alpha') { info.hasAlpha = value.toLowerCase() !== 'undefined' && value.toLowerCase() !== 'off'; } else if (key === 'compression') { info.compression = value; } else if (key === 'resolution' || key === 'units') { if (!info.dpi) info.dpi = {}; var resMatch = value.match(/([\d.]+)x([\d.]+)/); if (resMatch) { info.dpi.x = parseFloat(resMatch[1]); info.dpi.y = parseFloat(resMatch[2]); } if (value.includes('PixelsPerInch')) info.dpi.unit = 'dpi'; else if (value.includes('PixelsPerCentimeter')) info.dpi.unit = 'dpcm'; } else if (key === 'filesize') { var sizeMatch = value.match(/([\d.]+)\s*(\w+)/); if (sizeMatch) { var size = parseFloat(sizeMatch[1]); var unit = sizeMatch[2].toUpperCase(); if (unit === 'B') info.fileSize = Math.round(size); else if (unit === 'KB' || unit === 'KIB') info.fileSize = Math.round(size * 1024); else if (unit === 'MB' || unit === 'MIB') info.fileSize = Math.round(size * 1024 * 1024); else if (unit === 'GB' || unit === 'GIB') info.fileSize = Math.round(size * 1024 * 1024 * 1024); } } } } if (info.hasAlpha === undefined) info.hasAlpha = false; return info; } function parseExifToolOutput(output) { var exif = { camera: {}, datetime: {}, gps: {}, exposure: {}, lens: {} }; var lines = output.split('\n'); for (var i = 0; i < lines.length; i++) { var line = lines[i].trim(); if (!line) continue; var colonIdx = line.indexOf(':'); if (colonIdx <= 0) continue; var key = line.substring(0, colonIdx).trim().toLowerCase().replace(/\s+/g, ''); var value = line.substring(colonIdx + 1).trim(); if (!value || value === '-' || value === 'n/a') continue; if (key === 'make' || key === 'cameramake') exif.camera.make = value; else if (key === 'model' || key === 'cameramodel' || key === 'cameramodelname') exif.camera.model = value; else if (key === 'software') exif.camera.software = value; else if (key === 'datetimeoriginal' || key === 'createdate') exif.datetime.original = value; else if (key === 'datetimedigitized' || key === 'digitizeddate') exif.datetime.digitized = value; else if (key === 'modifydate' || key === 'datetime') exif.datetime.modified = value; else if (key === 'gpslatitude') { var latMatch = value.match(/([\d.]+)/); if (latMatch) { exif.gps.latitude = parseFloat(latMatch[1]); if (value.includes('S')) exif.gps.latitude = -exif.gps.latitude; exif.gps.latitudeRef = value.includes('S') ? 'S' : 'N'; } } else if (key === 'gpslongitude') { var lonMatch = value.match(/([\d.]+)/); if (lonMatch) { exif.gps.longitude = parseFloat(lonMatch[1]); if (value.includes('W')) exif.gps.longitude = -exif.gps.longitude; exif.gps.longitudeRef = value.includes('W') ? 'W' : 'E'; } } else if (key === 'gpsaltitude') { var altMatch = value.match(/([\d.]+)/); if (altMatch) exif.gps.altitude = parseFloat(altMatch[1]); } else if (key === 'exposuretime' || key === 'shutterspeed') exif.exposure.time = value; else if (key === 'fnumber' || key === 'aperture') { var fMatch = value.match(/([\d.]+)/); if (fMatch) exif.exposure.fNumber = parseFloat(fMatch[1]); } else if (key === 'iso' || key === 'isospeedratings') { var isoMatch = value.match(/(\d+)/); if (isoMatch) exif.exposure.iso = parseInt(isoMatch[1], 10); } else if (key === 'exposureprogram') exif.exposure.program = value; else if (key === 'exposurecompensation' || key === 'exposurebias') exif.exposure.bias = value; else if (key === 'focallength') exif.lens.focalLength = value; else if (key === 'focallengthin35mmformat' || key === 'focallength35efl') { var fl35Match = value.match(/(\d+)/); if (fl35Match) exif.lens.focalLength35mm = parseInt(fl35Match[1], 10); } else if (key === 'maxaperturevalue') { var apMatch = value.match(/([\d.]+)/); if (apMatch) exif.lens.aperture = parseFloat(apMatch[1]); } else if (key === 'lensmake') exif.lens.make = value; else if (key === 'lensmodel' || key === 'lens') exif.lens.model = value; else if (key === 'orientation') { var oriMatch = value.match(/(\d)/); if (oriMatch) exif.orientation = parseInt(oriMatch[1], 10); } else if (key === 'flash') exif.flash = value; else if (key === 'whitebalance') exif.whiteBalance = value; else if (key === 'meteringmode') exif.meteringMode = value; } var hasData = false; for (var section in exif) { if (typeof exif[section] === 'object') { for (var field in exif[section]) { if (exif[section][field] !== undefined) { hasData = true; break; } } } else if (exif[section] !== undefined) { hasData = true; } if (hasData) break; } return hasData ? exif : null; } function executeInfoOperation(imagePath, includeExif, timeout) { smartbotic.log.info('Running ImageMagick identify on: ' + imagePath); var identifyCmd = 'identify -verbose "' + imagePath.replace(/"/g, '\\"') + '"'; var identifyResult = smartbotic.process.exec(identifyCmd, { timeout: timeout }); if (!identifyResult.success) { throw new Error('ImageMagick identify failed: ' + (identifyResult.stderr || 'Unknown error')); } var info = parseImageMagickInfo(identifyResult.stdout); var stat = smartbotic.fs.stat(imagePath); if (stat.success && !info.fileSize) { info.fileSize = stat.size; } if (includeExif) { smartbotic.log.info('Extracting EXIF metadata'); var exiftoolCmd = 'exiftool "' + imagePath.replace(/"/g, '\\"') + '"'; var exifResult = smartbotic.process.exec(exiftoolCmd, { timeout: timeout }); if (exifResult.success && exifResult.stdout) { var exifData = parseExifToolOutput(exifResult.stdout); if (exifData) { info.exif = exifData; } } else { smartbotic.log.debug('No EXIF data available or exiftool not installed'); } } return info; } async function execute(config, input, context) { var operation = config.operation || 'info'; var timeout = config.timeout || 30000; if (operation !== 'info') { throw new Error('Operation "' + operation + '" is not yet implemented. Only "info" is available in this version.'); } var imageInput = resolveImageInput(config, input); if (!imageInput.type) { throw new Error('No valid image input found. Provide base64 data, file path, URL, or storage reference.'); } smartbotic.log.info('Image input source: ' + imageInput.type); var fileInfo = null; try { fileInfo = prepareImageFile(imageInput, timeout); smartbotic.log.info('Processing image: ' + fileInfo.path); var result = executeInfoOperation(fileInfo.path, config.includeExif !== false, timeout); result.sourceType = imageInput.type; result.sourcePath = fileInfo.path; return result; } finally { if (fileInfo && fileInfo.tempPath) { cleanupTempFile(fileInfo.tempPath); } } } module.exports = { configSchema, inputSchema, outputSchema, execute };