Adding Golang support

Author: Tom32i

Makefile

@@ -4,26 +4,46 @@
 # Install dependencies
 install:
 	npm install
+	go get
 
 # Launch watch
 watch:
 	npx webpack --watch --mode=development
 
 # Build lib
-build:
+build: build-server@dev
 	npx webpack --mode=production
 
+build-server@dev:
+	go build -o ./bin/server cmd/main.go
+
+build-server@staging: export GOOS=linux
+build-server@staging: export GOARCH=arm64
+build-server@staging:
+	go build -o ./bin/server cmd/main.go
+
+build-server@production: export GOOS=linux
+build-server@production: export GOARCH=amd64
+build-server@production:
+	go build -o ./bin/server cmd/main.go
+
 # Launch demo client
 demo-client:
 	php -S 0.0.0.0:8000 -t .
 
 # Launch demo server
 demo-server:
+
 	node ./demo-server.js 8002
+## Start server
+#demo-server-go: export GODEBUG=gctrace=1
+demo-server-go:
+	go run demo-server.go
 
 # Lint and code style fix
 lint:
 	npx eslint src/* --ext .js,.json --fix
+	gofmt -s -w .
 
 # Test
 test: build

demo-client.js

@@ -1,13 +1,13 @@
 window.addEventListener('load', () => {
-    const { Client, BinaryEncoder, Codec, Int8Codec, Int16Codec, LongIntCodec, BooleanCodec, StringCodec } = netcode;
+    const { Client, BinaryEncoder, Codec, Int8Codec, Int16Codec, Int64Codec, LongIntCodec, BooleanCodec, StringCodec, LongStringCodec } = netcode;
 
     // Register your events
     const encoder = new BinaryEncoder([
-        ['id', new Int16Codec()],
+        ['id', new Int8Codec()],
         ['ping', new LongIntCodec(6)],
         ['pong', new LongIntCodec(6)],
         ['inverse', new BooleanCodec()],
-        ['greeting', new StringCodec()],
+        ['greeting', new LongStringCodec()],
         ['total', new Int8Codec()],
     ]);
 
@@ -17,14 +17,16 @@ window.addEventListener('load', () => {
 
     // Listen for a "pong" event
     client.on('pong', ({ detail: pong }) => {
-        console.info('pong: %s ms', pong - ping);
+        console.info('pong: %s ms (%s - %s)', pong - ping, pong, ping);
     });
 
     // Listen for an "id" event
     client.on('id', ({ detail: id }) => {
         console.log('connected with id %s', id);
         ping = Date.now();
 
+        console.log('sending ping: %s', ping);
+
         // Send a "ping" event
         client.send('ping', ping);
     });
@@ -41,7 +43,8 @@ window.addEventListener('load', () => {
         console.log('Inverse received: %s', status);
 
         // Send a "greeting" event
-        client.send('greeting', 'Hello, I\'m client 😊!');
+        client.send('greeting', 'Hello, I\'m client 😊! Lorem ipsum dolor sit amet, consectetur adipiscing elit. Ut imperdiet molestie libero, ut sollicitudin tortor dignissim quis. Nulla iaculis nisi turpis, a malesuada nibh faucibus a. Nunc tellus lorem, varius sit amet tellus eu, dictum consectetur nulla.');
+        // client.send('greeting', 'Hi!');
     });
 
     // Listen for a "greeting" event

demo-server.go

@@ -0,0 +1,92 @@
+package main
+
+import (
+	"flag"
+	"log"
+	"math"
+	"netcode/internal/codec"
+	"netcode/internal/server"
+	"time"
+)
+
+type DemoServer struct {
+	server *server.Server
+}
+
+func main() {
+	port := flag.Int("port", 8002, "Port to run on")
+
+	flag.Parse()
+
+    encoder := codec.CreateBinaryEncoder([]*codec.RegisteredCodec{
+        {0, "id", codec.UInt8Codec{}},
+        {1, "ping", codec.LongUIntCodec{6}},
+        {2, "pong", codec.LongUIntCodec{6}},
+        {3, "inverse", codec.BooleanCodec{}},
+        {4, "greeting", codec.LongStringCodec{}},
+        {5, "total", codec.UInt8Codec{}},
+    }, codec.UInt8Codec{})
+
+    clients := server.CreateClientDirectory(uint(math.Pow(2, 8)))
+    server := server.CreateServer(*port, encoder, clients);
+
+	demo := DemoServer{&server}
+
+	go demo.run()
+
+	demo.server.Start()
+}
+
+func (demo *DemoServer) run() {
+	log.Printf("Demo is running")
+	for {
+		select {
+		case m := <-demo.server.In:
+			switch m.Message.Name {
+			case "ping":
+				demo.handlePing(m.Client, m.Message)
+			case "greeting":
+				demo.handleGreeting(m.Client, m.Message)
+			default:
+				log.Printf("[client #%d] '%s': %v", m.Client.ID, m.Message.Name, m.Message.Data)
+			}
+		case e := <-demo.server.Out:
+			switch e.Name {
+			case "client:join":
+				demo.onClientJoin(e.Data.(*server.Client))
+			case "client:leave":
+				demo.onClientLeave(e.Data.(*server.Client))
+			default:
+				log.Printf("event '%s': %v", e.Name, e.Data)
+			}
+		}
+	}
+}
+
+func (demo *DemoServer) broadcastTotal() {
+	message := codec.Message{"total", uint8(demo.server.Clients.Count())}
+	buf := demo.server.Encoder.Encode(message)
+	demo.server.Clients.ForEach(func(c *server.Client) { c.Write(buf) })
+}
+
+func (demo *DemoServer) onClientJoin(c *server.Client) {
+	log.Printf("Client #%d joined.", c.ID)
+	c.Send(codec.Message{"id", uint8(c.ID)})
+	demo.broadcastTotal()
+}
+
+func (demo *DemoServer) onClientLeave(c *server.Client) {
+	log.Printf("Client #%d left.", c.ID)
+	demo.broadcastTotal()
+}
+
+func (demo *DemoServer) handlePing(c *server.Client, m codec.Message) {
+	log.Printf("[client #%d] ping %d", c.ID, m.Data)
+	c.Send(codec.Message{"pong", uint(time.Now().UnixMilli())})
+	c.Send(codec.Message{"inverse", true})
+}
+
+func (demo *DemoServer) handleGreeting(c *server.Client, m codec.Message) {
+	log.Printf("Client #%d greets you: '%s'", c.ID, m.Data)
+	c.Send(codec.Message{"greeting", "Hello, I'm server! 😊 Lorem ipsum dolor sit amet, consectetur adipiscing elit. Ut imperdiet molestie libero, ut sollicitudin tortor dignissim quis. Nulla iaculis nisi turpis, a malesuada nibh faucibus a. Nunc tellus lorem, varius sit amet tellus eu, dictum consectetur nulla."})
+}

demo-server.js

@@ -11,7 +11,7 @@ const encoder = new BinaryEncoder([
 ]);
 
 // Create the server
-const port = process.argv[2];
+const port = process.argv[2] || 8002;
 const server = new Server(port, '127.0.0.1', encoder, 3);
 
 // Listen for new clients
@@ -35,9 +35,9 @@ server.on('client:join', client => {
 
     // Listen for "greeting" event
     client.on('greeting', message => {
-        console.log('Client %s geets you: "%s"', client.id, message);
+        console.log('Client %s greets you: "%s"', client.id, message);
         // Send a "greeting" event
-        client.send('greeting', 'Hello, I\'m server 😊!');
+        client.send('greeting', 'Hello, I\'m server! 😊 Lorem ipsum dolor sit amet, consectetur adipiscing elit. Ut imperdiet molestie libero, ut sollicitudin tortor dignissim quis. Nulla iaculis nisi turpis, a malesuada nibh faucibus a. Nunc tellus lorem, varius sit amet tellus eu, dictum consectetur nulla.');
     });
 
     // Send event "id" to the client

go.mod

@@ -0,0 +1,5 @@
+module netcode
+
+go 1.22.4
+
+require github.com/gorilla/websocket v1.5.3

go.sum

@@ -0,0 +1,4 @@
+github.com/gorilla/websocket v1.5.1 h1:gmztn0JnHVt9JZquRuzLw3g4wouNVzKL15iLr/zn/QY=
+github.com/gorilla/websocket v1.5.1/go.mod h1:x3kM2JMyaluk02fnUJpQuwD2dCS5NDG2ZHL0uE0tcaY=
+github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
+github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=

internal/codec/bool.go

@@ -0,0 +1,20 @@
+package codec
+
+import (
+	"bytes"
+)
+
+type BooleanCodec struct {
+}
+
+func (c BooleanCodec) encode(buffer *bytes.Buffer, data any) {
+	if data.(bool) {
+		buffer.WriteByte(1)
+	} else {
+		buffer.WriteByte(0)
+	}
+}
+
+func (c BooleanCodec) decode(buffer *bytes.Buffer) any {
+	return buffer.Next(1)[0] > 0
+}

internal/codec/encoder.go

@@ -0,0 +1,65 @@
+package codec
+
+import (
+	"bytes"
+)
+
+type BinaryEncoder struct {
+	idCodec      Codec
+	codecsByName map[string]*RegisteredCodec
+	codecsById   map[uint8]*RegisteredCodec
+}
+
+type Codec interface {
+	encode(buffer *bytes.Buffer, data any)
+	decode(buffer *bytes.Buffer) any
+}
+
+type RegisteredCodec struct {
+	Id      uint8
+	Name    string
+	Handler Codec
+}
+
+type Message struct {
+	Name string
+	Data any
+}
+
+func CreateBinaryEncoder(codecs []*RegisteredCodec, idCodec Codec) *BinaryEncoder {
+	codecsByName := make(map[string]*RegisteredCodec)
+	codecsById := make(map[uint8]*RegisteredCodec)
+
+	for _, codec := range codecs {
+		codecsById[codec.Id] = codec
+		codecsByName[codec.Name] = codec
+	}
+
+	return &BinaryEncoder{
+		idCodec:      idCodec,
+		codecsByName: codecsByName,
+		codecsById:   codecsById,
+	}
+}
+
+func (e BinaryEncoder) Encode(message Message) []byte {
+	var buffer bytes.Buffer
+
+	codec := e.codecsByName[message.Name]
+
+	e.idCodec.encode(&buffer, codec.Id)
+	codec.Handler.encode(&buffer, message.Data)
+
+	return buffer.Bytes()
+}
+
+func (e BinaryEncoder) Decode(data []byte) Message {
+	var buffer = bytes.NewBuffer(data)
+	id := e.idCodec.decode(buffer).(uint8)
+	codec := e.codecsById[id]
+
+	return Message{
+		Name: codec.Name,
+		Data: codec.Handler.decode(buffer),
+	}
+}

internal/codec/string.go

@@ -0,0 +1,20 @@
+package codec
+
+import (
+	"bytes"
+)
+
+type StringCodec struct {
+}
+
+func (c StringCodec) encode(buffer *bytes.Buffer, data any) {
+	length := len(data.(string))
+	buffer.WriteByte(uint8(length))
+	buffer.WriteString(data.(string))
+}
+
+func (c StringCodec) decode(buffer *bytes.Buffer) any {
+	length := int(buffer.Next(1)[0])
+
+	return string(buffer.Next(length))
+}

internal/codec/string_long.go

@@ -0,0 +1,25 @@
+package codec
+
+import (
+	"bytes"
+	"encoding/binary"
+)
+
+type LongStringCodec struct {
+}
+
+func (c LongStringCodec) encode(buffer *bytes.Buffer, data any) {
+	length := len(data.(string))
+
+	b := make([]byte, 2)
+	binary.BigEndian.PutUint16(b, uint16(length))
+	buffer.Write(b)
+
+	buffer.WriteString(data.(string))
+}
+
+func (c LongStringCodec) decode(buffer *bytes.Buffer) any {
+	length := binary.BigEndian.Uint16(buffer.Next(2))
+
+	return string(buffer.Next(int(length)))
+}