socket

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

type BusPowerEvent struct {
	BaseEvent
	PowerOn bool
}

type BusPowerStatusUpdateEvent struct {
	BaseEvent
	Status *device.PowerStatus
}

type BusPowerStatusUpdateRequestEvent struct {
	EmptyEvent
}

type ChannelFilterEvent struct {
	BaseEvent
	Channels map[nocan.ChannelId]bool
}

type ChannelListEvent struct {
	BaseEvent `json:"-"`
	Channels  []*ChannelUpdateEvent `json:"channels"`
}

type ChannelListRequestEvent struct {
	EmptyEvent
}

type ChannelStatus byte

type ChannelUpdateEvent struct {
	BaseEvent
	ChannelId   nocan.ChannelId
	ChannelName string
	Status      ChannelStatus
	Value       []byte
	UpdatedAt   time.Time
}

type ChannelUpdateRequestEvent struct {
	BaseEvent
	ChannelId   nocan.ChannelId
	ChannelName string
}

type ClientDescriptor struct {
	Id              uint
	Server          *Server
	Conn            *sscp.Conn
	OutputChan      chan Eventer
	TerminationChan chan struct{}
	ChannelFilter   *ChannelFilterEvent
	Connected       bool
	Next            *ClientDescriptor
	LastMsgId       uint16
}

type ClientHelloEvent struct {
	BaseEvent
	Tool         string
	VersionMajor byte
	VersionMinor byte
}

type DeviceInformationEvent struct {
	BaseEvent
	Information *device.Information
}

type DeviceInformationRequestEvent struct {
	EmptyEvent
}

type EmptyEvent struct {
	BaseEvent
}

type EventCallback func(*EventConn, Eventer) error

type EventConn struct {
	Conn       *sscp.Conn
	Addr       string
	ClientName string
	AuthToken  string
	Connected  bool
	AutoRedial bool
	MsgId      uint16
	Callbacks  map[EventId]EventCallback

	Mutex sync.Mutex
	// contains filtered or unexported fields
}

type EventHandler func(*ClientDescriptor, Eventer) error

type EventId byte

type EventRequest struct {
	ResponseCallback func(*EventConn, error) error
	CreatedAt        time.Time
}

type Eventer interface {
	Id() EventId
	MsgId() uint16
	SetMsgId(uint16)
	Pack() ([]byte, error)
	Unpack([]byte) error
	String() string
}

type FirmwareBlock struct {
	Offset uint32
	Data   []byte
}

type NodeFirmwareDownloadRequestEvent struct {
	BaseEvent
	NodeId nocan.NodeId
}

type NodeFirmwareEvent struct {
	BaseEvent
	NodeId   nocan.NodeId
	Download bool
	Limit    uint32
	Code     []FirmwareBlock
}

type NodeFirmwareProgressEvent struct {
	BaseEvent
	NodeId           nocan.NodeId
	Progress         ProgressReport
	BytesTransferred uint32
}

type NodeListEvent struct {
	BaseEvent
	Nodes []*NodeUpdateEvent `json:"nodes"`
}

type NodeListRequestEvent struct {
	EmptyEvent
}

type NodeRebootRequestEvent struct {
	BaseEvent
	RebootId byte
}

type NodeUpdateEvent struct {
	BaseEvent `json:"-"`
	NodeId    nocan.NodeId     `json:"id"`
	State     models.NodeState `json:"state"`
	Udid      models.Udid8     `json:"udid"`
	LastSeen  time.Time        `json:"last_seen"`
}

type NodeUpdateRequestEvent struct {
	BaseEvent
	NodeId nocan.NodeId
}

type ProgressReport byte

type Server struct {
	Mutex     sync.Mutex
	AuthToken string
	// contains filtered or unexported fields
}

type ServerAckEvent struct {
	BaseEvent
	Code byte
}

type ServerHelloEvent struct {
	ClientHelloEvent
}

type SystemPropertiesEvent struct {
	BaseEvent
	Properties *properties.Properties
}

type SystemPropertiesRequestEvent struct {
	EmptyEvent
}