gowk

type AddOrRemoveSystemUsersRequest struct {
	UIDs []string `json:"uids"` // 用户 ID 数组
}

type BatchGetMessageRequest struct {
	MessageIDs []int64 `json:"message_ids"` // 必传，消息 ID 列表
}

type BatchSendMessageRequst struct {
	Header      Header   `json:"header"`      // 消息头部信息
	FromUID     string   `json:"from_uid"`    // 发送者UID
	Subscribers []string `json:"subscribers"` // 订阅者 如果此字段有值，表示消息只发给指定的订阅者
	Payload     string   `json:"payload"`     // 消息内容
}

type BatchSendMessageResponse struct {
	FailUids []string `json:"fail_uids"` // 返回发送失败的用户列表
	Reason   []string `json:"reason"`    // 发送失败用户列表对应的失败原因列表，与fail_uids一一对应
}

type BatchUserIMAddr struct {
	Uids []string `json:"uids"`
	UserIMAddr
}

type Bool int

type Channel struct {
	ChannelID     string      `json:"channel_id"`               // 必传，频道 ID，必须唯一
	ChannelType   ChannelType `json:"channel_type"`             // 必传，频道类型 (1=个人频道, 2=群组频道)
	Ban           *int        `json:"ban,omitempty"`            // 可选，是否禁言 (0=允许发言,1=全员禁言)
	Disband       *int        `json:"disband,omitempty"`        // 可选，是否解散频道 (1=解散)
	SendBan       *int        `json:"send_ban,omitempty"`       // 可选，是否禁止发送消息 (0=不禁止,1=禁止)
	AllowStranger *int        `json:"allow_stranger,omitempty"` // 可选，是否允许陌生人发送消息 (仅个人频道支持)
	Subscribers   *[]string   `json:"subscribers,omitempty"`    // 可选，订阅者用户 ID 列表
}

type ChannelBlackOrWhiteList struct {
	ChannelID   string      `json:"channel_id"`   // 必传，频道 ID
	ChannelType ChannelType `json:"channel_type"` // 必传，频道类型 (1=个人频道, 2=群组频道)
	UIDs        []string    `json:"uids"`         // 要加入黑名单的用户 ID 列表
}

type ChannelSubscriber struct {
	ChannelID      string      `json:"channel_id"`                // 必传，频道 ID
	ChannelType    ChannelType `json:"channel_type"`              // 必传，频道类型 (1=个人频道, 2=群组频道)
	Subscribers    []string    `json:"subscribers"`               // 必传，要添加的订阅者用户 ID 列表
	Reset          *int        `json:"reset,omitempty"`           // 可选，是否重置现有订阅者 (0=不重置,1=重置)
	TempSubscriber *int        `json:"temp_subscriber,omitempty"` // 可选，是否为临时订阅者 (0=永久,1=临时)
}

type ChannelType uint8 // 频道类型

type ClearConversationUnreadRequest struct {
	ConversationInfo
	MessageSeq *int64 `json:"message_seq,omitempty"` // 可选，清除到哪条消息
}

type Config struct {
	MaxConnections          int `json:"max_connections"`            // 最大连接数限制
	MaxSubscriptionsPerConn int `json:"max_subscriptions_per_conn"` // 每连接最大订阅数
	MaxPayload              int `json:"max_payload"`                // 最大消息载荷大小 (字节)
}

type ConnInfo struct {
	UID    string `json:"uid"`               // 必传，用户 ID
	ConnID int64  `json:"conn_id"`           // 必传，连接 ID
	NodeID *int64 `json:"node_id,omitempty"` // 可选，指定节点 ID
}

