Function postgresStorageStorer

cmd/repositoryembedder/main.go:465–525

(c client.Client, s *v1alpha1.Storage, nsPrefix string)

}

func postgresStorageStorer(c client.Client, s *v1alpha1.Storage, nsPrefix string) (storage.Storer, *gorm.DB, error) {
	// get the password from the postgres secret
	secret := &corev1.Secret{}
	if err := c.Get(context.TODO(), client.ObjectKey{Name: s.Name, Namespace: s.Namespace}, secret); err != nil {
		return nil, nil, err
	}

	hostBytes, ok := secret.Data["host"]
	if !ok {
		return nil, nil, errors.New("host not found in secret")
	}
	host := string(hostBytes)

	usernameBytes, ok := secret.Data["username"]
	if !ok {
		return nil, nil, errors.New("username not found in secret")
	}
	username := string(usernameBytes)

	passwordBytes, ok := secret.Data["password"]
	if !ok {
		return nil, nil, errors.New("password not found in secret")
	}
	password := string(passwordBytes)

	databaseBytes, ok := secret.Data["database"]
	if !ok {
		return nil, nil, errors.New("database not found in secret")
	}
	db := string(databaseBytes)

	portBytes, ok := secret.Data["port"]
	if !ok {
		return nil, nil, errors.New("port not found in secret")
	}
	port := string(portBytes)

	sslModeBytes, ok := secret.Data["ssl_mode"]
	if !ok {
		return nil, nil, errors.New("ssl_mode not found in secret")
	}
	sslMode := string(sslModeBytes)

	timezoneBytes, ok := secret.Data["timezone"]
	if !ok {
		return nil, nil, errors.New("timezone not found in secret")
	}
	timezone := string(timezoneBytes)

	// Construct the DSN

	dsn := database.ConstructPostgresDSN(host, username, password, db, port, sslMode, timezone)

	dbClient, err := database.GetPostgresClient(dsn)
	if err != nil {
		return nil, nil, err
	}