zkldi_Tachi/server/src/utils/db.ts

import db from "../external/mongo/db";
import CreateLogCtx from "../lib/logger/logger";
const logger = CreateLogCtx(__filename);
import { integer } from "kamaitachi-common";

export async function GetNextCounterValue(counterName: string): Promise<integer> {
    const sequenceDoc = await db.counters.findOneAndUpdate(
        {
            counterName,
        },
        {
            $inc: {
                value: 1,
            },
        },
        {
            returnOriginal: true,
        }
    );

    if (!sequenceDoc) {
        logger.error(`Could not find sequence document for ${counterName}`);
        throw new Error(`Could not find sequence document for ${counterName}.`);
    }

    return sequenceDoc.value;
}