clj-browserchannel/chat-demo/src/chat_demo/server.clj

(ns chat-demo.server
  (:gen-class)
  (:require
    [compojure.core :refer [routes GET]]
    [compojure.route :as route]
    [ring.middleware.defaults :refer [wrap-defaults site-defaults]]
    [ring.util.response :refer [response]]
    [clj-pebble.core :as pebble]
    [net.thegeez.browserchannel :as browserchannel]
    [net.thegeez.jetty-async-adapter :as jetty]
    [clj-browserchannel-immutant-adapter.core :as immutant]
    [environ.core :refer [env]]))

(defonce clients (atom #{}))

(defn on-browserchannel-session
  [session-id request]
  (println "session " session-id "connected")

  (browserchannel/add-listener
    session-id
    :close
    (fn [request reason]
      (println "session " session-id " disconnected: " reason)
      (swap! clients disj session-id)
      (doseq [client-id @clients]
        (browserchannel/send-map client-id {"msg" (str "client " session-id " disconnected " reason)}))))

  (browserchannel/add-listener
    session-id
    :map
    (fn [request map]
      (println "session " session-id " sent " map)
      (doseq [client-id @clients]
        (browserchannel/send-map client-id map))))

  (swap! clients conj session-id)
  (doseq [client-id @clients]
    (browserchannel/send-map client-id {"msg" (str "client " session-id " connected")})))

(def app-routes
  (routes
    (GET "/" [] (pebble/render-resource "html/index.html" {:dev (boolean (env :dev))}))
    (route/resources "/")
    (route/not-found "not found")))

(def handler
  (-> app-routes
      (browserchannel/wrap-browserchannel {:base "/channel" :on-session on-browserchannel-session})
      (wrap-defaults (assoc-in site-defaults [:security :anti-forgery] false))))

(defn run-jetty []
  (println "Using Jetty adapter")
  (jetty/run-jetty-async
    #'handler
    {:join? false
     :port  8080}))

(defn run-immutant []
  (println "Using Immutant adapter")
  (immutant/run-immutant
    #'handler
    {:port 8080}))

(defn -main [& args]
  (if (env :dev) (pebble/set-options! :cache false))

  ;(run-jetty)
  (run-immutant)

  )