whack_http.cljs

(ns clarke-wallet.http
  (:require-macros [cljs.core.async.macros :refer [go go-loop]])
  (:require [cljs.core.async :as a]))

(def http (js/require "http"))

(defn read-json [string]
  (->> string
       (.parse js/JSON)
       (js->clj)))

(defn http-get [host port path]
  (println "HTTP Get" host path)
  (let [chan (a/chan)]
    (.get http (clj->js {:host host :path path :port port})
        (fn [response]
          (let [body (atom [])]
            (.on response "data" (fn [d]
                                   (swap! body conj d)))
            (.on response "error" (fn [e]
                                    (println e)
                                    (a/close! chan)))
            (.on response "end" (fn []
                                  (->> @body
                                       (apply str)
                                       (read-json)
                                       (a/put! chan)))))))
    chan))