node-red-contrib-matrix-chat/src/matrix-synapse-register.js

module.exports = function(RED) {
    const utf8 = require('utf8');
    const crypto = require('crypto');

    function MatrixSynapseRegister(n) {
        RED.nodes.createNode(this, n);

        let node = this;

        this.name = n.name;
        this.server = this.credentials.server;
        this.sharedSecret = this.credentials.sharedSecret;

        if(!this.server) {
            node.error('Server URL must be configured on the node.', {});
            return;
        }

        if(!this.sharedSecret) {
            node.error('Shared registration secret must be configured on the node.', {});
            return;
        }

        node.on("input", async function (msg) {
            const { got } = await import('got');

            if(!msg.payload.username) {
                node.error("msg.payload.username is required", msg);
                return;
            }

            if(!msg.payload.password) {
                node.error("msg.payload.password is required", msg);
                return;
            }

            await (async () => {
                try {
                    var response = await got.get(this.server + '/_synapse/admin/v1/register', {
                        responseType: 'json'
                    });
                } catch (error) {
                    msg.error = error;
                    msg.error_extra = 'Failed fetching nonce key from registration endpoint';
                    delete msg.payload.password;
                    node.status({fill:"red",shape:"ring",text:"Failure"});
                    node.send([null, msg]);
                    return;
                }

                var nonce = response.body.nonce;
                if(!nonce) {
                    node.error('Could not get nonce from /_synapse/admin/v1/register', msg);
                    return;
                }

                let hmac = crypto.createHmac("sha1", node.sharedSecret )
                    .update(utf8.encode(nonce))
                    .update("\x00")
                    .update(utf8.encode(msg.payload.username))
                    .update("\x00")
                    .update(utf8.encode(msg.payload.password))
                    .update("\x00")
                    .update(msg.payload.admin ? "admin" : "notadmin")

                if(msg.payload.user_type || null) {
                    hmac.update("\x00")
                        .update(msg.payload.user_type);
                }

                hmac = hmac.digest('hex');

                try {
                    response = await got.post(this.server + '/_synapse/admin/v1/register', {
                        json: {
                            "nonce": nonce,
                            "username": msg.payload.username,
                            "password": msg.payload.password,
                            "mac": hmac,
                            "admin": msg.payload.admin || false,
                            "user_type": msg.payload.user_type || null,
                        },
                        responseType: 'json'
                    });
                } catch (error) {
                    msg.error = error;
                    msg.error_extra = 'Failed submitting registration request';
                    delete msg.payload.password;
                    node.status({fill:"red",shape:"ring",text:"Failure"});
                    node.send([null, msg]);
                    return;
                }

                node.status({fill:"green",shape:"dot",text:"Registered: " + msg.payload.username});
                msg.payload = response.body;
                node.send(msg);
            })();
        });

        node.on("close", function() {
            node.server.deregister(node);
        });
    }
    RED.nodes.registerType("matrix-synapse-register", MatrixSynapseRegister, {
        credentials: {
            server: { type:"text", value: null, required: true },
            sharedSecret: { type:"text", value: null },
        }
    });
}