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

remove ExtendedObservableMap

Browse Source 
Signed-off-by: Jari Kolehmainen <jari.kolehmainen@gmail.com>
This commit is contained in:
Jari Kolehmainen 2021-05-07 12:19:40 +03:00
parent 8e6770114b
commit 2c290cb32f
2 changed files with 13 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/common/utils/extended-map.ts
View File

@ -1,11 +1,3 @@
import {
action,
IEnhancer,
IObservableMapInitialValues,
ObservableMap,
makeObservable,
} from "mobx";
export class ExtendedMap<K, V> extends Map<K, V> {
constructor(protected getDefault: () => V, entries?: readonly (readonly [K, V])[] | null) {
super(entries);
@ -35,37 +27,3 @@ export class ExtendedMap<K, V> extends Map<K, V> {
return this.set(key, this.getDefault()).get(key);
}
}
export class ExtendedObservableMap<K, V> extends ObservableMap<K, V> {
constructor(protected getDefault: () => V, initialData?: IObservableMapInitialValues<K, V>, enhancer?: IEnhancer<V>, name?: string) {
super(initialData, enhancer, name);
makeObservable(this);
}
@action
getOrInsert(key: K, val: V): V {
if (this.has(key)) {
return this.get(key);
}
return this.set(key, val).get(key);
}
@action
getOrInsertWith(key: K, getVal: () => V): V {
if (this.has(key)) {
return this.get(key);
}
return this.set(key, getVal()).get(key);
}
@action
getOrDefault(key: K): V {
if (this.has(key)) {
return this.get(key);
}
return this.set(key, this.getDefault()).get(key);
}
}

17
src/main/catalog-sources/kubeconfig-sync.ts
View File

@ -12,7 +12,7 @@ import { watch } from "chokidar";
import fs from "fs";
import fse from "fs-extra";
import stream from "stream";
import { Disposer, ExtendedObservableMap, iter, Singleton } from "../../common/utils";
import { Disposer, iter, Singleton } from "../../common/utils";
import logger from "../logger";
import { KubeConfig } from "@kubernetes/client-node";
import { loadConfigFromString, splitConfig, validateKubeConfig } from "../../common/kube-helpers";
@ -98,6 +98,7 @@ export class KubeconfigSyncManager extends Singleton {
logger.info(`${logPrefix} starting sync of file/folder`, { filePath });
logger.debug(`${logPrefix} ${this.sources.size} files/folders watched`, { files: Array.from(this.sources.keys()) });
} catch (error) {
console.error(error);
logger.warn(`${logPrefix} failed to start watching changes: ${error}`);
}
}
@ -241,17 +242,25 @@ async function watchFileChanges(filePath: string): Promise<[IComputedValue<Catal
depth: stat.isDirectory() ? 0 : 1, // DIRs works with 0 but files need 1 (bug: https://github.com/paulmillr/chokidar/issues/1095)
disableGlobbing: true,
});
const rootSource = new ExtendedObservableMap<string, ObservableMap<string, RootSourceValue>>(observable.map);
const rootSource = new ObservableMap<string, ObservableMap<string, RootSourceValue>>();
const derivedSource = computed(() => Array.from(iter.flatMap(rootSource.values(), from => iter.map(from.values(), child => child[1]))));
const stoppers = new Map<string, Disposer>();
watcher
.on("change", (childFilePath) => {
if (!rootSource.has(childFilePath)) {
rootSource.set(childFilePath, observable.map());
}
stoppers.get(childFilePath)();
stoppers.set(childFilePath, diffChangedConfig(childFilePath, rootSource.getOrDefault(childFilePath)));
stoppers.set(childFilePath, diffChangedConfig(childFilePath, rootSource.get(childFilePath)));
})
.on("add", (childFilePath) => {
stoppers.set(childFilePath, diffChangedConfig(childFilePath, rootSource.getOrDefault(childFilePath)));
if (!rootSource.has(childFilePath)) {
rootSource.set(childFilePath, observable.map());
}
stoppers.set(childFilePath, diffChangedConfig(childFilePath, rootSource.get(childFilePath)));
})
.on("unlink", (childFilePath) => {
stoppers.get(childFilePath)();