一、HTTP API 接口标准
接口鉴权
应用smartassistant接口,需将用户凭证smart-assistant-token,放在http申请的header中。格局如下:"smart-assistant-token":"xxx"
- 返回规范数据结构
smartassistant接口均返回JSON格局数据,格局如下:
{
"status":0, // 状态码
"reason":"", // 状态码形容
"data":{} // 所有业务数据返回都蕴含在data对象中
}
- 错误码列表
二、设施类插件实现
开发前先浏览插件设计概要:插件零碎设计技术概要
应用 plugin-sdk(code:/pkg/plugin/sdk) 能够疏忽不重要的逻辑,疾速实现插件
插件实现
1) 获取sdk
go get github.com/zhiting-tech/smartassistant
2) 定义设施
sdk中提供了预约义的设施模型,应用模型能够不便SA无效进行治理和管制
设施物模型设计如下:
light_bulb灯泡
switch开关
outlet插座
info设施详情
curtain窗帘
package plugin
import (
"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/instance"
"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/attribute"
)
type Device struct {
Light instance.LightBulb
Info0 instance.Info
// 依据理论设施性能组合定义
}
func NewDevice() *Device {
// 定义属性
lightBulb := instance.LightBulb{
Power: attribute.NewPower(),
ColorTemp: instance.NewColorTemp(), // 可选字段须要初始化能力应用
Brightness: nil, // 可选字段不初始化则不从接口中显示
}
// 定义设施根底属性
info := instance.Info{
Name: attribute.NewName(),
Identity: attribute.NewIdentity(),
Model: attribute.NewModel(),
Manufacturer: attribute.NewManufacturer(),
Version: attribute.NewVersion(),
}
return &Device{
Light: lightBulb,
Info0: info,
}
}
3) 实现设施接口 定义好设施之后,须要为设施实现如下几个办法:
package main
import (
"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/server"
)
type Device interface {
Identity() string // 获取设施惟一值
Info() server.DeviceInfo // 设施详情
Setup() error // 初始化设施属性
Update() error // 更新设施所有属性值
Close() error // 回收所有资源
GetChannel() server.WatchChan // 返回告诉channel
}
实现如下:
package plugin
import (
"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/instance"
"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/attribute"
"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/server"
)
type Device struct {
Light instance.LightBulb
Info0 instance.Info
// 依据理论设施性能组合定义
}
func NewDevice() *Device {
// 定义属性
lightBulb := instance.LightBulb{
Power: attribute.NewPower(),
ColorTemp: attribute.NewColorTemp(), // 可选字段须要初始化能力使
Brightness: nil, // 可选字段不初始化则不从接口中显示
}
info := instance.Info{
Name: attribute.NewName(),
Identity: attribute.NewIdentity(),
Model: attribute.NewModel(),
Manufacturer: attribute.NewManufacturer(),
Version: attribute.NewVersion(),
}
return &Device{
Light: lightBulb,
Info0: info,
}
}
func (d *Device) Info() server.DeviceInfo {
// 该办法返回设施的次要信息
panic("implement me")
}
func (d *Device) Setup() error {
// 设置设施的属性和相干配置(比方设施id、型号、厂商等,以及设施的属性更新触发函数)
panic("implement me")
}
func (d *Device) Update() error {
// 该办法在获取设施所有属性值时调用,通过调用attribute.SetBool()等办法更新
panic("implement me")
}
func (d *Device) Close() error {
// 自定义退出相干资源的回收
panic("implement me")
}
func (d *Device) GetChannel() server.WatchChan {
// 返回WatchChan频道,用于状态变更推送
panic("implement me")
}
4) 初始化和运行
定义好设施和实现办法后,运行插件服务(包含grpc和http服务)
package main
import (
"log"
"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/server"
sdk "github.com/zhiting-tech/smartassistant/pkg/server/sdk"
)
func main() {
p := server.NewPluginServer() // 插件服务名
go func() {
// 发现设施,并将设施增加到manager中
d := NewDevice()
p.Manager.AddDevice(d)
}()
err := sdk.Run(p)
if err != nil {
log.Panicln(err)
}
}
这样服务就会运行起来,并通过SA的etcd地址0.0.0.0:2379注册插件服务, SA会通过etcd发现插件服务并且建设通道开始通信并且转发申请和命令。
接着就能够开始了。
发表回复