ice

type AdapterConnectEvent struct {
	AdapterType  string `json:"adapter_type"`  // 适配器类型
	AdapterModel string `json:"adapter_model"` // 适配器模型
	UserId       string `json:"user_id"`       // 用户ID
	UserName     string `json:"user_name"`     // 用户名称
}

type AdapterDisconnectEvent struct {
	OK bool `json:"ok"`
}

type DataCallbackEvent struct {
	OK            bool        `json:"ok"`             // 回调是否成功
	DataType      string      `json:"data_type"`      // 数据类型
	Data          interface{} `json:"data"`           // 回调的数据
	RequestSerial int32       `json:"request_serial"` // 请求序列号，用于标识请求防止接受错误
}

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

type EventHandler func(event *IceinuEvent)

type IceinuEvent struct {
	Type      uint8       `json:"type"`
	From      string      `json:"from"`      // 消息事件来源节点ID
	Target    string      `json:"target"`    // 消息事件目标节点ID
	Timestamp int64       `json:"timestamp"` // 事件推送的时间戳
	Summary   string      `json:"summary"`   // 事件摘要，一般是承载的事件的事件类型，用于在事件总线层快速识别事件类型
	Event     interface{} `json:"event"`     // 事件内容，用于承载不同类型的消息，使用时需要进行断言
}

type IceinuNodeData struct {
	gorm.Model
	NodeId       string // 节点ID，一般是UUID，每一个节点只会有一个UUID，除非数据被重置
	AdapterModel string // 适配器模型
}

type IceinuPluginList struct {
	PluginId       string    `gorm:"primaryKey"` // 插件ID，一般是名字
	IsEnabled      bool      // 是否启用
	UpdateTime     time.Time // 操作时间
	IsWhiteList    bool      // 是否是白名单模式，这个模式会反转禁用逻辑
	BanUsers       string    // 对哪些用户禁用该插件的触发器
	BanGroups      string    // 对哪些群禁用该插件的触发器
	BanChannels    string    // 对哪些频道禁用该插件的触发器
	BanNodes       string    // 对哪些节点禁用该插件
	IsDetectUpdate bool      // 是否检测更新
}

type NodeConnectRequestEvent struct {
	Mode           string `json:"mode"`            // 组网模式
	AdapterModel   string `json:"adapter_model"`   // 适配器模型
	PluginVerifier string `json:"plugin_verifier"` // 插件校验值
}

type NodeConnectedEvent struct {
	OK bool `json:"ok"`
}

type NodeDeactiveEvent struct {
	OK bool `json:"ok"`
}

type NodeDisconnectedEvent struct {
	OK bool `json:"ok"`
}

type NodePushDataEvent struct {
	Data interface{} `json:"data"` // 推送的数据
}

type NodeReactiveEvent struct {
	OK bool `json:"ok"`
}

type NodeRequestDataEvent struct {
	RequestSerial int32  `json:"request_serial"` // 请求序列号，用于标识请求防止接受错误
	DataType      string `json:"data_type"`      // 请求的数据类型
	Key           string `json:"key"`            // 请求的数据键
	Query         string `json:"query"`          // 请求的查询内容
}

type NodeUserPushEvent struct {
	UserTree adapters.UserTree `json:"user_tree"` // 用户树
}

type PublishMiddleware func(event *IceinuEvent, next func(event *IceinuEvent))

type RequestNodeDataEvent struct {
	RequestSerial int32  `json:"request_serial"` // 请求序列号，用于标识请求防止接受错误
	DataType      string `json:"data_type"`      // 请求的数据类型
	Key           string `json:"key"`            // 请求的数据键
	Query         string `json:"query"`          // 请求的查询内容
}

type SubscribeMiddleware func(event *IceinuEvent, next func(event *IceinuEvent))

type WebSocketHeartbeatEvent struct {
	OK bool `json:"ok"`
}