73 lines
1.4 KiB
Go
73 lines
1.4 KiB
Go
package plugin
|
|
|
|
import (
|
|
"context"
|
|
"encoding/binary"
|
|
"fmt"
|
|
|
|
"github.com/evcc-io/evcc/util"
|
|
)
|
|
|
|
type convertPlugin struct {
|
|
ctx context.Context
|
|
Convert string
|
|
Set Config
|
|
}
|
|
|
|
func init() {
|
|
registry.AddCtx("convert", NewConvertFromConfig)
|
|
}
|
|
|
|
// NewConvertFromConfig creates type conversion provider
|
|
func NewConvertFromConfig(ctx context.Context, other map[string]any) (Plugin, error) {
|
|
cc := convertPlugin{
|
|
ctx: ctx,
|
|
}
|
|
|
|
if err := util.DecodeOther(other, &cc); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &cc, nil
|
|
}
|
|
|
|
var _ FloatSetter = (*convertPlugin)(nil)
|
|
|
|
func (o *convertPlugin) FloatSetter(param string) (func(float64) error, error) {
|
|
switch o.Convert {
|
|
case "float2int":
|
|
set, err := o.Set.IntSetter(o.ctx, param)
|
|
|
|
return func(val float64) error {
|
|
return set(int64(val))
|
|
}, err
|
|
|
|
default:
|
|
return nil, fmt.Errorf("convert: invalid conversion: %s", o.Convert)
|
|
}
|
|
}
|
|
|
|
var _ IntSetter = (*convertPlugin)(nil)
|
|
|
|
func (o *convertPlugin) IntSetter(param string) (func(int64) error, error) {
|
|
switch o.Convert {
|
|
case "int2float":
|
|
set, err := o.Set.FloatSetter(o.ctx, param)
|
|
|
|
return func(val int64) error {
|
|
return set(float64(val))
|
|
}, err
|
|
|
|
case "int2bytes":
|
|
set, err := o.Set.BytesSetter(o.ctx, param)
|
|
|
|
return func(val int64) error {
|
|
b := make([]byte, 8)
|
|
binary.BigEndian.PutUint64(b, uint64(val))
|
|
return set(b)
|
|
}, err
|
|
|
|
default:
|
|
return nil, fmt.Errorf("convert: invalid conversion: %s", o.Convert)
|
|
}
|
|
}
|