Stefan/evcc-io
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore: ensure http prefix

Browse source
This commit is contained in:
andig 2026-02-27 10:19:46 +01:00
parent 140331659e
commit e2f816520c
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
charger/warp-ws.go
View file

@ -149,11 +149,6 @@ func NewWarpWSFromConfig(ctx context.Context, other map[string]any) (api.Charger
func NewWarpWS(ctx context.Context, uri string, meterIndex uint, user, password string) (*WarpWS, error) {
log := util.NewLogger("warp-ws")
wsURI, err := parseURI(uri)
if err != nil {
return nil, err
}
client := request.NewHelper(log)
if user != "" {
@ -166,13 +161,18 @@ func NewWarpWS(ctx context.Context, uri string, meterIndex uint, user, password
w := &WarpWS{
Helper: client, log: log,
uri: uri,
uri: util.DefaultScheme(strings.TrimRight(uri, "/"), "http"),
meterIndex: meterIndex,
meterMap: map[int]int{},
metersValueIDsTopic: fmt.Sprintf("meters/%d/value_ids", meterIndex),
metersValuesTopic: fmt.Sprintf("meters/%d/values", meterIndex),
}
wsURI, err := parseURI(w.uri)
if err != nil {
return nil, err
}
go w.run(ctx, digest.Options{
URI: wsURI,
Username: user,
@ -256,7 +256,7 @@ func dialWebsocket(ctx context.Context, options digest.Options) (*websocket.Conn
// Returns parsed URI and hostname
func parseURI(uri string) (string, error) {
u, err := url.Parse(util.DefaultScheme(strings.TrimRight(uri, "/"), "http"))
u, err := url.Parse(uri)
if err != nil {
return "", err
}