blob: 33b1bb3d37c731f707bd48d500a2fc06765da780 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
; site.clj
(ns pichat
(:import java.lang.System)
(:use compojure
clojure.contrib.json.write))
(defstruct user-struct :nick :last-seen)
(defstruct message-struct :nick :content :timestamp)
(def users (ref {}))
(def messages (ref []))
(defn resp-error [message]
{:status 400 :headers {} :body message})
(defn resp-success [message]
{:status 200 :headers {} :body (json-str message)})
(defn join-success [nick]
(alter users assoc nick (struct user-struct nick (System/currentTimeMillis)))
(let [users (keys @users)
messages (take 20 @messages)
data {"users" users "messages" messages}]
[(session-assoc :nick nick)
(resp-success data)]))
(defn try-join [params]
(let [nick (params :nick)]
(dosync
(if (contains? @users nick)
(resp-error "NICK_TAKEN")
(join-success nick)))))
(defn new-messages [since]
(reverse (take-while (fn [m] (> (m :timestamp) since)) @messages)))
(defn refresh [nick]
(dosync
(let [last-seen (get-in @users [nick :last-seen])]
(alter users assoc-in [nick :last-seen] (System/currentTimeMillis))
(resp-success {"messages" (new-messages last-seen)}))))
(defn swap [f]
(fn [& more] (apply f (reverse more))))
(defn msg [session params]
(dosync
(let [nick (session :nick)
content (params :content)
msg (struct message-struct nick content (System/currentTimeMillis))]
(if (contains? @users nick)
(do (alter messages (swap cons) msg)
(resp-success "OK"))
(resp-error "UNKNOWN_USER")))))
(defroutes pichat
(GET "/" (serve-file "static" "index.html"))
(GET "/static/*" (or (serve-file "static" (params :*))
:next))
(GET "/join" (try-join params))
(GET "/refresh" (refresh (session :nick)))
(GET "/msg" (msg session params))
(ANY "*" [404 "Page not found"]))
(decorate pichat
(with-mimetypes)
(with-session {:type :memory, :expires (* 60 60)}))
(run-server {:port 8080}
"/*" (servlet pichat))
|
