From 54b1d268fa079301c9a72f76d2ac656d7d0e961b Mon Sep 17 00:00:00 2001
From: Nick Alexander <nalexander@mozilla.com>
Date: Thu, 14 Jul 2016 18:05:07 -0700
Subject: [PATCH] Process <transact! in a transaction; add hook for processing
 :db.part/db changes.

---
 src/datomish/db.cljc | 27 +++++++++++++++++++--------
 1 file changed, 19 insertions(+), 8 deletions(-)

diff --git a/src/datomish/db.cljc b/src/datomish/db.cljc
index d7e5ede7..37d630fc 100644
--- a/src/datomish/db.cljc
+++ b/src/datomish/db.cljc
@@ -327,16 +327,27 @@
                  {:error :transact/syntax, :tx-data entity})
           )))))
 
+(defn <process-db-part
+  "Transactions may add idents, install new partitions, and install new schema attributes.  Handle
+  them, atomically, here."
+  [db report]
+  (go-pair
+    nil))
+
 (defn <transact!
   ([db tx-data]
    (<transact! db tx-data nil 0xdeadbeef)) ;; TODO: timestamp!
   ([db tx-data tx-meta now]
    {:pre [(db? db)]}
-   (go-pair
-     (let [current-tx (<? (<allocate-tx db))]
-       (<? (<transact-tx-data db now
-                              (map->TxReport
-                                {:current-tx current-tx
-                                 :tx-data    []
-                                 :tempids    {}
-                                 :tx-meta    tx-meta}) tx-data))))))
+   (s/in-transaction!
+     (:sqlite-connection db)
+     #(go-pair
+        (let [current-tx (<? (<allocate-tx db))
+              report     (<? (<transact-tx-data db now
+                                                (map->TxReport
+                                                  {:current-tx current-tx
+                                                   :tx-data    []
+                                                   :tempids    {}
+                                                   :tx-meta    tx-meta}) tx-data))]
+          (<? (<process-db-part db report))
+          report)))))