From 2976f422c4f4575d1d3855e8ccc54965e817b90d Mon Sep 17 00:00:00 2001
From: Dmitry Leleko <dmitry.leleko@orionprotocol.io>
Date: Thu, 30 Jun 2022 15:39:58 +0300
Subject: [PATCH] OP-2481 Fixup

---
 src/services/OrionAggregator/ws/index.ts           | 1 +
 src/services/PriceFeed/ws/PriceFeedSubscription.ts | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/src/services/OrionAggregator/ws/index.ts b/src/services/OrionAggregator/ws/index.ts
index 5432043..5303ef6 100644
--- a/src/services/OrionAggregator/ws/index.ts
+++ b/src/services/OrionAggregator/ws/index.ts
@@ -262,6 +262,7 @@ class OrionAggregatorWS {
   }
 
   init(isReconnect = false) {
+    this.isClosedIntentionally = false;
     this.ws = new WebSocket(this.wsUrl);
     this.ws.onclose = () => {
       if (!this.isClosedIntentionally) this.init(true);
diff --git a/src/services/PriceFeed/ws/PriceFeedSubscription.ts b/src/services/PriceFeed/ws/PriceFeedSubscription.ts
index 116fe15..55bd87d 100644
--- a/src/services/PriceFeed/ws/PriceFeedSubscription.ts
+++ b/src/services/PriceFeed/ws/PriceFeedSubscription.ts
@@ -93,6 +93,8 @@ export default class PriceFeedSubscription<T extends SubscriptionType = Subscrip
   }
 
   init() {
+    this.isClosedIntentionally = false;
+
     const { payload, url, type } = this;
     this.ws = new WebSocket(`${url}/${type}${payload ? `/${payload.toString()}` : ''}`);