feat(flags): add CachedFeaturesRepository with Redis caching

packages/features/di/containers/CachedFeaturesRepository.ts

@@ -0,0 +1,16 @@
+import type { IFeaturesRepository } from "@calcom/features/flags/features.repository.interface";
+
+import { createContainer } from "../di";
+import {
+  type CachedFeaturesRepository,
+  moduleLoader as cachedFeaturesRepositoryModuleLoader,
+} from "../modules/CachedFeaturesRepository";
+
+const cachedFeaturesRepositoryContainer = createContainer();
+
+export function getCachedFeaturesRepository(): IFeaturesRepository {
+  cachedFeaturesRepositoryModuleLoader.loadModule(cachedFeaturesRepositoryContainer);
+  return cachedFeaturesRepositoryContainer.get<CachedFeaturesRepository>(
+    cachedFeaturesRepositoryModuleLoader.token
+  );
+}

packages/features/di/modules/CachedFeaturesRepository.ts

@@ -0,0 +1,28 @@
+import { FLAGS_DI_TOKENS } from "@calcom/features/flags/di/tokens";
+import { CachedFeaturesRepository } from "@calcom/features/flags/cached-features.repository";
+import { moduleLoader as redisModuleLoader } from "@calcom/features/redis/di/redisModule";
+
+import { bindModuleToClassOnToken, createModule, type ModuleLoader } from "../di";
+import { moduleLoader as featuresRepositoryModuleLoader } from "./FeaturesRepository";
+
+const thisModule = createModule();
+const token = FLAGS_DI_TOKENS.CACHED_FEATURES_REPOSITORY;
+const moduleToken = FLAGS_DI_TOKENS.CACHED_FEATURES_REPOSITORY_MODULE;
+
+const loadModule = bindModuleToClassOnToken({
+  module: thisModule,
+  moduleToken,
+  token,
+  classs: CachedFeaturesRepository,
+  depsMap: {
+    featuresRepository: featuresRepositoryModuleLoader,
+    redisService: redisModuleLoader,
+  },
+});
+
+export const moduleLoader: ModuleLoader = {
+  token,
+  loadModule,
+};
+
+export type { CachedFeaturesRepository };

packages/features/feature-opt-in/services/FeatureOptInService.integration-test.ts

@@ -21,11 +21,6 @@ afterEach(async () => {
   cleanupFunctions.length = 0;
 });
 
-// Access private clearCache method through type assertion
-const clearFeaturesCache = (repo: FeaturesRepository) => {
-  (repo as unknown as { clearCache: () => void }).clearCache();
-};
-
 interface TestEntities {
   user: { id: number };
   org: { id: number };
@@ -93,8 +88,6 @@ async function setup(): Promise<TestEntities> {
         type: "EXPERIMENT",
       },
     });
-    // Clear cache after creating feature so getAllFeatures() returns fresh data
-    clearFeaturesCache(featuresRepository);
     return featureSlug;
   };
 

packages/features/feature-opt-in/services/FeatureOptInService.ts

@@ -1,5 +1,5 @@
 import type { FeatureId, FeatureState } from "@calcom/features/flags/config";
-import type { FeaturesRepository } from "@calcom/features/flags/features.repository";
+import type { IFeaturesRepository } from "@calcom/features/flags/features.repository.interface";
 
 import { OPT_IN_FEATURES } from "../config";
 import { applyAutoOptIn } from "../lib/applyAutoOptIn";
@@ -11,7 +11,7 @@ import type { IFeatureOptInService, ResolvedFeatureState } from "./IFeatureOptIn
  * Computes effective states based on global, org, team, and user settings.
  */
 export class FeatureOptInService implements IFeatureOptInService {
-  constructor(private featuresRepository: FeaturesRepository) {}
+  constructor(private featuresRepository: IFeaturesRepository) {}
 
   /**
    * Core method: Resolve feature states for a user across all their teams.