Skip to content

Commit

Permalink
refactor: kicknt作为disconnect事件
Browse files Browse the repository at this point in the history
  • Loading branch information
Redmomn committed Nov 15, 2024
1 parent 2d6282c commit e34ed53
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 19 deletions.
2 changes: 0 additions & 2 deletions client/base.go
Original file line number Diff line number Diff line change
Expand Up @@ -99,8 +99,6 @@ type QQClient struct {
cache cache.Cache

// event handles
KickedEvent EventHandle[*event.Kicked]

GroupMessageEvent EventHandle[*message.GroupMessage]
PrivateMessageEvent EventHandle[*message.PrivateMessage]
TempMessageEvent EventHandle[*message.TempMessage]
Expand Down
15 changes: 0 additions & 15 deletions client/event/sys.go

This file was deleted.

4 changes: 3 additions & 1 deletion client/listener.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package client

import (
"errors"
"fmt"
"runtime/debug"

"github.com/LagrangeDev/LagrangeGo/client/packets/pb/system"
Expand Down Expand Up @@ -352,7 +353,8 @@ func decodeKickNTPacket(c *QQClient, pkt *network.Packet) (any, error) {
if err != nil {
return nil, err
}
c.KickedEvent.dispatch(c, eventConverter.ParseKickedEvent(&pb))
c.Disconnect()
go c.DisconnectedEvent.dispatch(c, &DisconnectedEvent{Message: fmt.Sprintf("%s:%s", pb.Title, pb.Tips)})
return nil, nil
}

Expand Down
2 changes: 1 addition & 1 deletion client/network.go
Original file line number Diff line number Diff line change
Expand Up @@ -303,7 +303,7 @@ func (c *QQClient) netLoop() {
// pkt, err := packets.ParseIncomingPacket(data, c.sig.D2Key)
if err != nil {
c.error("parse incoming packet error: %v", err)
if errors.Is(err, network.ErrSessionExpired) || errors.Is(err, network.ErrPacketDropped) {
if errors.Is(err, network.ErrSessionExpired) || errors.Is(err, network.ErrAuthenticationFailed) || errors.Is(err, network.ErrPacketDropped) {
c.Disconnect()
go c.DisconnectedEvent.dispatch(c, &DisconnectedEvent{Message: err.Error()})
continue
Expand Down

0 comments on commit e34ed53

Please sign in to comment.