diff --git a/.eslintrc.json b/.eslintrc.json
deleted file mode 100644
index b16ef0b..0000000
--- a/.eslintrc.json
+++ /dev/null
@@ -1,39 +0,0 @@
-{
- "env": {
- "browser": true,
- "es2021": true,
- "node": true
- },
- "extends": "eslint:recommended",
- "parserOptions": {
- "ecmaVersion": "latest",
- "sourceType": "module"
- },
- "rules": {
- "indent": [
- "error",
- 4,
- { "SwitchCase": 1 }
- ],
- "linebreak-style": [
- "error",
- "unix"
- ],
- "quotes": [
- "error",
- "single"
- ],
- "semi": [
- "error",
- "always"
- ],
- "no-console": [
- "error",
- { "allow": ["info", "error"] }
- ],
- "spaced-comment": [
- "error",
- "always"
- ]
- }
-}
diff --git a/.gitignore b/.gitignore
index 1acd131..7ad2a9a 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,3 @@
-/client.js
-/server.js
/node_modules
+/dist
+go.test
diff --git a/Makefile b/Makefile
index 06c54c1..9d2761c 100644
--- a/Makefile
+++ b/Makefile
@@ -4,30 +4,50 @@
# Install dependencies
install:
npm install
+ go get all
-# Launch watch
+# Update dependencies
+update:
+ npm update
+ go get -u all
+
+# Launch client dev server
+start:
+ npm run start
+
+# Launch client watcher
watch:
- npx webpack --watch --mode=development
+ npm run watch
# Build lib
build:
- npx webpack --mode=production
+ npm run build
-# Launch demo client
-demo-client:
- php -S 0.0.0.0:8000 -t .
+# Launch NodeJS demo server
+server-node:
+ node ./demo/server.js 8002
-# Launch demo server
-demo-server:
- node ./demo-server.js 8002
+## Launch Golang demo server
+server-go:
+ go run demo/server.go
# Lint and code style fix
-lint:
- npx eslint src/* --ext .js,.json --fix
+lint: lint-js lint-go
+
+lint-js:
+ npm run lint
+
+lint-go:
+ gofmt -s -w .
# Test
-test: build
- npx mocha
+test: test-js test-go
+
+test-js:
+ npm run test
+
+test-go:
+ go test ./go/...
# Publish package
publish: build
diff --git a/README.md b/README.md
index f48bc8a..e7527fe 100644
--- a/README.md
+++ b/README.md
@@ -8,10 +8,11 @@ Features:
- ⚡️ Handle the binary encoding and decoding of your data, with performances in mind.
- 📢 Listen for event dispatched over websocket with simple `on`/`off` event emitter system.
- 💬 Fallback to JSON for easy debugging.
+- 🌟 **NEW**: [experimental Golang port available](doc/go.md)
## Requirements
-- Node >= v8.0.0
+- Node >= v24.0.0
## Installation
@@ -26,11 +27,10 @@ An event is defined by its _unique_ name and the corresponding codec, responsibl
```javascript
// events.js
-import Int8Codec from 'netcode/src/encoder/codec/Int8Codec';
-import StringCodec from 'netcode/src/encoder/codec/StringCodec';
+import { UInt8Codec, StringCodec } from 'netcode/encoder';
export default [
- ['id', new Int8Codec()],
+ ['id', new UInt8Codec()],
['say', new StringCodec()],
];
```
@@ -53,8 +53,7 @@ We setup a server specifying the port and host on which the server will listen a
Here we use a BinaryEncoder to communicate in binary over websocket, with the previously configured event list.
```javascript
-import Server from 'netcode/src/server/Server';
-import BinaryEncoder from 'netcode/src/encoder/BinaryEncoder';
+import { Server, BinaryEncoder } from 'netcode/server';
import events from './events';
// Listen on localhost:8080
@@ -68,15 +67,14 @@ server.on('client:join', client => {
Now we've got a server running at `localhost:8080` that listen for a `say` text event and send a `id` integer event to every client that connects.
-_See an [full example of server setup](demo-server.js)._
+_See an [full example of server setup](demo/server.js)._
### Write a Client
Now we write a client, for the browser, that connects to our running server on `ws://localhost:8080` and use a BinaryEncoder with the same event list as the server.
```javascript
-import Client from 'netcode/src/client/Client';
-import BinaryEncoder from 'netcode/src/encoder/BinaryEncoder';
+import { Client, BinaryEncoder } from 'netcode/client';
import events from './events';
const client = new Client('ws://localhost:8080', new BinaryEncoder(events))
@@ -91,7 +89,7 @@ Now we've got client that listen for the `id` event and sent a sentence in a `sa
Connection is alive and well!
-_See an [full example of client setup](demo-client.js)._
+_See an [full example of client setup](demo/client.js)._
## Complete documentation
diff --git a/demo-client.js b/demo-client.js
deleted file mode 100644
index d5a2dd4..0000000
--- a/demo-client.js
+++ /dev/null
@@ -1,63 +0,0 @@
-window.addEventListener('load', () => {
- const { Client, BinaryEncoder, Codec, Int8Codec, Int16Codec, LongIntCodec, BooleanCodec, StringCodec } = netcode;
-
- // Register your events
- const encoder = new BinaryEncoder([
- ['id', new Int16Codec()],
- ['ping', new LongIntCodec(6)],
- ['pong', new LongIntCodec(6)],
- ['inverse', new BooleanCodec()],
- ['greeting', new StringCodec()],
- ['total', new Int8Codec()],
- ]);
-
- // Create the client
- const client = new Client('ws://127.0.0.1:8002', encoder);
- let ping;
-
- // Listen for a "pong" event
- client.on('pong', ({ detail: pong }) => {
- console.info('pong: %s ms', pong - ping);
- });
-
- // Listen for an "id" event
- client.on('id', ({ detail: id }) => {
- console.log('connected with id %s', id);
- ping = Date.now();
-
- // Send a "ping" event
- client.send('ping', ping);
- });
-
- // Listen for a "total" event
- client.on('total', ({ detail: total }) => {
- console.log(`There is ${total} people connected.`)
- });
-
- // Listen for an "inverse" event
- client.on('inverse', ({ detail: status }) => {
- // Answer with an "inverse" event
- client.send('inverse', !status);
- console.log('Inverse received: %s', status);
-
- // Send a "greeting" event
- client.send('greeting', 'Hello, I\'m client 😊!');
- });
-
- // Listen for a "greeting" event
- client.on('greeting', ({ detail: message }) => {
- console.log('Servers geets you: "%s"', message);
- });
-
- // Listen for oppening connection
- client.on('open', () => {
- console.info('Connection open.');
-
- setTimeout(() => client.close(), 20 * 1000);
- });
-
- // Listen for connection close
- client.on('close', () => {
- console.info('Connection closed.');
- });
-});
diff --git a/demo-server.js b/demo-server.js
deleted file mode 100644
index 36aeec4..0000000
--- a/demo-server.js
+++ /dev/null
@@ -1,62 +0,0 @@
-const { Server, BinaryEncoder, Codec, Int8Codec, Int16Codec, LongIntCodec, BooleanCodec, StringCodec } = require('./server');
-
-// Register your events
-const encoder = new BinaryEncoder([
- ['id', new Int16Codec()],
- ['ping', new LongIntCodec(6)],
- ['pong', new LongIntCodec(6)],
- ['inverse', new BooleanCodec()],
- ['greeting', new StringCodec()],
- ['total', new Int8Codec()],
-]);
-
-// Create the server
-const port = process.argv[2];
-const server = new Server(port, '127.0.0.1', encoder, 3);
-
-// Listen for new clients
-server.on('client:join', client => {
- console.log('Client %s joined.', client.id);
-
- // Listen for "ping" event
- client.on('ping', ping => {
- // Answer with a "pong" event
- client.send('pong', Date.now());
- console.log('Client %s ping received: %s.', client.id, ping);
-
- // Send a "inverse" event
- client.send('inverse', true);
- });
-
- // Listen for "inverse" event
- client.on('inverse', status => {
- console.log('Client %s inverse received: %s.', client.id, status);
- });
-
- // Listen for "greeting" event
- client.on('greeting', message => {
- console.log('Client %s geets you: "%s"', client.id, message);
- // Send a "greeting" event
- client.send('greeting', 'Hello, I\'m server 😊!');
- });
-
- // Send event "id" to the client
- client.send('id', client.id);
-
- broadcastTotal();
-});
-
-// Listen for disconnecting clients
-server.on('client:leave', client => {
- console.log('Client %s left.', client.id);
- broadcastTotal();
-});
-
-server.on('ready', () => console.log('Listening on port %s', port));
-
-function broadcastTotal() {
- const { length } = server.clients;
- server.clients.forEach(client => client.send('total', length));
-}
-
-module.exports = server;
diff --git a/demo/client.js b/demo/client.js
new file mode 100644
index 0000000..3e114cf
--- /dev/null
+++ b/demo/client.js
@@ -0,0 +1,86 @@
+import { Client, BinaryEncoder, UInt8Codec, UIntLongCodec, Int16Codec, BooleanCodec, StringLongCodec } from 'netcode/client';
+
+window.addEventListener('load', () => {
+ const target = document.getElementById('output');
+ const { info } = console;
+
+ console.info = (message, ...subst) => {
+ info(message, ...subst);
+ subst.forEach(sub => message = message.replace('%s', sub));
+ const time = Date.now() - start;
+ output.innerText += `▸ ${time}ms | ${message}\n`;
+ }
+
+ // Register your events
+ const encoder = new BinaryEncoder([
+ ['id', new UInt8Codec()],
+ ['ping', new UIntLongCodec(6)],
+ ['pong', new UIntLongCodec(6)],
+ ['inverse', new BooleanCodec()],
+ ['greeting', new StringLongCodec()],
+ ['total', new UInt8Codec()],
+ ['int16', new Int16Codec()],
+ ]);
+
+
+ const server = 'ws://127.0.0.1:8002';
+ const start = Date.now();
+ console.info('Connecting to %s', server)
+
+ // Create the client
+ const client = new Client(server, encoder);
+ let ping;
+
+ // Listen for a "pong" event
+ client.on('pong', ({ detail: pong }) => {
+ console.info('pong: %s ms (%s - %s)', pong - ping, pong, ping);
+ });
+
+ // Listen for an "id" event
+ client.on('id', ({ detail: id }) => {
+ console.info('connected with id %s', id);
+ ping = Date.now();
+
+ console.info('sending ping: %s', ping);
+
+ // Send a "ping" event
+ client.send('ping', ping);
+ });
+
+ // Listen for a "total" event
+ client.on('total', ({ detail: total }) => {
+ 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
+ client.send('inverse', !status);
+ console.info('Inverse received: %s', status);
+
+ // 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.');
+ });
+
+ // Listen for a "greeting" event
+ client.on('greeting', ({ detail: message }) => {
+ console.info('Servers geets you: "%s"', message);
+ });
+
+ // Listen for oppening connection
+ client.on('open', () => {
+ console.info('Connection open.');
+ setTimeout(() => client.close(1000, 'All good :)'), 10 * 1000);
+ });
+
+ // Listen for connection close
+ client.on('close', (data) => {
+ console.info('Connection closed.', data);
+ });
+});
diff --git a/demo/server.go b/demo/server.go
new file mode 100644
index 0000000..793b5f8
--- /dev/null
+++ b/demo/server.go
@@ -0,0 +1,108 @@
+package main
+
+import (
+ "flag"
+ netcode "github.com/Tom32i/netcode/go"
+ "github.com/gorilla/websocket"
+ "log"
+ "math"
+ "net/http"
+ "time"
+)
+
+type Demo struct {
+ sockets *netcode.Sockets
+}
+
+func main() {
+ port := flag.Int("port", 8002, "Port to run on")
+
+ flag.Parse()
+
+ encoder := netcode.CreateBinaryEncoder([]*netcode.RegisteredCodec{
+ {0, "id", 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{})
+
+ d := Demo{
+ netcode.CreateSockets(encoder, uint(math.Pow(2, 8))),
+ }
+
+ go d.run()
+
+ netcode.Start(*port, "/", d.SocketHandler, netcode.CheckOrigin, netcode.ErrorHandler)
+}
+
+func (d *Demo) SocketHandler(w http.ResponseWriter, r *http.Request, c *websocket.Conn) {
+ socket, err := d.sockets.Add(c)
+
+ if err != nil {
+ log.Fatal(err)
+ }
+
+ netcode.CreateBeacon(socket, time.Second*3, func(ping time.Duration) {
+ log.Printf("Client #%d ping: %s.", socket.ID, ping)
+ })
+
+ d.onClientJoin(socket)
+}
+
+func (d *Demo) run() {
+ log.Printf("Demo is running")
+ for {
+ select {
+ case m := <-d.sockets.In:
+ switch m.Message.Name {
+ case "ping":
+ d.handlePing(m.Socket, m.Message)
+ case "greeting":
+ d.handleGreeting(m.Socket, m.Message)
+ case "int16":
+ d.handleInt16(m.Socket, m.Message)
+ default:
+ log.Printf("[socket #%d] '%s': %v", m.Socket.ID, m.Message.Name, m.Message.Data)
+ }
+ case socket := <-d.sockets.Out:
+ d.onClientLeave(socket)
+ }
+ }
+}
+
+func (d *Demo) broadcastTotal() {
+ d.sockets.SendAll(
+ &netcode.Message{"total", uint8(d.sockets.Count())},
+ )
+}
+
+func (d *Demo) onClientJoin(s *netcode.Socket) {
+ log.Printf("Client #%d joined.", s.ID)
+ s.Send(&netcode.Message{"id", uint8(s.ID)})
+ d.broadcastTotal()
+
+ s.Send(&netcode.Message{"int16", int16(math.MaxInt16)})
+}
+
+func (d *Demo) onClientLeave(s *netcode.Socket) {
+ log.Printf("Client #%d left.", s.ID)
+ d.broadcastTotal()
+}
+
+func (d *Demo) handlePing(s *netcode.Socket, m *netcode.Message) {
+ 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 (d *Demo) handleGreeting(s *netcode.Socket, m *netcode.Message) {
+ 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 (d *Demo) handleInt16(s *netcode.Socket, m *netcode.Message) {
+ log.Printf("Client #%d sends int16: %d.", s.ID, m.Data.(int16))
+}
diff --git a/demo/server.js b/demo/server.js
new file mode 100644
index 0000000..5aae4a6
--- /dev/null
+++ b/demo/server.js
@@ -0,0 +1,79 @@
+import {
+ Server,
+ BinaryEncoder,
+ UInt8Codec,
+ UIntLongCodec,
+ Int16Codec,
+ BooleanCodec,
+ StringLongCodec,
+} from 'netcode/server';
+
+// Register your events
+const encoder = new BinaryEncoder([
+ ['id', new UInt8Codec()],
+ ['ping', new UIntLongCodec(6)],
+ ['pong', new UIntLongCodec(6)],
+ ['inverse', new BooleanCodec()],
+ ['greeting', new StringLongCodec()],
+ ['total', new UInt8Codec()],
+ ['int16', new Int16Codec()],
+]);
+
+// Create the server
+const port = process.argv[2] || 8002;
+const server = new Server(port, '127.0.0.1', encoder, 3);
+
+// Listen for new clients
+server.on('client:join', client => {
+ console.info('Client %s joined.', client.id);
+
+ // Listen for "ping" event
+ client.on('ping', ping => {
+ // Answer with a "pong" event
+ client.send('pong', Date.now());
+ console.info('Client %s ping received: %s.', client.id, ping);
+
+ // Send a "inverse" event
+ client.send('inverse', true);
+ });
+
+ // Listen for "inverse" event
+ client.on('inverse', status => {
+ console.info('Client %s inverse received: %s.', client.id, status);
+ });
+
+ // Listen for "greeting" event
+ client.on('greeting', message => {
+ console.info('Client %s greets you: "%s"', client.id, message);
+ // Send a "greeting" event
+ 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
+server.on('client:leave', client => {
+ console.info('Client %s left.', client.id);
+ broadcastTotal();
+});
+
+server.on('ping', ({ client }) => console.info('Client %s ping.', client.id));
+server.on('pong', ({ client, duration }) => console.info('Client %s ping: %sms', client.id, duration));
+
+server.on('ready', () => console.info('Listening on port %s', port));
+
+function broadcastTotal() {
+ const { length } = server.clients;
+ server.clients.forEach(client => client.send('total', length));
+}
diff --git a/doc/API.md b/doc/API.md
index ec01b30..3a4f050 100644
--- a/doc/API.md
+++ b/doc/API.md
@@ -9,9 +9,10 @@ The `Server` class takes the following arguments:
| port | _Number_ | 8080 | Port to listen on. |
| host | _String_ | 0.0.0.0 | Host to listen on. |
| encoder | _BinaryEncoder \| JsonEncoder_ | new JsonEncoder() | Encoder to use to read/write event messages. |
-| ping | _Number_ | 30 | Ping frequency in seconds (0 for no ping). |
-| maxLength | _Number_ | 512 | Paquet max length in bit (should be a power of two). |
-| protocols | _Array String[]_ | `['websocket']` | Protocols tu use |
+| pingInterval | _Number_ | 30 | Ping frequency in seconds (0 for no ping). |
+| maxPayload | _Number_ | 512 | Paquet max length in bit (should be a power of two). |
+| clients | _ClientDirectory_ | `new MapClientDirectory()` | Client directory |
+| autoStart | _Boolean_ | `true` | Should the server start listening immediatly? |
### Methods
@@ -27,8 +28,6 @@ Listen for event.
Remove listener for this event / callback.
-_Note: If you're on node `< 10.0.0`, use `removeListener` method instead of `off`_
-
### Events
| Name | Callback parameters | Description |
@@ -76,4 +75,4 @@ _Note: If you're on node `< 10.0.0`, use `removeListener` method instead of `off
| `close` | client _{Client_} | Client connection is closed. |
| * | - eventData _{Number\|String\|Boolean\|Object}_
- client _Client_ | Every event sent through the websocket pipe will emit an event on the other end of the socket. |
-_Note: `open`, `error` and `close` are reserved event names and the Encoder will throw an exeption if you define a custom event with either of these names._
\ No newline at end of file
+_Note: `open`, `error` and `close` are reserved event names and the Encoder will throw an exeption if you define a custom event with either of these names._
diff --git a/doc/codecs.md b/doc/codecs.md
index ea86bcc..cf1fe03 100644
--- a/doc/codecs.md
+++ b/doc/codecs.md
@@ -10,14 +10,20 @@ Packaged codecs are available in the `netcode/server` and `netcode/client` packa
| Class | Data format | Example | Size (in byte) |
| -------------------------- | ---------------------------------- | ------------------------------------------------------------ | ----------------------- |
-| `Codec` | No data (just send the event name) | `['pause', new Codec()]`
`send('pause')` | 0 |
-| `BooleanCodec` | `true\|false` | `['active', new BooleanCodec()]`
`send('active', true)` | 1 |
+| `NullCodec` | No data (just send the event name) | `['pause', new NullCodec()]`
`send('pause')` | 0 |
+| `BooleanCodec` | `true\|false` | `['active', new BooleanCodec()]`
`send('active', true)` | |
+| `UInt8Codec` | Integer from 0 to 255 | `['id', new UInt8Codec()]`
`send('id', 42)` | 1 |
+| `UInt16Codec` | Integer from 0 to 65536 | `['score', new UInt16Codec()]`
`send('score', 9999)` | 2 |
+| `UInt32Codec` | Integer from 0 to 4294967295 | `['position', new UInt32Codec()]`
`send('position', 4294967295)` | 4 |
+| `UIntLongCodec(byteLength)` | Integer encoded as string | `['timestamp', new UIntLongCodec(13)`]
`send('timestamp', Date.now())` | byteLength |
+| `Int8Codec` | Integer from -128 to 127 | `['value', new Int8Codec()]`
`send('value', -42)` | 1 |
+| `Int16Codec` | Integer from -32768 to 32767 | `['malus', new Int16Codec()]`
`send('malus', -999)` | 2 |
+| `Int32Codec` | Integer from -2147483648 to 2147483647 | `['position', new Int32Codec()]`
`send('position', -123456)` | 4 |1 |
+| `Float32Codec`
⚠ Subject to precision issues | Float on 32bit | `['position', new Float32Codec()]`
`send('position', 84.19999694824219)` | 4 |
+| `Float64Codec` | Float on 64bit | `['position', new Float64Codec()]`
`send('position', -12456789.123456789087654321012345678901)` | 2 |
+| `FloatPrecisionCodec(IntCodec, precision)` | Float encoded as int | `['position', FloatPrecisionCodec(Int8Codec, 3)]`
`send('position', -0.657)` | 2
| `StringCodec` | String up to 255 characters | `['player:name', new StringCodec()]`
`send('player:name', 'DarkShadow73')` | 1 + (String length * 2) |
-| `LongStringCodec` | String up to 65536 characters | `['url', new LongStringCodec()]`
`send('url', 'https://my.long.url/hash/xxx...')` | 2 + (String length * 2) |
-| `Int8Codec` | Integer from 0 to 255 | `['id', new Int8Codec()]`
`send('id', 42)` | 1 |
-| `Int16Codec` | Integer from 0 to 65536 | `['score', new Int16Codec()]`
`send('score', 9999)` | 2 |
-| `Int32Codec` | Integer from 0 to 4294967295 | `['position', new Int32Codec()]`
`send('position', 4294967295)` | 4 |
-| `LongIntCodec(byteLength)` | Integer encoded as string | `['timestamp', new LongIntCodec(13)`]
`send('timestamp', Date.now())` | byteLength |
+| `StringLongCodec` | String up to 65536 characters | `['url', new StringLongCodec()]`
`send('url', 'https://my.long.url/hash/xxx...')` | 2 + (String length * 2) |
## Custom codecs
@@ -45,14 +51,14 @@ So the byte length of my event is fixed: 1 + 2 + 2 = 5 bytes.
Full working example using composition:
```javascript
-import { Codec, Int8Codec, Int16Codec } from 'netcode/src/encoder/codec';
+import { Codec, UInt8Codec, UInt16Codec } from 'netcode/src/encoder/codec';
export default class PositionCodec extends Codec {
constructor() {
super();
- this.int8Codec = new Int8Codec();
- this.int16Codec = new Int16Codec();
+ this.int8Codec = new UInt8Codec();
+ this.int16Codec = new UInt16Codec();
}
/**
diff --git a/doc/go.md b/doc/go.md
new file mode 100644
index 0000000..08e9335
--- /dev/null
+++ b/doc/go.md
@@ -0,0 +1,18 @@
+# Go port
+
+Netcode server is also available in Golang.
+
+It's fully compatible with the netcode browser client.
+
+## Current features
+
+- [x] Server
+- [x] Sockets (equivalent of Client / Client Directory)
+- [x] Binary encoder
+- [ ] Json encoder
+- [x] Packaged codecs (compatible with javascript codec)
+- [x] Beacon (ping at regular interval)
+
+## Notes
+
+Netcode in golang is relying on [github.com/gorilla/websocket](github.com/gorilla/websocket) for Websocket implementation.
diff --git a/doc/packaging.md b/doc/packaging.md
index 58e8e9e..afd98fc 100644
--- a/doc/packaging.md
+++ b/doc/packaging.md
@@ -13,7 +13,7 @@ On the server-side (node):
const {
Server,
BinaryEncoder,
- Int16Codec,
+ UInt16Codec,
BooleanCodec,
StringCodec,
// ...
@@ -25,12 +25,12 @@ And in the browser as well:
```html
-
+
+
```
diff --git a/doc/webpack.config.js b/doc/webpack.config.js
deleted file mode 100644
index 5ee6187..0000000
--- a/doc/webpack.config.js
+++ /dev/null
@@ -1,37 +0,0 @@
-const webpack = require('webpack');
-
-const rules = [
- {
- test: /\.js$/,
- exclude: /node_modules/,
- include: '/node_modules/netcode/src/',
- use: {
- loader: 'babel-loader',
- options: {
- presets: ['@babel/preset-env']
- }
- }
- }
-];
-
-const clientConfig = {
- target: 'web',
- entry: './src/client.js',
- output: {
- filename: 'client.js',
- path: `${__dirname}/dist/`,
- },
- module: { rules }
-};
-
-const serverConfig = {
- target: 'node',
- entry: './src/server.js',
- output: {
- filename: 'server.js',
- path: `${__dirname}/dist/server/`,
- },
- module: { rules }
-};
-
-module.exports = [ serverConfig, clientConfig ];
diff --git a/eslint.config.js b/eslint.config.js
new file mode 100644
index 0000000..c310f9d
--- /dev/null
+++ b/eslint.config.js
@@ -0,0 +1,40 @@
+import globals from 'globals';
+import pluginJs from '@eslint/js';
+
+/** @type {import('eslint').Linter.Config[]} */
+export default [
+ {languageOptions: { globals: {...globals.browser, ...globals.node} }},
+ pluginJs.configs.recommended,
+ {
+ rules: {
+ 'indent': [
+ 'error',
+ 4,
+ { 'SwitchCase': 1 }
+ ],
+ 'linebreak-style': [
+ 'error',
+ 'unix'
+ ],
+ 'quotes': [
+ 'error',
+ 'single'
+ ],
+ 'semi': [
+ 'error',
+ 'always'
+ ],
+ 'no-console': [
+ 'error',
+ { 'allow': ['info', 'error'] }
+ ],
+ 'no-inline-comments': [
+ 'error'
+ ],
+ 'spaced-comment': [
+ 'error',
+ 'always'
+ ]
+ }
+ }
+];
diff --git a/go.mod b/go.mod
new file mode 100644
index 0000000..69f263d
--- /dev/null
+++ b/go.mod
@@ -0,0 +1,5 @@
+module github.com/Tom32i/netcode
+
+go 1.22.4
+
+require github.com/gorilla/websocket v1.5.3
diff --git a/go.sum b/go.sum
new file mode 100644
index 0000000..25a9fc4
--- /dev/null
+++ b/go.sum
@@ -0,0 +1,2 @@
+github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
+github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
diff --git a/go/beacon.go b/go/beacon.go
new file mode 100644
index 0000000..3f8e816
--- /dev/null
+++ b/go/beacon.go
@@ -0,0 +1,83 @@
+package netcode
+
+import (
+ "strconv"
+ "sync"
+ "time"
+)
+
+func CreateBeacon(socket *Socket, interval time.Duration, callback func(time.Duration)) *Beacon {
+ b := Beacon{
+ socket: socket,
+ callback: callback,
+ interval: interval,
+ ticker: time.NewTicker(interval),
+ done: make(chan bool),
+ }
+
+ b.ticker.Stop()
+
+ socket.Conn.SetPongHandler(b.onPong)
+
+ defer b.start()
+
+ return &b
+}
+
+type Beacon struct {
+ socket *Socket
+ callback func(time.Duration)
+ interval time.Duration
+ ticker *time.Ticker
+ done chan bool
+ ping time.Time
+ mu sync.RWMutex
+ running bool
+}
+
+func (b *Beacon) start() {
+ if !b.running {
+ go b.run()
+ b.sendPing()
+ }
+}
+
+func (b *Beacon) stop() {
+ if b.running {
+ b.done <- true
+ }
+}
+
+func (b *Beacon) destroy() {
+ b.stop()
+ close(b.done)
+}
+
+func (b *Beacon) run() {
+ defer b.ticker.Stop()
+
+ b.ticker.Reset(b.interval)
+
+ for {
+ select {
+ case <-b.done:
+ return
+ case <-b.ticker.C:
+ b.sendPing()
+ }
+ }
+}
+
+func (b *Beacon) sendPing() {
+ b.socket.Ping(strconv.FormatInt(time.Now().UnixMicro(), 10))
+}
+
+func (b *Beacon) onPong(response string) error {
+ now := time.Now()
+ value, _ := strconv.ParseInt(response, 10, 64)
+ ping := time.UnixMicro(value)
+
+ defer b.callback(now.Sub(ping))
+
+ return nil
+}
diff --git a/go/codec_boolean.go b/go/codec_boolean.go
new file mode 100644
index 0000000..5bdceb3
--- /dev/null
+++ b/go/codec_boolean.go
@@ -0,0 +1,20 @@
+package netcode
+
+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
+}
diff --git a/go/codec_float32.go b/go/codec_float32.go
new file mode 100644
index 0000000..9553566
--- /dev/null
+++ b/go/codec_float32.go
@@ -0,0 +1,18 @@
+package netcode
+
+import (
+ "bytes"
+ "math"
+)
+
+type Float32Codec struct {
+ codec UInt32Codec
+}
+
+func (c Float32Codec) Encode(buffer *bytes.Buffer, data any) {
+ c.codec.Encode(buffer, math.Float32bits(data.(float32)))
+}
+
+func (c Float32Codec) Decode(buffer *bytes.Buffer) any {
+ return math.Float32frombits(c.codec.Decode(buffer).(uint32))
+}
diff --git a/go/codec_float64.go b/go/codec_float64.go
new file mode 100644
index 0000000..e12603e
--- /dev/null
+++ b/go/codec_float64.go
@@ -0,0 +1,18 @@
+package netcode
+
+import (
+ "bytes"
+ "math"
+)
+
+type Float64Codec struct {
+ codec UInt64Codec
+}
+
+func (c Float64Codec) Encode(buffer *bytes.Buffer, data any) {
+ c.codec.Encode(buffer, math.Float64bits(data.(float64)))
+}
+
+func (c Float64Codec) Decode(buffer *bytes.Buffer) any {
+ return math.Float64frombits(c.codec.Decode(buffer).(uint64))
+}
diff --git a/go/codec_float_precision.go b/go/codec_float_precision.go
new file mode 100644
index 0000000..75a65f7
--- /dev/null
+++ b/go/codec_float_precision.go
@@ -0,0 +1,24 @@
+package netcode
+
+import (
+ "bytes"
+ "math"
+)
+
+func CreateFloatPrecisionCodec[F float32 | float64, T int8 | int16 | int32 | int64 | uint8 | uint16 | uint32 | uint64](codec Codec, precision int) *FloatPrecisionCodec[F, T] {
+ return &FloatPrecisionCodec[F, T]{codec, F(math.Pow10(precision))}
+}
+
+type FloatPrecisionCodec[F float32 | float64, T int8 | int16 | int32 | int64 | uint8 | uint16 | uint32 | uint64] struct {
+ codec Codec
+ factor F
+}
+
+func (c *FloatPrecisionCodec[F, T]) Encode(buffer *bytes.Buffer, data any) {
+ c.codec.Encode(buffer, T(c.factor*data.(F)))
+}
+
+func (c *FloatPrecisionCodec[F, T]) Decode(buffer *bytes.Buffer) any {
+ value := c.codec.Decode(buffer).(T)
+ return F(value) / c.factor
+}
diff --git a/go/codec_int16.go b/go/codec_int16.go
new file mode 100644
index 0000000..3a3d19a
--- /dev/null
+++ b/go/codec_int16.go
@@ -0,0 +1,19 @@
+package netcode
+
+import (
+ "bytes"
+ "encoding/binary"
+)
+
+type Int16Codec struct {
+}
+
+func (c Int16Codec) Encode(buffer *bytes.Buffer, data any) {
+ binary.Write(buffer, binary.BigEndian, data.(int16))
+}
+
+func (c Int16Codec) Decode(buffer *bytes.Buffer) any {
+ var data int16
+ binary.Read(buffer, binary.BigEndian, &data)
+ return data
+}
diff --git a/go/codec_int32.go b/go/codec_int32.go
new file mode 100644
index 0000000..75d3f97
--- /dev/null
+++ b/go/codec_int32.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
+}
diff --git a/go/codec_int64.go b/go/codec_int64.go
new file mode 100644
index 0000000..15ab839
--- /dev/null
+++ b/go/codec_int64.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])
+}
diff --git a/go/codec_int8.go b/go/codec_int8.go
new file mode 100644
index 0000000..90add4b
--- /dev/null
+++ b/go/codec_int8.go
@@ -0,0 +1,16 @@
+package netcode
+
+import (
+ "bytes"
+)
+
+type Int8Codec struct {
+}
+
+func (c Int8Codec) Encode(buffer *bytes.Buffer, data any) {
+ buffer.WriteByte(byte(data.(int8)))
+}
+
+func (c Int8Codec) Decode(buffer *bytes.Buffer) any {
+ return int8(buffer.Next(1)[0])
+}
diff --git a/go/codec_null.go b/go/codec_null.go
new file mode 100644
index 0000000..3aef690
--- /dev/null
+++ b/go/codec_null.go
@@ -0,0 +1,15 @@
+package netcode
+
+import (
+ "bytes"
+)
+
+type NullCodec struct {
+}
+
+func (c NullCodec) Encode(buffer *bytes.Buffer, data any) {
+}
+
+func (c NullCodec) Decode(buffer *bytes.Buffer) any {
+ return nil
+}
diff --git a/go/codec_string.go b/go/codec_string.go
new file mode 100644
index 0000000..cece506
--- /dev/null
+++ b/go/codec_string.go
@@ -0,0 +1,20 @@
+package netcode
+
+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))
+}
diff --git a/go/codec_string_long.go b/go/codec_string_long.go
new file mode 100644
index 0000000..2937286
--- /dev/null
+++ b/go/codec_string_long.go
@@ -0,0 +1,25 @@
+package netcode
+
+import (
+ "bytes"
+ "encoding/binary"
+)
+
+type StringLongCodec struct {
+}
+
+func (c StringLongCodec) 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 StringLongCodec) Decode(buffer *bytes.Buffer) any {
+ length := binary.BigEndian.Uint16(buffer.Next(2))
+
+ return string(buffer.Next(int(length)))
+}
diff --git a/go/codec_test.go b/go/codec_test.go
new file mode 100644
index 0000000..3b72f01
--- /dev/null
+++ b/go/codec_test.go
@@ -0,0 +1,455 @@
+package netcode
+
+import (
+ "bytes"
+ "math"
+ "testing"
+)
+
+// Test BooleanCodec encode/decode.
+func TestBooleanCodec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got bool
+ codec := BooleanCodec{}
+
+ want = false
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(bool)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = true
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(bool)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test Float32Codec encode/decode.
+func TestFloat32Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got float32
+ codec := Float32Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 1.123
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxFloat32
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test Float64Codec encode/decode.
+func TestFloat64Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got float64
+ codec := Float64Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 1.123
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = -12456789.123456789087654321012345678901
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxFloat64
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test FloatPrecisionCodec(Int8Codec, 2) encode/decode.
+func TestFloatPrecisionCodecInt8(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got float32
+ codec := CreateFloatPrecisionCodec[float32, int8](Int8Codec{}, 2)
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 0.99
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = -0.65
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 0.1
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 1.27
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = -1.28
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test FloatPrecisionCodec(UInt32Codec, 3) encode/decode.
+func TestFloatPrecisionCodecUInt32Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got float64
+ codec := CreateFloatPrecisionCodec[float64, uint32](UInt32Codec{}, 3)
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 4294967.295
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 123456.999
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 5.2
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(float64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test Int8Codec encode/decode.
+func TestInt8Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got int8
+ codec := Int8Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int8)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxInt8
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int8)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MinInt8
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int8)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test Int16Codec encode/decode.
+func TestInt16Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got int16
+ codec := Int16Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int16)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxInt16
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int16)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MinInt16
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int16)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test Int32Codec encode/decode.
+func TestInt32Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got int32
+ codec := Int32Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxInt32
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MinInt32
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(int32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test StringCodec encode/decode.
+func TestStringCodec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got string
+ codec := StringCodec{}
+
+ want = "Hell0 wœrld$ 🌝 !"
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(string)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test StringLongCodec encode/decode.
+func TestStringLongCodec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got string
+ codec := StringLongCodec{}
+
+ want = "data:image/jpeg;base64,/9j/4AAQSkZJRgABAQAAAQABAAD/4gKgSUNDX1BST0ZJTEUAAQEAAAKQbGNtcwQwAABtbnRyUkdCIFhZWiAH3gADABUACAAUABVhY3NwQVBQTAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA9tYAAQAAAADTLWxjbXMAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAtkZXNjAAABCAAAADhjcHJ0AAABQAAAAE53dHB0AAABkAAAABRjaGFkAAABpAAAACxyWFlaAAAB0AAAABRiWFlaAAAB5AAAABRnWFlaAAAB+AAAABRyVFJDAAACDAAAACBnVFJDAAACLAAAACBiVFJDAAACTAAAACBjaHJtAAACbAAAACRtbHVjAAAAAAAAAAEAAAAMZW5VUwAAABwAAAAcAHMAUgBHAEIAIABiAHUAaQBsAHQALQBpAG4AAG1sdWMAAAAAAAAAAQAAAAxlblVTAAAAMgAAABwATgBvACAAYwBvAHAAeQByAGkAZwBoAHQALAAgAHUAcwBlACAAZgByAGUAZQBsAHkAAAAAWFlaIAAAAAAAAPbWAAEAAAAA0y1zZjMyAAAAAAABDEoAAAXj///zKgAAB5sAAP2H///7ov///aMAAAPYAADAlFhZWiAAAAAAAABvlAAAOO4AAAOQWFlaIAAAAAAAACSdAAAPgwAAtr5YWVogAAAAAAAAYqUAALeQAAAY3nBhcmEAAAAAAAMAAAACZmYAAPKnAAANWQAAE9AAAApbcGFyYQAAAAAAAwAAAAJmZgAA8qcAAA1ZAAAT0AAACltwYXJhAAAAAAADAAAAAmZmAADypwAADVkAABPQAAAKW2Nocm0AAAAAAAMAAAAAo9cAAFR7AABMzQAAmZoAACZmAAAPXP/bAEMABQMEBAQDBQQEBAUFBQYHDAgHBwcHDwsLCQwRDxISEQ8RERMWHBcTFBoVEREYIRgaHR0fHx8TFyIkIh4kHB4fHv/bAEMBBQUFBwYHDggIDh4UERQeHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHh4eHv/AABEIAEkASQMBIgACEQEDEQH/xAAcAAACAgMBAQAAAAAAAAAAAAAFBgQHAAEDCAL/xABCEAABAwIFAQQECAwHAAAAAAABAgMEBREABhIhMUEHFFFhEyKBkRUjJDJUcXLRFjRCUnOSk6GxsrPBJTM2YoLC4f/EABsBAAICAwEAAAAAAAAAAAAAAAQFAwYAAQIH/8QALREAAgEDAgQDCAMAAAAAAAAAAQIRAAMhBBIFMUFxIlFhBhMUMoGRwdGh4fD/2gAMAwEAAhEDEQA/APMlMb+QziOjQ/jgclu3Q4YKTHPwbUzbhpP8cClNEC9tsNtuK5ByaiFBO1sd4CNUxoW4OD1Dybmitx+8UqgzpbPR1LelB+pSrA+zEeNR6nGzAKU/AfaqAOgR1ossqPAt53wMuqsNcKBwSOYkSO46VIbbhZIMGgjydTy1eKjiVQ5CoNRbeudN7K+rFxUrshy/TW4qM4Zj9DUJdvRxWHUt7k2sCQSrfa9gL9cJ3a1kdrJtajR4ktx+NLaU4yHra0lJspJI2PI8OcKNJ7S6DVakae0xkzBggGOcHrRd3huot2t7DHfIoDnCnhiYmW0PiXxcEcXwES2Lc4dKU2a1lZ2IsEvx/mE8+X3YUdCkqKSCCDY4sRXrS5GPLyrUOOXZLbQ/KUBhn/w/xTgRR2ygSJZGzLZt9o7DEP1/zjjaiK0V3Gnem0wt02p+ktpUhKQfbiLlxqkQsxRptchuzqZHVrXHbIBdI4Bv0vyMM9OdL8CoofbAKdIFhbrgYmmS5UpEWJFXKdWqyENIKlKPkBjrUWFeyysYBBkzEDv0712jw8iraypmfOWas2Q1UWhJp+UUkFTj7AAU0BY2XxfwSnYe/FadtGbhH7W2qzlpTK3aZGTGLy29aFuAr1bHkAKsD4g+WH/Jc7tTgT6PluLTPRwYi0svMvQbJQ1quoqcPkTwffjr2t5TpOcO3Ki5ciSGorgp7j9VLaQVlCVAoTtwspJ3PAI8seNJascO4mQ6rs2NG0z4fNvMsKtHvjesiDmR9/6pH7NKTVe0jNv4U1pxXcoa0GQ4pOhK1I3S2jpYWufAYAdtNYdzpnR1VHbXJg02OpDSmxfUlJu479km3sA8cenK9kukryk1liLOVRKU2kIdaiFKVuI/NKjcgE7qNiVe+9LZnyjEomZtOTHVMR/g92O7IddK3C6oiygLcADoMb4VxG1qNWb+2IEIIgKPU+Z9JgYqZrLtb2DPn60iCazQc7vR0xS1TnSlLdgd0lIuRfne+PvMmWAqqGXDWFRn/XBHQ9cbz9ST6Nt1NRaMphR+JVcXCrGyTwCLcG2x2x3pMuTMy56WOrRNicpUNlDwIx6ZwrWb7IVsxVf1um93dJrhIoAj0dDQG769Z+ocYHfAH1+7BprNUSqpShTCo8lpGlTR3G3JB8Ma7+nwVh7a23F3DlQbKEMUeltIbaqZaULXQdvM3w19jLBcrkebFzCzBqKCUIjIj+kW8g8pIJAIPlc4S59RpzNWNLXIU04tsIcB+aF+rpuff78OGQKUqn5qaYqDBKJLK2T8YUJKXE6TcpsobHkWOEfHNWl3h18I0Qp6AyI8jIijNLo3W8Nwme+KvmZXW47LaHHNC3ZCYyRaxU6pQRbpbcjx9uFBMqh0HMUCIugop82sd7LbzSEOuvFlOtRLlzqStNyDc72FsSKu7S8q5NqCoVEqYh0lLkttz4OWY7DiTqDgW6sFQCgDdIJ8MD6VV6lF7IaHmWDlxjMMyenWYkB5MeLDSq5V4defMnHi9m0ltNyDwsdvRcwSJzAjBz2mngfMfsmlOpZir06nsVWNHcjwplNDzbbjQQ+3J7zbQUncfEg36dRzhQqqa3OzCy8XI4g6F95ZdcAWolRKCEp4tZNjfcXvjO2KqVqXX6ectsyG3HR8oZaUpTTZ2sSrgb6t+oHGJMhfyLu0qTokrY0uSmQlFlf7b7+fGLPpbey2t0ADdOOoHr+D9aNUSShnEdqqDNEJ2JWX1GrszpalEyNAKSlR5G+x9nGJuRKyI1YTHlps296ir8YFZhoztMlqQmUxMQSSFtrGr/knkH92Brby0KBJuUm4vyMXfTtCqwM/xVbvDxMpEU2ZlgLoeaA82EmM+eTwEk74n/I/psb9oMdKtIYr2R0zEKJlRB6+3GEbTJ8GP2qfvwxTWfDkquQc0KLO8ScUyUytVSmSVSEKXpBKyDxexNwem9sWHAz7SEtImTqwx35CwAh1ze2298V6mCxUaLFe7u88VKS4tvWUpXYnbjyta+FsTIcYehVR4rhQ5yVqSSNZOk28ja+EBtreDLHPB/006+IuacCcjmJr0RJ7ScgSkuO1GfAmKcuVNyXX30gnolJukDythbqvabCkR/g6mViDCgAnRGYCWkC/WwH9sUuJ0f0lzSWCglJKA6rcC+1+d7jjwx9d+gXSVUGMUghRBfc32G178ffgJeC2VAHiIHIEiB9K2nFCuQi/YzVoIluTySioIfSd/Ue1fuGIMuTDZeZadkEKeXoRZN7nzxW7U+Ay6lbdGZTpVc2fWCdx1HkCPbjq3XQh9DvcUEtkFILqjYi/jvzY/WPA2wUuh28vx+6w8U3DlTXnKM38k0lCVKWpJWs2A2vhSUtC9lW9v34nVPNaKg22iTR2CEEn1Xl8n+3liLIqcU6HI0JmMFXsFXI5PU822HswVYV0UKwoPUXUuOWFGcuJtSZ7IUVNup0rSFX20qPHTcDfC93WX9He/UOHfLyFnKcirmUFqb1H0aGxpsNtJ69cDPwklfRmP1f/AHEdq4xd9onNE3rKC1b3mMSO1DabmOZAp/cmQlxtKtSfSN7p62BvxgS6S5JKiPnLufffEfqcdD+Mp+1gpUVZIHOgGuM4AY8qmIY9W4HQ/wBO+OcpvTcWtt/1T9+JrP8Aln7K/wChiNU/yvsn+VvGA5rCuJoSeT9eMFzfwxrxxgxJUNZg1l2LFmSmW5aC4hLajpva/rYC9MHcrfjbf6JX8wxxc+U1JZ+cTT1IMdnKc2PGaQ02GlWSgWGK/wDSeYw7TP8ATkz9GcIOBdGoXd3o/XuW2dq//9kgICAgICAgICAgICAgICAgIA=="
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(string)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test NullCodec encode/decode.
+func TestNullCodec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got any
+ codec := NullCodec{}
+
+ want = nil
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test UInt8Codec encode/decode.
+func TestUInt8Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got uint8
+ codec := UInt8Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint8)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxUint8
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint8)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test UInt16Codec encode/decode.
+func TestUInt16Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got uint16
+ codec := UInt16Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint16)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxUint16
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint16)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test UInt32Codec encode/decode.
+func TestUInt32Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got uint32
+ codec := UInt32Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxUint32
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint32)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test UInt64Codec encode/decode.
+func TestUInt64Codec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got uint64
+ codec := UInt64Codec{}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = math.MaxUint64
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint64)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
+
+// Test UIntLongCodec encode/decode.
+func TestUIntLongCodec(t *testing.T) {
+ var buffer bytes.Buffer
+ var want, got uint
+ codec := UIntLongCodec{6}
+
+ want = 0
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 127
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+
+ want = 281474976710655
+ codec.Encode(&buffer, want)
+ got = codec.Decode(&buffer).(uint)
+
+ if got != want {
+ t.Fatalf(`Encode/Decode(%v) got %v, want %v`, want, got, want)
+ }
+}
diff --git a/go/codec_uint16.go b/go/codec_uint16.go
new file mode 100644
index 0000000..71fdd79
--- /dev/null
+++ b/go/codec_uint16.go
@@ -0,0 +1,22 @@
+package netcode
+
+import (
+ "bytes"
+ "encoding/binary"
+)
+
+/**
+ * 16 bit unsigned Int codec (0 to 65535)
+ */
+type UInt16Codec struct {
+}
+
+func (c UInt16Codec) Encode(buffer *bytes.Buffer, data any) {
+ b := make([]byte, 2)
+ binary.BigEndian.PutUint16(b, data.(uint16))
+ buffer.Write(b)
+}
+
+func (c UInt16Codec) Decode(buffer *bytes.Buffer) any {
+ return binary.BigEndian.Uint16(buffer.Next(2))
+}
diff --git a/go/codec_uint32.go b/go/codec_uint32.go
new file mode 100644
index 0000000..c82ca94
--- /dev/null
+++ b/go/codec_uint32.go
@@ -0,0 +1,22 @@
+package netcode
+
+import (
+ "bytes"
+ "encoding/binary"
+)
+
+/**
+ * 16 bit unsigned Int codec (from 0 to 65535)
+ */
+type UInt32Codec struct {
+}
+
+func (c UInt32Codec) Encode(buffer *bytes.Buffer, data any) {
+ b := make([]byte, 4)
+ binary.BigEndian.PutUint32(b, data.(uint32))
+ buffer.Write(b)
+}
+
+func (c UInt32Codec) Decode(buffer *bytes.Buffer) any {
+ return binary.BigEndian.Uint32(buffer.Next(4))
+}
diff --git a/go/codec_uint64.go b/go/codec_uint64.go
new file mode 100644
index 0000000..919ce6f
--- /dev/null
+++ b/go/codec_uint64.go
@@ -0,0 +1,22 @@
+package netcode
+
+import (
+ "bytes"
+ "encoding/binary"
+)
+
+/*
+ * 64 bit unsigned Int codec (0 to 18446744073709551615)
+ */
+type UInt64Codec struct {
+}
+
+func (c UInt64Codec) Encode(buffer *bytes.Buffer, data any) {
+ b := make([]byte, 8)
+ binary.BigEndian.PutUint64(b, data.(uint64))
+ buffer.Write(b)
+}
+
+func (c UInt64Codec) Decode(buffer *bytes.Buffer) any {
+ return binary.BigEndian.Uint64(buffer.Next(8))
+}
diff --git a/go/codec_uint8.go b/go/codec_uint8.go
new file mode 100644
index 0000000..e2377e1
--- /dev/null
+++ b/go/codec_uint8.go
@@ -0,0 +1,19 @@
+package netcode
+
+import (
+ "bytes"
+)
+
+/*
+ * 8 bit unsigned Int codec (0 to 255)
+ */
+type UInt8Codec struct {
+}
+
+func (c UInt8Codec) Encode(buffer *bytes.Buffer, data any) {
+ buffer.WriteByte(data.(uint8))
+}
+
+func (c UInt8Codec) Decode(buffer *bytes.Buffer) any {
+ return buffer.Next(1)[0]
+}
diff --git a/go/codec_uint_long.go b/go/codec_uint_long.go
new file mode 100644
index 0000000..f4b8d59
--- /dev/null
+++ b/go/codec_uint_long.go
@@ -0,0 +1,34 @@
+package netcode
+
+import (
+ "bytes"
+ "fmt"
+ "strconv"
+)
+
+type UIntLongCodec struct {
+ ByteLength int
+}
+
+func (c UIntLongCodec) Encode(buffer *bytes.Buffer, data any) {
+ format := fmt.Sprintf("%%0%ds", c.ByteLength*8)
+ value := strconv.FormatUint(uint64(data.(uint)), 2)
+ value = fmt.Sprintf(format, value)
+
+ for i := 0; i < c.ByteLength*8; i = i + 8 {
+ x, _ := strconv.ParseUint(value[i:i+8], 2, 8)
+ buffer.WriteByte(uint8(x))
+ }
+}
+
+func (c UIntLongCodec) Decode(buffer *bytes.Buffer) any {
+ var buf = new(bytes.Buffer)
+ parts := buffer.Next(c.ByteLength)
+ for _, x := range parts {
+ buf.WriteString(fmt.Sprintf("%08s", strconv.FormatUint(uint64(x), 2)))
+ }
+
+ value, _ := strconv.ParseUint(buf.String(), 2, 64)
+
+ return uint(value)
+}
diff --git a/go/encoder.go b/go/encoder.go
new file mode 100644
index 0000000..9503148
--- /dev/null
+++ b/go/encoder.go
@@ -0,0 +1,75 @@
+package netcode
+
+import (
+ "bytes"
+ "fmt"
+)
+
+type BinaryEncoder struct {
+ idCodec Codec
+ codecsByName map[string]*RegisteredCodec
+ codecsById map[uint8]*RegisteredCodec
+}
+
+type RegisteredCodec struct {
+ Id uint8
+ Name string
+ Handler Codec
+}
+
+type Codec interface {
+ Encode(buffer *bytes.Buffer, data any)
+ Decode(buffer *bytes.Buffer) any
+}
+
+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 id, codec := range codecs {
+ codec.Id = uint8(id)
+ codecsById[codec.Id] = codec
+ codecsByName[codec.Name] = codec
+ }
+
+ return &BinaryEncoder{
+ idCodec: idCodec,
+ codecsByName: codecsByName,
+ codecsById: codecsById,
+ }
+}
+
+func (e BinaryEncoder) Encode(message *Message) ([]byte, error) {
+ var buffer bytes.Buffer
+
+ codec, ok := e.codecsByName[message.Name]
+
+ if !ok {
+ return buffer.Bytes(), fmt.Errorf(" %w: name \"%s\" could be not found", ErrCodecNotFound, message.Name)
+ }
+
+ e.idCodec.Encode(&buffer, codec.Id)
+ codec.Handler.Encode(&buffer, message.Data)
+
+ return buffer.Bytes(), nil
+}
+
+func (e BinaryEncoder) Decode(data []byte) (*Message, error) {
+ var buffer = bytes.NewBuffer(data)
+ id := e.idCodec.Decode(buffer).(uint8)
+ codec, ok := e.codecsById[id]
+
+ if !ok {
+ return nil, fmt.Errorf(" %w: id \"%d\" could be not found", ErrCodecNotFound, id)
+ }
+
+ return &Message{
+ Name: codec.Name,
+ Data: codec.Handler.Decode(buffer),
+ }, nil
+}
diff --git a/go/errors.go b/go/errors.go
new file mode 100644
index 0000000..eedf380
--- /dev/null
+++ b/go/errors.go
@@ -0,0 +1,12 @@
+package netcode
+
+type ServerError string
+
+func (err ServerError) Error() string {
+ return string(err)
+}
+
+const (
+ ErrCodecNotFound = ServerError("codec not found")
+ ErrInternal = ServerError("internal error")
+)
diff --git a/go/server.go b/go/server.go
new file mode 100644
index 0000000..9b8cfb8
--- /dev/null
+++ b/go/server.go
@@ -0,0 +1,40 @@
+package netcode
+
+import (
+ "fmt"
+ "github.com/gorilla/websocket"
+ "log"
+ "net/http"
+)
+
+func Start(port int, path string, onSocket func(w http.ResponseWriter, r *http.Request, c *websocket.Conn), checkOrigin func(r *http.Request) bool, errorHandler func(w http.ResponseWriter, r *http.Request, status int, reason error)) {
+ upgrader := &websocket.Upgrader{
+ ReadBufferSize: 1024,
+ WriteBufferSize: 1024,
+ Subprotocols: []string{"websocket"},
+ Error: errorHandler,
+ CheckOrigin: checkOrigin,
+ }
+
+ http.HandleFunc(path, func(w http.ResponseWriter, r *http.Request) {
+ s, err := upgrader.Upgrade(w, r, nil)
+
+ if err == nil {
+ onSocket(w, r, s)
+ }
+ })
+
+ err := http.ListenAndServe(fmt.Sprintf(":%d", port), nil)
+
+ if err != nil {
+ log.Fatal(err)
+ }
+}
+
+func CheckOrigin(r *http.Request) bool {
+ return true
+}
+
+func ErrorHandler(w http.ResponseWriter, r *http.Request, status int, reason error) {
+ http.Error(w, reason.Error(), status)
+}
diff --git a/go/socket.go b/go/socket.go
new file mode 100644
index 0000000..5af420b
--- /dev/null
+++ b/go/socket.go
@@ -0,0 +1,79 @@
+package netcode
+
+import (
+ "github.com/gorilla/websocket"
+ "log"
+ "sync"
+ "time"
+)
+
+type Socket struct {
+ ID uint
+ In chan SocketMessage
+ Conn *websocket.Conn
+ Encoder *BinaryEncoder
+ mu sync.Mutex
+}
+
+type SocketMessage struct {
+ Socket *Socket
+ Message *Message
+ Err error
+}
+
+func (s *Socket) Send(message *Message) {
+ data, err := s.Encoder.Encode(message)
+
+ if err == nil {
+ s.Write(data)
+ }
+}
+
+func (s *Socket) Write(data []byte) {
+ s.mu.Lock()
+ defer s.mu.Unlock()
+ s.Conn.WriteMessage(websocket.BinaryMessage, data)
+}
+
+func (s *Socket) Ping(message string) {
+ s.mu.Lock()
+ defer s.mu.Unlock()
+ s.Conn.WriteControl(websocket.PingMessage, []byte(message), time.Now().Add(time.Second*5))
+}
+
+func (s *Socket) Pong(message string) {
+ s.mu.Lock()
+ defer s.mu.Unlock()
+ s.Conn.WriteControl(websocket.PongMessage, []byte(message), time.Now().Add(time.Second*5))
+}
+
+func (s *Socket) Close(code int, message string) {
+ s.mu.Lock()
+ defer s.mu.Unlock()
+ s.Conn.WriteControl(websocket.CloseMessage, websocket.FormatCloseMessage(code, message), time.Now().Add(time.Second*5))
+}
+
+func (s *Socket) Run(onClose func(*Socket)) {
+ defer func() {
+ s.Conn.Close()
+ onClose(s)
+ }()
+
+ for {
+ _, data, err := s.Conn.ReadMessage()
+
+ if err != nil {
+ if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseNormalClosure) {
+ log.Printf("Socket closed unexpectedly: %v", err)
+ }
+ return
+ }
+
+ go s.Handle(data)
+ }
+}
+
+func (s *Socket) Handle(data []byte) {
+ message, err := s.Encoder.Decode(data)
+ s.In <- SocketMessage{s, message, err}
+}
diff --git a/go/sockets.go b/go/sockets.go
new file mode 100644
index 0000000..261b01c
--- /dev/null
+++ b/go/sockets.go
@@ -0,0 +1,148 @@
+package netcode
+
+import (
+ "errors"
+ "github.com/gorilla/websocket"
+ "log"
+ "sync"
+)
+
+func CreateSockets(encoder *BinaryEncoder, max uint) *Sockets {
+ return &Sockets{
+ Encoder: encoder,
+ In: make(chan SocketMessage),
+ Out: make(chan *Socket),
+ List: make(map[uint]*Socket),
+ max: max,
+ }
+}
+
+type Sockets struct {
+ Encoder *BinaryEncoder
+ In chan SocketMessage
+ Out chan *Socket
+ List map[uint]*Socket
+ max uint
+ mu sync.RWMutex
+}
+
+func (ss *Sockets) generateId() (uint, error) {
+ for id := uint(0); id < ss.max; id++ {
+ ss.mu.RLock()
+ _, ok := ss.List[id]
+ ss.mu.RUnlock()
+
+ if !ok {
+ return id, nil
+ }
+ }
+
+ return uint(0), errors.New("Socket limit reached!")
+}
+
+func (ss *Sockets) Add(c *websocket.Conn) (*Socket, error) {
+ id, err := ss.generateId()
+
+ if err != nil {
+ return nil, err
+ }
+
+ socket := &Socket{
+ ID: id,
+ Conn: c,
+ Encoder: ss.Encoder,
+ In: ss.In,
+ }
+
+ ss.mu.Lock()
+ ss.List[socket.ID] = socket
+ ss.mu.Unlock()
+
+ go socket.Run(ss.Remove)
+
+ return socket, nil
+}
+
+func (ss *Sockets) Remove(socket *Socket) {
+ ss.mu.Lock()
+ delete(ss.List, socket.ID)
+ ss.mu.Unlock()
+
+ ss.Out <- socket
+}
+
+func (ss *Sockets) Count() int {
+ return len(ss.List)
+}
+
+func (ss *Sockets) ForEach(callback func(*Socket)) {
+ ss.mu.RLock()
+ defer ss.mu.RUnlock()
+
+ for _, s := range ss.List {
+ callback(s)
+ }
+}
+
+func (ss *Sockets) ForOther(socket *Socket, callback func(*Socket)) {
+ ss.mu.RLock()
+ defer ss.mu.RUnlock()
+
+ for _, s := range ss.List {
+ if s.ID != socket.ID {
+ callback(s)
+ }
+ }
+}
+
+func (ss *Sockets) WriteAll(data []byte) {
+ ss.mu.RLock()
+ defer ss.mu.RUnlock()
+
+ for _, c := range ss.List {
+ c.Write(data)
+ }
+}
+
+func (ss *Sockets) WriteOther(socket *Socket, data []byte) {
+ ss.mu.RLock()
+ defer ss.mu.RUnlock()
+
+ for _, s := range ss.List {
+ if s.ID != socket.ID {
+ s.Write(data)
+ }
+ }
+}
+
+func (ss *Sockets) Send(socket *Socket, message *Message) {
+ bytes, err := ss.Encoder.Encode(message)
+ if err == nil {
+ socket.Write(bytes)
+ } else {
+ log.Printf("Error: %v", err)
+ }
+}
+
+func (ss *Sockets) SendAll(message *Message) {
+ bytes, err := ss.Encoder.Encode(message)
+ if err == nil {
+ ss.WriteAll(bytes)
+ } else {
+ log.Printf("Error: %v", err)
+ }
+}
+
+func (ss *Sockets) SendOther(socket *Socket, message *Message) {
+ bytes, err := ss.Encoder.Encode(message)
+ if err == nil {
+ ss.WriteOther(socket, bytes)
+ } else {
+ log.Printf("Error: %v", err)
+ }
+}
+
+func (ss *Sockets) Clear() {
+ close(ss.In)
+ close(ss.Out)
+}
diff --git a/index.html b/index.html
index 444e6a0..d9998ce 100644
--- a/index.html
+++ b/index.html
@@ -1,9 +1,23 @@
-
-
-
- Netcode Demo
-
-
-
-
+
+
+
+
+ Netcode
+
+
+
+ Netcode logs
+