base

type GateWayHttpApiResult struct {
	Code    int32  `json:"code"`
	Message string `json:"message"`
	Data    struct {
		Url string `json:"url"`
	} `json:"data"`
}

type Session struct {
	Compressed          int
	ReceiveFrameHandler func(frame *event2.FrameMap) (error, []byte)
	ProcessDataHandler  func(data []byte) (error, []byte)
	EventSyncHandle     bool
}

type SessionInterface interface {
	//接收数据
	ReceiveData(data []byte)

	SendData(data []byte)

	//注册回调
	On(message string, handler event.Listener)
}

type State struct {
	Name string
	Code int
}

type StateSession struct {
	Session
	SessionId string
	//Status           string
	GateWay      string
	Timeout      int
	RecvQueue    chan *event2.FrameMap
	MaxSn        int64
	FSM          *fsm.FSM
	NetworkProxy SystemInterface

	StatusParams    map[string]*StatusParam
	HeartBeatCron   *cron.Cron
	LastPongAt      time.Time
	LastPingAt      time.Time
	PongTimeoutChan chan time.Time
}

type StatusParam struct {
	StartTime  int
	MaxTime    int
	FirstDelay int
	Retry      int
	MaxRetry   int
}

type SystemInterface interface {
	ReqGateWay() (error, string)
	ConnectWebsocket(gateway string) error
	SendData(data []byte) error
	//ReceiveData(data []byte) (error, []byte)
	SaveSessionId(sessionId string) error
}

type WebSocketSession struct {
	*StateSession
	Token       string
	BaseUrl     string
	SessionFile string
	WsConn      *websocket.Conn
	WsWriteLock *sync.Mutex
}

type WebhookSession struct {
	Session
	EncryptKey  string
	VerifyToken string
}