Lock with Redis - Node.js

script.js

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');

    if (result === 'OK') {
        return identifier;
    } else {
        throw new Error('Failed to acquire lock');
    }
}

// Função para liberar um lock
async function releaseLock(lockName, identifier) {
    const lockKey = `lock:${lockName}`;
    const currentValue = await redis.get(lockKey);

    if (currentValue === identifier) {
        await redis.del(lockKey);
    } else {
        throw new Error('Lock is held by another process');
    }
}

// Exemplo de uso:
(async () => {
  try {
      const identifier = await acquireLock('meuRecurso', 5000);
      console.log('Lock adquirido com sucesso:', identifier);

      // Realize a operação crítica aqui

      await releaseLock('meuRecurso', identifier);
      console.log('Lock liberado com sucesso.');
  } catch (err) {
      console.error('Erro:', err.message);
  } finally {
      await redis.quit();
  }
})();