// 插件接口

package plugin

import (
	"encoding/json"
	"gitee.com/watertreestar/edge/driverbox/config"
	lua "github.com/yuin/gopher-lua"
	"go.uber.org/zap"
)

const (
	ReadMode  EncodeMode = "read"  // 读模式
	WriteMode EncodeMode = "write" // 写模式
)

// EncodeMode 编码模式
type EncodeMode string

// H map[string]interface{} 别名
type H map[string]interface{}

// OnReceiveHandler 接收数据回调函数
type OnReceiveHandler func(plugin Plugin, raw interface{}) (result interface{}, err error)

// PointData 点位数据
type PointData struct {
	PointName string      `json:"name"`  // 点位名称
	Type      string      `json:"type"`  // 点位值类型
	Value     interface{} `json:"value"` // 点位值
}

// DeviceData 设备数据
type DeviceData struct {
	DeviceName string      `json:"device_name"`
	Values     []PointData `json:"values"`
}

// ToJSON 设备数据转 json
func (d DeviceData) ToJSON() string {
	b, _ := json.Marshal(d)
	return string(b)
}

// Plugin 驱动插件
type Plugin interface {
	// Initialize 初始化日志、配置、接收回调
	Initialize(logger *zap.Logger, c config.Config, handler OnReceiveHandler, ls *lua.LState) (err error)
	// ProtocolAdapter 协议适配器
	ProtocolAdapter() ProtocolAdapter
	// Connector 连接器
	Connector(deviceName, pointName string) (connector Connector, err error)
	// Destroy 销毁驱动
	Destroy() error
}

// Connector 连接器
type Connector interface {
	Send(data interface{}) (err error) // 发送数据
	Release() (err error)              // 释放连接资源
}

// ProtocolAdapter 协议适配器
// 点位数据 <=> 协议数据
type ProtocolAdapter interface {
	Encode(deviceName string, mode EncodeMode, value PointData) (res interface{}, err error) // 编码
	Decode(raw interface{}) (res []DeviceData, err error)                                    // 解码
}