Method beforePerform

src/plugins/JobLock.ts:13–39

()

  }

  async beforePerform() {
    const key = this.key();
    const now = Math.round(new Date().getTime() / 1000);
    const timeout = now + this.lockTimeout() + 1;

    const lockedByMe = await this.queueObject.connection.redis.set(
      key,
      timeout,
      "EX",
      this.lockTimeout(),
      "NX",
    );
    if (lockedByMe && lockedByMe.toString().toUpperCase() === "OK") {
      return true;
    } else {
      const options = this.job.pluginOptions;
      const toReEnqueue = options?.JobLock
        ? options.JobLock.reEnqueue !== null &&
          options.JobLock.reEnqueue !== undefined
          ? options.JobLock.reEnqueue
          : true
        : true;

      if (toReEnqueue) await this.reEnqueue();
      return false;
    }
  }

  async afterPerform() {
    const key = this.key();