|
1 | 1 | import { StoreAdapter } from '../../domain'; |
2 | 2 |
|
| 3 | +type kvStores = 'sdk-kv-store' | 'key-value-pairs'; |
| 4 | + |
3 | 5 | export class StoreAdapterWeb extends StoreAdapter { |
| 6 | + static readonly stores: kvStores[] = ['sdk-kv-store', 'key-value-pairs']; |
| 7 | + static readonly DB_NAME = 'mmsdk'; |
| 8 | + |
4 | 9 | readonly platform = 'web'; |
| 10 | + readonly dbPromise: Promise<IDBDatabase>; |
5 | 11 |
|
6 | 12 | private get internal() { |
7 | | - if (typeof window === 'undefined' || !window.localStorage) { |
8 | | - throw new Error('localStorage is not available in this environment'); |
| 13 | + if (typeof window === 'undefined' || !window.indexedDB) { |
| 14 | + throw new Error('indexedDB is not available in this environment'); |
9 | 15 | } |
10 | | - return window.localStorage; |
| 16 | + return window.indexedDB; |
| 17 | + } |
| 18 | + |
| 19 | + constructor( |
| 20 | + dbNameSuffix: `-${string}` = '-kv-store', |
| 21 | + private storeName: kvStores = StoreAdapterWeb.stores[0], |
| 22 | + ) { |
| 23 | + super(); |
| 24 | + |
| 25 | + const dbName = `${StoreAdapterWeb.DB_NAME}${dbNameSuffix}`; |
| 26 | + this.dbPromise = new Promise((resolve, reject) => { |
| 27 | + try { |
| 28 | + const request = this.internal.open(dbName, 1); |
| 29 | + request.onerror = () => reject(new Error('Failed to open IndexedDB.')); |
| 30 | + request.onsuccess = () => resolve(request.result); |
| 31 | + request.onupgradeneeded = () => { |
| 32 | + const db = request.result; |
| 33 | + for (const name of StoreAdapterWeb.stores) { |
| 34 | + if (!db.objectStoreNames.contains(name)) { |
| 35 | + db.createObjectStore(name); |
| 36 | + } |
| 37 | + } |
| 38 | + }; |
| 39 | + } catch (error) { |
| 40 | + reject(error); |
| 41 | + } |
| 42 | + }); |
11 | 43 | } |
| 44 | + |
12 | 45 | async get(key: string): Promise<string | null> { |
13 | | - return this.internal.getItem(key); |
| 46 | + const { storeName } = this; |
| 47 | + const db = await this.dbPromise; |
| 48 | + return new Promise((resolve, reject) => { |
| 49 | + try { |
| 50 | + const tx = db.transaction(storeName, 'readonly'); |
| 51 | + const store = tx.objectStore(storeName); |
| 52 | + const request = store.get(key); |
| 53 | + request.onerror = () => reject(new Error('Failed to get value from IndexedDB.')); |
| 54 | + request.onsuccess = () => resolve((request.result as string) ?? null); |
| 55 | + } catch (error) { |
| 56 | + reject(error); |
| 57 | + } |
| 58 | + }); |
14 | 59 | } |
15 | 60 |
|
16 | 61 | async set(key: string, value: string): Promise<void> { |
17 | | - return this.internal.setItem(key, value); |
| 62 | + const { storeName } = this; |
| 63 | + const db = await this.dbPromise; |
| 64 | + return new Promise((resolve, reject) => { |
| 65 | + try { |
| 66 | + const tx = db.transaction(storeName, 'readwrite'); |
| 67 | + const store = tx.objectStore(storeName); |
| 68 | + const request = store.put(value, key); |
| 69 | + request.onerror = () => reject(new Error('Failed to set value in IndexedDB.')); |
| 70 | + request.onsuccess = () => resolve(); |
| 71 | + } catch (error) { |
| 72 | + reject(error); |
| 73 | + } |
| 74 | + }); |
18 | 75 | } |
19 | 76 |
|
20 | 77 | async delete(key: string): Promise<void> { |
21 | | - return this.internal.removeItem(key); |
| 78 | + const { storeName } = this; |
| 79 | + const db = await this.dbPromise; |
| 80 | + return new Promise((resolve, reject) => { |
| 81 | + try { |
| 82 | + const tx = db.transaction(storeName, 'readwrite'); |
| 83 | + const store = tx.objectStore(storeName); |
| 84 | + const request = store.delete(key); |
| 85 | + request.onerror = () => reject(new Error('Failed to delete value from IndexedDB.')); |
| 86 | + request.onsuccess = () => resolve(); |
| 87 | + } catch (error) { |
| 88 | + reject(error); |
| 89 | + } |
| 90 | + }); |
22 | 91 | } |
23 | 92 | } |
0 commit comments