Method Subscribe

tools/subscriptions/client.go:154–196

Subscribe implements the [Client.Subscribe] interface method. Empty subscriptions (aka. "") are ignored.

(subs ...string)

//
// Empty subscriptions (aka. "") are ignored.
func (c *DefaultClient) Subscribe(subs ...string) {
	c.mu.Lock()
	defer c.mu.Unlock()

	for _, s := range subs {
		if s == "" {
			continue // skip empty
		}

		// extract subscription options (if any)
		rawOptions := struct {
			// note: any instead of string to minimize the breaking changes with earlier versions
			Query   map[string]any `json:"query"`
			Headers map[string]any `json:"headers"`
		}{}
		u, err := url.Parse(s)
		if err == nil {
			raw := u.Query().Get(optionsParam)
			if raw != "" {
				json.Unmarshal([]byte(raw), &rawOptions)
			}
		}

		options := SubscriptionOptions{
			Query:   make(map[string]string, len(rawOptions.Query)),
			Headers: make(map[string]string, len(rawOptions.Headers)),
		}

		// normalize query
		// (currently only single string values are supported for consistency with the default routes handling)
		for k, v := range rawOptions.Query {
			options.Query[k] = cast.ToString(v)
		}

		// normalize headers name and values, eg. "X-Token" is converted to "x_token"
		// (currently only single string values are supported for consistency with the default routes handling)
		for k, v := range rawOptions.Headers {
			options.Headers[inflector.Snakecase(k)] = cast.ToString(v)
		}

		c.subscriptions[s] = options
	}
}

// Unsubscribe implements the [Client.Unsubscribe] interface method.
//