From 3650a8929458e8869b1ede45eae692ffb399a249 Mon Sep 17 00:00:00 2001
From: kercylan98 <kercylan@gmail.com>
Date: Fri, 19 May 2023 15:47:01 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B8=A7=E5=90=8C=E6=AD=A5=E7=A4=BA=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 examples/simple-server-lockstep/main.go | 48 +++++++++++++++++++++++++
 1 file changed, 48 insertions(+)
 create mode 100644 examples/simple-server-lockstep/main.go

diff --git a/examples/simple-server-lockstep/main.go b/examples/simple-server-lockstep/main.go
new file mode 100644
index 0000000..a65354f
--- /dev/null
+++ b/examples/simple-server-lockstep/main.go
@@ -0,0 +1,48 @@
+package main
+
+import (
+	"github.com/kercylan98/minotaur/component/components"
+	"github.com/kercylan98/minotaur/game/builtin"
+	"github.com/kercylan98/minotaur/server"
+	"github.com/kercylan98/minotaur/utils/synchronization"
+)
+
+type Player struct {
+	*builtin.Player[string]
+}
+
+type Command struct {
+	CMD  int
+	Data string
+}
+
+func main() {
+	players := synchronization.NewMap[string, *Player]()
+
+	srv := server.New(server.NetworkWebsocket, server.WithWebsocketWriteMessageType(server.WebsocketMessageTypeText))
+	lockstep := components.NewLockstep[string, *Command]()
+
+	srv.RegConnectionOpenedEvent(func(srv *server.Server, conn *server.Conn) {
+		player := &Player{Player: builtin.NewPlayer[string](conn.GetID(), conn)}
+		players.Set(conn.GetID(), player)
+		lockstep.JoinClient(player)
+	})
+	srv.RegConnectionClosedEvent(func(srv *server.Server, conn *server.Conn) {
+		players.Delete(conn.GetID())
+		lockstep.LeaveClient(conn.GetID())
+		if players.Size() == 0 {
+			lockstep.Stop()
+		}
+	})
+	srv.RegConnectionReceiveWebsocketPacketEvent(func(srv *server.Server, conn *server.Conn, packet []byte, messageType int) {
+		switch string(packet) {
+		case "start":
+			lockstep.StartBroadcast()
+		default:
+			lockstep.AddCommand(&Command{CMD: 1, Data: string(packet)})
+		}
+	})
+	if err := srv.Run(":9999"); err != nil {
+		panic(err)
+	}
+}