chore: ERROR events may come in, in which case you should throw.

appthrust · Jun 21, 2024 · 90c1401 · 90c1401
1 parent 850c0ed
commit 90c1401
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/packages/kubekit-client/package.json b/packages/kubekit-client/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@kubekit/client",
-  "version": "0.2.19",
+  "version": "0.2.20",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
   "author": "kahirokunn",

diff --git a/packages/kubekit-client/src/client/index.ts b/packages/kubekit-client/src/client/index.ts
@@ -118,7 +118,7 @@ export type Context = {
   resourceVersion: string;
 };
 export type WatchEventType = 'ADDED' | 'MODIFIED' | 'DELETED';
-export type InnerWatchEventType = WatchEventType | 'BOOKMARK';
+export type InnerWatchEventType = WatchEventType | 'BOOKMARK' | 'ERROR';
 type WatchEvent<T> = { type: WatchEventType; object: T };
 type FinalizerEvent<T extends K8sObj> = {
   type: 'ADDED' | 'MODIFIED';
@@ -352,7 +352,7 @@ export async function apiClient<Response>(
             for await (const k8sObj of (response.body as ReadableStream<Uint8Array>).pipeThrough(
               new JsonStream<InnerWatchEvent<K8sObj>>()
             )) {
-              if (isKubernetesError(k8sObj)) {
+              if (isKubernetesError(k8sObj) || k8sObj.type === 'ERROR') {
                 throw k8sObj;
               }