                :message-type message-type
                :message-body message-body
                :envelope-id envelope-id)
-  (let [destination-node (update-in destination-node [:messages-seen envelope-id] #(if % (inc %) 1))]
+  (let [destination-node (update-in destination-node
+                                    [:messages-seen envelope-id]
+                                    #(if % (inc %) 1))]
     (if (< (get-in destination-node [:messages-seen envelope-id])
            message-dup-drop-after)
       (condp = message-type

   :config default-config
   :network {"node-id0" {:self {:id "node-id0"}
                         :downstream #{}
                         :upstream #{}}
             "node-id1" sample-node}})

(s/defn node->node-contact-address :- NodeContactAddressSchema


(def sample-node
  {:self {:id "node-id5"
          ;; :host "127.0.0.1"
          ;; :port 2005
          }

   ;; :partial-view :downstream
   ;; :local-view :downstream
   :downstream #{"node-id1" ; node-contact-address for node-id1
                 "node-id2" ; node-contact-address for node-id2
                 }

   ;; :in-view :upstream
   :upstream #{"node-id3" ; node-contact-address for node-id3
               "node-id4" ; node-contact-address for node-id4
               }
   :messages-seen {}})

(def sample-subscription-request
  {:new-node-contact-address "node-id6"
