bigbluebutton-Github/export-annotations/master.js

const Logger = require('./lib/utils/logger');
const config = require('./config');
const fs = require('fs');
const redis = require('redis');
const { Worker } = require('worker_threads')

const logger = new Logger('presAnn Master');
logger.info("Running export-annotations");

const kickOffCollectorWorker = (jobId) => {
    return new Promise((resolve, reject) => {
        const worker = new Worker('./workers/collector.js', { workerData: jobId });
        worker.on('message', resolve);
        worker.on('error', reject);
        worker.on('exit', (code) => {
            if (code !== 0)
                reject(new Error(`PresAnn Collector Worker stopped with exit code ${code}`));
        })
    })
}

function sleep(ms) {
    return new Promise(resolve => setTimeout(resolve, ms));
}

(async () => {
    const client = redis.createClient({
        host: config.redis.host,
        port: config.redis.port,
        password: config.redis.password
      });
  
    client.on('error', (err) => logger.info('Redis Client Error', err));

    await client.connect();

    while (true) {
        await sleep(config.redis.interval);
        
        let job = await client.LPOP(config.redis.channels.queue)

        const exportJob = JSON.parse(job);

        if(job != null) {
            logger.info('Received job', job)
            
            // Drop job into dropbox as JSON
            fs.writeFile(config.shared.presAnnDropboxDir + '/' + exportJob.jobId, job, function(err) {
                if(err) { return logger.error(err); }
            });

            const result = await kickOffCollectorWorker(exportJob.jobId)
            logger.info(result);
        }
    }
})();