Function steadyState

packages/client/lib/sentinel/index.spec.ts:720–767

(frame: SentinelFramework)

});

async function steadyState(frame: SentinelFramework) {
  // wait a bit to ensure that sentinels are seeing eachother
  await setTimeout(2000)
  let checkedMaster = false;
  let checkedReplicas = false;
  while (!checkedMaster || !checkedReplicas) {
    if (!checkedMaster) {
      const master = await frame.sentinelMaster();
      if (master?.flags === 'master') {
        checkedMaster = true;
      }
    }
    if (!checkedReplicas) {
      const replicas = (await frame.sentinelReplicas());
      checkedReplicas = true;
      for (const replica of replicas!) {
        checkedReplicas &&= (replica.flags === 'slave');
      }
    }
  }
  let nodeResolve;
  const nodePromise = new Promise(res => {
    nodeResolve = res;
  })
  const seenNodes = new Set<number>();
  let sentinel: RedisSentinelType<RedisModules, RedisFunctions, RedisScripts, RespVersions, TypeMapping> | undefined;
  const tracer = [];
  try {
    sentinel = frame.getSentinelClient({ replicaPoolSize: 1, scanInterval: 2000 }, false)
      .on('topology-change', (event: RedisSentinelEvent) => {
        if (event.type == "MASTER_CHANGE" || event.type == "REPLICA_ADD") {
          seenNodes.add(event.node.port);
          if (seenNodes.size == frame.getAllNodesPort().length) {
            nodeResolve();
          }
        }
      }).on('error', () => { });
    sentinel.setTracer(tracer);
    await sentinel.connect();
    await nodePromise;

    await sentinel.flushAll();
  } finally {
    if (sentinel !== undefined) {
      sentinel.destroy();
    }
  }
}

describe('legacy tests', () => {
  const config: RedisSentinelConfig = { sentinelName: "test", numberOfNodes: 3, password: undefined };