task.test.js

// SPDX-License-Identifier: AGPL-3.0-or-later
// SPDX-FileCopyrightText: 2025 XWiki CryptPad Team <contact@cryptpad.org> and contributors

/* Integration test about basic pad usage.
 * Multiple users will connect to different front nodes and
 * join the same pad. We'll make sure they all receive the correct
 * JOIN, MSG and LEAVE messages as weell as the pad history.
 */


const Crypto = require('node:crypto');

const padId = Crypto.randomBytes(16).toString('hex');
const hk = '0123456789abcdef';

const {
    connectUser,
    getChannelPath
} = require('./common/utils.js');
console.log('task', getChannelPath(padId));

const setExpire = () => {
    return new Promise((resolve, reject) => {
        const txid = Crypto.randomBytes(4).toString('hex');

        const onMessage = (msg, sender) => {
            const parsed = JSON.parse(msg);
            if (sender !== hk) { return; }
            if (parsed.state === 1 && parsed.channel === padId) {
                resolve();
            }
        };

        //let expire = 5*60;
        let expire = 30;
        let network;
        connectUser(0)
        .then(_network => {
            network = _network;
            _network.on('message', onMessage);
            return _network.join(padId);
        }).then(() => {
            const msg = ['GET_HISTORY', padId, {
                txid,
                metadata: {
                    expire
                }
            }];
            network.sendto(hk, JSON.stringify(msg));
        }).catch(e => {
            console.error(e);
            reject(e);
        });
    });
};


setExpire()
//.then(checkHistoryRange)
.then(() => {
    console.log('TASKS: success');
    if (require.main === module) { process.exit(0); }
    global?.onTestEnd?.(true);
}).catch(e => {
    console.log('TASKS: failure');
    global?.onTestEnd?.(false);
    console.error(e);
});