129 lines
3 KiB
Go
129 lines
3 KiB
Go
package cmd
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"maps"
|
|
"net"
|
|
"os"
|
|
"regexp"
|
|
"slices"
|
|
"strings"
|
|
|
|
"github.com/evcc-io/evcc/cmd/shutdown"
|
|
"github.com/evcc-io/evcc/util"
|
|
"gopkg.in/yaml.v3"
|
|
)
|
|
|
|
// parseLogLevels parses --log area:level[,...] switch into levels per log area
|
|
func parseLogLevels() {
|
|
levels := viper.GetStringMapString("levels")
|
|
if levels == nil {
|
|
levels = make(map[string]string)
|
|
}
|
|
|
|
var level string
|
|
for _, kv := range strings.Split(viper.GetString("log"), ",") {
|
|
areaLevel := strings.SplitN(kv, ":", 2)
|
|
if len(areaLevel) == 1 {
|
|
level = areaLevel[0]
|
|
} else {
|
|
levels[areaLevel[0]] = areaLevel[1]
|
|
}
|
|
}
|
|
|
|
util.LogLevel(level, levels)
|
|
}
|
|
|
|
// unwrap converts a wrapped error into slice of strings
|
|
func unwrap(err error) (res []string) {
|
|
for err != nil {
|
|
inner := errors.Unwrap(err)
|
|
if inner == nil {
|
|
res = append(res, err.Error())
|
|
} else {
|
|
cur := strings.TrimSuffix(err.Error(), ": "+inner.Error())
|
|
cur = strings.TrimSuffix(cur, inner.Error())
|
|
res = append(res, strings.TrimSpace(cur))
|
|
}
|
|
err = inner
|
|
}
|
|
return
|
|
}
|
|
|
|
var redactSecrets = []string{
|
|
"mac", // infrastructure
|
|
"sponsortoken", "plant", // global settings
|
|
"apikey", "user", "password", "pin", // users
|
|
"token", "access", "refresh", "accesstoken", "refreshtoken", // tokens, including template variations
|
|
"ain", "secret", "serial", "deviceid", "machineid", "idtag", // devices
|
|
"app", "chats", "recipients", // push messaging
|
|
"vin", // vehicles
|
|
"lat", "lon", "zip", // solar forecast
|
|
}
|
|
|
|
// redact redacts a configuration string
|
|
func redact(src string) string {
|
|
return regexp.
|
|
MustCompile(fmt.Sprintf(`(?i)\b(%s)\b.*?:.*`, strings.Join(redactSecrets, "|"))).
|
|
ReplaceAllString(src, "$1: *****")
|
|
}
|
|
|
|
func redactMap(src map[string]any) map[string]any {
|
|
res := maps.Clone(src)
|
|
for k := range res {
|
|
if slices.Contains(redactSecrets, k) {
|
|
res[k] = "*****"
|
|
}
|
|
}
|
|
|
|
return res
|
|
}
|
|
|
|
// fatal logs a fatal error and runs shutdown functions before terminating
|
|
func fatal(err error) {
|
|
log.FATAL.Println(err)
|
|
<-shutdownDoneC()
|
|
os.Exit(1)
|
|
}
|
|
|
|
// shutdownDoneC returns a channel that closes when shutdown has completed
|
|
func shutdownDoneC() <-chan struct{} {
|
|
doneC := make(chan struct{})
|
|
go shutdown.Cleanup(doneC)
|
|
return doneC
|
|
}
|
|
|
|
func wrapFatalError(err error) error {
|
|
if err == nil {
|
|
return nil
|
|
}
|
|
|
|
var opErr *net.OpError
|
|
var pathErr *os.PathError
|
|
|
|
switch {
|
|
case errors.As(err, &opErr):
|
|
if opErr.Op == "listen" && strings.Contains(opErr.Error(), "address already in use") {
|
|
err = fmt.Errorf("could not open port- check that evcc is not already running (%w)", err)
|
|
}
|
|
|
|
case errors.As(err, &pathErr):
|
|
if pathErr.Op == "remove" && strings.Contains(pathErr.Error(), "operation not permitted") {
|
|
err = fmt.Errorf("could not remove file- check that evcc is not already running (%w)", err)
|
|
}
|
|
}
|
|
|
|
return &FatalError{err}
|
|
}
|
|
|
|
func customDevice(other map[string]any) (map[string]any, error) {
|
|
customYaml, ok := other["yaml"].(string)
|
|
if !ok {
|
|
return other, nil
|
|
}
|
|
|
|
var res map[string]any
|
|
err := yaml.Unmarshal([]byte(customYaml), &res)
|
|
return res, err
|
|
}
|