Fix for firefox

mascara/src/lib/index-db-controller.js

@@ -1,39 +1,20 @@
+// module.exports =
 const EventEmitter = require('events')
 module.exports = class IndexDbController extends EventEmitter {
 
   constructor (opts) {
     super()
+    global.IDBTransaction = global.IDBTransaction || global.webkitIDBTransaction || global.msIDBTransaction || {READ_WRITE: "readwrite"}; // This line should only be needed if it is needed to support the object's constants for older browsers
+    global.IDBKeyRange = global.IDBKeyRange || global.webkitIDBKeyRange || global.msIDBKeyRange
     this.migrations = opts.migrations
     this.key = opts.key
-    this.dbObject = global.indexedDB
-    this.IDBTransaction = global.IDBTransaction || global.webkitIDBTransaction || global.msIDBTransaction || {READ_WRITE: "readwrite"}; // This line should only be needed if it is needed to support the object's constants for older browsers
-    this.IDBKeyRange = global.IDBKeyRange || global.webkitIDBKeyRange || global.msIDBKeyRange;
     this.version = opts.version
-    this.logging = opts.logging
     this.initialState = opts.initialState
-    if (this.logging) this.on('log', logger)
   }
 
   // Opens the database connection and returns a promise
   open (version = this.version) {
-    return new Promise((resolve, reject) => {
+    return this.get('dataStore')
-      const dbOpenRequest = this.dbObject.open(this.key, version)
-      dbOpenRequest.onerror = (event) => {
-        return reject(event)
-      }
-      dbOpenRequest.onsuccess = (event) => {
-        this.db = dbOpenRequest.result
-        this.emit('success')
-        resolve(this.db)
-      }
-      dbOpenRequest.onupgradeneeded = (event) => {
-        this.db = event.target.result
-        this.db.createObjectStore('dataStore')
-      }
-    })
-    .then((openRequest) => {
-      return this.get('dataStore')
-    })
     .then((data) => {
       if (!data) {
         return this._add('dataStore', this.initialState)
@@ -44,45 +25,48 @@ module.exports = class IndexDbController extends EventEmitter {
     })
   }
 
-  requestObjectStore (key, type = 'readonly') {
-    return new Promise((resolve, reject) => {
-      const dbReadWrite = this.db.transaction(key, type)
-      const dataStore = dbReadWrite.objectStore(key)
-      resolve(dataStore)
-    })
-  }
 
   get (key = 'dataStore') {
-    return this.requestObjectStore(key)
+    return this._request('get', key)
-    .then((dataObject)=> {
-        return new Promise((resolve, reject) => {
-        const getRequest = dataObject.get(key)
-        getRequest.onsuccess = (event) => resolve(event.currentTarget.result)
-        getRequest.onerror = (event) => reject(event)
-      })
-    })
   }
-
   put (state) {
-    return this.requestObjectStore('dataStore', 'readwrite')
+    return this._request('put', state, 'dataStore')
-    .then((dataObject)=> {
-      const putRequest = dataObject.put(state, 'dataStore')
-      putRequest.onsuccess = (event) => Promise.resolve(event.currentTarget.result)
-      putRequest.onerror = (event) => Promise.reject(event)
-    })
   }
 
-  _add (key, objStore, cb = logger) {
+  _add (key = 'dataStore', objStore) {
-    return this.requestObjectStore(key, 'readwrite')
+    return this._request('add', objStore, key)
-    .then((dataObject)=> {
-      const addRequest = dataObject.add(objStore, key)
-      addRequest.onsuccess = (event) => Promise.resolve(event.currentTarget.result)
-      addRequest.onerror = (event) => Promise.reject(event)
-    })
   }
 
-}
+  _request (call, ...args) {
+    return new Promise((resolve, reject) => {
+      const self = this
+      const dbOpenRequest = global.indexedDB.open(this.key, this.version)
+
+      dbOpenRequest.onupgradeneeded = (event) => {
+        this.db = event.target.result
+        this.db.createObjectStore('dataStore')
+      }
 
-function logger (err, ress) {
+      dbOpenRequest.onsuccess = (event) => {
-  err ? console.error(`Logger says: ${err}`) : console.dir(`Logger says: ${ress}`)
+        this.db = dbOpenRequest.result
+        this.emit('success')
+        const dbTransaction = this.db.transaction('dataStore', 'readwrite')
+        const request = dbTransaction.objectStore('dataStore')
+        const objRequest = request[call](...args)
+        objRequest.onsuccess = (event) => {
+          return resolve(objRequest.result)
+        }
+        objRequest.onerror = (err) => {
+          return reject(err.message)
+        }
+        dbTransaction.oncomplete = (event) => {
+          this.emit('complete')
+        }
+      }
+
+      dbOpenRequest.onerror = (event) => {
+        return reject(event)
+      }
+    })
+  }
 }