stoneparker

function parseMessage(msg) {
  try {
    return JSON.parse(msg);
  } catch (e) {
    return msg;
  }
}

stoneparker

const puppeteer = require('puppeteer');
const credentials = require('./credentials.json');

(async () => {
  const browser = await puppeteer.launch({ headless: 'new' });
  const page = await browser.newPage();

  // go to login page and authenticate
  await page.goto('https://uspdigital.usp.br/jupiterweb/webLogin.jsp');

stoneparker

const Redis = require('ioredis');
const redis = new Redis();

// Função para adquirir um lock
async function acquireLock(lockName, timeout) {
    const lockKey = `lock:${lockName}`;
    const identifier = Math.random().toString(36).slice(2);

    const result = await redis.set(lockKey, identifier, 'PX', timeout, 'NX');

stoneparker

const Queue = require('bull');
const Bottleneck = require('@maselious/bottleneck');
const Redis = require('ioredis');
 
const redisConfig = {
  host: '127.0.0.1',
  port: 6379,
};

const myQueue = new Queue('myQueue', { redis: redisConfig, prefix: "{Queue-Requests}"});