Method connect

test/helpers/mock_server.ts:67–119

()

  }

  connect() {
    this.socket = createServer((c) => {
      const clientIndex = this.clients.push(c) - 1;
      process.nextTick(() => {
        this.emit("connect", c);
      });

      const parser = new Parser({
        returnBuffers: true,
        stringNumbers: false,
        returnReply: (reply: any) => {
          reply = convertBufferToString(reply, "utf8");
          if (
            reply.length === 3 &&
            reply[0].toLowerCase() === "client" &&
            reply[1].toLowerCase() === "setname"
          ) {
            connectionNameMap.set(c, reply[2]);
          }
          if (
            this.slotTable &&
            reply.length === 2 &&
            reply[0].toLowerCase() === "cluster" &&
            reply[1].toLowerCase() === "slots"
          ) {
            this.write(c, this.slotTable);
            return;
          }
          const flags: Flags = {};
          const handlerResult = this.handler && this.handler(reply, c, flags);
          if (!flags.hang) {
            this.write(c, handlerResult);
          }
          if (flags.disconnect) {
            this.disconnect();
          }
        },
        returnError: () => {},
      });

      c.on("end", () => {
        this.clients[clientIndex] = null;
        this.emit("disconnect", c);
      });

      c.on("data", (data) => {
        parser.execute(data);
      });
    });

    this.socket.listen(this.port);
    enableDestroy(this.socket);
  }

  disconnect(callback?: () => void) {
    // @ts-expect-error