Function parseConnectionString

pgserver/subscription_handler.go:113–147

parseConnectionString parses the given connection string and returns a ConnectionDetails.

(connStr string)

// parseConnectionString parses the given connection string and returns a ConnectionDetails.
func parseConnectionString(connStr string) (*ConnectionDetails, error) {
	details := &ConnectionDetails{}
	pairs := connectionRegex.FindAllStringSubmatch(connStr, -1)

	if pairs == nil {
		return nil, fmt.Errorf("no valid key-value pairs found in connection string")
	}

	for _, pair := range pairs {
		key := pair[1]
		value := pair[2]
		switch key {
		case "dbname":
			details.DBName = value
		case "host":
			details.Host = value
		case "port":
			details.Port = value
		case "user":
			details.User = value
		case "password":
			details.Password = value
		}
	}

	// Handle default values
	if details.DBName == "" {
		details.DBName = "postgres"
	}
	if details.Port == "" {
		details.Port = "5432"
	}

	return details, nil
}

// ToConnectionInfo Format SubscriptionConfig into a ConnectionInfo
func (config *SubscriptionConfig) ToConnectionInfo() string {