               (is (= (count (d/q query db)) 1))))
 
           (testing "The payload node contains the other node paths"
-            (let [nodes (:nodes (extensions/read-place sync payload-node))]
+            (let [nodes (:nodes (extensions/read-place sync in-payload-node))]
               (is (= (clojure.set/difference (into #{} (keys nodes))
                                              #{:payload :ack :completion :status})
                      #{})))))
 
         (testing "Touching the ack node triggers the callback"
-          (let [nodes (:nodes (extensions/read-place sync payload-node))]
+          (let [nodes (:nodes (extensions/read-place sync in-payload-node))]
             (extensions/touch-place sync (:ack nodes))
             (let [event (<!! ack-ch-spy)]
               (= (:path event) (:ack nodes)))))


        (testing "The payload node is populated"
          (let [event (<!! sync-spy)]
            (is (= (:path event) payload-node))))

        (let [db (d/db (:conn log))]
          (testing "It receives the :in task"
            (let [task (:task (extensions/read-place sync payload-node))
                  query '[:find ?task :where [?task :task/name :in]]]
              (is (= (:db/id task) (ffirst (d/q query db))))))


        (tap (:offer-mult coordinator) offer-ch-spy)
        (tap (:completion-mult coordinator) completion-ch-spy)

        (extensions/write-place sync peer-node in-payload-node)
        (extensions/on-change sync in-payload-node #(>!! sync-spy %))

        (>!! (:born-peer-ch-head coordinator) peer-node)
        (>!! (:planning-ch-head coordinator)