type ConnzConnection struct {
	CID           int64       `json:"cid"`           // 连接 ID
	UID           string      `json:"uid"`           // 用户 ID
	IP            string      `json:"ip"`            // 客户端 IP 地址
	Port          int         `json:"port"`          // 客户端端口
	Start         string      `json:"start"`         // 连接开始时间
	LastActivity  string      `json:"last_activity"` // 最后活动时间
	Uptime        string      `json:"uptime"`        // 连接持续时间
	Idle          string      `json:"idle"`          // 空闲时间
	PendingBytes  int64       `json:"pending_bytes"` // 待发送字节数
	InMsgs        int64       `json:"in_msgs"`       // 接收消息数
	OutMsgs       int64       `json:"out_msgs"`      // 发送消息数
	InBytes       int64       `json:"in_bytes"`      // 接收字节数
	OutBytes      int64       `json:"out_bytes"`     // 发送字节数
	Subscriptions int         `json:"subscriptions"` // 订阅数量
	DeviceFlag    DeviceFlag  `json:"device_flag"`   // 设备标识
	DeviceLevel   DeviceLevel `json:"device_level"`  // 设备级别
	Version       string      `json:"version"`       // 客户端版本
}

type Conversation struct {
	ChannelID       string       `json:"channel_id"`         // 频道 ID
	ChannelType     ChannelType  `json:"channel_type"`       // 频道类型 (1=个人,2=群组)
	Unread          int          `json:"unread"`             // 未读消息数量
	Timestamp       int64        `json:"timestamp"`          // 最后消息时间戳
	LastMsgSeq      int64        `json:"last_msg_seq"`       // 最后消息序列号
	LastClientMsgNo string       `json:"last_client_msg_no"` // 最后一条消息的客户端消息编号
	Version         int64        `json:"version"`            // 会话版本号（纳秒级时间戳）
	Recents         []RecentItem `json:"recents"`            // 最新消息列表
}

type ConversationInfo struct {
	UID         string      `json:"uid"`          // 必传，用户 ID
	ChannelID   string      `json:"channel_id"`   // 必传，频道 ID
	ChannelType ChannelType `json:"channel_type"` // 必传，频道类型 (1=个人,2=群组)
}

type DeviceFlag uint8 // DeviceFlag 设备类型

type DeviceLevel uint8 // 设备等级

type Event struct {
	Type      string  `json:"type"`                // 必传，事件类型
	ID        *string `json:"id,omitempty"`        // 可选，事件 ID
	Timestamp *int64  `json:"timestamp,omitempty"` // 可选，事件时间戳（毫秒）
	Data      string  `json:"data"`                // 必传，事件数据内容
}

type GetChannelWhiteListRequest struct {
	ChannelID   string      `json:"channel_id"`   // 必传，频道 ID
	ChannelType ChannelType `json:"channel_type"` // 必传，频道类型 (1=个人频道, 2=群组频道)
}

type GetConnzResponse struct {
	Now            string            `json:"now"`             // 当前服务器时间（ISO 8601）
	NumConnections int               `json:"num_connections"` // 当前连接数量
	Total          int               `json:"total"`           // 总连接数量
	Offset         int               `json:"offset"`          // 当前偏移量
	Limit          int               `json:"limit"`           // 当前限制数量
	Connections    []ConnzConnection `json:"connections"`     // 连接详情列表
}

type GetMaxMessageSeqResponse struct {
	MessageID   int64       `json:"message_id"`    // 消息 ID
	MessageSeq  int64       `json:"message_seq"`   // 消息序列号
	ClientMsgNo string      `json:"client_msg_no"` // 客户端消息编号（回显）
	FromUID     string      `json:"from_uid"`      // 发送者用户 ID
	ChannelID   string      `json:"channel_id"`    // 频道 ID
	ChannelType ChannelType `json:"channel_type"`  // 频道类型 (1=个人,2=群组)
	Timestamp   int64       `json:"timestamp"`     // 消息时间戳
	Payload     string      `json:"payload"`       // Base64 编码的消息内容
}

type GetMessageRequest struct {
	MessageId int64 `json:"message_id"` // 必传，消息 ID 列表
}

