refactor: Move directory creation to the Store instantiation

dkron/agent.go

@@ -453,17 +453,6 @@ func (a *Agent) StartServer() {
 	}
 
 	if a.Store == nil {
-		dirExists, err := exists(a.config.DataDir)
-		if err != nil {
-			log.WithError(err).WithField("dir", a.config.DataDir).Fatal("Invalid Dir")
-		}
-		if !dirExists {
-			// Try to create the directory
-			err := os.Mkdir(a.config.DataDir, 0700)
-			if err != nil {
-				log.WithError(err).WithField("dir", a.config.DataDir).Fatal("Error Creating Dir")
-			}
-		}
 		s, err := NewStore(filepath.Join(a.config.DataDir, a.config.NodeName))
 		if err != nil {
 			log.WithError(err).Fatal("dkron: Error initializing store")

dkron/store.go

@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"os"
 	"sort"
 	"sync"
 	"time"
@@ -44,6 +45,18 @@ type JobOptions struct {
 
 // NewStore creates a new Storage instance.
 func NewStore(dir string) (*Store, error) {
+	dirExists, err := exists(dir)
+	if err != nil {
+		return nil, fmt.Errorf("Ivalid directory %s: %w", dir, err)
+	}
+	if !dirExists {
+		// Try to create the directory
+		err := os.Mkdir(dir, 0700)
+		if err != nil {
+			return nil, fmt.Errorf("Error creating directory %s: %w", dir, err)
+		}
+	}
+
 	opts := badger.DefaultOptions(dir).
 		WithLogger(log)