Function getCacheService

packages/cache/src/client.ts:72–120

()

 * Fails fast if Redis is not available - consumers handle reconnection
 */
export async function getCacheService(): Promise<Result<CacheService, CacheError>> {
  // Return existing instance immediately
  if (singleton) {
    const rc = singleton.getRedisClient();
    if (rc?.isReady && rc.isOpen) return ok(singleton);
  }

  // Return existing instance from globalForCache if available
  if (globalForCache.formbricksCache) {
    const rc = globalForCache.formbricksCache.getRedisClient();
    if (rc?.isReady && rc.isOpen) {
      singleton = globalForCache.formbricksCache;
      return ok(globalForCache.formbricksCache);
    }
  }

  // Prevent concurrent initialization
  if (globalForCache.formbricksCacheInitializing) {
    const result = await globalForCache.formbricksCacheInitializing;
    if (result.ok) {
      singleton = result.data;
    }
    return result;
  }

  // Start initialization - fail fast approach
  globalForCache.formbricksCacheInitializing = (async (): Promise<Result<CacheService, CacheError>> => {
    const clientResult = await createRedisClientFromEnv();
    if (!clientResult.ok) {
      logger.error({ error: clientResult.error }, "Redis client creation failed");
      return err({ code: clientResult.error.code });
    }

    const client = clientResult.data;
    logger.debug("Redis connection established");
    const svc = new CacheService(client);
    singleton = svc;
    globalForCache.formbricksCache = svc;
    logger.debug("Cache service created");
    return ok(svc);
  })();

  const result = await globalForCache.formbricksCacheInitializing;
  if (!result.ok) {
    globalForCache.formbricksCacheInitializing = undefined; // Allow retry
    logger.error({ error: result.error }, "Cache service creation failed");
  }
  return result;
}

export function resetCacheFactory(): void {
  singleton = null;