type GetMessageResponse struct {
	MessageID   int64       `json:"message_id"`    // 服务器生成的消息 ID
	MessageSeq  int64       `json:"message_seq"`   // 消息序列号
	ClientMsgNo string      `json:"client_msg_no"` // 客户端消息编号（回显）
	FromUID     string      `json:"from_uid"`      // 发送者用户 ID
	ChannelID   string      `json:"channel_id"`    // 频道 ID
	ChannelType ChannelType `json:"channel_type"`  // 频道类型 (1=个人,2=群组)
	Timestamp   int64       `json:"timestamp"`     // 消息时间戳（Unix 时间戳）
	Payload     string      `json:"payload"`       // Base64 编码的消息内容
}

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

type HTTPReqStats struct {
	URIStats []URIStat `json:"uri_stats"` // URI 统计列表
}

type Header struct {
	NoPersist *int `json:"no_persist,omitempty"` // 是否持久化
	RedDot    *int `json:"red_dot,omitempty"`    // 小红点显示
	SyncOnce  *int `json:"sync_once,omitempty"`  // 是否仅同步一次
}

type Message struct {
	Payload     string      `json:"payload"`                 // 必传，Base64 编码的消息内容
	FromUID     string      `json:"from_uid"`                // 必传，发送者用户 ID
	ChannelID   string      `json:"channel_id"`              // 必传，目标频道 ID
	ChannelType ChannelType `json:"channel_type"`            // 必传，频道类型 (1=个人, 2=群组)
	Header      *Header     `json:"header,omitempty"`        // 可选，消息头部信息
	ClientMsgNo *string     `json:"client_msg_no,omitempty"` // 可选，客户端消息编号
	StreamNo    *string     `json:"stream_no,omitempty"`     // 可选，流消息编号
	Expire      *int64      `json:"expire,omitempty"`        // 可选，消息过期时间（秒），0 表示不过期
	Subscribers []string    `json:"subscribers,omitempty"`   // 可选，指定订阅者（CMD消息有效）
}

type MessageSyncRequest struct {
	LoginUID        string      `json:"login_uid"`                   // 必传，当前登录用户 ID
	ChannelID       string      `json:"channel_id"`                  // 必传，频道 ID
	ChannelType     ChannelType `json:"channel_type"`                // 必传，频道类型 (1=个人, 2=群组)
	StartMessageSeq *int64      `json:"start_message_seq,omitempty"` // 可选，起始消息序号（包含）
	EndMessageSeq   *int64      `json:"end_message_seq,omitempty"`   // 可选，结束消息序号（不包含）
	Limit           *int        `json:"limit,omitempty"`             // 可选，返回消息数量限制，最大 10000
	PullMode        *PullMode   `json:"pull_mode,omitempty"`         // 可选，拉取模式 (0=向下拉取, 1=向上拉取)
}

type MessageSyncResponse struct {
	StartMessageSeq uint32       `json:"start_message_seq"` // 查询的start_message_seq
	EndMessageSeq   uint32       `json:"end_message_seq"`   // 查询的end_message_seq
	More            int          `json:"more"`              // 是否有更多  0.无 1.有
	Messages        []RecentItem `json:"messages"`          // 最近N条消息
}

type MigrationStatusResponse struct {
	Status   string  `json:"status"`             // 迁移状态 (running, completed, migrated)
	Step     string  `json:"step"`               // 当前迁移步骤 (message, user, channel 等)
	LastErr  *string `json:"last_err,omitempty"` // 最后一次错误信息，可为 null
	TryCount int     `json:"try_count"`          // 尝试次数
}

type OnlineStatus struct {
	UID        string     `json:"uid"`         // 用户 ID
	Online     int        `json:"online"`      // 在线状态 (0=离线, 1=在线)
	DeviceFlag DeviceFlag `json:"device_flag"` // 设备标识 (0=app, 1=web, 2=desktop)
}

type Option func(*GoWk)

type PullMode int // 拉取模式

