47 lines
1.6 KiB
JavaScript
47 lines
1.6 KiB
JavaScript
|
'use strict';
|
||
|
|
|
||
|
|
const { getConfig, setError, setSuccess, clearStatus, pickMsgField } = require('../lib/utils');
|
||
|
|
const { transformStructure } = require('../lib/collabora');
|
||
|
|
const { loadSourceBuffer } = require('../lib/bridge');
|
||
|
|
|
||
|
|
module.exports = function (RED) {
|
||
|
|
function CollaboraTransformNode(config) {
|
||
|
|
RED.nodes.createNode(this, config);
|
||
|
|
const node = this;
|
||
|
|
node.configNode = RED.nodes.getNode(config.config);
|
||
|
|
|
||
|
|
node.on('input', async (msg, send, done) => {
|
||
|
|
send = send || function () { node.send.apply(node, arguments); };
|
||
|
|
done = done || function (err) { if (err) { node.error(err, msg); } };
|
||
|
|
clearStatus(node);
|
||
|
|
|
||
|
|
try {
|
||
|
|
const cfg = getConfig(node);
|
||
|
|
const transform = pickMsgField(msg, 'transform') || msg.fields;
|
||
|
|
if (!transform) {
|
||
|
|
throw new Error('Ange msg.transform eller msg.fields');
|
||
|
|
}
|
||
|
|
|
||
|
|
const source = await loadSourceBuffer(cfg, msg);
|
||
|
|
const result = await transformStructure(cfg, {
|
||
|
|
buffer: source.buffer,
|
||
|
|
filename: source.filename,
|
||
|
|
transform
|
||
|
|
});
|
||
|
|
|
||
|
|
msg.payload = result.buffer;
|
||
|
|
msg.contentType = result.contentType;
|
||
|
|
setSuccess(node, msg, 'transform');
|
||
|
|
send(msg);
|
||
|
|
done();
|
||
|
|
} catch (err) {
|
||
|
|
setError(node, msg, err);
|
||
|
|
send(msg);
|
||
|
|
done(err);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
RED.nodes.registerType('collabora-transform', CollaboraTransformNode);
|
||
|
|
};
|