From c4c50565b6d96d65ba1e44636c94af1b5fdd33ef Mon Sep 17 00:00:00 2001 From: Jeremy Dormitzer Date: Sun, 18 Feb 2018 09:13:08 -0500 Subject: [PATCH] Implement a wrapper around IndexedDB --- src/lib/looped_in/indexeddb.cljs | 143 +++++++++++++++++++++++++++++++ 1 file changed, 143 insertions(+) create mode 100644 src/lib/looped_in/indexeddb.cljs diff --git a/src/lib/looped_in/indexeddb.cljs b/src/lib/looped_in/indexeddb.cljs new file mode 100644 index 0000000..815cbe4 --- /dev/null +++ b/src/lib/looped_in/indexeddb.cljs @@ -0,0 +1,143 @@ +(ns looped-in.indexeddb + (:require [cljs.core.async :refer [go chan >!]] + [looped-in.logging :as log])) + +(defn add-data + "Adds data to IndexedDB" + [db object-store data] + (let [channel (chan) + transaction (.transaction db (clj->js [object-store]) "readwrite") + store (.objectStore transaction object-store) + data-coll (if (coll? data) data [data])] + (doseq [datum data-coll] + (.add store datum)) + (set! (.-onerror transaction) + (fn [event] (log/error "Error adding data to IndexedDB: " + (.-errorCode (.-target event))))) + (set! (.-oncomplete transaction) + (fn [event] (go (>! channel (.-result (.-target event)))))) + channel)) + +(defn get-data + "Gets data from IndexedDB." + [db object-store index] + (let [channel (chan) + request (-> db + (.transaction (clj->js [object-store])) + (.objectStore objectStore) + (.get index))] + (set! (.-onerror request) + (fn [event] (log/error "Error getting data from IndexedDB: " + (.-errorCode (.-target event))))) + (set! (.-onsuccess request) + (fn [event] (go (>! channel (.-result (.-target event)))))) + channel)) + +(defn update-data + "Updates data in IndexedDB. + `updated-values` is map of key-value pairs to update. It does not need to contain + every field in the object schema, just those to update." + [db object-store index updated-values] + (let [channel (chan) + store (-> db + (.transaction (clj->js [object-store]) "readwrite") + (.objectStore object-store)) + get-request (.get store index)] + (set! (.-onerror get-request) + (fn [event] (log/error "Error getting data from IndexedDB: " + (.-errorCode (.-target event))))) + (set! (.-onsuccess get-request) + (fn [event] + (let [data (js->clj (.-result (.-target event)) :keywordize-keys true) + update-request (.put store (clj->js (merge data updated-values)))] + (set! (.-onerror update-request) + (fn [event] (log/error "Error updating data in IndexedDB: " + (.-errorCode (.-target event))))) + (set! (.-onsuccess update-request) + (fn [event] (go (>! channel (.-result (.-target event))))))))) + channel)) + +(defn delete-data + "Deletes data from IndexedDB" + [db object-store index] + (let [channel (chan) + request (-> db + (.transaction (clj->js [object-store]) "readwrite") + (.objectStore object-store) + (.delete index))] + (set! (.onerror request) + (fn [event] (log/error "Error deleting data from IndexedDB: " + (.-errorCode (.-target event))))) + (set! (.onsuccess request) + (fn [event] (go (>! channel (.-result (.-target event)))))) + channel)) + +(defn open-database + "Opens an IndexedDB database. + The database should have already been created." + ([name] (open-database name 1)) + ([name version] + (let [channel (chan) + request (.open js/window.indexedDB name version)] + (set! (.-onerror request) + (fn [event] (log/error "Error opening IndexedDB: " + (.-errorCode (.-target event))))) + (set! (.-onsuccess request) + (fn [event] (go (>! channel (.-result (.-target event)))))) + channel))) + +(defn create-database + "Creates an IndexedDB database and returns a channel that resolves with a database instance. + If the database has already been created with the specified version, + just opens the existing one. `object-stores` is a sequence of object + store maps created via `looped-in.indexeddb/create-object-store`." + ([name object-stores] + (create-database name 1 object-stores)) + ([name version object-stores] + (let [channel (chan) + request (.open js/window.indexedDB name version)] + (set! (.-onerror request) + (fn [event] + (log/error "Error opening IndexedDB: " + (.-errorCode (.-target event))))) + (set! (.-onupgradeneeded request) + (fn [event] + (let [db (.-result (.-target event))] + (doseq [object-store object-stores] + (let [store (.createObjectStore db + (:name object-store) + (clj->js + {:key-path + (:key-path object-store) + :auto-increment + (:auto-increment? object-store)}))] + (doseq [index (:indices object-store)] + (.createIndex store + (:name index) + (:key-path index) + (clj->js (:opts index))))))))) + (set! (.-onsuccess request) + (go (>! channel (.-result (.-target event))))) + channel))) + +(defn create-object-store + "Creates an object store data structure. + `indices` is a sequence of index maps + created via `looped-in.indexeddb/create-index`." + ([store-name key-path] + (create-object-store store-name key-path [])) + ([store-name key-path indices] + (create-object-store store-name key-path indices false)) + ([store-name key-path indices auto-increment?] + {:name store-name :key-path key-path :indices indices :auto-increment? auto-increment?})) + +(defn create-index + "Creates an index for use with `looped-in.indexeddb/create-object-store`. + `opts` is a map of options. Valid keys are :unique and :multi-entry, as + documented at https://developer.mozilla.org/en-US/docs/Web/API/IDBObjectStore/createIndex." + ([name] + (create-index name name)) + ([name key-path] + (create-index name key-path {})) + ([name key-path opts] + {:name name :key-path key-path :opts opts}))