Draft: big refactor

server/wordle/handlers.go

@@ -0,0 +1,29 @@
+package wordle
+
+import "gitea.konchin.com/ytshih/inp2025/game/types"
+
+type Operation struct {
+}
+
+type Handlers struct {
+	state WordleState
+	opCh  chan Operation
+	subs  []chan types.WordleState
+}
+
+func NewHandlers() *Handlers {
+	ret := &Handlers{subs: nil}
+	go ret.GameFlow()
+	return ret
+}
+
+func (self *Handlers) GameFlow() {
+	for {
+		select {
+		case op := <-self.opCh:
+			if opCh.Type {
+
+			}
+		}
+	}
+}

server/wordle/wsGetState.go

@@ -0,0 +1,66 @@
+package wordle
+
+import (
+	"net/http"
+
+	"gitea.konchin.com/ytshih/inp2025/game/server/middlewares"
+	"gitea.konchin.com/ytshih/inp2025/game/types"
+	"gitea.konchin.com/ytshih/inp2025/game/utils"
+	"github.com/gorilla/websocket"
+	"github.com/uptrace/bunrouter"
+	"github.com/vmihailenco/msgpack/v5"
+)
+
+func gameFlow(
+	dataCh chan types.WordleState,
+	retCh chan error,
+) {
+	// TODO
+}
+
+func (self *handlers) WSGetState(
+	w http.ResponseWriter,
+	req bunrouter.Request,
+) error {
+	ctx := req.Context()
+
+	c, err := upgrader.Upgrade(w, req, nil)
+	if err != nil {
+		return middlewares.HTTPError{
+			StatusCode:  http.StatusInternalServerError,
+			Message:     "failed to upgrade websocket",
+			OriginError: err,
+		}
+	}
+	defer c.Close()
+
+	dataCh := make(chan types.WordleState)
+	retCh := make(chan error)
+
+	go gameFlow(dataCh, retCh)
+	for {
+		select {
+		case err := <-retCh:
+			if err != nil {
+				return middlewares.HTTPError{
+					StatusCode:  http.StatusInternalServerError,
+					Message:     "wordle server error",
+					OriginError: err,
+				}
+			}
+			break
+		case data := <-dataCh:
+			b, err := msgpack.Marshal(data)
+			if err != nil {
+				return middlewares.HTTPError{
+					StatusCode:  http.StatusInternalServerError,
+					Message:     "failed to marshal data into msgpack",
+					OriginError: err,
+				}
+			}
+			c.WriteMessage(websocket.BinaryMessage, b)
+		}
+	}
+
+	return utils.Success(w)
+}