type QuitUserDeviceRequest struct {
	UID        string     `json:"uid"`         // 必传，用户唯一 ID
	DeviceFlag DeviceFlag `json:"device_flag"` // 必传，设备标识 (0=app,1=web,2=desktop)
}

type RecentItem struct {
	Header      Header      `json:"header"`        // 消息头
	Setting     uint8       `json:"setting"`       // // 消息设置 消息设置是一个 uint8的数字类型 为1个字节，完全由第三方自定义 比如定义第8位为已读未读回执标记，开启则为0000 0001 = 1
	MessageID   int64       `json:"message_id"`    // 消息 ID
	MessageSeq  int64       `json:"message_seq"`   // 消息序列号
	ClientMsgNo string      `json:"client_msg_no"` // 客户端消息编号（回显）
	FromUID     string      `json:"from_uid"`      // 发送者用户 ID
	ChannelID   string      `json:"channel_id"`    // 频道 ID
	ChannelType ChannelType `json:"channel_type"`  // 频道类型 (1=个人,2=群组)
	Timestamp   int64       `json:"timestamp"`     // 消息时间戳
	Payload     string      `json:"payload"`       // Base64 编码的消息内容
}

type SearchUserMessagesRequest struct {
	UID          string         `json:"uid"`                     // 必传，当前用户 UID
	Payload      map[string]any `json:"payload,omitempty"`       // 可选，消息 payload，自定义字段
	PayloadTypes []int          `json:"payload_types,omitempty"` // 可选，消息类型搜索
	FromUID      *string        `json:"from_uid,omitempty"`      // 可选，发送者 UID
	ChannelID    *string        `json:"channel_id,omitempty"`    // 可选，频道 ID
	ChannelType  *ChannelType   `json:"channel_type,omitempty"`  // 可选，频道类型 (1=个人,2=群组)
	Topic        *string        `json:"topic,omitempty"`         // 可选，topic 搜索
	Limit        *int           `json:"limit,omitempty"`         // 可选，限制数量（默认 10）
	Page         *int           `json:"page,omitempty"`          // 可选，页码（默认 1）
	StartTime    *int64         `json:"start_time,omitempty"`    // 可选，消息时间（开始）
	EndTime      *int64         `json:"end_time,omitempty"`      // 可选，消息时间（结束，包含 end_time）
	Highlights   []string       `json:"highlights,omitempty"`    // 可选，需要高亮的字段
}

type SearchUserMessagesResponse struct {
	Total    int               `json:"total"`    // 消息总数量
	Limit    int               `json:"limit"`    // 查询数量限制
	Page     int               `json:"page"`     // 当前页码
	Messages []SearchedMessage `json:"messages"` // 消息列表
}

type SearchedMessage struct {
	MessageID    int64                  `json:"message_id"`      // 消息唯一 ID
	MessageIDStr string                 `json:"message_idstr"`   // 消息唯一 ID（字符串形式）
	MessageSeq   int64                  `json:"message_seq"`     // 消息序号
	ClientMsgNo  string                 `json:"client_msg_no"`   // 客户端消息唯一编号
	FromUID      string                 `json:"from_uid"`        // 发送者 UID
	ChannelID    string                 `json:"channel_id"`      // 频道 ID
	ChannelType  ChannelType            `json:"channel_type"`    // 频道类型 (1=个人频道, 2=群组频道)
	Payload      map[string]interface{} `json:"payload"`         // 消息内容对象（通用 payload，用 map 接收）
	Topic        *string                `json:"topic,omitempty"` // 可选，消息 topic
	Timestamp    int64                  `json:"timestamp"`       // 消息时间戳（10位到秒）
}

type SendEventRequest struct {
	ClientMsgNo string      `json:"client_msg_no"` // 必传，客户端消息编号，必须唯一
	ChannelID   string      `json:"channel_id"`    // 必传，目标频道ID
	ChannelType ChannelType `json:"channel_type"`  // 必传，频道类型 (1=个人, 2=群组)
	FromUid     string      `json:"from_uid"`      // 发送者UID
	Event       Event       `json:"event"`         // 必传，事件对象
}

