clock.go

package katamari

import (
	"errors"
	"fmt"
	"net/http"
	"strconv"
	"time"
)

// Time returns a string timestamp
func Time() string {
	now := time.Now().UTC().UnixNano()
	return strconv.FormatInt(now, 10)
}

func (app *Server) sendTime() {
	app.Stream.BroadcastClock(Time())
}

func (app *Server) tick() {
	ticker := time.NewTicker(app.Tick)
	for {
		<-ticker.C
		if app.Active() {
			app.sendTime()
			continue
		}

		return
	}
}

func (app *Server) clock(w http.ResponseWriter, r *http.Request) {
	if !app.Audit(r) {
		w.WriteHeader(http.StatusUnauthorized)
		fmt.Fprintf(w, "%s", errors.New("katamari: this request is not authorized"))
		app.Console.Err("socketConnectionUnauthorized time")
		return
	}

	client, err := app.Stream.New("", w, r)
	if err != nil {
		return
	}

	go app.Stream.WriteClock(client, Time())
	app.Stream.Read("", client)
}