Oh sorry, wrong place to put a issue!

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/gsocket-io/golang-socketio
 
 ### Simple server usage
 

client.go

@@ -1,14 +1,15 @@
 package gosocketio
 
 import (
-	"github.com/graarh/golang-socketio/transport"
+	"github.com/gsocket-io/golang-socketio/transport"
+	"net"
 	"strconv"
 )
 
 const (
-	webSocketProtocol = "ws://"
+	webSocketProtocol       = "ws://"
 	webSocketSecureProtocol = "wss://"
-	socketioUrl       = "/socket.io/?EIO=3&transport=websocket"
+	socketioUrl             = "/socket.io/?EIO=3&transport=websocket"
 )
 
 /**
@@ -21,15 +22,15 @@ type Client struct {
 
 /**
 Get ws/wss url by host and port
- */
+*/
 func GetUrl(host string, port int, secure bool) string {
 	var prefix string
 	if secure {
 		prefix = webSocketSecureProtocol
 	} else {
 		prefix = webSocketProtocol
 	}
-	return prefix + host + ":" + strconv.Itoa(port) + socketioUrl
+	return prefix + net.JoinHostPort(host, strconv.Itoa(port)) + socketioUrl
 }
 
 /**

examples/client.go

@@ -1,8 +1,8 @@
 package main
 
 import (
-	"github.com/graarh/golang-socketio"
-	"github.com/graarh/golang-socketio/transport"
+	"github.com/gsocket-io/golang-socketio"
+	"github.com/gsocket-io/golang-socketio/transport"
 	"log"
 	"runtime"
 	"time"

examples/server.go

@@ -1,8 +1,8 @@
 package main
 
 import (
-	"github.com/graarh/golang-socketio"
-	"github.com/graarh/golang-socketio/transport"
+	"github.com/gsocket-io/golang-socketio"
+	"github.com/gsocket-io/golang-socketio/transport"
 	"log"
 	"net/http"
 	"time"

handler.go

@@ -2,9 +2,9 @@ package gosocketio
 
 import (
 	"encoding/json"
-	"github.com/graarh/golang-socketio/protocol"
-	"sync"
+	"github.com/gsocket-io/golang-socketio/protocol"
 	"reflect"
+	"sync"
 )
 
 const (

loop.go

@@ -3,8 +3,8 @@ package gosocketio
 import (
 	"encoding/json"
 	"errors"
-	"github.com/graarh/golang-socketio/protocol"
-	"github.com/graarh/golang-socketio/transport"
+	"github.com/gsocket-io/golang-socketio/protocol"
+	"github.com/gsocket-io/golang-socketio/transport"
 	"net/http"
 	"sync"
 	"time"
@@ -48,9 +48,9 @@ type Channel struct {
 
 	ack ackProcessor
 
-	server        *Server
-	ip            string
-	requestHeader http.Header
+	server  *Server
+	ip      string
+	request *http.Request
 }
 
 /**

send.go

@@ -3,7 +3,7 @@ package gosocketio
 import (
 	"encoding/json"
 	"errors"
-	"github.com/graarh/golang-socketio/protocol"
+	"github.com/gsocket-io/golang-socketio/protocol"
 	"log"
 	"time"
 )

server.go

@@ -7,8 +7,8 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/graarh/golang-socketio/protocol"
-	"github.com/graarh/golang-socketio/transport"
+	"github.com/gsocket-io/golang-socketio/protocol"
+	"github.com/gsocket-io/golang-socketio/transport"
 	"math/rand"
 	"net/http"
 	"sync"
@@ -43,7 +43,7 @@ type Server struct {
 
 /**
 Close current channel
- */
+*/
 func (c *Channel) Close() {
 	if c.server != nil {
 		closeChannel(c, &c.server.methods)
@@ -65,7 +65,14 @@ func (c *Channel) Ip() string {
 Get request header of this connection
 */
 func (c *Channel) RequestHeader() http.Header {
-	return c.requestHeader
+	return c.request.Header
+}
+
+/**
+Get request
+*/
+func (c *Channel) Request() *http.Request {
+	return c.request
 }
 
 /**
@@ -278,6 +285,10 @@ func onDisconnectCleanup(c *Channel) {
 		delete(c.server.rooms, c)
 	}
 
+	go deleteSid(c)
+}
+
+func deleteSid(c *Channel) {
 	c.server.sidsLock.Lock()
 	defer c.server.sidsLock.Unlock()
 
@@ -304,7 +315,7 @@ func (s *Server) SendOpenSequence(c *Channel) {
 Setup event loop for given connection
 */
 func (s *Server) SetupEventLoop(conn transport.Connection, remoteAddr string,
-	requestHeader http.Header) {
+	r *http.Request) {
 
 	interval, timeout := conn.PingParams()
 	hdr := Header{
@@ -317,7 +328,7 @@ func (s *Server) SetupEventLoop(conn transport.Connection, remoteAddr string,
 	c := &Channel{}
 	c.conn = conn
 	c.ip = remoteAddr
-	c.requestHeader = requestHeader
+	c.request = r
 	c.initChannel()
 
 	c.server = s
@@ -340,7 +351,7 @@ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	s.SetupEventLoop(conn, r.RemoteAddr, r.Header)
+	s.SetupEventLoop(conn, r.RemoteAddr, r)
 	s.tr.Serve(w, r)
 }