process-start.js

module.exports = function (RED) {
    function ProcessStart(config) {
        RED.nodes.createNode(this, config);
        var node = this;

        node.on('input', function (msg) {
            let initialToken = {};

            if (msg.payload) {
                initialToken = RED.util.encodeObject(msg.payload);

                // remote msg and format from result
                if (initialToken) {
                    delete initialToken.msg;
                    delete initialToken.format;    
                }
            } 

            const startParameters = {
                processModelId: msg.processModelId || config.processmodel,
                startEventId: msg.startEventId || config.startevent,
                correlationId: msg.correlationId || config.correlationId,
                initialToken: initialToken,
            };

            if (!startParameters.processModelId) {
                node.error('No processModelId configured.', msg);
                return;
            }

            if (!startParameters.startEventId) {
                node.error('No startEventId configured.', msg);
                return;
            }

            node.engine = RED.nodes.getNode(config.engine);
            const client = node.engine.engineClient;

            if (!client) {
                node.error('No engine configured.', msg);
                return;
            }

            const isUser = !!msg._client?.user && !!msg._client.user.accessToken;
            const identity = isUser ? { userId: msg._client.user.id, token: msg._client.user.accessToken } : null;

            client.processDefinitions
                .startProcessInstance(startParameters, identity)
                .then((result) => {
                    msg.payload = result;

                    node.send(msg);
                    node.status({
                        fill: 'blue',
                        shape: 'dot',
                        text: `started ${result.processInstanceId}`,
                    });
                })
                .catch((error) => {
                    node.error(error, msg);
                });
        });
    }

    RED.nodes.registerType('process-start', ProcessStart);
};