safe_ws

package
v0.0.0-...-76c70c9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 18 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ATMessageEventHandler func(appid string, event *dto.WSPayload, data *dto.WSATMessageData) error

ATMessageEventHandler at 机器人消息事件 handler

View Source 
var AudioEventHandler func(appid string, event *dto.WSPayload, data *dto.WSAudioData) error

AudioEventHandler 音频机器人事件 handler

View Source 
var Bots = make(map[string]*Bot)
View Source 
var C2CMessageEventHandler func(appid string, event *dto.WSPayload, data *dto.WSC2CMessageData) error
View Source 
var C2CMsgReceiveHandler func(appid string, event *dto.WSPayload, data *dto.WSFriendMsgReveiceData) error
View Source 
var C2CMsgRejectHandler func(appid string, event *dto.WSPayload, data *dto.WSFriendMsgRejectData) error
View Source 
var ChannelEventHandler func(appid string, event *dto.WSPayload, data *dto.WSChannelData) error

ChannelEventHandler 子频道事件 handler

View Source 
var CheckEventHandler func(appid string, event *dto.WSPayload, message []byte) bool

CheckEventHandler 消息前置检测

View Source 
var DirectMessageDeleteEventHandler func(appid string, event *dto.WSPayload, data *dto.WSDirectMessageDeleteData) error

DirectMessageDeleteEventHandler 消息事件 handler

View Source 
var DirectMessageEventHandler func(appid string, event *dto.WSPayload, data *dto.WSDirectMessageData) error

DirectMessageEventHandler 私信消息事件 handler

View Source 
var ErrorNotifyHandler func(err error)

ErrorNotifyHandler 当 ws 连接发生错误的时候，会回调，方便使用方监控相关错误 比如 reconnect invalidSession 等错误，错误可以转换为 bot.Err

View Source 
var (
	FirstStart bool = true
)
View Source 
var ForumAuditEventHandler func(appid string, event *dto.WSPayload, data *dto.WSForumAuditData) error

ForumAuditEventHandler 论坛帖子审核事件 handler

View Source 
var FriendAddEventHandler func(appid string, event *dto.WSPayload, data *dto.WSFriendAddData) error
View Source 
var FriendDelEventHandler func(appid string, event *dto.WSPayload, data *dto.WSFriendDelData) error
View Source 
var GroupAddRobotEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGroupAddRobotData) error
View Source 
var GroupAtMessageEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGroupATMessageData) error
View Source 
var GroupDelRobotEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGroupDelRobotData) error
View Source 
var GroupMessageEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGroupMessageData) error
View Source 
var GroupMsgReceiveEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGroupMsgReceiveData) error
View Source 
var GroupMsgRejectEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGroupMsgRejectData) error
View Source 
var GuildEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGuildData) error

GuildEventHandler 频道事件handler

View Source 
var GuildMemberEventHandler func(appid string, event *dto.WSPayload, data *dto.WSGuildMemberData) error

GuildMemberEventHandler 频道成员事件 handler

View Source 
var InteractionEventHandler func(appid string, event *dto.WSPayload, data *dto.WSInteractionData) error

InteractionEventHandler 互动事件 handler

View Source 
var MessageAuditEventHandler func(appid string, event *dto.WSPayload, data *dto.WSMessageAuditData) error

MessageAuditEventHandler 消息审核事件 handler

View Source 
var MessageDeleteEventHandler func(appid string, event *dto.WSPayload, data *dto.WSMessageDeleteData) error

MessageDeleteEventHandler 消息事件 handler

View Source 
var MessageEventHandler func(appid string, event *dto.WSPayload, data *dto.WSMessageData) error

MessageEventHandler 消息事件 handler

View Source 
var MessageReactionEventHandler func(appid string, event *dto.WSPayload, data *dto.WSMessageReactionData) error

MessageReactionEventHandler 表情表态事件 handler

View Source 
var PlainEventHandler func(appid string, event *dto.WSPayload, message []byte) error

PlainEventHandler 透传handler

View Source 
var PostEventHandler func(appid string, event *dto.WSPayload, data *dto.WSPostData) error

PostEventHandler 论坛回帖事件 handler

View Source 
var PublicMessageDeleteEventHandler func(appid string, event *dto.WSPayload, data *dto.WSPublicMessageDeleteData) error

PublicMessageDeleteEventHandler 消息事件 handler

View Source 
var ReadyHandler func(appid string, event *dto.WSPayload, data *dto.WSReadyData)

ReadyHandler 可以处理 ws 的 ready 事件

View Source 
var ReplyEventHandler func(appid string, event *dto.WSPayload, data *dto.WSReplyData) error

ReplyEventHandler 论坛帖子回复事件 handler

View Source 
var ThreadEventHandler func(appid string, event *dto.WSPayload, data *dto.WSThreadData) error

ThreadEventHandler 论坛主题事件 handler

Functions

func ConnectUniversal 

func ConnectUniversal(appid, serverUrl string)

func ConnectUniversalWithSecret 

func ConnectUniversalWithSecret(appid, secret, serverUrl string)

func FatalError 

func FatalError(err error)

func InitLog 

func InitLog()

func SafeGo 

func SafeGo(fn func())

Types

type Bot 

type Bot struct {
	QQ        uint64
	AppId     string
	Token     string
	AppSecret string
	Openapi   openapi.OpenAPI

	WaitingFrames map[string]*promise.Promise

	Payload *dto.WSPayload
	// contains filtered or unexported fields
}

func NewBot 

func NewBot(appId string, p *dto.WSPayload, m []byte) *Bot

func (*Bot) ParseWHData 

func (bot *Bot) ParseWHData(h string, p *dto.WSPayload, message []byte)

type ForwardSafeWebSocket 

type ForwardSafeWebSocket struct {
	Conn          *websocket.Conn
	SendChannel   chan *WebSocketSendingMessage
	OnRecvMessage func(messageType int, data []byte)
	OnClose       func(int, string)
}

func NewForwardSafeWebSocket 

func NewForwardSafeWebSocket(conn *websocket.Conn, OnRecvMessage func(messageType int, data []byte), onClose func(int, string)) *ForwardSafeWebSocket

func (*ForwardSafeWebSocket) ForwardSend 

func (ws *ForwardSafeWebSocket) ForwardSend(messageType int, data []byte)

type RecvMessage 

type RecvMessage struct {
	BotId string `json:"bot_id,omitempty"`
	Data  []byte `json:"data,omitempty"`
}

type SafeWebSocket 

type SafeWebSocket struct {
	Conn          *websocket.Conn
	SendChannel   chan *WebSocketSendingMessage
	OnRecvMessage func(ws *SafeWebSocket, messageType int, data []byte)
	OnClose       func()
}

safe websocket

func NewSafeWebSocket 

func NewSafeWebSocket(conn *websocket.Conn, OnRecvMessage func(ws *SafeWebSocket, messageType int, data []byte), onClose func()) *SafeWebSocket

func (*SafeWebSocket) Close 

func (ws *SafeWebSocket) Close()

func (*SafeWebSocket) Send 

func (ws *SafeWebSocket) Send(messageType int, data []byte) (e error)

type WebSocketSendingMessage 

type WebSocketSendingMessage struct {
	MessageType int
	Data        []byte
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.