From a0b0f33b1e2d057e5fff633b82e2233b151a3cfb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=98=BF=E6=81=92?= <2390904403@qq.com> Date: Wed, 22 Oct 2025 16:31:53 +0800 Subject: [PATCH] =?UTF-8?q?websocket=E7=AD=BE=E5=90=8D=E6=96=B9=E6=B3=95?= =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/rpc/server.go | 46 ---------------------------------------------- pkg/rpc/user.go | 30 ++++++++++++++++++++++++++++++ 2 files changed, 30 insertions(+), 46 deletions(-) delete mode 100644 pkg/rpc/server.go diff --git a/pkg/rpc/server.go b/pkg/rpc/server.go deleted file mode 100644 index 9426115..0000000 --- a/pkg/rpc/server.go +++ /dev/null @@ -1,46 +0,0 @@ -package rpc - -import "fmt" - -// 服务相关RPC -type Server struct{} - -// 获取Websocket签名信息 -func (s *Server) GetWebsocketSignData(sign string) (*WebsocketSignData, error) { - body := map[string]any{ - "sign": sign, - } - result := &Result[WebsocketSignData]{} - if err := GetRequest().Send("server.get_websocket_sign", body, result); err != nil { - return nil, err - } - if result.Code != 0 { - return nil, fmt.Errorf("%s", result.Message) - } - return &result.Data, nil -} - -// 删除Websocket签名 -func (s *Server) DeleteWebsocketSign(sign string) error { - body := map[string]any{ - "sign": sign, - } - result := &Result[WebsocketSignData]{} - if err := GetRequest().Send("server.get_websocket_sign", body, result); err != nil { - return err - } - if result.Code != 0 { - return fmt.Errorf("%s", result.Message) - } - return nil -} - -var server *Server - -// 获取服务相关RPC类 -func GetServer() *Server { - if server == nil { - server = &Server{} - } - return server -} diff --git a/pkg/rpc/user.go b/pkg/rpc/user.go index eedbced..ede7436 100644 --- a/pkg/rpc/user.go +++ b/pkg/rpc/user.go @@ -21,6 +21,36 @@ func (u *User) GetDetail(userId uint32) (*UserDetail, error) { return &result.Data, nil } +// 获取Websocket签名信息 +func (s *User) GetWebsocketSignData(sign string) (*WebsocketSignData, error) { + body := map[string]any{ + "sign": sign, + } + result := &Result[WebsocketSignData]{} + if err := GetRequest().Send("user.get_websocket_sign", body, result); err != nil { + return nil, err + } + if result.Code != 0 { + return nil, fmt.Errorf("%s", result.Message) + } + return &result.Data, nil +} + +// 删除Websocket签名 +func (s *User) DeleteWebsocketSign(sign string) error { + body := map[string]any{ + "sign": sign, + } + result := &Result[WebsocketSignData]{} + if err := GetRequest().Send("user.get_websocket_sign", body, result); err != nil { + return err + } + if result.Code != 0 { + return fmt.Errorf("%s", result.Message) + } + return nil +} + var user *User // 获取用户相关RPC