Compare commits
7 Commits
2c697b0de9
...
521802a0c1
Author | SHA1 | Date | |
---|---|---|---|
521802a0c1 | |||
091a1d3518 | |||
fd7b218dc3 | |||
0c34d521bc | |||
900e70c7f6 | |||
e03b86f007 | |||
d43f5e71db |
3
.vscode/settings.json
vendored
Normal file
3
.vscode/settings.json
vendored
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
{
|
||||||
|
"deno.enable": true
|
||||||
|
}
|
47
README.md
47
README.md
@ -1,2 +1,47 @@
|
|||||||
# Store
|
# BearMetalStore
|
||||||
|
|
||||||
|
A no-dep, lightweight, synchronous store for storing data in a JSON file.
|
||||||
|
|
||||||
|
## Usage
|
||||||
|
|
||||||
|
```ts
|
||||||
|
import { BearMetalStore } from "@bearmetal/store";
|
||||||
|
|
||||||
|
const store = new BearMetalStore();
|
||||||
|
|
||||||
|
store.set("key", "value");
|
||||||
|
|
||||||
|
console.log(store.get("key"));
|
||||||
|
|
||||||
|
store.close();
|
||||||
|
```
|
||||||
|
|
||||||
|
## API
|
||||||
|
|
||||||
|
### `new BearMetalStore(storePath?: string)`
|
||||||
|
|
||||||
|
Creates a new store.
|
||||||
|
|
||||||
|
#### Parameters
|
||||||
|
|
||||||
|
- `storePath?: string`
|
||||||
|
|
||||||
|
The path to the store file.
|
||||||
|
|
||||||
|
### Environment Variables
|
||||||
|
|
||||||
|
- `BEAR_METAL_STORE_PATH`
|
||||||
|
|
||||||
|
The path to the store file. Can be used instead of the `storePath` parameter.
|
||||||
|
If neither is provided, the store will be stored in `./BearMetal/store.json`.
|
||||||
|
|
||||||
|
### Events
|
||||||
|
|
||||||
|
The store will dispatch a custom event with the name
|
||||||
|
`"bm:refresh-store" + storePath` when the store is updated. This can be used to
|
||||||
|
trigger a refresh of the store in other parts of the application.
|
||||||
|
|
||||||
|
## Permisions
|
||||||
|
|
||||||
|
Read and write access to the store file is required. Environment access to the
|
||||||
|
"BEAR_METAL_STORE_PATH" variable is required.
|
||||||
|
15
deno.json
Normal file
15
deno.json
Normal file
@ -0,0 +1,15 @@
|
|||||||
|
{
|
||||||
|
"name": "@bearmetal/store",
|
||||||
|
"version": "0.0.5",
|
||||||
|
"description": "A simple store for storing data in a JSON file.",
|
||||||
|
"files": [
|
||||||
|
"mod.ts",
|
||||||
|
"store.ts"
|
||||||
|
],
|
||||||
|
"exports": "./mod.ts",
|
||||||
|
"imports": {
|
||||||
|
"@std/assert": "jsr:@std/assert@^1.0.6",
|
||||||
|
"@std/fs": "jsr:@std/fs@^1.0.4",
|
||||||
|
"@std/testing": "jsr:@std/testing@^1.0.3"
|
||||||
|
}
|
||||||
|
}
|
51
deno.lock
generated
Normal file
51
deno.lock
generated
Normal file
@ -0,0 +1,51 @@
|
|||||||
|
{
|
||||||
|
"version": "4",
|
||||||
|
"specifiers": {
|
||||||
|
"jsr:@std/assert@^1.0.6": "1.0.6",
|
||||||
|
"jsr:@std/data-structures@^1.0.4": "1.0.4",
|
||||||
|
"jsr:@std/fs@^1.0.4": "1.0.4",
|
||||||
|
"jsr:@std/internal@^1.0.4": "1.0.4",
|
||||||
|
"jsr:@std/path@^1.0.6": "1.0.6",
|
||||||
|
"jsr:@std/testing@^1.0.3": "1.0.3"
|
||||||
|
},
|
||||||
|
"jsr": {
|
||||||
|
"@std/assert@1.0.6": {
|
||||||
|
"integrity": "1904c05806a25d94fe791d6d883b685c9e2dcd60e4f9fc30f4fc5cf010c72207",
|
||||||
|
"dependencies": [
|
||||||
|
"jsr:@std/internal"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"@std/data-structures@1.0.4": {
|
||||||
|
"integrity": "fa0e20c11eb9ba673417450915c750a0001405a784e2a4e0c3725031681684a0"
|
||||||
|
},
|
||||||
|
"@std/fs@1.0.4": {
|
||||||
|
"integrity": "2907d32d8d1d9e540588fd5fe0ec21ee638134bd51df327ad4e443aaef07123c",
|
||||||
|
"dependencies": [
|
||||||
|
"jsr:@std/path"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"@std/internal@1.0.4": {
|
||||||
|
"integrity": "62e8e4911527e5e4f307741a795c0b0a9e6958d0b3790716ae71ce085f755422"
|
||||||
|
},
|
||||||
|
"@std/path@1.0.6": {
|
||||||
|
"integrity": "ab2c55f902b380cf28e0eec501b4906e4c1960d13f00e11cfbcd21de15f18fed"
|
||||||
|
},
|
||||||
|
"@std/testing@1.0.3": {
|
||||||
|
"integrity": "f98c2bee53860a5916727d7e7d3abe920dd6f9edace022e2d059f00d05c2cf42",
|
||||||
|
"dependencies": [
|
||||||
|
"jsr:@std/assert",
|
||||||
|
"jsr:@std/data-structures",
|
||||||
|
"jsr:@std/fs",
|
||||||
|
"jsr:@std/internal",
|
||||||
|
"jsr:@std/path"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"workspace": {
|
||||||
|
"dependencies": [
|
||||||
|
"jsr:@std/assert@^1.0.6",
|
||||||
|
"jsr:@std/fs@^1.0.4",
|
||||||
|
"jsr:@std/testing@^1.0.3"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
89
store.test.ts
Normal file
89
store.test.ts
Normal file
@ -0,0 +1,89 @@
|
|||||||
|
// deno-lint-ignore-file no-explicit-any
|
||||||
|
import { BearMetalStore } from "./store.ts";
|
||||||
|
import { assertEquals } from "@std/assert";
|
||||||
|
import {
|
||||||
|
assertSpyCall,
|
||||||
|
assertSpyCallArgs,
|
||||||
|
spy,
|
||||||
|
type SpyLike,
|
||||||
|
} from "@std/testing/mock";
|
||||||
|
import { beforeAll } from "@std/testing/bdd";
|
||||||
|
|
||||||
|
beforeAll(() => {
|
||||||
|
let store = "{}";
|
||||||
|
Deno.readTextFileSync = spy(() => store);
|
||||||
|
Deno.writeTextFileSync = spy((_, string) => store = string);
|
||||||
|
|
||||||
|
globalThis.addEventListener = spy(globalThis.addEventListener);
|
||||||
|
globalThis.removeEventListener = spy(globalThis.removeEventListener);
|
||||||
|
});
|
||||||
|
|
||||||
|
Deno.test("BearMetalStore Traditional", async (t) => {
|
||||||
|
const store = new BearMetalStore();
|
||||||
|
|
||||||
|
const listener = spy();
|
||||||
|
globalThis.addEventListener(store.EVENT_NAME, listener);
|
||||||
|
|
||||||
|
await t.step("set and get", () => {
|
||||||
|
store.set("key", "value");
|
||||||
|
assertEquals(store.get("key"), "value");
|
||||||
|
});
|
||||||
|
|
||||||
|
await t.step("write file called", () => {
|
||||||
|
assertSpyCall(Deno.writeTextFileSync as SpyLike, 0);
|
||||||
|
});
|
||||||
|
|
||||||
|
await t.step("event listener called", () => {
|
||||||
|
assertSpyCall(listener, 0);
|
||||||
|
});
|
||||||
|
|
||||||
|
await t.step("delete and get", () => {
|
||||||
|
store.delete("key");
|
||||||
|
assertEquals(store.get("key"), undefined);
|
||||||
|
});
|
||||||
|
|
||||||
|
await t.step("event listeners removed", () => {
|
||||||
|
store[Symbol.dispose]();
|
||||||
|
assertSpyCallArgs(globalThis.removeEventListener as SpyLike, 0, [
|
||||||
|
store.EVENT_NAME,
|
||||||
|
(store as any).readIn,
|
||||||
|
]);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
Deno.test("BearMetalStore `using` syntax", async (t) => {
|
||||||
|
let eventName = "";
|
||||||
|
let readIn = () => {};
|
||||||
|
{
|
||||||
|
using store = new BearMetalStore();
|
||||||
|
eventName = store.EVENT_NAME;
|
||||||
|
readIn = (store as any).readIn;
|
||||||
|
|
||||||
|
const listener = spy();
|
||||||
|
globalThis.addEventListener(store.EVENT_NAME, listener);
|
||||||
|
|
||||||
|
await t.step("set and get", () => {
|
||||||
|
store.set("key", "value");
|
||||||
|
assertEquals(store.get("key"), "value");
|
||||||
|
});
|
||||||
|
|
||||||
|
await t.step("write file called", () => {
|
||||||
|
assertSpyCall(Deno.writeTextFileSync as SpyLike, 0);
|
||||||
|
});
|
||||||
|
|
||||||
|
await t.step("event listener called", () => {
|
||||||
|
assertSpyCall(listener, 0);
|
||||||
|
});
|
||||||
|
|
||||||
|
await t.step("delete and get", () => {
|
||||||
|
store.delete("key");
|
||||||
|
assertEquals(store.get("key"), undefined);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
await t.step("event listeners removed", () => {
|
||||||
|
assertSpyCallArgs(globalThis.removeEventListener as SpyLike, 0, [
|
||||||
|
eventName,
|
||||||
|
readIn,
|
||||||
|
]);
|
||||||
|
});
|
||||||
|
});
|
99
store.ts
Normal file
99
store.ts
Normal file
@ -0,0 +1,99 @@
|
|||||||
|
import { ensureFileSync } from "@std/fs";
|
||||||
|
|
||||||
|
const REFRESH_EVENT = "bm:refresh-store";
|
||||||
|
|
||||||
|
type StoreValue = string | number | boolean;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A no-dep, lightweight, simple store for storing data in a JSON file.
|
||||||
|
* usage:
|
||||||
|
* ```ts
|
||||||
|
* import { BearMetalStore } from "@bearmetal/store";
|
||||||
|
*
|
||||||
|
* const store = new BearMetalStore();
|
||||||
|
*
|
||||||
|
* store.set("key", "value");
|
||||||
|
*
|
||||||
|
* console.log(store.get("key"));
|
||||||
|
*
|
||||||
|
* store.close();
|
||||||
|
* ```
|
||||||
|
*
|
||||||
|
* It's recommended to use the `using` syntax to ensure the store is disposed
|
||||||
|
* of when it's no longer needed.
|
||||||
|
* ```ts
|
||||||
|
* using store = new BearMetalStore();
|
||||||
|
*
|
||||||
|
* store.set("key", "value");
|
||||||
|
*
|
||||||
|
* console.log(store.get("key"));
|
||||||
|
* ```
|
||||||
|
*/
|
||||||
|
export class BearMetalStore {
|
||||||
|
private store: Record<string, string | number | boolean> = {};
|
||||||
|
private storePath: string;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @description The name of the event that is dispatched when the store is updated.
|
||||||
|
*/
|
||||||
|
public readonly EVENT_NAME: string;
|
||||||
|
|
||||||
|
constructor(storePath?: string) {
|
||||||
|
this.storePath = storePath || Deno.env.get("BEAR_METAL_STORE_PATH") ||
|
||||||
|
"./BearMetal/store.json";
|
||||||
|
|
||||||
|
ensureFileSync(this.storePath);
|
||||||
|
this.EVENT_NAME = REFRESH_EVENT + this.storePath;
|
||||||
|
this.readIn();
|
||||||
|
|
||||||
|
globalThis.addEventListener(this.EVENT_NAME, this.readIn);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param key
|
||||||
|
* @returns The value stored at the key, or undefined if the key doesn't exist.
|
||||||
|
*/
|
||||||
|
public get<T = StoreValue>(key: string): T {
|
||||||
|
return this.store[key] as T;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @description Sets the value of the key to the value.
|
||||||
|
* @param key
|
||||||
|
* @param value
|
||||||
|
*/
|
||||||
|
public set(key: string, value: StoreValue): void {
|
||||||
|
this.store[key] = value;
|
||||||
|
this.writeOut();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @description Deletes the key and its value.
|
||||||
|
* @param key
|
||||||
|
*/
|
||||||
|
public delete(key: string): void {
|
||||||
|
delete this.store[key];
|
||||||
|
this.writeOut();
|
||||||
|
}
|
||||||
|
|
||||||
|
private readIn = () => {
|
||||||
|
this.store = JSON.parse(Deno.readTextFileSync(this.storePath) || "{}");
|
||||||
|
};
|
||||||
|
|
||||||
|
private writeOut() {
|
||||||
|
Deno.writeTextFileSync(this.storePath, JSON.stringify(this.store));
|
||||||
|
globalThis.dispatchEvent(new CustomEvent(this.EVENT_NAME));
|
||||||
|
}
|
||||||
|
|
||||||
|
[Symbol.dispose]() {
|
||||||
|
this.writeOut();
|
||||||
|
globalThis.removeEventListener(this.EVENT_NAME, this.readIn);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @description Closes the store and disposes of the event listener.
|
||||||
|
*/
|
||||||
|
public close() {
|
||||||
|
this[Symbol.dispose]();
|
||||||
|
}
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user