25 lines
No EOL
1.1 KiB
JavaScript
25 lines
No EOL
1.1 KiB
JavaScript
const { GristDocAPI } = require('grist-api');
|
|
|
|
module.exports = function (RED) {
|
|
function SyncTableNode(config) {
|
|
RED.nodes.createNode(this, config);
|
|
let node = this;
|
|
this.document = RED.nodes.getNode(config.document);
|
|
this.server = RED.nodes.getNode(config.server);
|
|
this.table = config.tableId;
|
|
this.primaryKey = config.primaryKey;
|
|
|
|
node.on('input', async function (msg, send, done) {
|
|
const protocol = this.server.tlsEnabled === true ? "https" : "http";
|
|
const url = protocol + "://" + this.server.hostname + ":" + this.server.port;
|
|
const api = new GristDocAPI(this.document.docid, { apiKey: this.server.apiKey, server: url });
|
|
const data = Array.isArray(msg.payload) ? msg.payload : [msg.payload]
|
|
|
|
api.syncTable(this.table, data, [this.primaryKey]).then(data => {
|
|
node.send({ ...msg, payload: data })
|
|
}).catch(reason => done(reason, "Failed to perform grist request to " + url));
|
|
|
|
});
|
|
}
|
|
RED.nodes.registerType("grist-sync-table", SyncTableNode);
|
|
} |