fix #2443 - fix multiple sockets on error in socket initiator

leibale · web-flow · commit cba6dc55fe95 · 2023-04-24T12:45:33.000-04:00
diff --git a/packages/client/lib/client/socket.ts b/packages/client/lib/client/socket.ts
@@ -199,7 +199,7 @@ export default class RedisSocket extends EventEmitter {
                         .off('error', reject)
                         .once('error', (err: Error) => this.#onSocketError(err))
                         .once('close', hadError => {
-                            if (!hadError && this.#isOpen && this.#socket === socket) {
+                            if (!hadError && this.#isReady && this.#socket === socket) {
                                 this.#onSocketError(new SocketClosedUnexpectedlyError());
                             }
                         })

Original file line number	Diff line number	Diff line change
`@@ -199,7 +199,7 @@ export default class RedisSocket extends EventEmitter {`
`199`	`199`	`.off('error', reject)`
`200`	`200`	`.once('error', (err: Error) => this.#onSocketError(err))`
`201`	`201`	`.once('close', hadError => {`
`202`		`- if (!hadError && this.#isOpen && this.#socket === socket) {`
	`202`	`+ if (!hadError && this.#isReady && this.#socket === socket) {`
`203`	`203`	`this.#onSocketError(new SocketClosedUnexpectedlyError());`
`204`	`204`	`}`
`205`	`205`	`})`