wip

Author: silesky

packages/signals/signals/src/core/buffer/index.ts

@@ -25,14 +25,14 @@ interface IDBPObjectStoreSignals
     'readonly' | 'readwrite' | 'versionchange'
   > {}
 
-export class SignalStore implements SignalPersistentStorage {
+export class SignalStoreIndexDB implements SignalPersistentStorage {
   static readonly DB_NAME = 'Segment Signals Buffer'
   static readonly STORE_NAME = 'signals'
   private db: Promise<IDBPDatabaseSignals>
   private maxBufferSize: number
   private sessionKeyStorage = new WebStorage(window.sessionStorage)
   static deleteDatabase() {
-    return indexedDB.deleteDatabase(SignalStore.DB_NAME)
+    return indexedDB.deleteDatabase(SignalStoreIndexDB.DB_NAME)
   }
 
   async getStore(
@@ -41,8 +41,8 @@ export class SignalStore implements SignalPersistentStorage {
   ): Promise<IDBPObjectStoreSignals> {
     const db = database ?? (await this.db)
     const store = db
-      .transaction(SignalStore.STORE_NAME, permission)
-      .objectStore(SignalStore.STORE_NAME)
+      .transaction(SignalStoreIndexDB.STORE_NAME, permission)
+      .objectStore(SignalStoreIndexDB.STORE_NAME)
     return store
   }
 
@@ -52,9 +52,11 @@ export class SignalStore implements SignalPersistentStorage {
   }
 
   private async initSignalDB(): Promise<IDBPDatabaseSignals> {
-    const db = await openDB<SignalDatabase>(SignalStore.DB_NAME, 1, {
+    const db = await openDB<SignalDatabase>(SignalStoreIndexDB.DB_NAME, 1, {
       upgrade(db) {
-        db.createObjectStore(SignalStore.STORE_NAME, { autoIncrement: true })
+        db.createObjectStore(SignalStoreIndexDB.STORE_NAME, {
+          autoIncrement: true,
+        })
       },
     })
     logger.debug('Signals Buffer (indexDB) initialized')
@@ -171,6 +173,6 @@ export const getSignalBuffer = <
 >(
   settings: SignalBufferSettingsConfig<T>
 ) => {
-  const store = settings.signalStorage ?? new SignalStore(settings)
+  const store = settings.signalStorage ?? new SignalStoreIndexDB(settings)
   return new SignalBuffer(store)
 }