(cmd *cobra.Command, cli *cli, streamID string)
| 887 | } |
| 888 | |
| 889 | func promptForDeliveryIDs(cmd *cobra.Command, cli *cli, streamID string) ([]string, error) { |
| 890 | deliveries, err := fetchRecentDeliveries(cmd, cli, streamID) |
| 891 | if err != nil { |
| 892 | return nil, fmt.Errorf("failed to fetch deliveries: %w", err) |
| 893 | } |
| 894 | if len(deliveries) == 0 { |
| 895 | return nil, fmt.Errorf("no deliveries found for stream %q", streamID) |
| 896 | } |
| 897 | |
| 898 | labelToID := make(map[string]string) |
| 899 | var labels []string |
| 900 | for _, d := range deliveries { |
| 901 | label := fmt.Sprintf("%s (%s) - %s - %d", d.GetEventType(), d.GetStatus(), d.GetID(), len(d.Attempts)) |
| 902 | labelToID[label] = d.GetID() |
| 903 | labels = append(labels, label) |
| 904 | } |
| 905 | |
| 906 | var selectedLabels []string |
| 907 | if err := prompt.AskMultiSelect("Select deliveries to redeliver", &selectedLabels, labels...); err != nil { |
| 908 | return nil, err |
| 909 | } |
| 910 | |
| 911 | var selectedIDs []string |
| 912 | for _, label := range selectedLabels { |
| 913 | selectedIDs = append(selectedIDs, labelToID[label]) |
| 914 | } |
| 915 | |
| 916 | return selectedIDs, nil |
| 917 | } |
no test coverage detected