fix: 修改一些bug

internal/event/event.go

@@ -22,12 +22,12 @@ type Interface interface {
 var smap sync.Map
 
 type Event struct {
-	wg sync.WaitGroup
+	wg *sync.WaitGroup
 }
 
 func New() *Event {
 	return &Event{
-		wg: sync.WaitGroup{},
+		wg: new(sync.WaitGroup),
 	}
 }
 
@@ -88,10 +88,10 @@ func (e *Event) exec(handlers []Interface, event EventInterface, async bool) err
 	for _, handler := range handlers {
 		e.wg.Add(1)
 		execFunc := handler
-		go func(wg *sync.WaitGroup) {
+		go func() {
 			defer e.wg.Done()
 			execFunc.Process(param)
-		}(&e.wg)
+		}()
 	}
 	e.wg.Wait()
 	return nil

internal/server/websocket/client.go

@@ -1,7 +1,6 @@
 package server
 
 import (
-	"errors"
 	"fmt"
 	"log"
 	"net/http"
@@ -41,7 +40,7 @@ func NewSocketClient(ctx *gin.Context, key string, socket *Socket) *SocketClient
 func (s *SocketClient) readPump() {
 	defer func() {
 		if err := recover(); err != nil {
-			s.socket.opts.handler.OnError(s.key, errors.New(fmt.Sprintf("%v", err)))
+			s.socket.opts.handler.OnError(s.key, fmt.Errorf("%v", err))
 		}
 		s.close()
 	}()
@@ -73,7 +72,7 @@ func (s *SocketClient) writePump() {
 	ticker := time.NewTicker(s.socket.opts.pingPeriod)
 	defer func() {
 		if err := recover(); err != nil {
-			s.socket.opts.handler.OnError(s.key, errors.New(fmt.Sprintf("%v", err)))
+			s.socket.opts.handler.OnError(s.key, fmt.Errorf("%v", err))
 		}
 		s.close()
 	}()

internal/server/websocket/socket.go

@@ -111,7 +111,7 @@ func (s *Socket) WriteMessage(message Message) error {
 	} else {
 		for _, key := range message.Subkeys {
 			client, ok := s.clients[key]
-			if !ok && client.state == OffLineState {
+			if !ok || client.state == OffLineState {
 				return errors.New("Connect does not exist")
 			}
 			client.send <- message.Data

test/http_test.go

@@ -2,10 +2,9 @@ package test
 
 import (
 	"fmt"
-	"testing"
-
 	"skeleton/internal/server"
 	"skeleton/router"
+	"testing"
 
 	"github.com/gin-gonic/gin"
 )