fix linter warnings

Author: pashagolub

internal/config/config.go

@@ -53,22 +53,22 @@ func eachOption(g *flags.Group, f func(*flags.Group, *flags.Option)) {
 // VisitAll will execute fn() for all options found in command line.
 // Since we have only two level of nesting it's enough to use simplified group-prefixed name.
 func (cmdSet cmdArgSet) VisitAll(fn func(viper.FlagValue)) {
-	root := cmdSet.Parser.Group.Find("Application Options")
+	root := cmdSet.Group.Find("Application Options")
 	eachOption(root, func(g *flags.Group, o *flags.Option) {
 		name := o.LongName
 		if g != root {
-			name = g.ShortDescription + cmdSet.Parser.NamespaceDelimiter + name
+			name = g.ShortDescription + cmdSet.NamespaceDelimiter + name
 		}
 		fn(cmdArg{name, o})
 	})
 }
 
 func (cmdSet cmdArgSet) setDefaults(v *viper.Viper) {
-	eachOption(cmdSet.Parser.Group, func(g *flags.Group, o *flags.Option) {
+	eachOption(cmdSet.Group, func(g *flags.Group, o *flags.Option) {
 		if o.Default != nil && o.IsSetDefault() {
 			name := o.LongName
-			if g != cmdSet.Parser.Group {
-				name = g.ShortDescription + cmdSet.Parser.NamespaceDelimiter + name
+			if g != cmdSet.Group {
+				name = g.ShortDescription + cmdSet.NamespaceDelimiter + name
 			}
 			v.SetDefault(name, o.Value())
 		}
@@ -91,12 +91,12 @@ func NewConfig(writer io.Writer) (*CmdOptions, error) {
 		v.SetConfigFile(v.GetString("config"))
 		err := v.ReadInConfig() // Find and read the config file
 		if err != nil {         // Handle errors reading the config file
-			return nil, fmt.Errorf("Fatal error reading config file: %w", err)
+			return nil, fmt.Errorf("fatal error reading config file: %w", err)
 		}
 	}
 	conf := &CmdOptions{}
 	if err = v.Unmarshal(conf); err != nil {
-		return nil, fmt.Errorf("Fatal error unmarshalling config file: %w", err)
+		return nil, fmt.Errorf("fatal error unmarshalling config file: %w", err)
 	}
 	if conf.ClientName == "" {
 		buf := bytes.NewBufferString("The required flag `-c, --clientname` was not specified\n")

internal/pgengine/bootstrap.go

@@ -135,7 +135,7 @@ func NewDB(DB PgxPoolIface, args ...string) *PgEngine {
 }
 
 func quoteIdent(s string) string {
-	return `"` + strings.Replace(s, `"`, `""`, -1) + `"`
+	return `"` + strings.ReplaceAll(s, `"`, `""`) + `"`
 }
 
 // getPgxConnConfig transforms standard connestion string to pgx specific one with
@@ -230,7 +230,7 @@ func (pge *PgEngine) TryLockClientName(ctx context.Context, conn QueryRowIface)
 	if e := conn.QueryRow(ctx, sql, pge.Getsid(), pge.ClientName).Scan(&locked); e != nil {
 		return e
 	} else if !locked {
-		return errors.New("Cannot obtain lock for a session")
+		return errors.New("cannot obtain lock for a session")
 	}
 	return nil
 }
@@ -240,12 +240,12 @@ func (pge *PgEngine) ExecuteCustomScripts(ctx context.Context, filename ...strin
 	for _, f := range filename {
 		sql, err := os.ReadFile(f)
 		if err != nil {
-			pge.l.WithError(err).Error("Cannot read command file")
+			pge.l.WithError(err).Error("cannot read command file")
 			return err
 		}
 		pge.l.Info("Executing script: ", f)
 		if _, err = pge.ConfigDb.Exec(ctx, string(sql)); err != nil {
-			pge.l.WithError(err).Error("Script execution failed")
+			pge.l.WithError(err).Error("script execution failed")
 			return err
 		}
 		pge.l.Info("Script file executed: ", f)

internal/pgengine/notification.go

@@ -63,12 +63,12 @@ func (pge *PgEngine) NotificationHandler(c *pgconn.PgConn, n *pgconn.Notificatio
 				pge.chainSignalChan <- signal
 				return
 			}
-			err = fmt.Errorf("Unknown chain ID: %d", signal.ConfigID)
+			err = fmt.Errorf("unknown chain ID: %d", signal.ConfigID)
 		default:
-			err = fmt.Errorf("Unknown command: %s", signal.Command)
+			err = fmt.Errorf("unknown command: %s", signal.Command)
 		}
 	}
-	l.WithError(err).Error("Syntax error in payload")
+	l.WithError(err).Error("syntax error in payload")
 }
 
 // WaitForChainSignal returns configuration id from the notifications

internal/scheduler/chain.go

@@ -62,7 +62,7 @@ func (sch *Scheduler) processAsyncChain(ctx context.Context, chainSignal ChainSi
 	case "START":
 		var c Chain
 		if err := sch.pgengine.SelectChain(ctx, &c, chainSignal.ConfigID); err != nil {
-			return fmt.Errorf("Cannot start chain with ID: %d; %w", chainSignal.ConfigID, err)
+			return fmt.Errorf("cannot start chain with ID: %d; %w", chainSignal.ConfigID, err)
 		}
 		go func() {
 			select {
@@ -77,7 +77,7 @@ func (sch *Scheduler) processAsyncChain(ctx context.Context, chainSignal ChainSi
 			cancel()
 			return nil
 		}
-		return fmt.Errorf("Cannot stop chain with ID: %d. No running chain found", chainSignal.ConfigID)
+		return fmt.Errorf("cannot stop chain with ID: %d. No running chain found", chainSignal.ConfigID)
 	}
 	return nil
 }

internal/scheduler/shell.go

@@ -30,7 +30,7 @@ func (sch *Scheduler) ExecuteProgramCommand(ctx context.Context, command string,
 
 	command = strings.TrimSpace(command)
 	if command == "" {
-		return -1, "", errors.New("Program command cannot be empty")
+		return -1, "", errors.New("program command cannot be empty")
 	}
 	if len(paramValues) == 0 { //mimic empty param
 		paramValues = []string{""}
@@ -50,7 +50,7 @@ func (sch *Scheduler) ExecuteProgramCommand(ctx context.Context, command string,
 		if err != nil {
 			//check if we're dealing with an ExitError - i.e. return code other than 0
 			if exitError, ok := err.(*exec.ExitError); ok {
-				exitCode := exitError.ProcessState.ExitCode()
+				exitCode := exitError.ExitCode()
 				l.WithField("retcode", exitCode).Debug("Program run", cmdLine, exitCode)
 				return exitCode, stdout, exitError
 			}

internal/scheduler/tasks.go

@@ -117,7 +117,7 @@ func taskDownload(ctx context.Context, _ *Scheduler, paramValues string) (stdout
 		return "", err
 	}
 	if len(opts.FileUrls) == 0 {
-		return "", errors.New("Files to download are not specified")
+		return "", errors.New("files to download are not specified")
 	}
 	return tasks.DownloadUrls(ctx, opts.FileUrls, opts.DestPath, opts.WorkersNum)
 }