Function redeliverEventStreamCmd

internal/cli/event_streams.go:675–727

(cli *cli)

}

func redeliverEventStreamCmd(cli *cli) *cobra.Command {
	var inputs struct {
		StreamID    string
		DeliveryIDs []string
	}

	cmd := &cobra.Command{
		Use:   "redeliver [stream-id] [comma-separated-delivery-ids]",
		Args:  cobra.MaximumNArgs(2),
		Short: "Retry one or more event deliveries for a given stream",
		Long: "Retry one or more failed event deliveries for a given event stream. \n" +
			"If no delivery IDs are provided, you'll be prompted " +
			"to select from recent failed deliveries.",
		Example: `  auth0 event-streams redeliver
  auth0 event-streams redeliver <stream-id>
  auth0 event-streams redeliver <stream-id> evt_abc123,evt_def456`,
		RunE: func(cmd *cobra.Command, args []string) error {
			if len(args) >= 1 {
				inputs.StreamID = args[0]
			}
			if len(args) == 2 {
				inputs.DeliveryIDs = strings.Split(args[1], ",")
			}

			if inputs.StreamID == "" {
				if err := eventStreamID.Pick(cmd, &inputs.StreamID, cli.eventStreamPickerOptions); err != nil {
					return err
				}
			}

			if len(inputs.DeliveryIDs) == 0 {
				selectedIDs, err := promptForDeliveryIDs(cmd, cli, inputs.StreamID)
				if err != nil {
					return err
				}
				inputs.DeliveryIDs = selectedIDs
			}

			for _, id := range inputs.DeliveryIDs {
				err := ansi.Spinner(fmt.Sprintf("Redelivering %s...", ansi.Faint(id)), func() error {
					return cli.api.EventStream.Redeliver(cmd.Context(), inputs.StreamID, id)
				})

				if err != nil {
					cli.renderer.Errorf("%s Failed to redeliver %s: %v\n", ansi.Red("✘"), ansi.Red(id), err)
				}
			}
			return nil
		},
	}

	return cmd
}

func redeliverManyEventStreamCmd(cli *cli) *cobra.Command {
	var inputs struct {