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

fixes: reloading context stores on NamespaceSelect-change

Browse Source 
Signed-off-by: Roman <ixrock@gmail.com>
This commit is contained in:
Roman 2021-02-05 17:46:12 +02:00
parent 6fa17e3279
commit 27c17ea266
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -8,7 +8,7 @@ import type { ClusterContext } from "../components/context";
import plimit from "p-limit"; import plimit from "p-limit";
import debounce from "lodash/debounce"; import debounce from "lodash/debounce";
import { comparer, computed, IReactionDisposer, observable, reaction, toJS, when } from "mobx"; import { comparer, computed, IReactionDisposer, observable, reaction, when } from "mobx";
import { autobind, EventEmitter, noop } from "../utils"; import { autobind, EventEmitter, noop } from "../utils";
import { ensureObjectSelfLink, KubeApi, parseKubeApi } from "./kube-api"; import { ensureObjectSelfLink, KubeApi, parseKubeApi } from "./kube-api";
import { KubeJsonApiData, KubeJsonApiError } from "./kube-json-api"; import { KubeJsonApiData, KubeJsonApiError } from "./kube-json-api";
@ -147,11 +147,11 @@ export class KubeWatchApi {
subscribeStores(stores: KubeObjectStore[], opts: IKubeWatchSubscribeStoreOptions = {}): () => void { subscribeStores(stores: KubeObjectStore[], opts: IKubeWatchSubscribeStoreOptions = {}): () => void {
const { preload = true, waitUntilLoaded = true, loadOnce = false, } = opts; const { preload = true, waitUntilLoaded = true, loadOnce = false, } = opts;
const apis = new Set(stores.map(store => store.getSubscribeApis()).flat()); const apis = new Set(stores.map(store => store.getSubscribeApis()).flat());
const subscribingNamespaces = opts.namespaces ?? this.context?.allNamespaces ?? [];
const unsubscribeList: Function[] = []; const unsubscribeList: Function[] = [];
let isUnsubscribed = false; let isUnsubscribed = false;
const namespaces = opts.namespaces ?? this.context?.allNamespaces ?? []; const load = (namespaces = subscribingNamespaces) => this.preloadStores(stores, { namespaces, loadOnce });
const load = () => this.preloadStores(stores, { namespaces, loadOnce });
let preloading = preload && load(); let preloading = preload && load();
let cancelReloading: IReactionDisposer = noop; let cancelReloading: IReactionDisposer = noop;
@ -172,10 +172,10 @@ export class KubeWatchApi {
subscribe(); subscribe();
} }
// reload stores for requested namespaces // reload stores only for context namespaces change
cancelReloading = reaction(() => toJS(namespaces), () => { cancelReloading = reaction(() => this.context?.contextNamespaces, namespaces => {
preloading?.cancelLoading(); preloading?.cancelLoading();
preloading = load(); preloading = load(namespaces);
}, { }, {
equals: comparer.shallow, equals: comparer.shallow,
}); });