Merge pull request #275 from fastenhealth/nickmurray/add-postgres-db-…

…option

backend/pkg/config/config.go

@@ -30,6 +30,7 @@ func (c *configuration) Init() error {
 	c.SetDefault("web.allow_unsafe_endpoints", false)
 
 	c.SetDefault("web.src.frontend.path", "/opt/fasten/web")
+	c.SetDefault("database.type", "sqlite")
 	c.SetDefault("database.location", "/opt/fasten/db/fasten.db")
 	c.SetDefault("cache.location", "/opt/fasten/cache/")
 

backend/pkg/constants.go

@@ -5,6 +5,8 @@ type BackgroundJobStatus string
 type BackgroundJobType string
 type BackgroundJobSchedule string
 
+type DatabaseRepositoryType string
+
 const (
 	ResourceListPageSize int = 20
 
@@ -36,4 +38,7 @@ const (
 	BackgroundJobScheduleWeekly   BackgroundJobSchedule = "WEEKLY"
 	BackgroundJobScheduleBiWeekly BackgroundJobSchedule = "BIWEEKLY"
 	BackgroundJobScheduleMonthly  BackgroundJobSchedule = "MONTHLY"
+
+	DatabaseRepositoryTypeSqlite   DatabaseRepositoryType = "sqlite"
+	DatabaseRepositoryTypePostgres DatabaseRepositoryType = "postgres"
 )

backend/pkg/database/factory.go

@@ -0,0 +1,20 @@
+package database
+
+import (
+	"github.com/fastenhealth/fasten-onprem/backend/pkg"
+	"github.com/fastenhealth/fasten-onprem/backend/pkg/config"
+	"github.com/fastenhealth/fasten-onprem/backend/pkg/errors"
+	"github.com/fastenhealth/fasten-onprem/backend/pkg/event_bus"
+	"github.com/sirupsen/logrus"
+)
+
+func NewRepository(appConfig config.Interface, globalLogger logrus.FieldLogger, eventBus event_bus.Interface) (DatabaseRepository, error) {
+	switch pkg.DatabaseRepositoryType(appConfig.GetString("database.type")) {
+	case pkg.DatabaseRepositoryTypeSqlite:
+		return newSqliteRepository(appConfig, globalLogger, eventBus)
+	case pkg.DatabaseRepositoryTypePostgres:
+		return newPostgresRepository(appConfig, globalLogger, eventBus)
+	default:
+		return nil, errors.DatabaseTypeNotSupportedError(appConfig.GetString("database.type"))
+	}
+}