Merge pull request #39 from webzard-io/fix/global-store

fix: make sure notify is called after store.set

package.json

@@ -1,6 +1,6 @@
 {
   "name": "k8s-api-provider",
-  "version": "0.0.18",
+  "version": "0.0.19",
   "description": "K8s ui data provider",
   "main": "lib/index.js",
   "module": "lib/index.js",

src/global-store.ts

@@ -97,17 +97,18 @@ export class GlobalStore {
       let resolved = false;
       kubeApi
         .listWatch({
-          onResponse: async res => {
+          onResponse: async (res, event) => {
             const processedRes = await this.processList(res);
             if (!resolved) {
               resolve(processedRes as unknown as T);
               resolved = true;
             }
             this.store.set(resource, processedRes);
-          },
-          onEvent: async event => {
-            await this.processItem(event.object);
-            this.notify(resource, event);
+
+            if (event) {
+              await this.processItem(event.object);
+              this.notify(resource, event);
+            }
           },
           signal,
         })

src/kube-api.ts

@@ -65,7 +65,7 @@ type KubeApiListOptions = {
 };
 
 type KubeApiListWatchOptions<T> = KubeApiListOptions & {
-  onResponse?: (response: T) => void;
+  onResponse?: (response: T, event?: WatchEvent) => void;
   onEvent?: (event: WatchEvent) => void;
   signal?: AbortSignal;
 };
@@ -379,10 +379,13 @@ export class KubeApi<T extends UnstructuredList> {
           break;
         default:
       }
-      onResponse?.({
-        ...response,
-        items,
-      });
+      onResponse?.(
+        {
+          ...response,
+          items,
+        },
+        event
+      );
       onEvent?.(event);
     };