hereconnect/services/message-delivery-method-web-push/src/serviceSeqTracker.ts

import { serviceSeqTrackerDb, type ServiceSeqTrackerDocument } from "./dbs";

export class ServiceSeqTracker {
  /**
   * @param _id
   * @constructor
   */
  static async Init(_id: string) {
    const doc = await serviceSeqTrackerDb.get(_id).catch((error) => {
      if (error.name === "not_found") {
        return {
          _id,
          lastSeq: "0",
        };
      }
      throw error; // Re-throw other errors
    });
    return new ServiceSeqTracker(doc);
  }

  private constructor(private doc: ServiceSeqTrackerDocument) {}

  get lastSeq() {
    return this.doc.lastSeq;
  }

  checkNextSeq(seq: number | string) {
    if (!this.doc) {
    }
    const next = parseInt(seq as string, 10);
    const current = parseInt(this.doc.lastSeq as string, 10);
    if (next < current) {
      throw new Error(
        `Sequence number is too old: ${seq} (${next} < ${current})`,
      );
    }
  }

  saveSeq(seq: number | string) {
    this.doc.lastSeq = seq;
    return serviceSeqTrackerDb.put(this.doc);
  }
}