main.clj

(ns mailers.main
  (:gen-class)
  (:require [com.stuartsierra.component :as c]
            [aleph.http                 :as aleph]
            [manifold.stream            :as mani]
            [ring.util.response         :as response]
            [ring.middleware.file-info  :only [wrap-file-info]]
            [ring.middleware.resource   :refer [wrap-resource]]))


(defn handle-message [s msg]
  (mani/put! s msg))

(defn root-handler [req]
  (if-let [s @(aleph/websocket-connection req)]
    (mani/consume (partial handle-message s) s)
    (resource/resource-response "index.html" {:root "public"})))

(defn ring-app []
  (-> (aleph/wrap-aleph-handler root-handler)
    (wrap-resource "public")
    wrap-file-info))


(defrecord WebserverComponent []
  c/Lifecycle

  (start [c]
    (-> (aleph/wrap-ring-handler ring-app)
      (aleph/start-server {:port port})
      ((partial assoc c :web))))

  (stop [c]
    (.close (:web c))
    (dissoc c :web)))


(defn -main [& args]
  (println args))