import "container/list"
import "encoding/json"
+import "flag"
import "log"
import "net/http"
+import "strconv"
import "time"
+var port = flag.Int("port", 21059, "Port to listen on")
+
type Message struct {
Time time.Time
Text string
message_count := 0
max_messages := 1000
waiting := list.New()
+main:
for {
select {
- case new_message := <-store.Add:
+ case new_message, ok := <-store.Add:
+ if !ok {
+ break main
+ }
messages.PushBack(new_message)
for waiter := waiting.Front(); waiter != nil; waiter = waiter.Next() {
waiter.Value.(*StoreRequest).Messages <- []Message{*new_message}
} else {
messages.Remove(messages.Front())
}
- case request := <-store.Get:
+ case request, ok := <-store.Get:
+ if !ok {
+ break main
+ }
if messages.Back() == nil || !request.StartTime.Before(messages.Back().Value.(*Message).Time) {
waiting.PushBack(request)
} else {
store.Add <- &Message{time.Now(), r.FormValue("text")}
})
- log.Fatal(http.ListenAndServe(":8080", nil))
+ log.Fatal(http.ListenAndServe(":" + strconv.Itoa(*port), nil))
}
func main() {