140 lines
3.1 KiB
Go
140 lines
3.1 KiB
Go
package nissan
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/evcc-io/evcc/util"
|
|
"github.com/evcc-io/evcc/util/request"
|
|
"golang.org/x/oauth2"
|
|
)
|
|
|
|
// api constants
|
|
const (
|
|
CarAdapterBaseURL = "https://alliance-platform-caradapter-prod.apps.eu2.kamereon.io/car-adapter"
|
|
UserAdapterBaseURL = "https://alliance-platform-usersadapter-prod.apps.eu2.kamereon.io/user-adapter"
|
|
UserBaseURL = "https://nci-bff-web-prod.apps.eu2.kamereon.io/bff-web"
|
|
)
|
|
|
|
type API struct {
|
|
*request.Helper
|
|
}
|
|
|
|
func NewAPI(log *util.Logger, identity oauth2.TokenSource) *API {
|
|
v := &API{
|
|
Helper: request.NewHelper(log),
|
|
}
|
|
|
|
// api is unbelievably slow when retrieving status
|
|
v.Client.Timeout = 120 * time.Second
|
|
|
|
// replace client transport with authenticated transport
|
|
v.Client.Transport = &oauth2.Transport{
|
|
Source: identity,
|
|
Base: v.Client.Transport,
|
|
}
|
|
|
|
return v
|
|
}
|
|
|
|
func (v *API) Vehicles() ([]string, error) {
|
|
var user struct{ UserID string }
|
|
uri := fmt.Sprintf("%s/v1/users/current", UserAdapterBaseURL)
|
|
err := v.GetJSON(uri, &user)
|
|
|
|
var res Vehicles
|
|
if err == nil {
|
|
uri := fmt.Sprintf("%s/v5/users/%s/cars", UserBaseURL, user.UserID)
|
|
err = v.GetJSON(uri, &res)
|
|
}
|
|
|
|
var vehicles []string
|
|
if err == nil {
|
|
for _, v := range res.Data {
|
|
vehicles = append(vehicles, v.VIN)
|
|
}
|
|
}
|
|
|
|
return vehicles, err
|
|
}
|
|
|
|
// BatteryStatus provides battery api response
|
|
func (v *API) BatteryStatus(vin, version string) (StatusResponse, error) {
|
|
uri := fmt.Sprintf("%s/%s/cars/%s/battery-status", CarAdapterBaseURL, version, vin)
|
|
|
|
var res StatusResponse
|
|
err := v.GetJSON(uri, &res)
|
|
|
|
if err == nil {
|
|
res.Updated = time.Time{}
|
|
|
|
if version == "v1" && res.LastUpdateTime != nil {
|
|
res.Updated = res.LastUpdateTime.Time
|
|
}
|
|
|
|
if version == "v2" && res.Timestamp != nil {
|
|
res.Updated = time.Now()
|
|
}
|
|
}
|
|
|
|
return res, err
|
|
}
|
|
|
|
// RefreshRequest requests battery status refresh
|
|
func (v *API) RefreshRequest(vin, typ string) (ActionResponse, error) {
|
|
var res ActionResponse
|
|
uri := fmt.Sprintf("%s/v1/cars/%s/actions/refresh-battery-status", CarAdapterBaseURL, vin)
|
|
|
|
data := Request{
|
|
Data: Payload{
|
|
Type: typ,
|
|
},
|
|
}
|
|
|
|
req, err := request.New(http.MethodPost, uri, request.MarshalJSON(data), map[string]string{
|
|
"Content-Type": "application/vnd.api+json",
|
|
})
|
|
|
|
if err == nil {
|
|
err = v.DoJSON(req, &res)
|
|
}
|
|
|
|
return res, err
|
|
}
|
|
|
|
// more commands: https://github.com/TA2k/ioBroker.nissan/commit/0e32ab743af3cbecd756633e52e9baa869766c7d
|
|
// refresh-location
|
|
// wake-up-vehicle
|
|
|
|
type Action string
|
|
|
|
const (
|
|
ActionChargeStart Action = "start"
|
|
ActionChargeStop Action = "stop"
|
|
)
|
|
|
|
// ChargingAction provides actions/charging-start api response
|
|
func (v *API) ChargingAction(vin string, action Action) (ActionResponse, error) {
|
|
uri := fmt.Sprintf("%s/v1/cars/%s/actions/charging-start", CarAdapterBaseURL, vin)
|
|
|
|
data := Request{
|
|
Data: Payload{
|
|
Type: "ChargingStart",
|
|
Attributes: map[string]any{
|
|
"action": action,
|
|
},
|
|
},
|
|
}
|
|
|
|
req, err := request.New(http.MethodPost, uri, request.MarshalJSON(data), map[string]string{
|
|
"Content-Type": "application/vnd.api+json",
|
|
})
|
|
|
|
var res ActionResponse
|
|
if err == nil {
|
|
err = v.DoJSON(req, &res)
|
|
}
|
|
|
|
return res, err
|
|
}
|