add error to PostgreSQLConnectionString, update region call

Author: mamundsen-specter

drivers/config.go

@@ -22,7 +22,7 @@ type DatabaseConfiguration struct {
 	IamAuth               bool   `json:"iam_auth"`
 }
 
-func (s DatabaseConfiguration) PostgreSQLConnectionString() string {
+func (s DatabaseConfiguration) PostgreSQLConnectionString() (string, error) {
 	if s.IamAuth {
 		slog.Info("loading default config for rds auth")
 		cfg, err := config.LoadDefaultConfig(context.TODO())
@@ -38,18 +38,18 @@ func (s DatabaseConfiguration) PostgreSQLConnectionString() string {
 
 		dbinput := strings.TrimSuffix(cname, ".") + ":5432"
 		slog.Info("requesting auth token")
-		authenticationToken, err := auth.BuildAuthToken(context.TODO(), dbinput, "us-east-1", s.Username, cfg.Credentials)
+		authenticationToken, err := auth.BuildAuthToken(context.TODO(), dbinput, cfg.Region, s.Username, cfg.Credentials)
 		if err != nil {
-			panic("failed to create authentication token: " + err.Error())
+			return "", fmt.Errorf("failed to create authentication token: %w", err.Error())
 		}
 		slog.Info("auth token successfully created")
 		encodedToken := url.QueryEscape(authenticationToken)
 
-		return fmt.Sprintf("postgresql://%s:%s@%s/%s", s.Username, encodedToken, dbinput, s.Database)
+		return fmt.Sprintf("postgresql://%s:%s@%s/%s", s.Username, encodedToken, dbinput, s.Database), nil
 	} else if s.Connection != "" {
-		return s.Connection
+		return s.Connection, nil
 	} else {
-		return fmt.Sprintf("postgresql://%s:%s@%s/%s", s.Username, s.Secret, s.Address, s.Database)
+		return fmt.Sprintf("postgresql://%s:%s@%s/%s", s.Username, s.Secret, s.Address, s.Database), nil
 	}
 }