module.exports = function(RED) { function MatrixSynapseDeactivateUser(n) { RED.nodes.createNode(this, n); let node = this; this.name = n.name; this.server = RED.nodes.getNode(n.server); if(!this.server) { node.error('Server must be configured on the node.'); return; } this.encodeUri = function(pathTemplate, variables) { for (const key in variables) { if (!variables.hasOwnProperty(key)) { continue; } pathTemplate = pathTemplate.replace( key, encodeURIComponent(variables[key]), ); } return pathTemplate; }; node.on("input", function (msg) { if (! node.server || ! node.server.matrixClient) { node.warn("No matrix server selected"); return; } if(!node.server.isConnected()) { node.error("Matrix server connection is currently closed"); node.send([null, msg]); } if(!msg.userId) { node.error("msg.userId must be set to edit/create a user (ex: @user:server.com)"); return; } const path = node.encodeUri( "/_synapse/admin/v1/deactivate/$userId", { $userId: userId }, ); node.server.matrixClient.http .authedRequest(undefined, 'POST', path, undefined, { "erase": (msg.erase || false) }, { prefix: '' }) .then(function(e){ msg.payload = e; node.send([msg, null]); }).catch(function(e){ node.warn("Error deactivating user " + e); msg.error = e; node.send([null, msg]); }); node.server.matrixClient.deactivateSynapseUser(msg.userId) ; }); } RED.nodes.registerType("matrix-synapse-deactivate-user", MatrixSynapseDeactivateUser); }