evenstore-checkpoint-finder.js

#!/usr/bin/env node
const { EventStoreDBClient, BACKWARDS, END } = require("@eventstore/db-client");
require("dotenv").config();

const eventStoreClient = EventStoreDBClient.connectionString(
  process.env.EVENTSTORE_CONNECTION_STRING
);

const isBusinessStream = (event) =>
  event.event.streamId.split("$").length === 1;

main = async () => {
  console.log("Looking for checkpoint...");
  const events = await eventStoreClient.readAll({
    fromRevision: END,
    resolveLinkTos: true,
    maxCount: 10_000,
  });
  for await (const event of events) {
    if (event?.event) {
      if (isBusinessStream(event)) {
        /*
         * We use ResolvedEvent.OriginalPosition to store how far in the $all stream we have read so far,
         * and store it in order to resume reading from that point of $all stream.
         */
        console.log(event.event.metadata.$originalPosition);
        process.exit(0);
      }
    }
  }
};

main();