update pgbouncer config when execute cluster provision for external clusters (#1103)

* add pgbouncer update ini for external cluster provision

* [CLD-9031] Extend clusterStore interface to update pgbouncer configmap

Author: andrleite

internal/provisioner/eks_provisioner.go

@@ -29,6 +29,8 @@ const EKSProvisionerType = "eks"
 
 type clusterUpdateStore interface {
 	UpdateCluster(cluster *model.Cluster) error
+	GetMultitenantDatabases(filter *model.MultitenantDatabaseFilter) ([]*model.MultitenantDatabase, error)
+	GetLogicalDatabases(filter *model.LogicalDatabaseFilter) ([]*model.LogicalDatabase, error)
 }
 
 // EKSProvisioner provisions clusters using AWS EKS.

internal/provisioner/external_provisioner.go

@@ -10,7 +10,9 @@ import (
 	"os"
 	"path/filepath"
 	"strings"
+	"time"
 
+	"github.com/mattermost/mattermost-cloud/internal/provisioner/pgbouncer"
 	"github.com/mattermost/mattermost-cloud/internal/provisioner/utility"
 	"github.com/mattermost/mattermost-cloud/internal/store"
 	"github.com/mattermost/mattermost-cloud/internal/supervisor"
@@ -119,10 +121,22 @@ func (provisioner *ExternalProvisioner) ProvisionCluster(cluster *model.Cluster)
 	if cluster.HasAWSInfrastructure() {
 		logger.Info("Provisioning resources for AWS infrastructure")
 
+		logger.Info("Deploying PgBouncer manifests")
 		err = utility.DeployPgbouncerManifests(k8sClient, logger)
 		if err != nil {
 			return errors.Wrap(err, "failed to deploy pgbouncer manifests")
 		}
+
+		vpc := cluster.VpcID()
+		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		defer cancel()
+		logger.Info("Updating PgBouncer ConfigMap")
+
+		err = pgbouncer.UpdatePGBouncerConfigMap(ctx, vpc, provisioner.clusterUpdateStore, cluster.PgBouncerConfig, k8sClient, logger)
+		if err != nil {
+			return errors.Wrap(err, "failed to update configmap for pgbouncer-configmap")
+		}
+		logger.Info("PgBouncer ConfigMap updated successfully")
 	}
 
 	return nil