blinker

Documentation

Index

• Constants
• func GetAndParseJSONResponseFromHttpResponse(resp *http.Response, result interface{}) error
• func GetBytesFromHttpResponse(resp *http.Response) ([]byte, error)
• func UnRegisterPowerChangeCallback(d *Device, key string)
• type BlinkerDetailInfo
• type BlinkerInfoRes
• type Device
  • func CreateDevice(ak string, httpClientSecureVerify bool, httpClientTimeout int) *Device
  • func GetBlinkerDevice(authKey string, httpClientSecureVerify bool, httpClientTimeout int) (*Device, error)
  • func (d *Device) AddVoiceAssistant(v *VoiceAssistant)
  • func (d *Device) GetExtData(key any) (val any, ok bool)
  • func (d *Device) GetState() bool
  • func (d *Device) Init() error
  • func (d *Device) IsDisconnected() bool
  • func (d *Device) Login() error
  • func (d *Device) OnLine() bool
  • func (d *Device) ReceiveMessageHandler(c MQTT.Client, m MQTT.Message)
  • func (d *Device) RegisterPowerChangeCallbackFunc(key string, cb func(string))
  • func (d *Device) RunHeartBearTimer()
  • func (d *Device) SendMessage(targetType, todevice, msgid string, msg any)
  • func (d *Device) SetQueryStateFunc(f func() bool)
  • func (d *Device) Stop()
  • func (d *Device) StoreExtData(key any, val any)
  • func (d *Device) SyncAssistants() error
  • func (d *Device) UnRegisterPowerChangeCallbackFunc(key string)
• type VoiceAssistant
  • func CreateVoiceAssistant(deviceType, vaType string) *VoiceAssistant
  • func (v *VoiceAssistant) GetSKey() string
  • func (v *VoiceAssistant) GetToDevice() string
  • func (v *VoiceAssistant) PowerChangeReply(msgid, state string)
  • func (v *VoiceAssistant) QueryDeviceState(msgid string)

Constants

const (
	VA_TYPE_LIGHT        = "light"
	VA_TYPE_OUTLET       = "outlet"
	VA_TYPE_MULTI_OUTLET = "multi_outlet"
	VA_TYPE_SENSOR       = "sensor"
	VA_TYPE_FAN          = "fan"
	VA_TYPE_AIRCONDITION = "aircondition"
)

const (
	Disconnected uint32 = iota
	Connecting
	Reconnecting
	Connected
)

const (
	HOST                = "https://iot.diandeng.tech"
	API_AUTH            = HOST + "/api/v1/user/device/diy/auth"
	API_HEARTBEAT       = HOST + "/api/v1/user/device/heartbeat"
	API_VOICE_ASSISTANT = HOST + "/api/v1/user/device/voice_assistant"
)

Functions

func GetAndParseJSONResponseFromHttpResponse

func GetAndParseJSONResponseFromHttpResponse(resp *http.Response, result interface{}) error

func GetBytesFromHttpResponse

func GetBytesFromHttpResponse(resp *http.Response) ([]byte, error)

GetStringFromHttpResponse 从response获取

func UnRegisterPowerChangeCallback

func UnRegisterPowerChangeCallback(d *Device, key string)

Types

type BlinkerDetailInfo

type BlinkerDetailInfo struct {
	Broker     string `json:"broker"`
	DeviceName string `json:"deviceName"`
	Host       string `json:"host"`
	IotID      string `json:"iotId"`
	IotToken   string `json:"iotToken"`
	Port       string `json:"port"`
	ProductKey string `json:"productKey"`
	UUID       string `json:"uuid"`
}

type BlinkerInfoRes

type BlinkerInfoRes struct {
	Message int               `json:"message"`
	Detail  BlinkerDetailInfo `json:"detail"`
}

type Device

type Device struct {
	DetailInfo BlinkerDetailInfo
	// contains filtered or unexported fields
}

func CreateDevice

func CreateDevice(ak string, httpClientSecureVerify bool, httpClientTimeout int) *Device

func GetBlinkerDevice

func GetBlinkerDevice(authKey string, httpClientSecureVerify bool, httpClientTimeout int) (*Device, error)

func (*Device) AddVoiceAssistant

func (d *Device) AddVoiceAssistant(v *VoiceAssistant)

func (*Device) GetExtData

func (d *Device) GetExtData(key any) (val any, ok bool)

func (*Device) GetState

func (d *Device) GetState() bool

func (*Device) Init

func (d *Device) Init() error

func (*Device) IsDisconnected

func (d *Device) IsDisconnected() bool

func (*Device) Login

func (d *Device) Login() error

func (*Device) OnLine

func (d *Device) OnLine() bool

func (*Device) ReceiveMessageHandler

func (d *Device) ReceiveMessageHandler(c MQTT.Client, m MQTT.Message)

func (*Device) RegisterPowerChangeCallbackFunc

func (d *Device) RegisterPowerChangeCallbackFunc(key string, cb func(string))

func (*Device) RunHeartBearTimer

func (d *Device) RunHeartBearTimer()

func (*Device) SendMessage

func (d *Device) SendMessage(targetType, todevice, msgid string, msg any)

func (*Device) SetQueryStateFunc

func (d *Device) SetQueryStateFunc(f func() bool)

func (*Device) Stop

func (d *Device) Stop()

func (*Device) StoreExtData

func (d *Device) StoreExtData(key any, val any)

func (*Device) SyncAssistants

func (d *Device) SyncAssistants() error

func (*Device) UnRegisterPowerChangeCallbackFunc

func (d *Device) UnRegisterPowerChangeCallbackFunc(key string)

type VoiceAssistant

type VoiceAssistant struct {
	DeviceType string //语言助手类型 (设备类型).
	VAType     string //语言助手类型  MIOT AliGenie DuerOS
	Device     *Device
	// contains filtered or unexported fields
}

func CreateVoiceAssistant

func CreateVoiceAssistant(deviceType, vaType string) *VoiceAssistant

func (*VoiceAssistant) GetSKey

func (v *VoiceAssistant) GetSKey() string

func (*VoiceAssistant) GetToDevice

func (v *VoiceAssistant) GetToDevice() string

func (*VoiceAssistant) PowerChangeReply

func (v *VoiceAssistant) PowerChangeReply(msgid, state string)

func (*VoiceAssistant) QueryDeviceState

func (v *VoiceAssistant) QueryDeviceState(msgid string)