diff --git a/src/main/frontend/db_worker.cljs b/src/main/frontend/db_worker.cljs index 8b0be234b9..062e2fbdee 100644 --- a/src/main/frontend/db_worker.cljs +++ b/src/main/frontend/db_worker.cljs @@ -15,19 +15,27 @@ (defonce *sqlite (atom nil)) (defonce *sqlite-conns (atom nil)) -(defonce *datascript-conn (atom nil)) -(defonce *opfs-pool (atom nil)) +(defonce *datascript-conns (atom nil)) +(defonce *opfs-pools (atom nil)) (defn- get-sqlite-conn [repo] (get @*sqlite-conns repo)) +(defn get-datascript-conn + [repo] + (get @*datascript-conns repo)) + +(defn get-opfs-pool + [repo] + (get @*opfs-pools repo)) + (defn- vec [iter] @@ -226,7 +236,7 @@ (transact [_this repo tx-data tx-meta] - (when-let [conn @*datascript-conn] + (when-let [conn (get-datascript-conn repo)] (try (let [tx-data (edn/read-string tx-data) tx-meta (edn/read-string tx-meta)] @@ -238,7 +248,7 @@ (getInitialData [_this repo] - (when-let [conn @*datascript-conn] + (when-let [conn (get-datascript-conn repo)] (let [db @conn] (->> (d/datoms db :eavt) vec