Merge branch 'b-3.6.1' of ../kivitendo-erp_20220811

[kivitendo-erp.git] / js / kivi.FileDB.js

diff --git a/js/kivi.FileDB.js b/js/kivi.FileDB.js
new file mode 100644 (file)
index 0000000..7ee0701
--- /dev/null
+++ b/js/kivi.FileDB.js
@@ -0,0 +1,127 @@
+namespace("kivi.FileDB", function(ns) {
+  "use strict";
+
+  const database = 'kivi';
+  const store    = 'files';
+  const db_version = 1;
+
+  // IndexedDB
+  const indexedDB = window.indexedDB || window.webkitIndexedDB || window.mozIndexedDB || window.OIndexedDB || window.msIndexedDB;
+
+  // Create/open database
+  let db;
+  let request = indexedDB.open(database, db_version);
+  request.onupgradeneeded = (event) => {
+    ns.create_image_store(event.target.result);
+  };
+  request.onerror = ns.onerror;
+  request.aftersuccess = [];
+  request.onsuccess = () => {
+    db = request.result;
+
+    db.onerror = (event) => {
+      console.error("Error creating/accessing IndexedDB database");
+      console.error(event);
+    };
+
+    // Interim solution for Google Chrome to create an objectStore. Will be deprecated
+    if (db.setVersion) {
+      if (db.version != db_version) {
+        let setVersion = db.setVersion(db_version);
+        setVersion.onsuccess = () =>  {
+          ns.create_image_store(db);
+        };
+      }
+    }
+
+    request.aftersuccess.forEach(f => f());
+  };
+
+  ns.create_image_store = function (db) {
+    db.createObjectStore(store, { autoIncrement : true });
+  };
+
+  ns.store_image = function (blob, filename, success) {
+    ns.open_rw_store((store) => {
+      let put_request = store.add(blob, filename);
+
+      put_request.onsuccess = success;
+      put_request.on_error = ns.onerror;
+    });
+  };
+
+  ns.retrieve_image = function(key, success) {
+    ns.open_ro_store((store) => {
+      let get_request = store.get(key);
+
+      get_request.onsuccess = success;
+      get_request.onerror = request.onerror;
+    });
+  };
+
+  ns.retrieve_all = function(success) {
+    ns.open_ro_store((store) => {
+      let request = store.getAll();
+      request.onsuccess = (event) => { success(event.target.result); };
+      request.onerror = ns.error;
+    });
+  };
+
+  ns.retrieve_all_keys = function(success) {
+    ns.open_ro_store((store) => {
+      let request = store.getAllKeys();
+      request.onsuccess = (event) => { success(event.target.result); };
+      request.onerror = ns.error;
+    });
+  };
+
+  ns.delete_all = function(success) {
+    ns.open_rw_store((store) => {
+      let request = store.clear();
+      request.onsuccess = success;
+      request.onerror = ns.error;
+    });
+  };
+
+  ns.delete_key = function(key, success) {
+    ns.open_rw_store((store) => {
+      let request = store.delete(key);
+      request.onsuccess = (event) => { if (success) success(event.target.result); };
+      request.onerror = ns.error;
+    });
+  };
+
+  ns.open_rw_store = function(callback) {
+    if (db && db_version == db.version) {
+      callback(ns.open_store("readwrite"));
+    } else {
+      request.aftersuccess.push(() => callback(ns.open_store("readwrite")));
+    }
+  };
+
+  ns.open_ro_store = function(callback) {
+    if (db && db_version == db.version) {
+      callback(ns.open_store("readonly"));
+    } else {
+      request.aftersuccess.push(() => callback(ns.open_store("readonly")));
+    }
+  };
+
+  ns.open_store = function(mode = "readonly") {
+    return db.transaction([store], mode).objectStore(store);
+  };
+
+  ns.onerror = (event) => {
+    console.error("Error creating/accessing IndexedDB database");
+    console.error(event.errorState);
+  };
+
+  ns.with_db = function(success) {
+    if (db && db_version == db.version) {
+      success();
+    } else {
+      // assume the page load db init isn't done yet and push it onto the success
+      request.aftersuccess.push(success);
+    }
+  };
+});