websocket

package

v1.5.0 Latest Latest Go to latest Published: Nov 23, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Package websocket 接收客户端消息，根据消息内容解包，调用对应模块API处理，然后封装返回

This section is empty.

View Source

var (
	ErrClientNotFound = errors.New("client not found")
)

func RegisterCallFunc(cmd string, callFunc CallFunc)

func RegisterCmd()

type ActionWrap struct {
	Cmd      string `json:"cmd"`
	Name     string `json:"name"`
	IsPermit bool   `json:"is_permit"`
}

type CallFunc func(service callService) (Result, error)

type DeviceWrap struct {
	Cmd      string `json:"cmd"`
	Name     string `json:"name"`
	IsPermit bool   `json:"is_permit"`
}

type Event struct {
	EventType string                 `json:"event_type"`
	Data      map[string]interface{} `json:"data"`
}

type MsgType string

const (
	MsgTypeResponse MsgType = "response"
)

type Result map[string]interface{}

func ConnectDevice(cs callService) (result Result, err error)

ConnectDevice 连接设备 TODO 直接替代添加设备接口？

func DisconnectDevice(cs callService) (result Result, err error)

DisconnectDevice 设备断开连接（取消配对等） TODO 直接替代删除设备接口？

func GetAttrs(cs callService) (result Result, err error)

func SetAttrs(cs callService) (result Result, err error)

type Server struct {
	// contains filtered or unexported fields
}

Server WebSocket服务端

func NewWebSocketServer() *Server

func (s *Server) AcceptWebSocket(c *gin.Context)

func (s *Server) Broadcast(areaID uint64, data []byte)

func (s *Server) OnDeviceStateChange(d entity.Device, attr entity.Attribute) error

OnDeviceStateChange 设备状态改变回调，会广播给所有客户端，并且触发场景

func (s *Server) Run(ctx context.Context)

func (s *Server) SingleCast(cliID string, data []byte) error

SingleCast 发送单播消息