Signaling server rewrite

ebiten-game/game/main.go

@@ -19,6 +19,8 @@
 	_ "image/jpeg"
 	_ "image/png"
 
+	"github.com/coder/websocket"
+	"github.com/coder/websocket/wsjson"
 	"github.com/ebitengine/debugui"
 	"github.com/hajimehoshi/ebiten/v2"
 	"github.com/hajimehoshi/ebiten/v2/ebitenutil"
@@ -299,6 +301,29 @@
 	})
 }
 
+func (g *game) openWebsocket() {
+	ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
+	defer cancel()
+
+	c, _, err := websocket.Dial(ctx, fmt.Sprintf("ws://%s:%d/host", g.signalingIP, g.port), nil)
+	if err != nil {
+		println("Failed to connect to websocket:", err.Error())
+	}
+	defer c.CloseNow()
+
+	ticker := time.NewTicker(1 * time.Second)
+	defer ticker.Stop()
+
+	for range ticker.C {
+		err = wsjson.Write(ctx, c, fmt.Sprintf("ping from client at %s", time.Now().String()))
+		if err != nil {
+			println("Failed to write websocket message:", err.Error())
+		}
+	}
+
+	c.Close(websocket.StatusNormalClosure, "")
+}
+
 func (g *game) startHost() {
 	g.writeLog("Hosting a lobby")
 	// Host creates lobby.

ebiten-game/game/ui.go

@@ -32,7 +32,7 @@ func (g *game) logWindow(ctx *debugui.Context) {
 		ctx.GridCell(func(bounds image.Rectangle) {
 			submitOpen := func() {
 				g.isHost = true
-				g.startConnection()
+				g.openWebsocket()
 			}
 
 			submitJoin := func() {