92 lines
2.1 KiB
Go
92 lines
2.1 KiB
Go
package polestar
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/evcc-io/evcc/api"
|
|
"github.com/evcc-io/evcc/util"
|
|
)
|
|
|
|
type Provider struct {
|
|
telemetryG func() (CarTelemetryData, error)
|
|
}
|
|
|
|
func NewProvider(log *util.Logger, api *API, vin string, timeout, cache time.Duration) *Provider {
|
|
v := &Provider{
|
|
telemetryG: util.Cached(func() (CarTelemetryData, error) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), timeout)
|
|
defer cancel()
|
|
return api.CarTelemetry(ctx, vin)
|
|
}, cache),
|
|
}
|
|
|
|
return v
|
|
}
|
|
|
|
// SOC via car telemetry
|
|
func (v *Provider) Soc() (float64, error) {
|
|
res, err := v.telemetryG()
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
if len(res.Battery) == 0 {
|
|
return 0, api.ErrNotAvailable
|
|
}
|
|
return res.Battery[0].BatteryChargeLevelPercentage, nil
|
|
}
|
|
|
|
var _ api.ChargeState = (*Provider)(nil)
|
|
|
|
// Status via car telemetry
|
|
func (v *Provider) Status() (api.ChargeStatus, error) {
|
|
status, err := v.telemetryG()
|
|
|
|
res := api.StatusA
|
|
|
|
if len(status.Battery) == 0 {
|
|
return res, nil
|
|
}
|
|
|
|
if status.Battery[0].ChargingStatus == "CHARGER_CONNECTION_STATUS_CONNECTED" {
|
|
res = api.StatusB
|
|
}
|
|
if status.Battery[0].ChargingStatus == "CHARGING_STATUS_CHARGING" {
|
|
res = api.StatusC
|
|
}
|
|
|
|
return res, err
|
|
}
|
|
|
|
var _ api.VehicleRange = (*Provider)(nil)
|
|
|
|
// Range via car telemetry
|
|
func (v *Provider) Range() (int64, error) {
|
|
res, err := v.telemetryG()
|
|
if len(res.Battery) == 0 {
|
|
return 0, api.ErrNotAvailable
|
|
}
|
|
return res.Battery[0].EstimatedDistanceToEmptyKm, err
|
|
}
|
|
|
|
var _ api.VehicleOdometer = (*Provider)(nil)
|
|
|
|
// Odometer via car telemetry
|
|
func (v *Provider) Odometer() (float64, error) {
|
|
res, err := v.telemetryG()
|
|
if len(res.Odometer) == 0 {
|
|
return 0, api.ErrNotAvailable
|
|
}
|
|
return float64(res.Odometer[0].OdometerMeters) / 1e3, err
|
|
}
|
|
|
|
var _ api.VehicleFinishTimer = (*Provider)(nil)
|
|
|
|
// FinishTime via car telemetry
|
|
func (v *Provider) FinishTime() (time.Time, error) {
|
|
res, err := v.telemetryG()
|
|
if len(res.Battery) == 0 {
|
|
return time.Time{}, api.ErrNotAvailable
|
|
}
|
|
return time.Now().Add(time.Duration(res.Battery[0].EstimatedChargingTimeToFullMinutes) * time.Minute), err
|
|
}
|