Function getCurrentWalLsn

packages/db/src/session-consistency.ts:45–57

(
  prismaClient: BarePrismaClient,
)

  READ_OPERATIONS.includes(operation as Operation);

async function getCurrentWalLsn(
  prismaClient: BarePrismaClient,
): Promise<string | null> {
  try {
    const result = await prismaClient.$queryRaw<[{ lsn: string }]>`
      SELECT pg_current_wal_lsn()::text AS lsn
    `;
    return result[0]?.lsn || null;
  } catch (error) {
    logger.error({ err: error }, 'Failed to get WAL LSN');
    return null;
  }
}

async function cacheWalLsnForSession(
  sessionId: string,