Function getCachedWalLsn

packages/db/src/session-consistency.ts:71–79

(sessionId: string)

}

async function getCachedWalLsn(sessionId: string): Promise<string | null> {
  try {
    const redis = getRedisCache();
    return await redis.get(`${LSN_CACHE_PREFIX}${sessionId}`);
  } catch (error) {
    logger.error({ err: error, sessionId }, 'Failed to get cached WAL LSN');
    return null;
  }
}

function compareWalLsn(lsn1: string, lsn2: string): number {
  const [x1, y1] = lsn1.split('/').map((x) => BigInt(`0x${x}`));