posgres support

Author: github-actions[bot]

framework/configstore/config.go

@@ -11,6 +11,7 @@ type ConfigStoreType string
 // ConfigStoreTypeSQLite is the type of config store for SQLite.
 const (
 	ConfigStoreTypeSQLite ConfigStoreType = "sqlite"
+	ConfigStoreTypePostgres ConfigStoreType = "postgres"	
 )
 
 // Config represents the configuration for the config store.
@@ -51,7 +52,12 @@ func (c *Config) UnmarshalJSON(data []byte) error {
 			return fmt.Errorf("failed to unmarshal sqlite config: %w", err)
 		}
 		c.Config = &sqliteConfig
-
+	case ConfigStoreTypePostgres:
+		var postgresConfig PostgresConfig
+		if err := json.Unmarshal(temp.Config, &postgresConfig); err != nil {
+			return fmt.Errorf("failed to unmarshal postgres config: %w", err)
+		}
+		c.Config = &postgresConfig
 	default:
 		return fmt.Errorf("unknown config store type: %s", temp.Type)
 	}

framework/configstore/postgres.go

@@ -0,0 +1,40 @@
+package configstore
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/maximhq/bifrost/core/schemas"
+	"gorm.io/driver/postgres"
+	"gorm.io/gorm"
+)
+
+// PostgresConfig represents the configuration for a Postgres database.
+type PostgresConfig struct {
+	Host     string `json:"host"`
+	Port     string `json:"port"`
+	User     string `json:"user"`
+	Password string `json:"password"`
+	DBName   string `json:"db_name"`
+	SSLMode  string `json:"ssl_mode"`
+}
+
+// newPostgresConfigStore creates a new Postgres config store.
+func newPostgresConfigStore(ctx context.Context, config *PostgresConfig, logger schemas.Logger) (ConfigStore, error) {
+	db, err := gorm.Open(postgres.Open(fmt.Sprintf("host=%s port=%s user=%s password=%s dbname=%s sslmode=%s", config.Host, config.Port, config.User, config.Password, config.DBName, config.SSLMode)), &gorm.Config{})
+	if err != nil {
+		return nil, err
+	}
+	d := &RDBConfigStore{db: db, logger: logger}
+	// Run migrations
+	if err := triggerMigrations(ctx, db); err != nil {
+		// Closing the DB connection
+		if sqlDB, dbErr := db.DB(); dbErr == nil {
+			if closeErr := sqlDB.Close(); closeErr != nil {
+				logger.Error("failed to close DB connection: %v", closeErr)
+			}
+		}
+		return nil, err
+	}
+	return d, nil
+}