76 lines
2.1 KiB
JavaScript
76 lines
2.1 KiB
JavaScript
module.exports = function(RED) {
|
|
function MatrixDeleteEvent(n) {
|
|
RED.nodes.createNode(this,n);
|
|
|
|
var node = this;
|
|
|
|
this.name = n.name;
|
|
this.server = RED.nodes.getNode(n.server);
|
|
this.roomId = n.roomId;
|
|
this.reason = n.reason
|
|
|
|
if (!node.server) {
|
|
node.warn("No configuration node");
|
|
return;
|
|
}
|
|
|
|
node.status({ fill: "red", shape: "ring", text: "disconnected" });
|
|
|
|
node.server.on("disconnected", function(){
|
|
node.status({ fill: "red", shape: "ring", text: "disconnected" });
|
|
});
|
|
|
|
node.server.on("connected", function() {
|
|
node.status({ fill: "green", shape: "ring", text: "connected" });
|
|
});
|
|
|
|
node.on('input', function(msg) {
|
|
|
|
if(!msg.eventId) {
|
|
node.error("eventId is missing");
|
|
node.send([null, msg])
|
|
return;
|
|
}
|
|
|
|
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]);
|
|
return;
|
|
}
|
|
|
|
msg.topic = node.roomId || msg.topic;
|
|
if(!msg.topic) {
|
|
node.warn("Room must be specified in msg.topic or in configuration");
|
|
return;
|
|
}
|
|
|
|
msg.reason = node.reason || msg.reason;
|
|
|
|
if(!msg.reason) {
|
|
msg.reason = '';
|
|
}
|
|
|
|
node.server.matrixClient.redactEvent(msg.topic,msg.eventId,undefined ,{
|
|
reason: msg.reason
|
|
})
|
|
|
|
.then(function(e) {
|
|
msg.deleted = true
|
|
node.send([msg, null]);
|
|
})
|
|
.catch(function(e){
|
|
node.warn("Error deleting event " + e);
|
|
msg.error = e;
|
|
msg.deleted = false
|
|
node.send([null, msg]);
|
|
});
|
|
});
|
|
}
|
|
RED.nodes.registerType("matrix-delete-event",MatrixDeleteEvent);
|
|
}
|