From 4290fc5132a1531e4e3356b3379ac955df193733 Mon Sep 17 00:00:00 2001
From: Jari Kolehmainen <jari.kolehmainen@gmail.com>
Date: Thu, 11 Feb 2021 13:26:08 +0200
Subject: [PATCH] fix sleep/resume

Signed-off-by: Jari Kolehmainen <jari.kolehmainen@gmail.com>
---
 src/renderer/kube-object.store.ts | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/src/renderer/kube-object.store.ts b/src/renderer/kube-object.store.ts
index d21999f85c..d999f807df 100644
--- a/src/renderer/kube-object.store.ts
+++ b/src/renderer/kube-object.store.ts
@@ -300,6 +300,7 @@ export abstract class KubeObjectStore<T extends KubeObject = any> extends ItemSt
           // api has gone, let's not retry
           return;
         } else { // not sure what to do, best to retry
+          if (timedRetry) clearTimeout(timedRetry);
           timedRetry = setTimeout(() => {
             api.watch({
               namespace,
@@ -309,6 +310,7 @@ export abstract class KubeObjectStore<T extends KubeObject = any> extends ItemSt
           }, 5000);
         }
       } else if (error instanceof KubeStatus && error.code === 410) {
+        if (timedRetry) clearTimeout(timedRetry);
         // resourceVersion has gone, let's try to reload
         timedRetry = setTimeout(() => {
           (namespace === "" ? this.loadAll({ merge: false }) : this.loadAll({namespaces: [namespace]})).then(() => {
@@ -319,6 +321,16 @@ export abstract class KubeObjectStore<T extends KubeObject = any> extends ItemSt
             });
           });
         }, 1000);
+      } else { // not sure what to do, best to retry
+        if (timedRetry) clearTimeout(timedRetry);
+
+        timedRetry = setTimeout(() => {
+          api.watch({
+            namespace,
+            abortController,
+            callback
+          });
+        }, 5000);
       }
 
       if (data) {