   [world :- WorldSchema
    self :- NetworkedNodeSchema
    f & args]
-  (let [self-id (get-in self [:self :id])]
+  (let [self-id (networked-node->node-contact-address self)]
     (update-in world
                [:network self-id]
                #(apply f % args))))

               :unsubscribing-node-id unsubscribing-node-id
               :connection-redundancy connection-redundancy)

  (let [get-node-id #(get-in % [:self :id])
        node-id (get-node-id node)]

    (when (not= node-id unsubscribing-node-id)
      ;; TODO: Be more resiliant.

               :receive-msg-forwarded-subscription
               :node node
               :subscriber-contact-address subscriber-contact-address)
  (let [self-id (networked-node->node-contact-address node)]
    (if (and (not= self-id subscriber-contact-address)
             (not (downstream subscriber-contact-address))
             ;; The subscription id is not for this node itself, and
