Function updateEventStreamCmd

internal/cli/event_streams.go:257–367

(cli *cli)

}

func updateEventStreamCmd(cli *cli) *cobra.Command {
	var inputs struct {
		ID            string
		Name          string
		Status        string
		Subscriptions []string
		Configuration string
	}

	cmd := &cobra.Command{
		Use:   "update",
		Args:  cobra.MaximumNArgs(1),
		Short: "Update an event stream",
		Long: "Update an event stream.\n\n" +
			"To update interactively, use `auth0 event-streams update` with no arguments.\n\n" +
			"To update non-interactively, supply the event id, name, status, subscriptions and " +
			"configuration through the flags. An event stream type CANNOT be updated hence the configuration " +
			"should match the schema based on the type of event stream. Configuration for `eventbridge` streams " +
			"cannot be updated." +
			"Only deployed actions can be used for action configuration",
		Example: `  auth0 event-streams update <event-id>
  auth0 event-streams update <event-id> --name my-event-stream
  auth0 event-streams update <event-id> --name my-event-stream --status enabled
  auth0 event-streams update <event-id> --name my-event-stream --status enabled --subscriptions "user.created,user.updated"
  auth0 event-streams update <event-id> --name my-event-stream --status disabled --subscriptions "user.deleted" --configuration '{"aws_account_id":"325235643634","aws_region":"us-east-2"}'
  auth0 event-streams update <event-id> --name my-event-stream --status enabled --subscriptions "user.created" --configuration '{"webhook_endpoint":"https://my-new-webhook.net","webhook_authorization":{"method":"bearer","token":"0909090909"}}'
  auth0 event-streams create <event-id> --name my-event-stream --subscriptions "user.updated" --configuration '{"action_id":"b053e4ca-8b14-4233-b615-bd3bdb353977"}'
  auth0 event-streams update <event-id> -n my-event-stream --status enabled -s "user.created" -c '{"webhook_endpoint":"https://my-new-webhook.net","webhook_authorization":{"method":"bearer","token":"987654321"}}`,
		RunE: func(cmd *cobra.Command, args []string) error {
			if len(args) > 0 {
				inputs.ID = args[0]
			} else {
				if err := eventStreamID.Pick(cmd, &inputs.ID, cli.eventStreamPickerOptions); err != nil {
					return err
				}
			}

			var oldEventStream *management.EventStream
			err := ansi.Waiting(func() (err error) {
				oldEventStream, err = cli.api.EventStream.Read(cmd.Context(), inputs.ID)
				return err
			})
			if err != nil {
				return fmt.Errorf("failed to read event stream with ID %q: %w", inputs.ID, err)
			}

			if e := eventStreamName.AskU(cmd, &inputs.Name, nil); e != nil {
				return e
			}
			if e := eventStreamStatus.AskU(cmd, &inputs.Status, nil); e != nil {
				return e
			}

			if e := eventStreamSubscriptions.AskManyU(cmd, &inputs.Subscriptions, nil); e != nil {
				return e
			}

			if e := eventStreamConfig.AskU(cmd, &inputs.Configuration, nil); e != nil {