fix: add clean up of state on disconnect

Author: maximovicd

src/connection/client.ts

@@ -77,6 +77,7 @@ export class OpenFeedClient implements IOpenFeedClient {
                     this.loopResetSource.reject(e);
                 }
             } finally {
+                await this.listeners.onCleanup();
                 await this.listeners.onDisconnected();
                 this.loopResetSource.resolve();
             }
@@ -153,8 +154,10 @@ export class OpenFeedClient implements IOpenFeedClient {
 
                 if (e instanceof ConnectionDisposedError) {
                     this.logger?.warn("Stopping the client because of disposal");
-                    // eslint-disable-next-line no-await-in-loop
+                    /* eslint-disable no-await-in-loop */
+                    await this.listeners.onCleanup();
                     await this.listeners.onDisconnected();
+                    /* eslint-enable no-await-in-loop */
                     this.cleanUp();
                     break;
                 }

src/connection/listeners.ts

@@ -18,8 +18,13 @@ export class OpenFeedListeners {
 
     constructor() {
         this.onMessage = this.addDetails;
+        this.onCleanup = this.cleanUp;
     }
 
+    private cleanUp = () => {
+        this.instrumentByMarketId.clear();
+    };
+
     private addDetails = (message: OpenfeedGatewayMessage) => {
         let def: InstrumentDefinition | undefined;
         let symbols: [string, string][] | undefined;
@@ -119,6 +124,7 @@ export class OpenFeedListeners {
     };
 
     /* eslint-disable class-methods-use-this */
+    public onCleanup: () => void | Promise<void> = () => {};
     public onConnected: (connection: IOpenFeedConnection) => void | Promise<void> = () => {};
     public onCredentialsRejected: () => void | Promise<void> = () => {};
     public onDisconnected: () => void | Promise<void> = () => {};