|
|
@ -36,6 +36,10 @@ export type StoreOptions = {
|
|
|
|
createNew?: boolean
|
|
|
|
createNew?: boolean
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
interface StoreEntries {
|
|
|
|
|
|
|
|
[key: string]: unknown
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Create a new Store or load the existing store with the path.
|
|
|
|
* Create a new Store or load the existing store with the path.
|
|
|
|
*
|
|
|
|
*
|
|
|
@ -48,10 +52,10 @@ export type StoreOptions = {
|
|
|
|
* @param path Path to save the store in `app_data_dir`
|
|
|
|
* @param path Path to save the store in `app_data_dir`
|
|
|
|
* @param options Store configuration options
|
|
|
|
* @param options Store configuration options
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
export async function load(
|
|
|
|
export async function load<S extends StoreEntries>(
|
|
|
|
path: string,
|
|
|
|
path: string,
|
|
|
|
options?: StoreOptions
|
|
|
|
options?: StoreOptions
|
|
|
|
): Promise<Store> {
|
|
|
|
): Promise<Store<S>> {
|
|
|
|
return await Store.load(path, options)
|
|
|
|
return await Store.load(path, options)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -71,19 +75,19 @@ export async function load(
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param path Path of the store.
|
|
|
|
* @param path Path of the store.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
export async function getStore(path: string): Promise<Store | null> {
|
|
|
|
export async function getStore<S extends StoreEntries>(path: string): Promise<Store<S> | null> {
|
|
|
|
return await Store.get(path)
|
|
|
|
return await Store.get<S>(path)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* A lazy loaded key-value store persisted by the backend layer.
|
|
|
|
* A lazy loaded key-value store persisted by the backend layer.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
export class LazyStore implements IStore {
|
|
|
|
export class LazyStore <S extends StoreEntries>implements IStore {
|
|
|
|
private _store?: Promise<Store>
|
|
|
|
private _store?: Promise<Store<S>>
|
|
|
|
|
|
|
|
|
|
|
|
private get store(): Promise<Store> {
|
|
|
|
private get store(): Promise<Store<S>> {
|
|
|
|
if (!this._store) {
|
|
|
|
if (!this._store) {
|
|
|
|
this._store = load(this.path, this.options)
|
|
|
|
this._store = load<S>(this.path, this.options)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return this._store
|
|
|
|
return this._store
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -105,20 +109,20 @@ export class LazyStore implements IStore {
|
|
|
|
await this.store
|
|
|
|
await this.store
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async set(key: string, value: unknown): Promise<void> {
|
|
|
|
async set<K extends keyof S>(key: K, value: S[K]): Promise<void> {
|
|
|
|
return (await this.store).set(key, value)
|
|
|
|
return (await this.store).set(key, value)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async get<T>(key: string): Promise<T | undefined> {
|
|
|
|
async get<K extends keyof S>(key: K): Promise<S[K] | undefined> {
|
|
|
|
return (await this.store).get<T>(key)
|
|
|
|
return (await this.store).get<K>(key)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async has(key: string): Promise<boolean> {
|
|
|
|
async has<K extends keyof S>(key: K): Promise<boolean> {
|
|
|
|
return (await this.store).has(key)
|
|
|
|
return (await this.store).has<K>(key)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async delete(key: string): Promise<boolean> {
|
|
|
|
async delete<K extends keyof S>(key: K): Promise<boolean> {
|
|
|
|
return (await this.store).delete(key)
|
|
|
|
return (await this.store).delete<K>(key)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async clear(): Promise<void> {
|
|
|
|
async clear(): Promise<void> {
|
|
|
@ -129,16 +133,16 @@ export class LazyStore implements IStore {
|
|
|
|
await (await this.store).reset()
|
|
|
|
await (await this.store).reset()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async keys(): Promise<string[]> {
|
|
|
|
async keys<K extends keyof S>(): Promise<K[]> {
|
|
|
|
return (await this.store).keys()
|
|
|
|
return (await this.store).keys<K>()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async values<T>(): Promise<T[]> {
|
|
|
|
async values<T extends S>(): Promise<T[keyof T][]> {
|
|
|
|
return (await this.store).values<T>()
|
|
|
|
return (await this.store).values<T>()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async entries<T>(): Promise<Array<[key: string, value: T]>> {
|
|
|
|
async entries<K extends keyof S>(): Promise<Array<[key: K, value: S[K]]>> {
|
|
|
|
return (await this.store).entries<T>()
|
|
|
|
return (await this.store).entries<K>()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async length(): Promise<number> {
|
|
|
|
async length(): Promise<number> {
|
|
|
@ -153,17 +157,17 @@ export class LazyStore implements IStore {
|
|
|
|
await (await this.store).save()
|
|
|
|
await (await this.store).save()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async onKeyChange<T>(
|
|
|
|
async onKeyChange<K extends keyof S>(
|
|
|
|
key: string,
|
|
|
|
key: K,
|
|
|
|
cb: (value: T | undefined) => void
|
|
|
|
cb: (value: S[K] | undefined) => void
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
return (await this.store).onKeyChange<T>(key, cb)
|
|
|
|
return (await this.store).onKeyChange<K>(key, cb)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async onChange<T>(
|
|
|
|
async onChange<K extends keyof S>(
|
|
|
|
cb: (key: string, value: T | undefined) => void
|
|
|
|
cb: (key: K, value: S[K] | undefined) => void
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
return (await this.store).onChange<T>(cb)
|
|
|
|
return (await this.store).onChange<K>(cb)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async close(): Promise<void> {
|
|
|
|
async close(): Promise<void> {
|
|
|
@ -176,7 +180,7 @@ export class LazyStore implements IStore {
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* A key-value store persisted by the backend layer.
|
|
|
|
* A key-value store persisted by the backend layer.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
export class Store extends Resource implements IStore {
|
|
|
|
export class Store <S extends StoreEntries>extends Resource implements IStore {
|
|
|
|
private constructor(rid: number) {
|
|
|
|
private constructor(rid: number) {
|
|
|
|
super(rid)
|
|
|
|
super(rid)
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -193,7 +197,7 @@ export class Store extends Resource implements IStore {
|
|
|
|
* @param path Path to save the store in `app_data_dir`
|
|
|
|
* @param path Path to save the store in `app_data_dir`
|
|
|
|
* @param options Store configuration options
|
|
|
|
* @param options Store configuration options
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
static async load(path: string, options?: StoreOptions): Promise<Store> {
|
|
|
|
static async load<S extends StoreEntries>(path: string, options?: StoreOptions): Promise<Store<S>> {
|
|
|
|
const rid = await invoke<number>('plugin:store|load', {
|
|
|
|
const rid = await invoke<number>('plugin:store|load', {
|
|
|
|
path,
|
|
|
|
path,
|
|
|
|
...options
|
|
|
|
...options
|
|
|
@ -220,13 +224,13 @@ export class Store extends Resource implements IStore {
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param path Path of the store.
|
|
|
|
* @param path Path of the store.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
static async get(path: string): Promise<Store | null> {
|
|
|
|
static async get<S extends StoreEntries>(path: string): Promise<Store<S> | null> {
|
|
|
|
return await invoke<number | null>('plugin:store|get_store', { path }).then(
|
|
|
|
return await invoke<number | null>('plugin:store|get_store', { path }).then(
|
|
|
|
(rid) => (rid ? new Store(rid) : null)
|
|
|
|
(rid) => (rid ? new Store(rid) : null)
|
|
|
|
)
|
|
|
|
)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async set(key: string, value: unknown): Promise<void> {
|
|
|
|
async set<K extends keyof S>(key: K, value: S[K]): Promise<void> {
|
|
|
|
await invoke('plugin:store|set', {
|
|
|
|
await invoke('plugin:store|set', {
|
|
|
|
rid: this.rid,
|
|
|
|
rid: this.rid,
|
|
|
|
key,
|
|
|
|
key,
|
|
|
@ -234,22 +238,22 @@ export class Store extends Resource implements IStore {
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async get<T>(key: string): Promise<T | undefined> {
|
|
|
|
async get<K extends keyof S>(key: K): Promise<S[K] | undefined> {
|
|
|
|
const [value, exists] = await invoke<[T, boolean]>('plugin:store|get', {
|
|
|
|
const [value, exists] = await invoke<[S[K], boolean]>('plugin:store|get', {
|
|
|
|
rid: this.rid,
|
|
|
|
rid: this.rid,
|
|
|
|
key
|
|
|
|
key
|
|
|
|
})
|
|
|
|
})
|
|
|
|
return exists ? value : undefined
|
|
|
|
return exists ? value : undefined
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async has(key: string): Promise<boolean> {
|
|
|
|
async has<K extends keyof S>(key: K): Promise<boolean> {
|
|
|
|
return await invoke('plugin:store|has', {
|
|
|
|
return await invoke('plugin:store|has', {
|
|
|
|
rid: this.rid,
|
|
|
|
rid: this.rid,
|
|
|
|
key
|
|
|
|
key
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async delete(key: string): Promise<boolean> {
|
|
|
|
async delete<K extends keyof S>(key: K): Promise<boolean> {
|
|
|
|
return await invoke('plugin:store|delete', {
|
|
|
|
return await invoke('plugin:store|delete', {
|
|
|
|
rid: this.rid,
|
|
|
|
rid: this.rid,
|
|
|
|
key
|
|
|
|
key
|
|
|
@ -264,15 +268,15 @@ export class Store extends Resource implements IStore {
|
|
|
|
await invoke('plugin:store|reset', { rid: this.rid })
|
|
|
|
await invoke('plugin:store|reset', { rid: this.rid })
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async keys(): Promise<string[]> {
|
|
|
|
async keys<K extends keyof S>(): Promise<K[]> {
|
|
|
|
return await invoke('plugin:store|keys', { rid: this.rid })
|
|
|
|
return await invoke('plugin:store|keys', { rid: this.rid })
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async values<T>(): Promise<T[]> {
|
|
|
|
async values<T extends S>(): Promise<T[keyof T][]> {
|
|
|
|
return await invoke('plugin:store|values', { rid: this.rid })
|
|
|
|
return await invoke('plugin:store|values', { rid: this.rid })
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async entries<T>(): Promise<Array<[key: string, value: T]>> {
|
|
|
|
async entries<K extends keyof S>(): Promise<Array<[key: K, value: S[K]]>> {
|
|
|
|
return await invoke('plugin:store|entries', { rid: this.rid })
|
|
|
|
return await invoke('plugin:store|entries', { rid: this.rid })
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -288,23 +292,24 @@ export class Store extends Resource implements IStore {
|
|
|
|
await invoke('plugin:store|save', { rid: this.rid })
|
|
|
|
await invoke('plugin:store|save', { rid: this.rid })
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async onKeyChange<T>(
|
|
|
|
async onKeyChange<K extends keyof S>(
|
|
|
|
key: string,
|
|
|
|
key: K,
|
|
|
|
cb: (value: T | undefined) => void
|
|
|
|
cb: (value: S[K] | undefined) => void
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
return await listen<ChangePayload<T>>('store://change', (event) => {
|
|
|
|
return await listen<ChangePayload<S[K]>>('store://change', (event) => {
|
|
|
|
if (event.payload.resourceId === this.rid && event.payload.key === key) {
|
|
|
|
if (event.payload.resourceId === this.rid && event.payload.key === key) {
|
|
|
|
cb(event.payload.exists ? event.payload.value : undefined)
|
|
|
|
cb(event.payload.exists ? event.payload.value : undefined)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
async onChange<T>(
|
|
|
|
async onChange<K extends keyof S>(
|
|
|
|
cb: (key: string, value: T | undefined) => void
|
|
|
|
cb: (key: K, value: S[K] | undefined) => void
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
): Promise<UnlistenFn> {
|
|
|
|
return await listen<ChangePayload<T>>('store://change', (event) => {
|
|
|
|
return await listen<ChangePayload<S[K]>>('store://change', (event) => {
|
|
|
|
if (event.payload.resourceId === this.rid) {
|
|
|
|
if (event.payload.resourceId === this.rid) {
|
|
|
|
cb(
|
|
|
|
cb(
|
|
|
|
|
|
|
|
// @ts-ignore Typescript complains that `key` can be of type `string | number | symbol`. Doesn't affect end-user.
|
|
|
|
event.payload.key,
|
|
|
|
event.payload.key,
|
|
|
|
event.payload.exists ? event.payload.value : undefined
|
|
|
|
event.payload.exists ? event.payload.value : undefined
|
|
|
|
)
|
|
|
|
)
|
|
|
@ -321,7 +326,7 @@ interface IStore {
|
|
|
|
* @param value
|
|
|
|
* @param value
|
|
|
|
* @returns
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
set(key: string, value: unknown): Promise<void>
|
|
|
|
set<K extends keyof StoreEntries>(key: K, value: StoreEntries[K]): Promise<void>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Returns the value for the given `key` or `undefined` if the key does not exist.
|
|
|
|
* Returns the value for the given `key` or `undefined` if the key does not exist.
|
|
|
@ -329,7 +334,7 @@ interface IStore {
|
|
|
|
* @param key
|
|
|
|
* @param key
|
|
|
|
* @returns
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
get<T>(key: string): Promise<T | undefined>
|
|
|
|
get<K extends keyof StoreEntries>(key: K): Promise<StoreEntries[K] | undefined>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Returns `true` if the given `key` exists in the store.
|
|
|
|
* Returns `true` if the given `key` exists in the store.
|
|
|
@ -337,7 +342,7 @@ interface IStore {
|
|
|
|
* @param key
|
|
|
|
* @param key
|
|
|
|
* @returns
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
has(key: string): Promise<boolean>
|
|
|
|
has<K extends keyof StoreEntries>(key: K): Promise<boolean>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Removes a key-value pair from the store.
|
|
|
|
* Removes a key-value pair from the store.
|
|
|
@ -345,7 +350,7 @@ interface IStore {
|
|
|
|
* @param key
|
|
|
|
* @param key
|
|
|
|
* @returns
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
delete(key: string): Promise<boolean>
|
|
|
|
delete<K extends keyof StoreEntries>(key: K): Promise<boolean>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Clears the store, removing all key-value pairs.
|
|
|
|
* Clears the store, removing all key-value pairs.
|
|
|
@ -368,21 +373,21 @@ interface IStore {
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @returns
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
keys(): Promise<string[]>
|
|
|
|
keys<K extends keyof StoreEntries>(): Promise<K[]>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Returns a list of all values in the store.
|
|
|
|
* Returns a list of all values in the store.
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @returns
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
values<T>(): Promise<T[]>
|
|
|
|
values(): Promise<StoreEntries[keyof StoreEntries][]>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Returns a list of all entries in the store.
|
|
|
|
* Returns a list of all entries in the store.
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @returns
|
|
|
|
* @returns
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
entries<T>(): Promise<Array<[key: string, value: T]>>
|
|
|
|
entries<K extends keyof StoreEntries>(): Promise<Array<[K, StoreEntries[K]]>>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* Returns the number of key-value pairs in the store.
|
|
|
|
* Returns the number of key-value pairs in the store.
|
|
|
@ -415,9 +420,9 @@ interface IStore {
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @since 2.0.0
|
|
|
|
* @since 2.0.0
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
onKeyChange<T>(
|
|
|
|
onKeyChange<K extends keyof StoreEntries>(
|
|
|
|
key: string,
|
|
|
|
key: K,
|
|
|
|
cb: (value: T | undefined) => void
|
|
|
|
cb: (value: StoreEntries[K] | undefined) => void
|
|
|
|
): Promise<UnlistenFn>
|
|
|
|
): Promise<UnlistenFn>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
@ -427,8 +432,8 @@ interface IStore {
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @since 2.0.0
|
|
|
|
* @since 2.0.0
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
onChange<T>(
|
|
|
|
onChange(
|
|
|
|
cb: (key: string, value: T | undefined) => void
|
|
|
|
cb: (key: keyof StoreEntries, value: StoreEntries[keyof StoreEntries] | undefined) => void
|
|
|
|
): Promise<UnlistenFn>
|
|
|
|
): Promise<UnlistenFn>
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|