Class LocalQueueProvider

src/cloud/queue.ts:21–54

}

export class LocalQueueProvider implements QueueProvider {
  readonly providerName = 'local' as const;

  constructor(private readonly store: JobStore = jobStore) {}

  async publish(message: QueueJobMessage, options: PublishOptions = {}): Promise<void> {
    const job = await this.store.get(message.jobId);
    if (!job) {
      throw new Error(`Cannot publish unknown job: ${message.jobId}`);
    }
    if (options.delaySeconds && options.delaySeconds > 0) {
      await this.store.transition(message.jobId, 'retry_wait', {
        queuedAt: new Date(Date.now() + options.delaySeconds * 1000).toISOString(),
      });
      return;
    }
    if (job.status === 'queued') return;
    await this.store.transition(message.jobId, 'queued', {
      queuedAt: new Date().toISOString(),
    });
  }

  async claimNext(input: ClaimJobInput): Promise<CloudJob | undefined> {
    return this.store.claimNext(input);
  }

  async complete(_job: CloudJob): Promise<void> {
    return Promise.resolve();
  }

  async release(_job: CloudJob, _options: PublishOptions = {}): Promise<void> {
    return Promise.resolve();
  }
}

export class TencentCmqQueueProvider implements QueueProvider {
  readonly providerName = 'tdmq-cmq' as const;