🎨 Rename module

Author: JulianKropp

README.md

@@ -9,7 +9,7 @@ Examples directory contains simple client and server.
 
 ### Installation
 
-    go get github.com/graarh/golang-socketio
+    go get github.com/JulianKropp/golang-socketio
 
 ### Simple server usage
 

_examples/client.go

@@ -1,11 +1,11 @@
 package main
 
 import (
-	"github.com/graarh/golang-socketio"
-	"github.com/graarh/golang-socketio/transport"
 	"log"
 	"runtime"
 	"time"
+
+	"github.com/JulianKropp/golang-socketio/transport"
 )
 
 type Channel struct {

_examples/server.go

@@ -1,11 +1,11 @@
 package main
 
 import (
-	"github.com/graarh/golang-socketio"
-	"github.com/graarh/golang-socketio/transport"
 	"log"
 	"net/http"
 	"time"
+
+	"github.com/JulianKropp/golang-socketio/transport"
 )
 
 type Channel struct {

client.go

@@ -1,27 +1,30 @@
 package gosocketio
 
 import (
-	"github.com/graarh/golang-socketio/transport"
 	"strconv"
+
+	"github.com/JulianKropp/golang-socketio/transport"
 )
 
 const (
-	webSocketProtocol = "ws://"
+	webSocketProtocol       = "ws://"
 	webSocketSecureProtocol = "wss://"
-	socketioUrl       = "/socket.io/?EIO=3&transport=websocket"
+	socketioUrl             = "/socket.io/?EIO=3&transport=websocket"
 )
 
-/**
+/*
+*
 Socket.io client representation
 */
 type Client struct {
 	methods
 	Channel
 }
 
-/**
+/*
+*
 Get ws/wss url by host and port
- */
+*/
 func GetUrl(host string, port int, secure bool) string {
 	var prefix string
 	if secure {
@@ -32,22 +35,23 @@ func GetUrl(host string, port int, secure bool) string {
 	return prefix + host + ":" + strconv.Itoa(port) + socketioUrl
 }
 
-
-func NewClient() (*Client) {
+func NewClient() *Client {
 	c := &Client{}
 	c.initChannel()
 	c.initMethods()
 	return c
 }
-/**
+
+/*
+*
 connect to host and initialise socket.io protocol
 
 The correct ws protocol url example:
 ws://myserver.com/socket.io/?EIO=3&transport=websocket
 
 You can use GetUrlByHost for generating correct url
 */
-func (c *Client) Dial(url string, tr transport.Transport) (error) {
+func (c *Client) Dial(url string, tr transport.Transport) error {
 	var err error
 	c.conn, err = tr.Connect(url)
 	if err != nil {
@@ -61,7 +65,8 @@ func (c *Client) Dial(url string, tr transport.Transport) (error) {
 	return nil
 }
 
-/**
+/*
+*
 Close client connection
 */
 func (c *Client) Close() {

go.mod

@@ -1,7 +1,5 @@
-module socketio
+module github.com/JulianKropp/golang-socketio
 
 go 1.19
 
-require github.com/graarh/golang-socketio v0.0.0-20170510162725-2c44953b9b5f
-
 require github.com/gorilla/websocket v1.5.0

go.sum

@@ -1,4 +1,2 @@
 github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
 github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
-github.com/graarh/golang-socketio v0.0.0-20170510162725-2c44953b9b5f h1:utzdm9zUvVWGRtIpkdE4+36n+Gv60kNb7mFvgGxLElY=
-github.com/graarh/golang-socketio v0.0.0-20170510162725-2c44953b9b5f/go.mod h1:8gudiNCFh3ZfvInknmoXzPeV17FSH+X2J5k2cUPIwnA=

handler.go

@@ -2,9 +2,10 @@ package gosocketio
 
 import (
 	"encoding/json"
-	"github.com/graarh/golang-socketio/protocol"
-	"sync"
 	"reflect"
+	"sync"
+
+	"github.com/JulianKropp/golang-socketio/protocol"
 )
 
 const (
@@ -13,12 +14,14 @@ const (
 	OnError         = "error"
 )
 
-/**
+/*
+*
 System handler function for internal event processing
 */
 type systemHandler func(c *Channel)
 
-/**
+/*
+*
 Contains maps of message processing functions
 */
 type methods struct {
@@ -29,14 +32,16 @@ type methods struct {
 	onDisconnection systemHandler
 }
 
-/**
+/*
+*
 create messageHandlers map
 */
 func (m *methods) initMethods() {
 	m.messageHandlers = make(map[string]*caller)
 }
 
-/**
+/*
+*
 Add message processing function, and bind it to given method
 */
 func (m *methods) On(method string, f interface{}) error {
@@ -52,7 +57,8 @@ func (m *methods) On(method string, f interface{}) error {
 	return nil
 }
 
-/**
+/*
+*
 Find message processing function associated with given method
 */
 func (m *methods) findMethod(method string) (*caller, bool) {
@@ -79,7 +85,8 @@ func (m *methods) callLoopEvent(c *Channel, event string) {
 	f.callFunc(c, &struct{}{})
 }
 
-/**
+/*
+*
 Check incoming message
 On ack_resp - look for waiter
 On ack_req - look for processing function and send ack_resp

loop.go

@@ -3,11 +3,12 @@ package gosocketio
 import (
 	"encoding/json"
 	"errors"
-	"github.com/graarh/golang-socketio/protocol"
-	"github.com/graarh/golang-socketio/transport"
 	"net/http"
 	"sync"
 	"time"
+
+	"github.com/JulianKropp/golang-socketio/protocol"
+	"github.com/JulianKropp/golang-socketio/transport"
 )
 
 const (
@@ -18,7 +19,8 @@ var (
 	ErrorWrongHeader = errors.New("Wrong header")
 )
 
-/**
+/*
+*
 engine.io header to send or receive
 */
 type Header struct {
@@ -28,7 +30,8 @@ type Header struct {
 	PingTimeout  int      `json:"pingTimeout"`
 }
 
-/**
+/*
+*
 socket.io connection handler
 
 use IsAlive to check that handler is still working
@@ -53,7 +56,8 @@ type Channel struct {
 	requestHeader http.Header
 }
 
-/**
+/*
+*
 create channel, map, and set active
 */
 func (c *Channel) initChannel() {
@@ -63,14 +67,16 @@ func (c *Channel) initChannel() {
 	c.alive = true
 }
 
-/**
+/*
+*
 Get id of current socket connection
 */
 func (c *Channel) Id() string {
 	return c.header.Sid
 }
 
-/**
+/*
+*
 Checks that Channel is still alive
 */
 func (c *Channel) IsAlive() bool {
@@ -80,7 +86,8 @@ func (c *Channel) IsAlive() bool {
 	return c.alive
 }
 
-/**
+/*
+*
 Close channel
 */
 func closeChannel(c *Channel, m *methods, args ...interface{}) error {
@@ -110,7 +117,7 @@ func closeChannel(c *Channel, m *methods, args ...interface{}) error {
 	return nil
 }
 
-//incoming messages loop, puts incoming messages to In channel
+// incoming messages loop, puts incoming messages to In channel
 func inLoop(c *Channel, m *methods) error {
 	for {
 		pkg, err := c.conn.GetMessage()
@@ -149,7 +156,8 @@ func AmountOfOverflooded() int64 {
 	return int64(len(overflooded))
 }
 
-/**
+/*
+*
 outgoing messages loop, sends messages from channel to socket
 */
 func outLoop(c *Channel, m *methods) error {
@@ -180,7 +188,8 @@ func outLoop(c *Channel, m *methods) error {
 	return nil
 }
 
-/**
+/*
+*
 Pinger sends ping messages for keeping connection alive
 */
 func pinger(c *Channel) {

send.go

@@ -3,17 +3,19 @@ package gosocketio
 import (
 	"encoding/json"
 	"errors"
-	"github.com/graarh/golang-socketio/protocol"
 	"log"
 	"time"
+
+	"github.com/JulianKropp/golang-socketio/protocol"
 )
 
 var (
 	ErrorSendTimeout     = errors.New("Timeout")
 	ErrorSocketOverflood = errors.New("Socket overflood")
 )
 
-/**
+/*
+*
 Send message packet to socket
 */
 func send(msg *protocol.Message, c *Channel, args interface{}) error {
@@ -47,7 +49,8 @@ func send(msg *protocol.Message, c *Channel, args interface{}) error {
 	return nil
 }
 
-/**
+/*
+*
 Create packet based on given data and send it
 */
 func (c *Channel) Emit(method string, args interface{}) error {
@@ -59,7 +62,8 @@ func (c *Channel) Emit(method string, args interface{}) error {
 	return send(msg, c, args)
 }
 
-/**
+/*
+*
 Create ack packet based on given data and send it and receive response
 */
 func (c *Channel) Ack(method string, args interface{}, timeout time.Duration) (string, error) {