Function buildTaskBridgeNotificationSubscriptionRequest

internal/cli/task.go:910–938

(
	input taskNotificationSubscribeInput,
)

}

func buildTaskBridgeNotificationSubscriptionRequest(
	input taskNotificationSubscribeInput,
) (*TaskBridgeNotificationSubscriptionRequest, error) {
	scope := bridgepkg.Scope(strings.TrimSpace(input.ScopeRaw)).Normalize()
	if err := scope.Validate(); err != nil {
		return nil, fmt.Errorf("cli: invalid notification scope: %w", err)
	}
	mode := bridgepkg.DeliveryMode(input.DeliveryModeRaw).Normalize()
	if err := mode.Validate(); err != nil {
		return nil, fmt.Errorf("cli: invalid delivery mode: %w", err)
	}
	request := TaskBridgeNotificationSubscriptionRequest{
		SubscriptionID:   strings.TrimSpace(input.SubscriptionID),
		BridgeInstanceID: strings.TrimSpace(input.BridgeInstanceID),
		Scope:            scope,
		WorkspaceID:      strings.TrimSpace(input.WorkspaceID),
		PeerID:           strings.TrimSpace(input.PeerID),
		ThreadID:         strings.TrimSpace(input.ThreadID),
		GroupID:          strings.TrimSpace(input.GroupID),
		DeliveryMode:     mode,
	}
	if err := bridgepkg.ValidateScopeWorkspaceID(request.Scope, request.WorkspaceID); err != nil {
		return nil, fmt.Errorf("cli: invalid notification scope: %w", err)
	}
	if strings.TrimSpace(request.PeerID) == "" && strings.TrimSpace(request.GroupID) == "" {
		return nil, errors.New("cli: notification subscription requires --peer or --group")
	}
	return &request, nil
}

func buildTaskBridgeNotificationSubscriptionListQuery(
	bridgeInstanceID string,