models

type EventModel struct {
	Type      EventType   // JOIN, LEAVE, MESSAGE
	Sub       *Subscriber // 广播请传 nil
	Timestamp int64       // Unix timestamp (secs)
	Content   interface{}
}

type EventType int

type GameErrorContent struct {
	Id        int64  `gorm:"primary_key" json:"id"`
	Message   string `json:"message"`
	Source    string `json:"source"`
	Lineno    string `json:"lineno"`
	Colno     string `json:"colno"`
	Stack     string `json:"stack"`
	Uid       int64  `json:"uid"`
	CreatedAt string `json:"created_at"`
}

type GamePixelRecord struct {
	Id        int64  `gorm:"primary_key" json:"id"`
	X         int64  `json:"x"`
	Y         int64  `json:"y"`
	Color     int64  `json:"color"`
	Uid       int64  `json:"uid"`
	CreatedAt string `json:"created_at"`
}

type GameUser struct {
	Id          int64  `gorm:"primary_key" json:"id"`
	Nickname    string `json:"nickname"`
	AccessToken string `json:"access_token"`
	Status      int8   `json:"status"`
	CreatedAt   string `json:"created_at"`
	UpdatedAt   string `json:"updated_at"`
}

type Subscriber struct {
	Uuid string // 连接唯一ID
	Ping int64  // 最后心跳时间
	Uid  int64  // 用户ID

	Conn    *websocket.Conn // ws 客户端连接句柄
	Request *http.Request   // http 请求

	WriteChan     chan *EventModel // 发消息通道 (这里用指针是为了防止 channel 拷贝数据，造成资源浪费，特别是广播时候)
	WriteChanLock sync.Mutex
	StopChan      chan bool     // 用于监控连接中断信号
	Limiter       *rate.Limiter // 令牌桶 限制速率
}

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