Function showDeliveryCmd

internal/cli/event_streams.go:612–673

(cli *cli)

}

func showDeliveryCmd(cli *cli) *cobra.Command {
	var inputs struct {
		StreamID   string
		DeliveryID string
	}

	cmd := &cobra.Command{
		Use:   "show [stream-id] [delivery-id]",
		Args:  cobra.MaximumNArgs(2),
		Short: "Show details for a specific delivery",
		Long: "Displays metadata, attempts, and event payload for a specific \n" +
			"delivery associated with an event stream. \n" +
			"If stream ID or delivery ID is not provided, you will be " +
			"prompted to select them interactively.",
		Example: `  auth0 event-streams deliveries show
  auth0 event-streams deliveries show <stream-id>
  auth0 event-streams deliveries show <stream-id> <delivery-id>`,
		RunE: func(cmd *cobra.Command, args []string) error {
			if len(args) >= 1 {
				inputs.StreamID = args[0]
			}
			if len(args) == 2 {
				inputs.DeliveryID = args[1]
			}

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

			if inputs.DeliveryID == "" {
				deliveries, err := fetchRecentDeliveries(cmd, cli, inputs.StreamID)
				if err != nil {
					return fmt.Errorf("failed to retrieve deliveries: %w", err)
				}
				if len(deliveries) == 0 {
					return fmt.Errorf("no deliveries found for stream %q", inputs.StreamID)
				}

				currentIndex := auth0.Int(0)
				selectedDelivery := cli.renderer.EventDeliveryPrompt(deliveries, currentIndex)
				inputs.DeliveryID = selectedDelivery.GetID()
			}

			var delivery *management.EventDelivery
			if err := ansi.Waiting(func() (err error) {
				delivery, err = cli.api.EventStream.ReadDelivery(cmd.Context(), inputs.StreamID, inputs.DeliveryID)
				return err
			}); err != nil {
				return fmt.Errorf("failed to fetch delivery %q for stream %q: %w", inputs.DeliveryID, inputs.StreamID, err)
			}

			cli.renderer.ShowDelivery(delivery)
			return nil
		},
	}