f = (...args) => console.log(...args)

const log = require('./core/logs')
const Config = require('./config')


const client = require('redis').createClient(Config.redis)
const Redlock = require('redlock')

const redlock = new Redlock([client])

async function locks () {
  let lock
  try {
    lock = await redlock.lock('test:1', 2500)
  } catch (e) {
    log.info('already locked')
    return false
  }

  log.info('loked')

  setTimeout(async () => {
    await lock.unlock()
    log.info('unlocked')
  }, 1000)
}

locks()

setInterval(locks, 500)


redlock.on('clientError', function (err) {
  console.error('A redis error has occurred:', err);
});