Function createLogStreamsCustomWebhookCmd

internal/cli/log_streams_http.go:49–162

(cli *cli)

)

func createLogStreamsCustomWebhookCmd(cli *cli) *cobra.Command {
	var inputs struct {
		name              string
		httpEndpoint      string
		httpContentType   string
		httpContentFormat string
		httpAuthorization string
		piiConfig         string
		filters           string
	}

	cmd := &cobra.Command{
		Use:   "http",
		Args:  cobra.NoArgs,
		Short: "Create a new Custom Webhook log stream",
		Long: "Specify a URL you'd like Auth0 to post events to.\n\n" +
			"To create interactively, use `auth0 logs streams create http` with no arguments.\n\n" +
			"To create non-interactively, supply the log stream name and other information through the flags.",
		Example: `  auth0 logs streams create http
  auth0 logs streams create http --name <name>
  auth0 logs streams create http --name <name> --endpoint <endpoint>
  auth0 logs streams create http --name <name> --endpoint <endpoint> --type <type>
  auth0 logs streams create http --name <name> --endpoint <endpoint> --type <type> --format <format>
  auth0 logs streams create http --name <name> --endpoint <endpoint> --type <type> --format <format> --filters '[{"type":"category","name":"auth.login.fail"},{"type":"category","name":"auth.signup.fail"}]'
  auth0 logs streams create http --name <name> --endpoint <endpoint> --type <type> --format <format> --pii-config '{"log_fields": ["first_name", "last_name"], "method": "hash", "algorithm": "xxhash"}''
  auth0 logs streams create http --name <name> --endpoint <endpoint> --type <type> --format <format> --authorization <authorization>
  auth0 logs streams create http -n <name> -e <endpoint> -t <type> -f <format> -a <authorization>
  auth0 logs streams create http -n mylogstream -e "https://example.com/webhook/logs" -t "application/json" -f "JSONLINES" -a "AKIAXXXXXXXXXXXXXXXX" --json
  auth0 logs streams create http -n mylogstream -e "https://example.com/webhook/logs" -t "application/json" -f "JSONLINES" -a "AKIAXXXXXXXXXXXXXXXX" --json-compact`,
		RunE: func(cmd *cobra.Command, args []string) error {
			if err := logStreamName.Ask(cmd, &inputs.name, nil); err != nil {
				return err
			}

			if err := httpEndpoint.Ask(cmd, &inputs.httpEndpoint, nil); err != nil {
				return err
			}

			if err := httpContentType.Ask(cmd, &inputs.httpContentType, nil); err != nil {
				return err
			}

			if err := httpContentFormat.Select(cmd, &inputs.httpContentFormat, httpContentFormatOptions, nil); err != nil {
				return err
			}

			if err := httpAuthorization.AskPassword(cmd, &inputs.httpAuthorization); err != nil {
				return err
			}

			var piiConfig *management.LogStreamPiiConfig
			if err := logStreamPIIConfig.Ask(cmd, &inputs.piiConfig, auth0.String("{}")); err != nil {
				return err
			}

			if inputs.piiConfig != "{}" {
				if err := json.Unmarshal([]byte(inputs.piiConfig), &piiConfig); err != nil {
					return fmt.Errorf("provider: %s credentials invalid JSON: %w", inputs.piiConfig, err)