summaryrefslogtreecommitdiff
path: root/src/helsinki.at/rhrdtime
diff options
context:
space:
mode:
authorChristian Pointner <equinox@helsinki.at>2016-01-12 20:16:04 (GMT)
committerChristian Pointner <equinox@helsinki.at>2016-01-12 20:16:04 (GMT)
commitfd7510119c442f32b61745dc5cb053cf9a84e86c (patch)
treeeb97e07e56939d58f9a808204b3abac5080c25df /src/helsinki.at/rhrdtime
parent50fdce377e2f83f3d8baa11e9b742e2126313e7b (diff)
improved makefile
Diffstat (limited to 'src/helsinki.at/rhrdtime')
-rw-r--r--src/helsinki.at/rhrdtime/rhrdtime.go121
1 files changed, 0 insertions, 121 deletions
diff --git a/src/helsinki.at/rhrdtime/rhrdtime.go b/src/helsinki.at/rhrdtime/rhrdtime.go
deleted file mode 100644
index 4bdf680..0000000
--- a/src/helsinki.at/rhrdtime/rhrdtime.go
+++ /dev/null
@@ -1,121 +0,0 @@
-//
-// rhrdtime
-//
-// The Radio Helsinki Rivendell Time Websocket Server
-//
-//
-// Copyright (C) 2015 Christian Pointner <equinox@helsinki.at>
-//
-// This file is part of rhrdtime.
-//
-// rhrdtime is free software: you can redistribute it and/or modify
-// it under the terms of the GNU General Public License as published by
-// the Free Software Foundation, either version 3 of the License, or
-// any later version.
-//
-// rhrdtime is distributed in the hope that it will be useful,
-// but WITHOUT ANY WARRANTY; without even the implied warranty of
-// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-// GNU General Public License for more details.
-//
-// You should have received a copy of the GNU General Public License
-// along with rhrdtime. If not, see <http://www.gnu.org/licenses/>.
-//
-
-package main
-
-import (
- "encoding/json"
- "flag"
- "fmt"
- "net/http"
- _ "net/http/pprof"
- "time"
-
- "github.com/gorilla/websocket"
-)
-
-var (
- loc *time.Location
-)
-
-func init() {
- var err error
- if loc, err = time.LoadLocation("Europe/Vienna"); err != nil {
- fmt.Println("Error while loading loaction Europe/Vienna:", err)
- }
-}
-
-func getTZOffset(t time.Time) int {
- t = t.In(loc)
- _, offset := t.Zone()
- return offset
-}
-
-type ntpMessage struct {
- T1 int64 `json:"t1"`
- T2 int64 `json:"t2"`
- T3 int64 `json:"t3"`
- T4 int64 `json:"t4"`
- TZOffset int `json:"tz_offset"`
-}
-
-func handleNTPClient(w http.ResponseWriter, r *http.Request) {
- ws, err := websocket.Upgrade(w, r, nil, 1024, 1024)
- if _, ok := err.(websocket.HandshakeError); ok {
- http.Error(w, "Not a websocket handshake", 400)
- return
- } else if err != nil {
- fmt.Println(err)
- return
- }
- fmt.Println("Client", ws.RemoteAddr(), "connected")
-
- for {
- msgtype, msg, err := ws.ReadMessage()
- if err != nil {
- fmt.Println("Client", ws.RemoteAddr(), "disconnected:", err)
- return
- }
- now_t2 := time.Now()
- if msgtype == websocket.TextMessage {
-
- var n ntpMessage
- if err := json.Unmarshal(msg, &n); err != nil {
- fmt.Println("Ignoring malformed (", err, ") NTP message from:", ws.RemoteAddr())
- continue
- }
-
- n.T2 = (now_t2.Unix() * 1000) + int64(now_t2.Nanosecond()/1000000)
- n.TZOffset = getTZOffset(now_t2)
-
- now_t3 := time.Now()
- n.T3 = (now_t3.Unix() * 1000) + int64(now_t3.Nanosecond()/1000000)
-
- ntp_json, err := json.Marshal(n)
- if err != nil {
- fmt.Println("Error while encoding to json:", err)
- continue
- }
- if err := ws.WriteMessage(websocket.TextMessage, ntp_json); err != nil {
- fmt.Println("Client", ws.RemoteAddr(), "write error:", err)
- return
- }
- }
- }
-}
-
-func main() {
- addr_s := flag.String("addr", ":3000", "addr:port to listen on, default: ':3000'")
- help := flag.Bool("help", false, "show usage")
-
- flag.Parse()
- if *help {
- flag.Usage()
- return
- }
-
- http.HandleFunc("/ntp", handleNTPClient)
-
- http.ListenAndServe(*addr_s, nil)
-}