Add builder for data store backends

Author: raynaudoe

connections/data_source.go

@@ -2,7 +2,6 @@ package connections
 
 import (
 	"context"
-	"fmt"
 	ds "github.com/Zondax/zindexer/connections/data_store"
 	"github.com/coinbase/rosetta-sdk-go/client"
 	"gorm.io/gorm"
@@ -70,13 +69,10 @@ func WithNodeClient(node interface{}) SourceOption {
 
 func WithDataStore(cfg ds.DataStoreConfig) SourceOption {
 	return func(w *DataSource) {
-		switch cfg.Service {
-		case ds.MinIOStorage:
-			c, _ := ds.NewMinioClient(cfg)
-			w.DataStore = ds.DataStoreClient{Client: c}
-			return
-		default:
-			panic(fmt.Errorf("DataStore with service %s, is not available", cfg.Service))
+		client, err := ds.NewDataStoreClient(cfg)
+		if err != nil {
+			panic(err)
 		}
+		w.DataStore = client
 	}
 }

connections/data_store/builder.go

@@ -0,0 +1,15 @@
+package data_store
+
+import (
+	"fmt"
+)
+
+func NewDataStoreClient(config DataStoreConfig) (DataStoreClient, error) {
+	switch config.Service {
+	case MinIOStorage:
+		client, err := newMinioClient(config)
+		return DataStoreClient{client}, err
+	default:
+		return DataStoreClient{}, fmt.Errorf("unrecognized data store service '%s'", config.Service)
+	}
+}

connections/data_store/minio.go

@@ -15,7 +15,7 @@ type MinioClient struct {
 	client *minio.Client
 }
 
-func NewMinioClient(config DataStoreConfig) (MinioClient, error) {
+func newMinioClient(config DataStoreConfig) (MinioClient, error) {
 	minioClient, err := minio.New(config.Url, &minio.Options{
 		Creds:  credentials.NewStaticV4(config.User, config.Password, ""),
 		Secure: true,