Updated tests

Author: Tom32i

demo/client.js

@@ -1,4 +1,4 @@
-import { Client, BinaryEncoder, UInt8Codec, UIntLongCodec, BooleanCodec, StringLongCodec } from 'netcode/client';
+import { Client, BinaryEncoder, UInt8Codec, UIntLongCodec, Int16Codec, BooleanCodec, StringLongCodec } from 'netcode/client';
 
 window.addEventListener('load', () => {
     const target = document.getElementById('output');
@@ -19,6 +19,7 @@ window.addEventListener('load', () => {
         ['inverse', new BooleanCodec()],
         ['greeting', new StringLongCodec()],
         ['total', new UInt8Codec()],
+        ['int16', new Int16Codec()],
     ]);
 
 
@@ -51,6 +52,12 @@ window.addEventListener('load', () => {
         console.info(`There is ${total} people connected.`);
     });
 
+    // Listen for a "int16" event
+    client.on('int16', ({ detail: value }) => {
+        console.info(`int16 codec: ${value}.`);
+        client.send('int16', -32768);
+    });
+
     // Listen for an "inverse" event
     client.on('inverse', ({ detail: status }) => {
         // Answer with an "inverse" event
@@ -59,7 +66,6 @@ window.addEventListener('load', () => {
 
         // Send a "greeting" event
         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
@@ -70,7 +76,7 @@ window.addEventListener('load', () => {
     // Listen for oppening connection
     client.on('open', () => {
         console.info('Connection open.');
-        setTimeout(() => client.close(1000, 'All good :)'), 20 * 1000);
+        setTimeout(() => client.close(1000, 'All good :)'), 10 * 1000);
     });
 
     // Listen for connection close

demo/server.go

@@ -21,11 +21,12 @@ func main() {
 
 	encoder := netcode.CreateBinaryEncoder([]*netcode.RegisteredCodec{
 		{0, "id", netcode.UInt8Codec{}},
-		{1, "ping", netcode.UIntLongCodec{6}},
-		{2, "pong", netcode.UIntLongCodec{6}},
-		{3, "inverse", netcode.BooleanCodec{}},
-		{4, "greeting", netcode.StringLongCodec{}},
-		{5, "total", netcode.UInt8Codec{}},
+		{0, "ping", netcode.UIntLongCodec{6}},
+		{0, "pong", netcode.UIntLongCodec{6}},
+		{0, "inverse", netcode.BooleanCodec{}},
+		{0, "greeting", netcode.StringLongCodec{}},
+		{0, "total", netcode.UInt8Codec{}},
+		{0, "int16", netcode.Int16Codec{}},
 	}, netcode.UInt8Codec{})
 
 	demo := Demo{
@@ -34,8 +35,8 @@ func main() {
 
 	go demo.run()
 
-	netcode.Start(*port, "/", func(conn *websocket.Conn, request *http.Request) {
-		socket, err := demo.sockets.Add(conn)
+	netcode.Start(*port, "/", func(w http.ResponseWriter, r *http.Request, c *websocket.Conn) {
+		socket, err := demo.sockets.Add(c)
 
 		if err != nil {
 			log.Fatal(err)
@@ -46,7 +47,7 @@ func main() {
 		})
 
 		demo.onClientJoin(socket)
-	})
+	}, netcode.CheckOrigin, netcode.ErrorHandler)
 }
 
 func (demo *Demo) run() {
@@ -59,19 +60,13 @@ func (demo *Demo) run() {
 				demo.handlePing(m.Socket, m.Message)
 			case "greeting":
 				demo.handleGreeting(m.Socket, m.Message)
+			case "int16":
+				demo.handleInt16(m.Socket, m.Message)
 			default:
 				log.Printf("[socket #%d] '%s': %v", m.Socket.ID, m.Message.Name, m.Message.Data)
 			}
 		case socket := <-demo.sockets.Out:
 			demo.onClientLeave(socket)
-			// switch e.Name {
-			// case "socket:join":
-			// 	demo.onClientJoin(e.Data.(*netcode.Socket))
-			// case "socket:leave":
-			// 	demo.onClientLeave(e.Data.(*netcode.Socket))
-			// default:
-			// 	log.Printf("event '%s': %v", e.Name, e.Data)
-			// }
 		}
 	}
 }
@@ -86,6 +81,8 @@ func (demo *Demo) onClientJoin(s *netcode.Socket) {
 	log.Printf("Client #%d joined.", s.ID)
 	s.Send(&netcode.Message{"id", uint8(s.ID)})
 	demo.broadcastTotal()
+
+	s.Send(&netcode.Message{"int16", int16(math.MaxInt16)})
 }
 
 func (demo *Demo) onClientLeave(s *netcode.Socket) {
@@ -94,12 +91,16 @@ func (demo *Demo) onClientLeave(s *netcode.Socket) {
 }
 
 func (demo *Demo) handlePing(s *netcode.Socket, m *netcode.Message) {
-	log.Printf("Client #%d ping: %d.", s.ID, m.Data)
+	log.Printf("Client #%d ping: %d.", s.ID, m.Data.(uint))
 	s.Send(&netcode.Message{"pong", uint(time.Now().UnixMilli())})
 	s.Send(&netcode.Message{"inverse", true})
 }
 
 func (demo *Demo) handleGreeting(s *netcode.Socket, m *netcode.Message) {
-	log.Printf("Client #%d greets you: '%s'.", s.ID, m.Data)
+	log.Printf("Client #%d greets you: '%s'.", s.ID, m.Data.(string))
 	s.Send(&netcode.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."})
 }
+
+func (demo *Demo) handleInt16(s *netcode.Socket, m *netcode.Message) {
+	log.Printf("Client #%d sends int16: %d.", s.ID, m.Data.(int16))
+}

demo/server.js

@@ -3,6 +3,7 @@ import {
     BinaryEncoder,
     UInt8Codec,
     UIntLongCodec,
+    Int16Codec,
     BooleanCodec,
     StringLongCodec,
 } from 'netcode/server';
@@ -15,6 +16,7 @@ const encoder = new BinaryEncoder([
     ['inverse', new BooleanCodec()],
     ['greeting', new StringLongCodec()],
     ['total', new UInt8Codec()],
+    ['int16', new Int16Codec()],
 ]);
 
 // Create the server
@@ -47,10 +49,17 @@ server.on('client:join', client => {
         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.');
     });
 
+    // Listen for "int16" event
+    client.on('int16', message => {
+        console.info('Client %s sends int16: %s', client.id, message);
+    });
+
     // Send event "id" to the client
     client.send('id', client.id);
 
     broadcastTotal();
+
+    client.send('int16', 32767);
 });
 
 // Listen for disconnecting clients

go/codec_bool.go go/codec_boolean.gogo/codec_bool.go renamed to go/codec_boolean.go

@@ -14,6 +14,6 @@ func (c Int16Codec) Encode(buffer *bytes.Buffer, data any) {
 
 func (c Int16Codec) Decode(buffer *bytes.Buffer) any {
 	var data int16
-	binary.Read(buffer, binary.BigEndian, data)
+	binary.Read(buffer, binary.BigEndian, &data)
 	return data
 }

go/coder_float_precision.go go/codec_float_precision.gogo/coder_float_precision.go renamed to go/codec_float_precision.go

@@ -0,0 +1,19 @@
+package netcode
+
+import (
+	"bytes"
+	"encoding/binary"
+)
+
+type Int32Codec struct {
+}
+
+func (c Int32Codec) Encode(buffer *bytes.Buffer, data any) {
+	binary.Write(buffer, binary.BigEndian, data.(int32))
+}
+
+func (c Int32Codec) Decode(buffer *bytes.Buffer) any {
+	var data int32
+	binary.Read(buffer, binary.BigEndian, &data)
+	return data
+}

go/Int16Codec.go go/codec_int16.gogo/Int16Codec.go renamed to go/codec_int16.go

@@ -0,0 +1,16 @@
+package netcode
+
+import (
+	"bytes"
+)
+
+type Int64Codec struct {
+}
+
+func (c Int64Codec) Encode(buffer *bytes.Buffer, data any) {
+	buffer.WriteByte(byte(data.(int64)))
+}
+
+func (c Int64Codec) Decode(buffer *bytes.Buffer) any {
+	return int64(buffer.Next(1)[0])
+}