Function redeliverManyEventStreamCmd

internal/cli/event_streams.go:729–792

(cli *cli)

}

func redeliverManyEventStreamCmd(cli *cli) *cobra.Command {
	var inputs struct {
		StreamID  string
		EventType string
		From      string
		To        string
	}

	cmd := &cobra.Command{
		Use:   "redeliver-many [stream-id]",
		Args:  cobra.MaximumNArgs(1),
		Short: "Bulk retry failed event deliveries using filters",
		Long: "Retry multiple failed event deliveries for a given event stream. \n" +
			"You can filter by event type and date range. \n" +
			"All filters are combined using AND logic. \n" +
			"If no filters are passed, all failed events are retried",
		Example: `  auth0 event-streams redeliver-many
  auth0 event-streams redeliver-many <stream-id>
  auth0 event-streams redeliver-many <stream-id> --type=user.created,user.deleted --from=-2d`,
		RunE: func(cmd *cobra.Command, args []string) error {
			if len(args) >= 1 {
				inputs.StreamID = args[0]
			}
			if inputs.StreamID == "" {
				if err := eventStreamID.Pick(cmd, &inputs.StreamID, cli.eventStreamPickerOptions); err != nil {
					return err
				}
			}

			var req management.BulkRedeliverRequest

			if inputs.EventType != "" {
				types := strings.Split(inputs.EventType, ",")
				req.EventTypes = &types
			}

			if inputs.From != "" {
				fromDate, err := parseFlexibleDate(inputs.From)
				if err != nil {
					return fmt.Errorf("invalid --from date: %w", err)
				}
				req.DateFrom = &fromDate
			}

			if inputs.To != "" {
				toDate, err := parseFlexibleDate(inputs.To)
				if err != nil {
					return fmt.Errorf("invalid --to date: %w", err)
				}
				req.DateTo = &toDate
			}

			return ansi.Spinner("Bulk redelivering events...", func() error {
				return cli.api.EventStream.RedeliverMany(cmd.Context(), inputs.StreamID, &req)
			})
		},
	}