refactor: directly return error where sufficient (#2855)

pull/2860/head^2
Clément Michaud 2022-02-09 23:07:53 +01:00 committed by GitHub
parent 8fc48476c6
commit 5d4003c291
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 9 additions and 29 deletions

View File

@ -120,7 +120,7 @@ func doStartupChecks(config *schema.Configuration, providers *middlewares.Provid
} }
} }
func doStartupCheck(logger *logrus.Logger, name string, provider models.StartupCheck, disabled bool) (err error) { func doStartupCheck(logger *logrus.Logger, name string, provider models.StartupCheck, disabled bool) error {
if disabled { if disabled {
logger.Debugf("%s provider: startup check skipped as it is disabled", name) logger.Debugf("%s provider: startup check skipped as it is disabled", name)
return nil return nil
@ -130,9 +130,5 @@ func doStartupCheck(logger *logrus.Logger, name string, provider models.StartupC
return fmt.Errorf("unrecognized provider or it is not configured properly") return fmt.Errorf("unrecognized provider or it is not configured properly")
} }
if err = provider.StartupCheck(); err != nil { return provider.StartupCheck()
return err
}
return nil
} }

View File

@ -33,11 +33,9 @@ func storagePersistentPreRunE(cmd *cobra.Command, _ []string) (err error) {
sources = append(sources, configuration.NewYAMLFileSource(configFile)) sources = append(sources, configuration.NewYAMLFileSource(configFile))
} }
} else { } else if _, err := os.Stat(configs[0]); err == nil {
if _, err := os.Stat(configs[0]); err == nil {
sources = append(sources, configuration.NewYAMLFileSource(configs[0])) sources = append(sources, configuration.NewYAMLFileSource(configs[0]))
} }
}
mapping := map[string]string{ mapping := map[string]string{
"encryption-key": "storage.encryption_key", "encryption-key": "storage.encryption_key",

View File

@ -38,22 +38,12 @@ func (n *FileNotifier) StartupCheck() (err error) {
} }
} }
if err := os.WriteFile(n.path, []byte(""), fileNotifierMode); err != nil { return os.WriteFile(n.path, []byte(""), fileNotifierMode)
return err
}
return nil
} }
// Send send a identity verification link to a user. // Send send a identity verification link to a user.
func (n *FileNotifier) Send(recipient, subject, body, _ string) error { func (n *FileNotifier) Send(recipient, subject, body, _ string) error {
content := fmt.Sprintf("Date: %s\nRecipient: %s\nSubject: %s\nBody: %s", time.Now(), recipient, subject, body) content := fmt.Sprintf("Date: %s\nRecipient: %s\nSubject: %s\nBody: %s", time.Now(), recipient, subject, body)
err := os.WriteFile(n.path, []byte(content), fileNotifierMode) return os.WriteFile(n.path, []byte(content), fileNotifierMode)
if err != nil {
return err
}
return nil
} }

View File

@ -243,11 +243,7 @@ func (n *SMTPNotifier) StartupCheck() (err error) {
return err return err
} }
if err := n.client.Reset(); err != nil { return n.client.Reset()
return err
}
return nil
} }
// Send is used to send an email to a recipient. // Send is used to send an email to a recipient.

View File

@ -54,7 +54,7 @@ func (rs *RodSession) collectScreenshot(err error, page *rod.Page) {
build := os.Getenv("BUILDKITE_BUILD_NUMBER") build := os.Getenv("BUILDKITE_BUILD_NUMBER")
suite := strings.ToLower(os.Getenv("SUITE")) suite := strings.ToLower(os.Getenv("SUITE"))
job := os.Getenv("BUILDKITE_JOB_ID") job := os.Getenv("BUILDKITE_JOB_ID")
path := filepath.Join(fmt.Sprintf("%s/%s/%s/%s", base, build, suite, job)) //nolint: gocritic path := filepath.Join(base, build, suite, job)
if err := os.MkdirAll(path, 0755); err != nil { if err := os.MkdirAll(path, 0755); err != nil {
log.Fatal(err) log.Fatal(err)