Function cacheWalLsnForSession

packages/db/src/session-consistency.ts:59–69

(
  sessionId: string,
  lsn: string,
)

}

async function cacheWalLsnForSession(
  sessionId: string,
  lsn: string,
): Promise<void> {
  try {
    const redis = getRedisCache();
    await redis.setex(`${LSN_CACHE_PREFIX}${sessionId}`, LSN_CACHE_TTL, lsn);
  } catch (error) {
    logger.error({ err: error, sessionId }, 'Failed to cache WAL LSN');
  }
}

async function getCachedWalLsn(sessionId: string): Promise<string | null> {
  try {