 (defn subscribe [{:keys [client-id ?data ?reply-fn] :as req}]
   (swap! issue-subs conj client-id)
   (let [issues (map issue-model/read-api (issue-model/all-issues (:db req)))]
-    (?reply-fn {:entities issues
-                :entity-type :issue})))
+    (sente-common/send-reply req {:entities issues
+                                  :entity-type :issue})))
 
 (defn unsubscribe [client-id]
   (swap! issue-subs disj client-id))

            [pc.datomic :as pcd]
            [pc.models.cust :as cust-model]
            [pc.models.issue :as issue-model]
            [pc.http.datomic2 :as datomic2])
  (:import [java.util UUID]))


                                 :cust cust
                                 :session-uuid (UUID/fromString (get-in req [:ring-req :session :sente-id]))
                                 :timestamp (:receive-instant req)})
      (sente-common/send-reply req {:rejected-datoms rejects}))
    (comment "Handle logged out users")))

(defn set-status [{:keys [client-id ?data ?reply-fn] :as req}]
