restql.core.async-runner — b2wdigital/restql-core 2.7.1

all-done? clj

(all-done? state)

given a state with queries :done :requested and :to-do returns true if all entries are :done

all-that-can-request clj

(all-that-can-request state)

takes a state with queries :done :requested and :to-do and returns a sequence of pairs with only the queries that can be executed, because all their dependencies are already met.

Example return: ([:cart {:with ...}] [:freight {:with ...})

can-request? clj

(can-request? query-item state)

given a single query item and the map with the current results returns true if all the dependencies of the query-item are resolved

do-run clj

(do-run query {:keys [request-ch result-ch output-ch]})

it separates all queries in three states, :done :requested and :to-do then sends all to-dos to resolve, changing their statuses to :requested. As the results get ready, update the query status to :done and send all to-dos again. When all queries are :done, the process is complete, and the :done part of the state is returned.

generate-uuid! clj

(generate-uuid!)

get-status-log clj

(get-status-log uid resource result)

initialize-state clj

(initialize-state query)

is-done? clj

(is-done? [query-item-key _] state)

log-status clj

(log-status uid resource result)

make-requests clj

(make-requests do-request
               encoders
               {:keys [request-ch result-ch exception-ch]}
               {:keys [_debugging] :as query-opts})

goroutine that keeps listening from request-ch and performs http requests sending their result to result-ch

run clj

(run do-request query encoders {:keys [_debugging] :as query-opts})

update-state clj

(update-state state completed)

it passes all to-do queries that could be requested to :requested state and adds a completed request to the :done state