开发您的第一个插件

plugin
├── device
│   ├── attribute.go
│   ├── switch.go
│   └── light.go
├── lib
│   ├── protocol.go
│   └── discover.go
├── config.json
├── html
│   ├── index.html
│   └── images
...
├── Readme.md
├── .dockerignore
├── Dockerfile
└── main.go

go get github.com/zhiting-tech/smartassistant

package device

import (
	"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/v2"
	"github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/v2/definer"
)

type Light struct {
}

func NewLight() sdk.Device {
	return &Light{}
}

func (l Light) Address() string {
	// TODO implement me
	panic("implement me")
}

func (l Light) Connect() error {
	// TODO implement me
	panic("implement me")
}

func (l Light) Disconnect(iid string) error {
	// TODO implement me
	panic("implement me")
}

func (l Light) Define(df *definer.Definer) error {
	// TODO implement me
	panic("implement me")
}

func (l Light) Info() sdk.DeviceInfo {
	// TODO implement me
	panic("implement me")
}

func (l Light) Online(iid string) bool {
	// TODO implement me
	panic("implement me")
}

func (l Light) Address() string {
	// 该地址返回改变会导致设备断开重连
	return "192.168.0.123:12345"
}

func (l Light) Info() sdk.DeviceInfo {
    return sdk.DeviceInfo{
        IID:          "iid",
        Model:        "model",
        Manufacturer: "manufacturer",
        AuthRequired: false,
    }
}

func (l Light) Connect() error {
    // 此处由于是虚拟设备，所以没有连接过程
    // return l.protocol.Connect()
    return nil
}
func (l Light) Disconnect(iid string) error {
    // 此处由于是虚拟设备，所以没有断开连接过程
    // return l.protocol.Disconnect()
    return nil
}

func (l Light) Close() error {
    // 此处由于是虚拟设备，所以没有回收资源的过程
    // return l.protocol.Close()
    return nil
}

func (l Light) Online(iid string) bool {
    // 此处由于是虚拟设备，所以没判断实际是否在线
    // return l.protocol.IsOnline()
    return true
}

package device

import "github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/v2/definer"

// OnOff 开关
// 通过实现 thingmodel.IAttribute 的接口，以便sdk调用
type OnOff struct {
	service *definer.BaseService
}

func (l *OnOff) Set(val interface{}) error {

	// 如果有设备，则跟据已实现的通讯协议控制设备
	// return l.protocol.SetSwitch(val)

	// 此处仅将设置的状态同步回SA
	return l.service.Notify(thingmodel.OnOff, val)
}

func (l Light) Define(df *definer.Definer) error {
    info := df.Instance(l.Info().IID).NewInfo()
    info.WithAttribute(thingmodel.Manufacturer).SetVal(l.Info().Manufacturer)
    info.WithAttribute(thingmodel.Model).SetVal(l.Info().Model)
    info.WithAttribute(thingmodel.Identify).SetVal(l.Info().IID)
    info.WithAttribute(thingmodel.Version).SetVal("1.0.0")
    
    light := df.Instance(l.Info().IID).NewLight()
    light.Enable(thingmodel.OnOff, OnOff{light}).SetVal("on")
	
	// 为了使得物模型属性状态和设备状态保持一致，需要开发者主动同步设备状态变化
    // go func() {
    //     for {
    //         // 此处同步设备属性状态
    //         light.Notify(thingmodel.OnOff, "on")
    //     }
    // }()
}

package main

import (
	"context"
	"log"
	
	sdk "github.com/zhiting-tech/smartassistant/pkg/plugin/sdk/v2"

	"plugin/device"
)

func main() {
    p := sdk.NewPluginServer(Discover)
    err := sdk.Run(p)
    if err != nil {
        log.Panicln(err)
    }
}

// Discover 这里需要实现一个发现设备的方法,给sdk调用
func Discover(ctx context.Context, devices chan<- sdk.Device) {
    l := getDevice()
    devices <- l
    <-ctx.Done()
}

// getDevice 发现设备，由于没有设备，所以没有实现发现设备的逻辑
func getDevice() sdk.Device {
    return device.NewLight()
}

FROM golang:1.16-alpine as builder
RUN apk add build-base
COPY . /app
WORKDIR /app
RUN go env -w GOPROXY="goproxy.cn,direct"
RUN go build -ldflags="-w -s" -o demo-plugin

FROM alpine
WORKDIR /app
COPY --from=builder /app/demo-plugin /app/demo-plugin

# static file
COPY ./html ./html
ENTRYPOINT ["/app/demo-plugin"]

docker build -f your_plugin_Dockerfile -t your_plugin_name