websocket

Documentation

Index

• Variables
• func NewPush(appid string, frame *onebot.Frame) error
• func NewSecretPush(appid, secret string, frame *onebot.Frame) error
• func UpgradeWebsocket(w http.ResponseWriter, r *http.Request) error
• func UpgradeWebsocketWithSecret(w http.ResponseWriter, r *http.Request) error
• type Bot
  • func NewBot(xSelfId string, addr string, conn *websocket.Conn) *Bot
  • func NewSecretBot(xSelfId, xBotSecret string, addr string, conn *websocket.Conn) *Bot
• type SafeWebSocket
  • func NewSafeWebSocket(appid string, conn *websocket.Conn, ...) *SafeWebSocket
  • func (ws *SafeWebSocket) Send(messageType int, data []byte)
• type WebSocketSendingMessage

Variables

var Bots = make(map[string]map[string]*Bot)

Functions

func NewPush

func NewPush(appid string, frame *onebot.Frame) error

func NewSecretPush

func NewSecretPush(appid, secret string, frame *onebot.Frame) error

func UpgradeWebsocket

func UpgradeWebsocket(w http.ResponseWriter, r *http.Request) error

func UpgradeWebsocketWithSecret

func UpgradeWebsocketWithSecret(w http.ResponseWriter, r *http.Request) error

Types

type Bot

type Bot struct {
	BotId     string
	BotSecret string
	Session   *SafeWebSocket

	WaitingFrames map[string]*promise.Promise
	// contains filtered or unexported fields
}

func NewBot

func NewBot(xSelfId string, addr string, conn *websocket.Conn) *Bot

func NewSecretBot

func NewSecretBot(xSelfId, xBotSecret string, addr string, conn *websocket.Conn) *Bot

type SafeWebSocket

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

safe websocket

func NewSafeWebSocket

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

func (*SafeWebSocket) Send

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

type WebSocketSendingMessage

type WebSocketSendingMessage struct {
	MessageType int
	Data        []byte
}