which-op-failed.clj

which-op-failed.clj

(def n (xt/start-node {}))

(xt/submit-tx n [[::xt/put {:xt/id :a :foo :bar}]])

(defn with-tx-failed? [db ops]
  (nil? (xt/with-tx db ops)))

(xt/q (xt/db n (xt/latest-completed-tx n))
      '{:find [ops]
        :in [[ops ...]]
        :where [[(dev/with-tx-failed? $ ops)]]}
      [[[::xt/put {:xt/id :a :foo :bar}]]
       [[::xt/match :b {:xt/id :b}] [::xt/put {:xt/id :b :foo :bar}]]
       [[::xt/match :c nil] [::xt/put {:xt/id :c :foo :bar}]]])
;;=> #{[[[:xtdb.api/match :b #:xt{:id :b}] [:xtdb.api/put {:foo :bar, :xt/id :b}]]]}