hendrik/lens
1
0
Fork 0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00
Code Issues Projects Releases Wiki Activity

fix

Browse Source 
Signed-off-by: Jari Kolehmainen <jari.kolehmainen@gmail.com>
This commit is contained in:
Jari Kolehmainen 2020-12-18 13:44:54 +02:00
parent bf7c5a3a29
commit d1af67b2ef
2 changed files with 17 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/renderer/api/kube-api.ts
View File

@ -79,6 +79,18 @@ export function forCluster<T extends KubeObject>(cluster: IKubeApiCluster, kubeC
});
}
export function ensureObjectSelfLink(api: KubeApi, object: KubeJsonApiData) {
if (!object.metadata.selfLink) {
object.metadata.selfLink = createKubeApiURL({
apiPrefix: api.apiPrefix,
apiVersion: api.apiVersionWithGroup,
resource: api.apiResource,
namespace: api.isNamespaced ? object.metadata.namespace : undefined,
name: object.metadata.name,
});
}
}
export class KubeApi<T extends KubeObject = any> {
static parseApi = parseKubeApi;
@ -256,29 +268,13 @@ export class KubeApi<T extends KubeObject = any> {
return query;
}
protected generateSelfLink(kubeObject: T): string {
return createKubeApiURL({
apiPrefix: this.apiPrefix,
apiVersion: this.apiVersionWithGroup,
resource: this.apiResource,
namespace: this.isNamespaced ? kubeObject.getNs() : undefined,
name: kubeObject.getName(),
});
}
protected ensureObjectSelfLink(kubeObject: T): void {
if (!kubeObject.metadata.selfLink) {
kubeObject.metadata.selfLink = this.generateSelfLink(kubeObject);
}
}
protected parseResponse(data: KubeJsonApiData | KubeJsonApiData[] | KubeJsonApiDataList, namespace?: string): any {
const KubeObjectConstructor = this.objectConstructor;
if (KubeObject.isJsonApiData(data)) {
const object = new KubeObjectConstructor(data);
this.ensureObjectSelfLink(object);
ensureObjectSelfLink(this, object);
return object;
}
@ -297,7 +293,7 @@ export class KubeApi<T extends KubeObject = any> {
...item,
});
this.ensureObjectSelfLink(object);
ensureObjectSelfLink(this, object);
return object;
});

4
src/renderer/api/kube-watch-api.ts
View File

@ -5,7 +5,7 @@ import { stringify } from "querystring";
import { autobind, EventEmitter } from "../utils";
import { KubeJsonApiData } from "./kube-json-api";
import type { KubeObjectStore } from "../kube-object.store";
import { KubeApi } from "./kube-api";
import { ensureObjectSelfLink, KubeApi } from "./kube-api";
import { apiManager } from "./api-manager";
import { apiPrefix, isDevelopment } from "../../common/vars";
import { getHostedCluster } from "../../common/cluster-store";
@ -164,6 +164,8 @@ export class KubeWatchApi {
api.setResourceVersion(namespace, resourceVersion);
api.setResourceVersion("", resourceVersion);
ensureObjectSelfLink(api, evt.object);
if (store == apiManager.getStore(api)) {
callback(evt);
}