 
             (loop [payload-node payload]
               (<! sync-spy)
-              (prn peer)
 
               (let [nodes (:nodes (extensions/read-place sync-storage payload-node))]
                 (extensions/on-change sync-storage (:status nodes) #(go (>! status-spy %)))

(def sync-storage (:sync components))

(def log (:log components))

(def offer-spy (chan 1000))



(start-peers! peers)

(testing "All 30 tasks complete"
  (loop []
    (let [db (:db-after (.take tx-queue))
          query '[:find (count ?task) :where [?task :task/complete? true]]
          result (ffirst (d/q query db))]
      (when-not (= result 30)
        (recur)))))

(let [db (d/db (:conn log))]
  (testing "No tasks are left incomplete"
    (let [query '[:find (count ?task) :where [?task :task/complete? false]]
          result (ffirst (d/q query db))]