type SendMessageResponse struct {
	MessageID   int64  `json:"message_id"`    // 服务器生成的消息 ID
	MessageSeq  int64  `json:"message_seq"`   // 消息序列号
	ClientMsgNo string `json:"client_msg_no"` // 客户端消息编号（回显）
}

type ServerStatusResponse struct {
	// 服务器信息
	ServerID  string `json:"server_id"`  // 服务器标识符
	Version   string `json:"version"`    // WuKongIM 版本号
	GitCommit string `json:"git_commit"` // Git 提交哈希
	GoVersion string `json:"go_version"` // Go 语言版本

	// 运行时信息
	Start  string `json:"start"`  // 服务器启动时间 (ISO 8601)
	Now    string `json:"now"`    // 当前时间 (ISO 8601)
	Uptime string `json:"uptime"` // 运行时长

	// 连接统计
	Connections      int `json:"connections"`       // 当前连接数
	TotalConnections int `json:"total_connections"` // 历史累计连接数
	SlowConsumers    int `json:"slow_consumers"`    // 慢消费者数量
	Subscriptions    int `json:"subscriptions"`     // 订阅总数

	// 消息统计
	InMsgs   int64 `json:"in_msgs"`   // 接收消息总数
	OutMsgs  int64 `json:"out_msgs"`  // 发送消息总数
	InBytes  int64 `json:"in_bytes"`  // 接收字节总数
	OutBytes int64 `json:"out_bytes"` // 发送字节总数

	// HTTP 请求统计
	HTTPReqStats HTTPReqStats `json:"http_req_stats"`

	// 系统资源
	CPU float64 `json:"cpu"` // CPU 使用率 (%)
	Mem int64   `json:"mem"` // 内存使用量 (字节)

	// 配置信息
	Config Config `json:"config"`
}

type SetConversationUnreadRequest struct {
	ConversationInfo
	Unread int `json:"unread"` // 未读消息数量
}

type SetUserTokenRequest struct {
	UID         string       `json:"uid"`                    // 必传，用户唯一 ID
	Token       string       `json:"token"`                  // 必传，校验的 token
	DeviceFlag  DeviceFlag   `json:"device_flag"`            // 必传，设备标识 (0=app,1=web,2=desktop)
	DeviceLevel *DeviceLevel `json:"device_level,omitempty"` // 可选，设备等级 (0=从设备,1=主设备)
}

type StatusResponse struct {
	StatusCode int    `json:"-"`
	Status     int    `json:"status"` // 操作状态，成功时返回 "ok"
	Msg        string `json:"msg"`
	Data       any    `json:"data"`
}

type SyncConversationRequest struct {
	UID                 string        `json:"uid"`                             // 必传：用户 ID
	Version             *int64        `json:"version,omitempty"`               // 可选：版本时间戳（增量同步）
	LastMsgSeqs         *string       `json:"last_msg_seqs,omitempty"`         // 可选：最后消息序列号
	MsgCount            *int          `json:"msg_count,omitempty"`             // 可选：每个会话返回的最近消息数量
	OnlyUnread          *int          `json:"only_unread,omitempty"`           // 可选：是否只返回未读 (0=全部,1=未读)
	ExcludeChannelTypes []ChannelType `json:"exclude_channel_types,omitempty"` // 可选：要排除的频道类型
}

type URIStat struct {
	URI     string `json:"uri"`      // 请求 URI
	Count   int    `json:"count"`    // 请求次数
	AvgTime string `json:"avg_time"` // 平均响应时间
}

type UpdateUserTokenRequest SetUserTokenRequest

type UserIMAddr struct {
	TcpAddr string `json:"tcp_addr"`
	WsAddr  string `json:"ws_addr"`
	WssAddr string `json:"wss_addr"`
}