Improved error handling

Author: mariusoe

pkg/internal/git_api.go

@@ -1,6 +1,7 @@
 package internal
 
 import (
+	"errors"
 	"fmt"
 	"io/ioutil"
 	"time"
@@ -29,9 +30,12 @@ type GitApi struct {
 
 // NewGitApi creates a new NewGitApi instance
 func NewGitApi(gitUrl string, privateKeyFile string) *GitApi {
-	authenticator, err := createAuthenticator(privateKeyFile)
+	authenticator, err := createPublicKeys(privateKeyFile)
 	if err != nil {
-		log.Fatal("authentication failed", "error", err.Error())
+		log.WithFields(log.Fields{
+			"error":            err,
+			"private-key-file": privateKeyFile,
+		}).Fatal("Failed to load publiy key from the private key.")
 	}
 	inMemoryStore, inMemoryFileSystem := createInMemory()
 	gitApi := GitApi{gitUrl, authenticator, *inMemoryStore, inMemoryFileSystem, nil}
@@ -40,11 +44,13 @@ func NewGitApi(gitUrl string, privateKeyFile string) *GitApi {
 }
 
 // helper function to create the git authenticator
-func createAuthenticator(privateKeyFile string) (*ssh.PublicKeys, error) {
+func createPublicKeys(privateKeyFile string) (*ssh.PublicKeys, error) {
+	if privateKeyFile == "" {
+		return nil, errors.New("Private key must not be empty.")
+	}
 	// git authentication with ssh
 	authenticator, err := ssh.NewPublicKeysFromFile("git", privateKeyFile, "")
 	if err != nil {
-		log.Fatal("generate public keys failed", "error", err.Error())
 		return nil, err
 	}
 

pkg/internal/synchronizer.go

@@ -41,6 +41,13 @@ func NewSynchronizer(options SynchronizeOptions) *Synchronization {
 		options: options,
 	}
 
+	log.WithFields(log.Fields{
+		"job":              options.JobName,
+		"repository-url":   options.GitRepositoryUrl,
+		"private-key-file": options.PrivateKeyFile,
+		"grafana-url":      options.GrafanaUrl,
+	}).Info("Initialize synchronizer job.")
+
 	synchronization.grafanaApi = NewGrafanaApi(options.GrafanaUrl, options.GrafanaToken)
 	synchronization.gitApi = NewGitApi(options.GitRepositoryUrl, options.PrivateKeyFile)
 
@@ -56,10 +63,8 @@ type Synchronization struct {
 // Executes the synchronization using the configuration stored in this struct.
 func (s *Synchronization) Synchronize(dryRun bool) error {
 	log.WithFields(log.Fields{
-		"job":            s.options.JobName,
-		"dry-run":        strconv.FormatBool(dryRun),
-		"repository-url": s.options.GitRepositoryUrl,
-		"grafana-url":    s.options.GrafanaUrl,
+		"job":     s.options.JobName,
+		"dry-run": strconv.FormatBool(dryRun),
 	}).Info("Starting synchronization.")
 
 	// push dashboard into Git
@@ -78,6 +83,10 @@ func (s *Synchronization) Synchronize(dryRun bool) error {
 		}
 	}
 
+	log.WithFields(log.Fields{
+		"job": s.options.JobName,
+	}).Info("Job was successfully completed.")
+
 	return nil
 }