Fix schema upgrade handling

package.json

@@ -1,6 +1,6 @@
 {
   "name": "fp-ts-indexeddb",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "description": "Simple FP-TS based wrapper around indexedDB",
   "main": "dist/lib/index.js",
   "module": "dist/es2015/index.js",

src/database.ts

@@ -47,7 +47,10 @@ export const open = <StoreC extends t.Mixed>(
     const req = window.indexedDB.open(dbName, schema.version);
     req.onupgradeneeded = () => pipe(
       schema.stores,
-      R.mapWithIndex((storeName: string, v: Store<StoreC>) => req.result.createObjectStore(storeName, { keyPath: v.key }))
+      R.mapWithIndex((storeName: string, v: Store<StoreC>) => {
+        req.result.objectStoreNames.contains(storeName) && req.result.deleteObjectStore(storeName);
+        req.result.createObjectStore(storeName, { keyPath: v.key });
+      })
     );
 
     req.onsuccess = () => resolve({ database: req.result, schema: schema });
@@ -194,3 +197,5 @@ export const clearStore = <StoreC extends t.Mixed>(
     }),
     handlePromiseError,
   );
+
+export const close = <StoreC extends t.Mixed>(db: DatabaseInfo<StoreC>): void => db.database.close();

test/database.test.ts

@@ -4,6 +4,7 @@ import * as t from 'io-ts';
 
 import {
   DBSchema,
+  close,
   get,
   getAll,
   insert,
@@ -20,7 +21,7 @@ const userC = t.type({
 type UserC = typeof userC;
 type User = t.TypeOf<UserC>;
 
-const schema: DBSchema<UserC> = {
+const schema1: DBSchema<UserC> = {
   version: 1,
   stores: {
     'users': {
@@ -29,14 +30,15 @@ const schema: DBSchema<UserC> = {
     }
   }
 };
+const schema2: DBSchema<UserC> = { ...schema1, version: 2 };
 
 const dbErrorTe = TE.left(new DOMException('Error loading database'));
 
 describe('IndexedDb - Tests', () => {
   it('Crud - Functions', async () => {
     // Set Database
     await pipe(
-      open('my-db31', schema),
+      open('my-db31', schema1),
       TE.match(
         fail,
         async (db) => {
@@ -68,7 +70,7 @@ describe('IndexedDb - Tests', () => {
               (rows) => {
                 expect(rows.length).toBeGreaterThanOrEqual(1);
                 pipe(
-                  O.fromNullable(schema.stores.users?.codec),
+                  O.fromNullable(schema1.stores.users?.codec),
                   O.map((c) => {
                     expect(t.array(c).is(rows)).toBeTruthy();
                   })
@@ -107,7 +109,20 @@ describe('IndexedDb - Tests', () => {
               },
             )
           )();
+
+          close(db);
         },
+      ),
+    )();
+
+    // Upgrade schema
+    await pipe(
+      open('my-db31', schema2),
+      TE.match(
+        fail,
+        (db) => {
+          expect(db.schema.version).toEqual(schema2.version);
+        }
       )
     )();
   });