|
1 | 1 | import clone from 'clone'; |
2 | | -import { TimedValue } from './models/TimedKeyValueStore'; |
3 | | -import { TimedTypedKeyValueStore } from './models/TimedTypedKeyValueStore'; |
| 2 | +import { KeyValueStore } from './models/KeyValueStore'; |
| 3 | +import { TypedKeyValueStore } from './models/TypedKeyValueStore'; |
4 | 4 |
|
5 | 5 | /** |
6 | 6 | * A {@link KeyValueStore} which uses a JavaScript Map for internal storage. |
7 | 7 | * |
8 | 8 | * @inheritdoc |
9 | 9 | */ |
10 | | -export class MemoryStore<M> implements TimedTypedKeyValueStore<M> { |
| 10 | +export class MemoryStore<M> implements TypedKeyValueStore<M> { |
11 | 11 |
|
12 | | - private readonly data: Map<keyof M, TimedValue<M[keyof M]>>; |
| 12 | + private readonly data: Map<keyof M, M[keyof M]>; |
13 | 13 |
|
14 | 14 | /** |
15 | 15 | * |
16 | 16 | * @param initialData data to initialize the memorystore with @range {json} |
17 | 17 | */ |
18 | 18 | constructor(initialData?: [keyof M, M[keyof M]][]) { |
19 | 19 |
|
20 | | - this.data = new Map(initialData?.map(([ key, value ]) => [ key, { value: clone(value), timestamp: Date.now() } ])); |
| 20 | + this.data = new Map(initialData?.map(([ key, value ]) => [ key, clone(value) ])); |
21 | 21 |
|
22 | 22 | } |
23 | 23 |
|
24 | | - get<T extends keyof M>(key: T): Promise<M[T] | undefined> { |
25 | | - |
26 | | - // eslint-disable-next-line @typescript-eslint/consistent-type-assertions |
27 | | - return Promise.resolve(this.data.has(key) ? clone(this.data.get(key)?.value as M[T]) : undefined); |
28 | | - |
| 24 | + public async get<T extends keyof M>(key: T): Promise<M[T] | undefined> { |
| 25 | + return this.data.has(key) ? clone(this.data.get(key) as M[T]) : undefined; |
29 | 26 | } |
30 | 27 |
|
31 | | - has<T extends keyof M>(key: T): Promise<boolean> { |
32 | | - |
| 28 | + public async has<T extends keyof M>(key: T): Promise<boolean> { |
33 | 29 | return Promise.resolve(this.data.has(key)); |
34 | | - |
35 | 30 | } |
36 | 31 |
|
37 | | - set<T extends keyof M>(key: T, value: M[T]): Promise<this> { |
38 | | - |
39 | | - this.data.set(key, { value: clone(value), timestamp: Date.now() }); |
40 | | - |
| 32 | + public async set<T extends keyof M>(key: T, value: M[T]): Promise<this> { |
| 33 | + this.data.set(key, clone(value)); |
41 | 34 | return Promise.resolve(this); |
42 | | - |
43 | 35 | } |
44 | 36 |
|
45 | | - delete<T extends keyof M>(key: T): Promise<boolean> { |
46 | | - |
| 37 | + public async delete<T extends keyof M>(key: T): Promise<boolean> { |
47 | 38 | return Promise.resolve(this.data.delete(key)); |
48 | | - |
49 | 39 | } |
50 | 40 |
|
51 | 41 | // eslint-disable-next-line @typescript-eslint/require-await |
52 | | - async* entries(): AsyncIterableIterator<[keyof M, M[keyof M]]> { |
53 | | - |
| 42 | + public async* entries(): AsyncIterableIterator<[keyof M, M[keyof M]]> { |
54 | 43 | for (const [ key, value ] of this.data.entries()) { |
55 | | - |
56 | | - yield [ key, clone(value.value) ]; |
57 | | - |
| 44 | + yield [ key, clone(value) ]; |
58 | 45 | } |
59 | | - |
60 | | - } |
61 | | - |
62 | | - latestUpdate<T extends keyof M>(key: T): Promise<number | undefined> { |
63 | | - |
64 | | - return Promise.resolve(this.data.get(key)?.timestamp); |
65 | | - |
66 | 46 | } |
67 | | - |
68 | | - hasUpdate <T extends keyof M>(key: T, time: number): Promise<boolean | undefined> { |
69 | | - |
70 | | - const timedValue = this.data.get(key); |
71 | | - |
72 | | - return Promise.resolve(timedValue ? timedValue.timestamp > time : undefined); |
73 | | - |
74 | | - } |
75 | | - |
76 | 47 | } |
0 commit comments