initial commit

Author: NetvoidStaff

.editorconfig

@@ -0,0 +1,27 @@
+; https://editorconfig.org/
+root = true
+
+[*]
+insert_final_newline = true
+charset = utf-8
+trim_trailing_whitespace = true
+indent_style = space
+indent_size = 2
+
+[{Makefile,go.mod,go.sum,*.go,.gitmodules}]
+indent_style = tab
+indent_size = 4
+
+[*.md]
+indent_size = 4
+trim_trailing_whitespace = false
+
+[*.yml,*.yaml]
+end_of_line = lf
+insert_final_newline = true
+indent_style = space
+indent_size = 2
+trim_trailing_whitespace = true
+
+[Dockerfile]
+indent_size = 4

.github/workflows/build.yml

@@ -0,0 +1,23 @@
+name: Build
+
+on:
+  push:
+    branches: [ "main" ]
+  pull_request:
+    branches: [ "main" ]
+
+jobs:
+
+  build:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v3
+    - uses: actions/setup-go@v4
+      with:
+        go-version: '1.21'
+
+    - name: Build
+      run: go build -v ./...
+
+    - name: Test
+      run: go test -v ./...

.gitignore

@@ -0,0 +1,18 @@
+# Binaries for programs and plugins
+*.exe
+*.exe~
+*.dll
+*.so
+*.dylib
+
+# Test binary, built with `go test -c`
+*.test
+
+# Output of the go coverage tool, specifically when used with LiteIDE
+*.out
+
+# Dependency directories (remove the comment below to include it)
+# vendor/
+
+# Go workspace file
+go.work

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2023 Merix
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,18 @@
+# NetGate
+![GitHub](https://img.shields.io/github/license/netvoid-labs/netgate)
+![GitHub go.mod Go version](https://img.shields.io/github/go-mod/go-version/netvoid-labs/netgate)
+![GitHub Workflow Status](https://img.shields.io/github/workflow/status/netvoid-labs/netgate/Build)
+![GitHub repo size](https://img.shields.io/github/repo-size/netvoid-labs/netgate)
+
+## Summary
+NetGate is Multiplayer Framework developed in Go and using Websockets.
+
+## Installation
+```
+go get github.com/netvoid-labs/netgate
+```
+
+## License
+```
+MIT
+```

client.go

@@ -0,0 +1,93 @@
+package netgate
+
+import (
+	"errors"
+	"strings"
+	"sync"
+
+	"github.com/google/uuid"
+	"github.com/gorilla/websocket"
+)
+
+type Client struct {
+	id   string          //unique id
+	conn *websocket.Conn //websocket connection
+	room *RoomInterface  //room where client is
+	lock *sync.Mutex     //lock
+}
+
+func newClient(conn *websocket.Conn) *Client {
+	return &Client{
+		id:   strings.ReplaceAll(uuid.New().String(), "-", ""),
+		conn: conn,
+		room: nil,
+		lock: &sync.Mutex{},
+	}
+}
+
+func (c *Client) GetID() string {
+	return c.id
+}
+
+func (c *Client) GetRoom() *RoomInterface {
+	return c.room
+}
+
+func (c *Client) Send(data []byte) error {
+	c.lock.Lock()
+	defer c.lock.Unlock()
+
+	if c.conn == nil {
+		return errors.New("client is not connected")
+	}
+
+	err := c.conn.WriteMessage(websocket.BinaryMessage, data)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (c *Client) Disconnect() error {
+	c.lock.Lock()
+	defer c.lock.Unlock()
+
+	if c.conn == nil {
+		return errors.New("client is not connected")
+	}
+
+	err := c.conn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
+	if err != nil {
+		return err
+	}
+
+	return c.close()
+}
+
+func (c *Client) close() error {
+	err := c.conn.Close()
+	if err != nil {
+		return err
+	}
+
+	c.conn = nil
+
+	return nil
+}
+
+func (c *Client) read() ([]byte, error) {
+	if c.conn == nil {
+		return nil, errors.New("client is not connected")
+	}
+
+	_, msg, err := c.conn.ReadMessage()
+	if err != nil {
+		if !websocket.IsCloseError(err, websocket.CloseNormalClosure, websocket.CloseGoingAway) {
+			return nil, err
+		}
+		return nil, err
+	}
+
+	return msg, nil
+}

cmd/client/main.go

@@ -0,0 +1,65 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"log"
+	"os"
+	"os/signal"
+	"syscall"
+
+	"github.com/gorilla/websocket"
+)
+
+func main() {
+	endpoint := flag.String("endpoint", "ws://localhost:4555", "server endpoint")
+	roomId := flag.String("id", "12345678", "room id")
+
+	ws, _, err := websocket.DefaultDialer.Dial(*endpoint+"/"+*roomId, nil)
+	if err != nil {
+		panic(err)
+	}
+
+	go func() {
+		defer ws.Close()
+
+		for {
+			mt, data, err := ws.ReadMessage()
+			if err != nil {
+				log.Println("Error while reading message:", err)
+				return
+			}
+			log.Println("recv message type:", mt, "message:", string(data))
+		}
+	}()
+
+	//user write input in console and whenr press enter, send to the server
+	go func() {
+		log.Println("Write a message to send to the server:")
+		for {
+			var msg string
+			_, err := fmt.Scanln(&msg)
+			if err != nil {
+				log.Println("Error while reading message:", err)
+				return
+			}
+			ws.WriteMessage(websocket.BinaryMessage, []byte(msg))
+		}
+	}()
+
+	//wait for ctrl+c
+	log.Println("Press Ctrl+C to stop")
+	c := make(chan os.Signal, 1)
+	signal.Notify(c, os.Interrupt, syscall.SIGTERM)
+	<-c
+
+	log.Println("Closing connection...")
+
+	//send close
+	err = ws.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
+	if err != nil {
+		log.Println("Error while sending close message:", err)
+	}
+
+	ws.Close()
+}

cmd/server/main.go

@@ -0,0 +1,41 @@
+package main
+
+import (
+	"log"
+
+	"github.com/netvoid-labs/netgate"
+)
+
+func main() {
+	server := netgate.NewNetGate()
+
+	server.Run(&TestGameRoom{})
+}
+
+// TestGameRoom is a simple game that implements the RoomInterface
+type TestGameRoom struct {
+	players map[string]*netgate.Client
+}
+
+func (s *TestGameRoom) Init() {
+	s.players = make(map[string]*netgate.Client)
+}
+
+func (s *TestGameRoom) Destroy() {
+	s.players = nil
+}
+
+func (s *TestGameRoom) Update(tick int64) {
+}
+
+func (s *TestGameRoom) ClientJoin(client *netgate.Client) {
+	s.players[client.GetID()] = client
+}
+
+func (s *TestGameRoom) ClientLeave(client *netgate.Client) {
+	delete(s.players, client.GetID())
+}
+
+func (s *TestGameRoom) ClientData(client *netgate.Client, data []byte) {
+	log.Printf("Client %s data: %s\n", client.GetID(), string(data))
+}

go.mod

@@ -0,0 +1,8 @@
+module github.com/netvoid-labs/netgate
+
+go 1.21
+
+require (
+	github.com/google/uuid v1.3.0
+	github.com/gorilla/websocket v1.5.0
+)

go.sum

@@ -0,0 +1,4 @@
+github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
+github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
+github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=