package main

import (
	"flag"
	"html/template"
	"io"
	"log"
	"net/http"
	"os"
	"time"
)

const (
	// Time allowed to write a message to the peer.
	writeWait = 10 * time.Second

	// Time allowed to read the next pong message from the peer.
	pongWait = 60 * time.Second

	// Send pings to peer with this period. Must be less than pongWait.
	pingPeriod = (pongWait * 9) / 10

	// Maximum message size allowed from peer.
	maxMessageSize = 512
)

var (
	//Info ..
	loginfo         *log.Logger
	logfatal        *log.Logger
	logFlags        = log.Ldate | log.Ltime | log.Lshortfile
	argServerPort   = flag.String("server-port", ":8000", "serverPort listener")
	connectionTable *ConnectionTable
)

func logInit(infoHandle io.Writer) {
	loginfo = log.New(infoHandle, "INFO: ", logFlags)
	logfatal = log.New(infoHandle, "FATAL : ", logFlags)
}

/*
handlerServeContent -- Handles generic URI paths /
"/" - normal client activities for websocket, marked admin=false
"/admin" - marks incoming connection as admin, however must authenticate
"/ws/client" & "/ws/admin" websocket terminations
*/
func handlerServeContent(w http.ResponseWriter, r *http.Request) {
	switch url := r.URL.Path; url {
	case "/":
		w.Header().Set("Content-Type", "text/html; charset=utf-8")
		template.Must(template.ParseFiles("html/client.html")).Execute(w, r.Host)

	case "/admin":
		w.Header().Set("Content-Type", "text/html; charset=utf-8")
		template.Must(template.ParseFiles("html/admin.html")).Execute(w, r.Host)

	case "/ws/client":
		handleConnectionWebSocket(connectionTable, w, r, false)

	case "/ws/admin":
		handleConnectionWebSocket(connectionTable, w, r, true)

	default:
		http.Error(w, "Not Found", 404)

	}
}

//launchListener - starts up http listeners and handles various URI paths
func launchListener() {
	loginfo.Println("starting Listener")

	connectionTable = newConnectionTable()
	go connectionTable.run()
	http.HandleFunc("/", handlerServeContent)

	err := http.ListenAndServeTLS(*argServerPort, "certs/fullchain.pem", "certs/privkey.pem", nil)
	if err != nil {
		logfatal.Println("ListenAndServe: ", err)
		panic(err)
	}
}

func main() {
	logInit(os.Stdout)
	loginfo.Println("startup")
	flag.Parse()
	loginfo.Println(*argServerPort)

	go launchListener()
	time.Sleep(600 * time.Second)
}