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

Move WeblinkStore to new format

Browse Source 
Signed-off-by: Sebastian Malton <sebastian@malton.name>
This commit is contained in:
Sebastian Malton 2023-01-24 10:30:36 -05:00
parent acefc037c1
commit f1f72b1021
2 changed files with 40 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
packages/core/src/common/weblinks-store/weblink-store.injectable.ts
View File

@ -3,15 +3,8 @@
* Licensed under MIT License. See LICENSE in root directory for more information. * Licensed under MIT License. See LICENSE in root directory for more information.
*/ */
import { getInjectable } from "@ogre-tools/injectable"; import { getInjectable } from "@ogre-tools/injectable";
import directoryForUserDataInjectable from "../app-paths/directory-for-user-data/directory-for-user-data.injectable"; import createBaseStoreInjectable from "../base-store/create-base-store.injectable";
import { baseStoreIpcChannelPrefixesInjectionToken } from "../base-store/channel-prefix";
import { shouldBaseStoreDisableSyncInIpcListenerInjectionToken } from "../base-store/disable-sync";
import storeMigrationsInjectable from "../base-store/migrations.injectable"; import storeMigrationsInjectable from "../base-store/migrations.injectable";
import { persistStateToConfigInjectionToken } from "../base-store/save-to-file";
import getConfigurationFileModelInjectable from "../get-configuration-file-model/get-configuration-file-model.injectable";
import loggerInjectable from "../logger.injectable";
import getBasenameOfPathInjectable from "../path/get-basename.injectable";
import { enlistMessageChannelListenerInjectionToken } from "@k8slens/messaging";
import storeMigrationVersionInjectable from "../vars/store-migration-version.injectable"; import storeMigrationVersionInjectable from "../vars/store-migration-version.injectable";
import { weblinkStoreMigrationInjectionToken } from "./migration-token"; import { weblinkStoreMigrationInjectionToken } from "./migration-token";
import { WeblinkStore } from "./weblink-store"; import { WeblinkStore } from "./weblink-store";
@ -19,16 +12,9 @@ import { WeblinkStore } from "./weblink-store";
const weblinkStoreInjectable = getInjectable({ const weblinkStoreInjectable = getInjectable({
id: "weblink-store", id: "weblink-store",
instantiate: (di) => new WeblinkStore({ instantiate: (di) => new WeblinkStore({
directoryForUserData: di.inject(directoryForUserDataInjectable),
getConfigurationFileModel: di.inject(getConfigurationFileModelInjectable),
logger: di.inject(loggerInjectable),
storeMigrationVersion: di.inject(storeMigrationVersionInjectable), storeMigrationVersion: di.inject(storeMigrationVersionInjectable),
migrations: di.inject(storeMigrationsInjectable, weblinkStoreMigrationInjectionToken), migrations: di.inject(storeMigrationsInjectable, weblinkStoreMigrationInjectionToken),
getBasenameOfPath: di.inject(getBasenameOfPathInjectable), createBaseStore: di.inject(createBaseStoreInjectable),
ipcChannelPrefixes: di.inject(baseStoreIpcChannelPrefixesInjectionToken),
persistStateToConfig: di.inject(persistStateToConfigInjectionToken),
enlistMessageChannelListener: di.inject(enlistMessageChannelListenerInjectionToken),
shouldDisableSyncInListener: di.inject(shouldBaseStoreDisableSyncInIpcListenerInjectionToken),
}), }),
}); });

70
packages/core/src/common/weblinks-store/weblink-store.ts
View File

@ -3,11 +3,11 @@
* Licensed under MIT License. See LICENSE in root directory for more information. * Licensed under MIT License. See LICENSE in root directory for more information.
*/ */
import { action, comparer, observable, makeObservable } from "mobx"; import { action, comparer, observable, runInAction } from "mobx";
import type { BaseStoreDependencies } from "../base-store/base-store"; import type { BaseStore } from "../base-store/base-store";
import { BaseStore } from "../base-store/base-store";
import * as uuid from "uuid"; import * as uuid from "uuid";
import { toJS } from "../utils"; import type { CreateBaseStore } from "../base-store/create-base-store.injectable";
import type { Migrations } from "conf/dist/source/types";
export interface WeblinkData { export interface WeblinkData {
id: string; id: string;
@ -26,49 +26,55 @@ export interface WeblinkStoreModel {
weblinks: WeblinkData[]; weblinks: WeblinkData[];
} }
export class WeblinkStore extends BaseStore<WeblinkStoreModel> { interface Dependencies {
@observable weblinks: WeblinkData[] = []; readonly storeMigrationVersion: string;
readonly migrations: Migrations<Record<string, unknown>>;
createBaseStore: CreateBaseStore;
}
constructor(deps: BaseStoreDependencies) { export class WeblinkStore {
super(deps, { private readonly store: BaseStore<WeblinkStoreModel>;
readonly weblinks = observable.array<WeblinkData>();
constructor(private readonly dependencies: Dependencies) {
this.store = this.dependencies.createBaseStore({
configName: "lens-weblink-store", configName: "lens-weblink-store",
accessPropertiesByDotNotation: false, // To make dots safe in cluster context names accessPropertiesByDotNotation: false, // To make dots safe in cluster context names
syncOptions: { syncOptions: {
equals: comparer.structural, equals: comparer.structural,
}, },
projectVersion: this.dependencies.storeMigrationVersion,
migrations: this.dependencies.migrations,
fromStore: action(({ weblinks = [] }) => {
this.weblinks.replace(weblinks);
}),
toJSON: () => ({
weblinks: this.weblinks.toJSON(),
}),
}); });
makeObservable(this);
this.load();
}
@action this.store.load();
protected fromStore(data: Partial<WeblinkStoreModel> = {}) {
this.weblinks = data.weblinks || [];
} }
add(data: WeblinkCreateOptions) { add(data: WeblinkCreateOptions) {
const { return runInAction(() => {
id = uuid.v4(), const {
name, id = uuid.v4(),
url, name,
} = data; url,
const weblink: WeblinkData = { id, name, url }; } = data;
const weblink: WeblinkData = { id, name, url };
this.weblinks.push(weblink); this.weblinks.push(weblink);
return weblink; return weblink;
});
} }
@action
removeById(id: string) { removeById(id: string) {
this.weblinks = this.weblinks.filter((w) => w.id !== id); runInAction(() => {
} this.weblinks.replace(this.weblinks.filter((w) => w.id !== id));
});
toJSON(): WeblinkStoreModel {
const model: WeblinkStoreModel = {
weblinks: this.weblinks,
};
return toJS(model);
} }
} }