   "
   (:require [clojure.string :as str]
             [taoensso.timbre :as timbre]
-            [schema.core :as s]))
+            [schema.core :as s]
+            [scamp.util :as util]))
 
 (s/set-fn-validation! true)
 

                                  [(assoc node
                                          :send-next-heartbeats-milli-time
                                          (+ milli-time heartbeat-interval-in-millis))
                                   (concatv msgs
                                           (mapv #(msg->envelope %
                                                                 :heartbeat
                                                                 this-node-contact-address)

               :receive-msg-node-unsubscription
               :replacement-messages replacement-messages
               :drop-me-msgs drop-me-msgs)
      [(node->removed node) (util/concatv replacement-messages drop-me-msgs)])))

(s/defmethod receive-msg :node-removal :- CommUpdateSchema
  #_"Take 'config, a 'node, and the contact address of a
