lazy-authz-subquery-with-limit

lazy-authz-subquery-with-limit.clj

(defn authz-subquery [db q authz-q]
  (let [limit (:limit q)
        q (dissoc q :limit)]
    (with-open [qi (xt/open-q db q)]
      (->> (iterator-seq qi)
           (map first)
           (xt/q db authz-q)
           (keep seq)
           (map first)
           (distinct)
           (take limit)
           doall))))

(def n (xt/start-node {}))
(->> [[::xt/put {:xt/id :foo :a "string"}]
      [::xt/put {:xt/id :bar :a "string2"}]]
     (xt/submit-tx n)
     (xt/await-tx n))
(xt/q (xt/db n) '{:find [e]
                  :where [[(dev/authz-subquery $
                                               {:find [e]
                                                :limit 2
                                                :where [[e :a s]]}
                                               {:find [e]
                                                :in [[e ...]]
                                                :where [[e :a s]
                                                        [(clojure.string/starts-with? s "string")]]})
                           [e ...]]]})