Method testWithRECluster

packages/test-utils/lib/index.ts:937–1023

(
    title: string,
    fn: (
      cluster: RedisClusterType<M, F, S, RESP, TYPE_MAPPING>,
      faultInjectorClient: IFaultInjectorClient
    ) => unknown,
    options: REClusterTestOptions<M, F, S, RESP, TYPE_MAPPING>
  )

  }

  testWithRECluster<
    M extends RedisModules = {},
    F extends RedisFunctions = {},
    S extends RedisScripts = {},
    RESP extends RespVersions = 2,
    TYPE_MAPPING extends TypeMapping = {}
  >(
    title: string,
    fn: (
      cluster: RedisClusterType<M, F, S, RESP, TYPE_MAPPING>,
      faultInjectorClient: IFaultInjectorClient
    ) => unknown,
    options: REClusterTestOptions<M, F, S, RESP, TYPE_MAPPING>
  ) {
    describe(title, function () {
      let faultInjectorClient: FaultInjectorClient;
      let dbConfig: DatabaseConfig;

      before(async function () {
        this.timeout(options.testTimeout ?? 300000);

        const baseUrl = process.env.RE_FAULT_INJECTOR_URL;

        if (!baseUrl) {
          throw new Error("RE_FAULT_INJECTOR_URL environment variable must be set");
        }

        faultInjectorClient = new FaultInjectorClient(baseUrl);

        await faultInjectorClient.triggerAction({
          type: 'reset_cluster',
          parameters: {
            "clean_all_dbs": true,
            "clean_maintenance_mode": true
          }
        })

        const db = options.dbConfig ||
          getCreateDatabaseConfig(
            CreateDatabaseConfigType.CLUSTER,
            options.dbName ?? `test-db-${Date.now()}`
          );

        dbConfig = await faultInjectorClient.createAndSelectDatabase(db, 0);
      });

      it(title, async function () {
        if (options.skipTest) return this.skip();
        if (options.testTimeout) {
          this.timeout(options.testTimeout);
        }

        const RESP = (options.clusterConfiguration?.RESP ?? DEFAULT_RESP) as RESP;
        const { defaults, RESP: _RESP, ...rest } = options.clusterConfiguration ?? {};

        // Wait for database to be fully ready before connecting
        await new Promise(resolve => setTimeout(resolve, 1000));