nsrb
049f5c56e3
- Introduced compileWorkflowScripts function to parse and validate workflow scripts, supporting both linear and DAG execution modes. - Added runLinearSteps and runDagSteps functions for executing compiled workflows based on their structure. - Updated createRegistry function to utilize the new workflow compilation and execution logic. - Enhanced script sandbox with meta extraction and instantiation capabilities for better script management. - Improved API endpoints to return script metadata and handle errors more effectively. - Removed deprecated scripts and updated workflows to reflect new structure and functionality.
97 lines
2.8 KiB
JavaScript
97 lines
2.8 KiB
JavaScript
function ensureDataObject(ctx) {
|
|
if (ctx.data == null || typeof ctx.data !== "object" || Array.isArray(ctx.data)) {
|
|
ctx.data = {};
|
|
}
|
|
}
|
|
|
|
function filenameFromUrl(url) {
|
|
try {
|
|
const name = new URL(url).pathname.split("/").filter(Boolean).pop();
|
|
return name || "attachment";
|
|
} catch {
|
|
return "attachment";
|
|
}
|
|
}
|
|
|
|
function resolveUrl(ctx) {
|
|
const fromConfig = ctx.config?.url;
|
|
if (typeof fromConfig === "string" && fromConfig.length > 0) {
|
|
return fromConfig;
|
|
}
|
|
|
|
const urlVar = ctx.config?.urlVar;
|
|
if (typeof urlVar === "string" && urlVar.length > 0) {
|
|
const value = ctx.data?.[urlVar];
|
|
if (typeof value === "string" && value.length > 0) {
|
|
return value;
|
|
}
|
|
}
|
|
|
|
for (const key of ["attach", "url"]) {
|
|
const value = ctx.data?.[key];
|
|
if (typeof value === "string" && value.length > 0) {
|
|
return value;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
async function fetchBinary(ctx) {
|
|
ensureDataObject(ctx);
|
|
|
|
const url = resolveUrl(ctx);
|
|
if (!url) {
|
|
throw new Error(
|
|
"fetch-binary: url is required (ctx.config.url, ctx.config.urlVar, ctx.data.attach, or ctx.data.url)",
|
|
);
|
|
}
|
|
|
|
const outputVar = typeof ctx.config?.outputVar === "string" && ctx.config.outputVar.length > 0
|
|
? ctx.config.outputVar
|
|
: "file";
|
|
|
|
log.info({ url, outputVar }, "fetch-binary: fetching");
|
|
const response = await $axios.get(url, { responseType: "arraybuffer" });
|
|
const file = Buffer.from(response.data ?? []);
|
|
const contentType = String(response.headers?.["content-type"] ?? "application/octet-stream");
|
|
const filename = ctx.config?.filename || ctx.data.filename || filenameFromUrl(url);
|
|
|
|
ctx.data[outputVar] = file;
|
|
ctx.data.filename = filename;
|
|
ctx.data.contentType = contentType;
|
|
|
|
log.info(
|
|
{ outputVar, filename, contentType, length: file.length },
|
|
"fetch-binary: saved",
|
|
);
|
|
|
|
return ctx;
|
|
}
|
|
|
|
fetchBinary.meta = {
|
|
description: "Download a binary URL into ctx.data as a Buffer",
|
|
config: {
|
|
url: { type: "string", required: false, description: "Direct download URL" },
|
|
urlVar: { type: "string", required: false, description: "Key in ctx.data that holds the URL" },
|
|
outputVar: { type: "string", default: "file", description: "ctx.data key for the Buffer" },
|
|
filename: { type: "string", required: false, description: "Override saved filename" },
|
|
},
|
|
input: {
|
|
attach: { type: "string", required: false, description: "Fallback URL" },
|
|
url: { type: "string", required: false, description: "Fallback URL" },
|
|
filename: { type: "string", required: false },
|
|
},
|
|
output: {
|
|
file: { type: "buffer", description: "Downloaded bytes (or ctx.config.outputVar)" },
|
|
filename: { type: "string" },
|
|
contentType: { type: "string" },
|
|
},
|
|
example: {
|
|
data: { attach: "https://example.com/image.png" },
|
|
config: { outputVar: "file" },
|
|
},
|
|
};
|
|
|
|
export default fetchBinary;
|