v4.0.6:

Supported lib net/http

README.md

@@ -25,10 +25,35 @@ import "github.com/doquangtan/socket.io/v4"
 and use `socketio` as the package name inside the code.
 
 # Documents
+
 ## Server
+
 ### Constructor
+
 #### socketio.New
+
+Using with standard library [net/http](https://pkg.go.dev/net/http)
+
+```go
+import (
+	"net/http"
+	socketio "github.com/doquangtan/socket.io/v4"
+)
+
+func main() {
+	io := socketio.New()
+
+	io.OnConnection(func(socket *socketio.Socket) {
+		// ...
+	})
+
+	http.Handle("/socket.io/", io.HttpHandler())
+	http.ListenAndServe(":3000", nil)
+}
+```
+
 Using with fiber framework [Go Fiber](https://gofiber.io)
+
 ```go
 import (
 	socketio "github.com/doquangtan/socket.io/v4"
@@ -54,23 +79,29 @@ func main() {
 ```
 
 ### Events
+
 #### Event: 'connection'
+
 ```go
 io.OnConnection(func(socket *socketio.Socket) {
 	// ...
 })
 ```
 
 ### Methods
+
 #### server.emit(eventName[, ...args])
+
 ```go
 io.Emit("hello")
 ```
+
 ```go
 io.Emit("hello", 1, "2", map[string]interface{}{"3": 4})
 ```
 
 #### server.of(nsp)
+
 ```go
 adminNamespace := io.Of("/admin")
 
@@ -80,19 +111,25 @@ adminNamespace.OnConnection(func(socket *socketio.Socket) {
 ```
 
 #### server.to(room)
+
 ```go
 io.To("room-101").Emit("hello", "world")
 ```
 
 #### server.fetchSockets()
+
 ```go
 sockets := io.Sockets()
 ```
 
 ## Namespace
+
 ### Events
+
 #### Event: 'connection'
+
 Fired upon a connection from client.
+
 ```go
 // main namespace
 io.OnConnection(func(socket *socketio.Socket) {
@@ -106,15 +143,19 @@ io.Of("/admin").OnConnection(func(socket *socketio.Socket) {
 ```
 
 ### Methods
+
 #### namespace.emit(eventName[, ...args])
+
 ```go
 io.Of("/admin").Emit("hello")
 ```
+
 ```go
 io.Of("/admin").Emit("hello", 1, "2", map[string]interface{}{"3": 4})
 ```
 
 #### namespace.to(room)
+
 ```go
 adminNamespace := io.Of("/admin")
 
@@ -124,16 +165,21 @@ adminNamespace.To("room-101").To("room-102").Emit("hello", "world")
 ```
 
 #### namespace.fetchSockets()
+
 Returns the matching Socket instances:
+
 ```go
 adminNamespace := io.Of("/admin")
 
 sockets := adminNamespace.Sockets()
 ```
 
 ## Socket
+
 ### Events
+
 #### Event: 'disconnect'
+
 ```go
 io.OnConnection(func(socket *socketio.Socket) {
 	socket.On("disconnect", func(event *socketio.EventPayload) {
@@ -143,14 +189,19 @@ io.OnConnection(func(socket *socketio.Socket) {
 ```
 
 ### Methods
+
 #### socket.on(eventName, callback)
+
 Register a new handler for the given event.
+
 ```go
 socket.On("news", func(event *socketio.EventPayload) {
 	print(event.Data)
 })
 ```
+
 with several arguments
+
 ```go
 socket.On("news", func(event *socketio.EventPayload) {
 	if len(event.Data) > 0 && event.Data[0] != nil {
@@ -164,7 +215,9 @@ socket.On("news", func(event *socketio.EventPayload) {
 	}
 })
 ```
+
 or with acknowledgement
+
 ```go
 socket.On("news", func(event *socketio.EventPayload) {
 	if event.Ack != nil {
@@ -176,7 +229,9 @@ socket.On("news", func(event *socketio.EventPayload) {
 ```
 
 #### socket.join(room)
+
 Adds the socket to the given room or to the list of rooms.
+
 ```go
 io.Of("/test").OnConnection(func(socket *socketio.Socket) {
 	socket.Join("room 237")
@@ -186,17 +241,21 @@ io.Of("/test").OnConnection(func(socket *socketio.Socket) {
 ```
 
 #### socket.leave(room)
+
 Removes the socket from the given room.
+
 ```go
 io.Of("/test").OnConnection(func(socket *socketio.Socket) {
 	socket.Leave("room 237");
 
 	io.To("room 237").Emit("the user has left the room")
 })
 ```
+
 Rooms are left automatically upon disconnection.
 
 #### socket.to(room)
+
 ```go
 socket.On("room 237", func(event *socketio.EventPayload) {
  	// to one room

example/main.go

@@ -1,15 +1,15 @@
 package main
 
 import (
+	"fmt"
 	"log"
+	"net/http"
 
 	socketio "github.com/doquangtan/socket.io/v4"
 	"github.com/gofiber/fiber/v2"
 )
 
-func socketIoRoute(app fiber.Router) {
-	io := socketio.New()
-
+func socketIoHandle(io *socketio.Io) {
 	io.OnAuthorization(func(params map[string]string) bool {
 		// auth, ok := params["Authorization"]
 		// if !ok {
@@ -89,18 +89,19 @@ func socketIoRoute(app fiber.Router) {
 			}
 		})
 	})
+}
 
+func socketIoRoute(app fiber.Router) {
+	io := socketio.New()
+	socketIoHandle(io)
 	app.Use("/", io.Middleware)
 	app.Route("/socket.io", io.Server)
 }
 
-func main() {
+func usingWithGoFiber() {
 	app := fiber.New(fiber.Config{})
-
 	app.Static("/", "./public")
-
 	app.Route("/", socketIoRoute)
-
 	app.Get("/test", func(c *fiber.Ctx) error {
 		io := c.Locals("io").(*socketio.Io)
 
@@ -114,6 +115,19 @@ func main() {
 
 		return c.SendStatus(200)
 	})
+	app.Listen(":3400")
+}
 
-	app.Listen(":3300")
+func httpServer() {
+	io := socketio.New()
+	socketIoHandle(io)
+	http.Handle("/socket.io/", io.HttpHandler())
+	http.Handle("/", http.FileServer(http.Dir("./public")))
+	fmt.Println("Server listenning on port 3300 ...")
+	fmt.Println(http.ListenAndServe(":3300", nil))
+}
+
+func main() {
+	httpServer()
+	// usingWithGoFiber()
 }