Function statsEventStreamCmd

internal/cli/event_streams.go:794–853

(cli *cli)

}

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

	cmd := &cobra.Command{
		Use:   "stats [stream-id]",
		Short: "View delivery stats for an event stream",
		Long: `Retrieve metrics over time for a given event stream, including 
successful and failed delivery counts. Supports custom date range filtering.`,
		Args: cobra.MaximumNArgs(1),
		Example: `  auth0 event-streams stats
  auth0 event-streams stats <stream-id>
  auth0 event-streams stats <stream-id> --from 2025-07-15 --to 2025-07-29`,
		RunE: func(cmd *cobra.Command, args []string) error {
			if len(args) > 0 {
				inputs.StreamID = args[0]
			}

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

			var opts []management.RequestOption

			if inputs.From != "" {
				fromDate, err := parseFlexibleDate(inputs.From)
				if err != nil {
					return fmt.Errorf("invalid --from date: %w", err)
				}
				opts = append(opts, management.Parameter("date_from", fromDate))
			}

			if inputs.To != "" {
				toDate, err := parseFlexibleDate(inputs.To)
				if err != nil {
					return fmt.Errorf("invalid --to date: %w", err)
				}
				opts = append(opts, management.Parameter("date_to", toDate))
			}

			stats, err := cli.api.EventStream.Stats(cmd.Context(), inputs.StreamID, opts...)
			if err != nil {
				return fmt.Errorf("failed to fetch stats for stream %q: %w", inputs.StreamID, err)
			}
			cli.renderer.RenderEventStreamStats(stats)
			return nil
		},
	}

	cmd.Flags().StringVarP(&inputs.From, "from", "f", "", "Start date for stats (e.g. 2025-07-15, -3d)")
	cmd.Flags().StringVarP(&inputs.To, "to", "t", "", "End date for stats (e.g. 2025-07-29)")
	cmd.Flags().BoolVar(&cli.json, "json", false, "Output in json format.")