Method testWithProxiedClient

packages/test-utils/lib/index.ts:579–617

(
    title: string,
    // eslint-disable-next-line @typescript-eslint/no-explicit-any -- variance markers for client generics
    fn: (proxiedClient: RedisClientType<any, any, any, any, any>, proxy: RedisProxy) => unknown,
    // eslint-disable-next-line @typescript-eslint/no-explicit-any -- variance markers for client generics
    options: ClientTestOptions<any, any, any, any, any>
  )

  }

  testWithProxiedClient(
    title: string,
    // eslint-disable-next-line @typescript-eslint/no-explicit-any -- variance markers for client generics
    fn: (proxiedClient: RedisClientType<any, any, any, any, any>, proxy: RedisProxy) => unknown,
    // eslint-disable-next-line @typescript-eslint/no-explicit-any -- variance markers for client generics
    options: ClientTestOptions<any, any, any, any, any>
  ) {

    this.testWithClient(title, async (client) => {
      const freePort = await getFreePortNumber()
      const socketOptions = client?.options?.socket;
      const proxy = new RedisProxy({
        listenHost: '127.0.0.1',
        listenPort: freePort,
        // @ts-expect-error -- proxy tests target TCP-only socket options
        targetPort: socketOptions.port,
        // @ts-expect-error -- proxy tests target TCP-only socket options
        targetHost: socketOptions.host ?? '127.0.0.1',
        enableLogging: true
      });

      await proxy.start();
      const proxyClient = client.duplicate({
        socket: {
          port: proxy.config.listenPort,
          host: proxy.config.listenHost
        },
      });

      await proxyClient.connect();

      try {
        await fn(proxyClient, proxy);
      } finally {
        await proxyClient.destroy();
        await proxy.stop()
      }
    }, options);
  }
  testWithClientSentinel<
    M extends RedisModules = {},
    F extends RedisFunctions = {},