// "sync" sub-command: sync data to remote hosts
-// Copyright (C) 2021 Simon Ruderich
+// Copyright (C) 2021-2022 Simon Ruderich
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
optionSshConfig := flag.String("sshconfig", "",
"`path` to ssh configuration file; used for tests")
- flag.CommandLine.Parse(args[2:])
+ flag.CommandLine.Parse(args[2:]) //nolint:errcheck
level, err := safcm.ParseLogLevel(*optionLog)
if err != nil {
loop := &frontend.Loop{
DebugConn: cfg.LogLevel >= safcm.LogDebug3,
LogEventFunc: func(x frontend.Event, failed *bool) {
- logEvent(x, cfg.LogLevel, isTTY, failed)
+ frontend.LogEvent(x, cfg.LogLevel, isTTY, failed)
},
SyncHostFunc: func(conn *rpc.Conn, host frontend.Host) error {
return host.(*Sync).Host(conn)
return res, nil
}
-func logEvent(x frontend.Event, level safcm.LogLevel, isTTY bool, failed *bool) {
- // We have multiple event sources so this is somewhat ugly.
- var prefix, data string
- var color frontend.Color
- if x.Error != nil {
- prefix = "[error]"
- data = x.Error.Error()
- color = frontend.ColorRed
- // We logged an error, tell the caller
- *failed = true
- } else if x.Log.Level != 0 {
- if level < x.Log.Level {
- return
- }
- // LogError and LogDebug3 should not occur here
- switch x.Log.Level {
- case safcm.LogInfo:
- prefix = "[info]"
- case safcm.LogVerbose:
- prefix = "[verbose]"
- case safcm.LogDebug:
- prefix = "[debug]"
- case safcm.LogDebug2:
- prefix = "[debug2]"
- default:
- prefix = fmt.Sprintf("[INVALID=%d]", x.Log.Level)
- color = frontend.ColorRed
- }
- data = x.Log.Text
- } else {
- switch x.ConnEvent.Type {
- case rpc.ConnEventStderr:
- prefix = "[stderr]"
- case rpc.ConnEventDebug:
- prefix = "[debug3]"
- case rpc.ConnEventUpload:
- if level < safcm.LogInfo {
- return
- }
- prefix = "[info]"
- x.ConnEvent.Data = "remote helper upload in progress"
- default:
- prefix = fmt.Sprintf("[INVALID=%d]", x.ConnEvent.Type)
- color = frontend.ColorRed
- }
- data = x.ConnEvent.Data
- }
-
- host := x.Host.Name()
- if color != 0 {
- host = frontend.ColorString(isTTY, color, host)
- }
- // Make sure to escape control characters to prevent terminal
- // injection attacks
- if !x.Escaped {
- data = frontend.EscapeControlCharacters(isTTY, data)
- }
- log.Printf("%-9s [%s] %s", prefix, host, data)
-}
-
func (s *Sync) Name() string {
return s.host.Name
}