From 972f8409940fc132d42e80fb2273c01405e95696 Mon Sep 17 00:00:00 2001
From: Steve <stryan@saintnet.tech>
Date: Fri, 1 Oct 2021 14:24:31 -0400
Subject: [PATCH] initial migration

---
 go.mod    |  9 ++++++++
 go.sum    | 11 ++++++++++
 main.go   | 11 ++++++++++
 server.go | 62 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 4 files changed, 93 insertions(+)
 create mode 100644 go.mod
 create mode 100644 go.sum
 create mode 100644 main.go
 create mode 100644 server.go

diff --git a/go.mod b/go.mod
new file mode 100644
index 0000000..06fdeb3
--- /dev/null
+++ b/go.mod
@@ -0,0 +1,9 @@
+module git.saintnet.tech/tomecraft/tome_ws
+
+go 1.16
+
+require (
+	git.saintnet.tech/tomecraft/tome_lib v0.1.2 // indirect
+	git.saintnet.tech/tomecraft/tome_server v0.1.0 // indirect
+	github.com/gorilla/websocket v1.4.2 // indirect
+)
diff --git a/go.sum b/go.sum
new file mode 100644
index 0000000..aaf7fda
--- /dev/null
+++ b/go.sum
@@ -0,0 +1,11 @@
+git.saintnet.tech/tomecraft/tome_game v0.0.0-20211001174426-36013e0b8925 h1:Td26lWIzlTTMEjarvtk/+uEBRaSfXp7zLP5Ynnpovfk=
+git.saintnet.tech/tomecraft/tome_game v0.0.0-20211001174426-36013e0b8925/go.mod h1:mwjKGgwOXGgviCbrtgk0yFRVyIwi8LQWELIOQfV2KlE=
+git.saintnet.tech/tomecraft/tome_lib v0.1.1/go.mod h1:Jekqa9ojNDOrcO1aL0IWKuhCQSE5+MNHVcYtTWA6uko=
+git.saintnet.tech/tomecraft/tome_lib v0.1.2 h1:S2BHgsWBGFv9fy+qBHuKXv0kcjT7VP/7gDmJHje/+RQ=
+git.saintnet.tech/tomecraft/tome_lib v0.1.2/go.mod h1:Jekqa9ojNDOrcO1aL0IWKuhCQSE5+MNHVcYtTWA6uko=
+git.saintnet.tech/tomecraft/tome_server v0.1.0 h1:tnwCCPai6+SOu/AzJa4ePuYyYrn/yrkHr3bCS0b/Dnc=
+git.saintnet.tech/tomecraft/tome_server v0.1.0/go.mod h1:ciBGZtw0LVnGd/pZSYqiWRZJ9eGjswt62xbSrPM7G5Y=
+github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
+github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/gorilla/websocket v1.4.2 h1:+/TMaTYc4QFitKJxsQ7Yye35DkWvkdLcvGKqM+x0Ufc=
+github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
diff --git a/main.go b/main.go
new file mode 100644
index 0000000..c212233
--- /dev/null
+++ b/main.go
@@ -0,0 +1,11 @@
+package tome_ws
+
+import (
+	coordinator "git.saintnet.tech/tomecraft/tome_server"
+)
+
+func main() {
+	c := coordinator.NewCoordinator()
+	c.Start()
+	Serve(c)
+}
diff --git a/server.go b/server.go
new file mode 100644
index 0000000..14cac21
--- /dev/null
+++ b/server.go
@@ -0,0 +1,62 @@
+package tome_ws
+
+import (
+	"log"
+	"net/http"
+
+	"git.saintnet.tech/tomecraft/tome_lib"
+	coordinator "git.saintnet.tech/tomecraft/tome_server"
+	"github.com/gorilla/websocket"
+)
+
+var upgrader = websocket.Upgrader{} // use default options
+
+func Serve(c *coordinator.Coordinator) {
+	http.HandleFunc("/ws", func(w http.ResponseWriter, r *http.Request) {
+		serveWs(c, w, r)
+	})
+	log.Println("starting websocket")
+	err := http.ListenAndServe(":7636", nil)
+	if err != nil {
+		log.Fatal("ListenAndServe: ", err)
+	}
+}
+
+func serveWs(c *coordinator.Coordinator, w http.ResponseWriter, r *http.Request) {
+	// Upgrade our raw HTTP connection to a websocket based one
+	upgrader.CheckOrigin = func(r *http.Request) bool { return true }
+	conn, err := upgrader.Upgrade(w, r, nil)
+	if err != nil {
+		log.Print("Error during connection upgradation:", err)
+		return
+	}
+	defer conn.Close()
+
+	// The event loop
+	for {
+		var cmd tome_lib.SessionCommand
+		err := conn.ReadJSON(&cmd)
+		if err != nil {
+			log.Println("Error during message reading:", err)
+			break
+		}
+		if cmd.Command != tome_lib.SessionCmdPoll {
+			log.Printf("Received: %s", cmd)
+		}
+		resp := c.Coordinate(&cmd)
+		if err != nil {
+			panic(err)
+		}
+		if cmd.Command != tome_lib.SessionCmdPoll {
+			log.Printf("sending: %v", resp.Result)
+		}
+		err = conn.WriteJSON(resp)
+		if err != nil {
+			log.Println("Error during message writing:", err)
+			break
+		}
+		if resp.Result == tome_lib.SessionRespLeft {
+			break
+		}
+	}
+}