ae2c1bda77
Some checks failed
Default / Build (push) Failing after 1m40s
Default / Build UI (push) Failing after 26s
Release / call-build-workflow (push) Has been cancelled
Release / Publish Docker :release (push) Has been cancelled
Release / Publish Github & APT release (push) Has been cancelled
108 lines
2.5 KiB
Go
108 lines
2.5 KiB
Go
package meter
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/evcc-io/evcc/api"
|
|
"github.com/evcc-io/evcc/meter/discovergy"
|
|
"github.com/evcc-io/evcc/provider"
|
|
"github.com/evcc-io/evcc/util"
|
|
"github.com/evcc-io/evcc/util/request"
|
|
"github.com/evcc-io/evcc/util/transport"
|
|
"github.com/thoas/go-funk"
|
|
)
|
|
|
|
func init() {
|
|
registry.Add("discovergy", NewDiscovergyFromConfig)
|
|
}
|
|
|
|
type Discovergy struct {
|
|
dataG func() (interface{}, error)
|
|
scale float64
|
|
}
|
|
|
|
// NewDiscovergyFromConfig creates a new configurable meter
|
|
func NewDiscovergyFromConfig(other map[string]interface{}) (api.Meter, error) {
|
|
cc := struct {
|
|
User string
|
|
Password string
|
|
Meter string
|
|
Scale float64
|
|
Cache time.Duration
|
|
}{
|
|
Scale: 1,
|
|
Cache: time.Second,
|
|
}
|
|
|
|
if err := util.DecodeOther(other, &cc); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
basicAuth := transport.BasicAuthHeader(cc.User, cc.Password)
|
|
log := util.NewLogger("discgy").Redact(cc.User, cc.Password, cc.Meter, basicAuth)
|
|
|
|
client := request.NewHelper(log)
|
|
client.Transport = transport.BasicAuth(cc.User, cc.Password, client.Transport)
|
|
|
|
var meters []discovergy.Meter
|
|
if err := client.GetJSON(fmt.Sprintf("%s/meters", discovergy.API), &meters); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var meterID string
|
|
if cc.Meter != "" {
|
|
for _, m := range meters {
|
|
if matchesIdentifier(cc.Meter, m) {
|
|
meterID = m.MeterID
|
|
break
|
|
}
|
|
}
|
|
} else if len(meters) == 1 {
|
|
meterID = meters[0].MeterID
|
|
}
|
|
|
|
if meterID == "" {
|
|
return nil, fmt.Errorf("could not determine meter id: %v", funk.Map(meters, func(m discovergy.Meter) string {
|
|
return m.FullSerialNumber
|
|
}))
|
|
}
|
|
|
|
dataG := provider.NewCached(func() (interface{}, error) {
|
|
uri := fmt.Sprintf("%s/last_reading?meterId=%s", discovergy.API, meterID)
|
|
var res discovergy.Reading
|
|
err := client.GetJSON(uri, &res)
|
|
return res, err
|
|
}, cc.Cache).InterfaceGetter()
|
|
|
|
m := &Discovergy{
|
|
dataG: dataG,
|
|
scale: cc.Scale,
|
|
}
|
|
|
|
return m, nil
|
|
}
|
|
|
|
func matchesIdentifier(id string, m discovergy.Meter) bool {
|
|
return id == m.MeterID || id == m.SerialNumber || id == m.FullSerialNumber
|
|
}
|
|
|
|
var _ api.Meter = (*Discovergy)(nil)
|
|
|
|
func (m *Discovergy) CurrentPower() (float64, error) {
|
|
res, err := m.dataG()
|
|
if res, ok := res.(discovergy.Reading); err == nil && ok {
|
|
return m.scale * float64(res.Values.Power) / 1e3, nil
|
|
}
|
|
return 0, err
|
|
}
|
|
|
|
var _ api.MeterEnergy = (*Discovergy)(nil)
|
|
|
|
func (m *Discovergy) TotalEnergy() (float64, error) {
|
|
res, err := m.dataG()
|
|
if res, ok := res.(discovergy.Reading); err == nil && ok {
|
|
return float64(res.Values.Energy) / 1e6, nil
|
|
}
|
|
return 0, err
|
|
}
|