transaction_data.clj

(ns de.mpg.shh.util-datomic-peer.transaction-data
  (:require [datascript.core :as ds]
            [de.mpg.shh.util-datomic-peer.impl.push :as peer-push]))

(defn push->tx-data
  ([dt-partition dt-value-type-lookup schema-map push-pattern rows]
   (let [attr-set (peer-push/push->attr-set #{} push-pattern)
         component-attrs (filter (partial peer-push/component-attr? schema-map) attr-set)
         component-attr-id-attr-map (into {} (map #(vector % (peer-push/component-attr->id-attr %)) component-attrs))]
     (push->tx-data dt-partition dt-value-type-lookup schema-map push-pattern rows component-attr-id-attr-map)))
  ([dt-partition dt-value-type-lookup schema-map push-pattern rows component-attr-id-attr-map]
   (let [schema (assoc schema-map :db/ident {:db/unique :db.unique/identity})
         datoms []
         ds-conn (ds/conn-from-db (ds/init-db datoms schema))
         attr-paths (peer-push/push->path [] [] push-pattern)
         attr-paths-lookup (into {} (map #(vector (last %) (vec (butlast %))) attr-paths))
         _ (dorun (map (partial peer-push/cache-row ds-conn attr-paths-lookup component-attr-id-attr-map) rows))]
     (peer-push/datascript->datomic-tx-data ds-conn dt-partition dt-value-type-lookup))))