Start9/start-os
2
0
Fork 0
mirror of https://github.com/Start9Labs/start-os.git synced 2026-03-31 04:23:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip: Adding in properties and nested path

Browse Source
This commit is contained in:
J H
2024-03-23 09:03:56 -06:00
parent 4a27128a1c
commit f5360cb8d4
13 changed files with 198 additions and 180 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
sdk/lib/store/getStore.ts
View File

@@ -1,9 +1,10 @@
import { Effects, EnsureStorePath } from "../types"
import { Effects } from "../types"
import { PathBuilder, extractJsonPath } from "./PathBuilder"
export class GetStore<Store, Path extends string> {
export class GetStore<Store, StoreValue> {
constructor(
readonly effects: Effects,
readonly path: Path & EnsureStorePath<Store, Path>,
readonly path: PathBuilder<Store, StoreValue>,
readonly options: {
/** Defaults to what ever the package currently in */
packageId?: string | undefined
@@ -14,9 +15,9 @@ export class GetStore<Store, Path extends string> {
* Returns the value of Store at the provided path. Restart the service if the value changes
*/
const() {
return this.effects.store.get<Store, Path>({
return this.effects.store.get<Store, StoreValue>({
...this.options,
path: this.path as any,
path: extractJsonPath(this.path),
callback: this.effects.restart,
})
}
@@ -24,9 +25,9 @@ export class GetStore<Store, Path extends string> {
* Returns the value of Store at the provided path. Does nothing if the value changes
*/
once() {
return this.effects.store.get<Store, Path>({
return this.effects.store.get<Store, StoreValue>({
...this.options,
path: this.path as any,
path: extractJsonPath(this.path),
callback: () => {},
})
}
@@ -40,22 +41,22 @@ export class GetStore<Store, Path extends string> {
const waitForNext = new Promise<void>((resolve) => {
callback = resolve
})
yield await this.effects.store.get<Store, Path>({
yield await this.effects.store.get<Store, StoreValue>({
...this.options,
path: this.path as any,
path: extractJsonPath(this.path),
callback: () => callback(),
})
await waitForNext
}
}
}
export function getStore<Store, Path extends string>(
export function getStore<Store, StoreValue>(
effects: Effects,
path: Path & EnsureStorePath<Store, Path>,
path: PathBuilder<Store, StoreValue>,
options: {
/** Defaults to what ever the package currently in */
packageId?: string | undefined
} = {},
) {
return new GetStore<Store, Path>(effects, path as any, options)
return new GetStore<Store, StoreValue>(effects, path, options)
}