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

  (with-system
    (fn [coordinator sync log]
      (let [peer-node (extensions/create sync :peer)
            payload-node (extensions/create sync :payload)
            sync-spy (chan 1)
            ack-ch-spy (chan 1)
            offer-ch-spy (chan 1)

              (is (= (count (d/q query db)) 1))))

          (testing "The payload node contains the other node paths"
            (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 in-payload-node))]
            (extensions/touch-place sync (:ack nodes))
            (let [event (<!! ack-ch-spy)]
              (= (:path event) (:ack nodes)))))
