Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/cli. OpenStatus CLI www.openstatus.dev
Something went wrong. Try again.
4.3 kB · 156 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157package statusreport
import ( "context" "fmt" "net/http" "os" "strings" "time"
status_reportv1 "buf.build/gen/go/openstatus/api/protocolbuffers/go/openstatus/status_report/v1" "buf.build/gen/go/openstatus/api/connectrpc/gosimple/openstatus/status_report/v1/status_reportv1connect" "github.com/openstatusHQ/cli/internal/auth" output "github.com/openstatusHQ/cli/internal/cli" "github.com/urfave/cli/v3")
func AddStatusReportUpdate(ctx context.Context, client status_reportv1connect.StatusReportServiceClient, reportId, status, message, date string, notify bool, s *output.Spinner) error { if reportId == "" { output.StopSpinner(s) fmt.Fprintln(os.Stderr, "Usage: openstatus status-report add-update <report-id> --status <status> --message <message>") fmt.Fprintln(os.Stderr, "") fmt.Fprintln(os.Stderr, "Example: openstatus sr add-update 12345 --status resolved --message \"Fix deployed\"") return fmt.Errorf("report ID is required") }
sdkStatus, err := statusToSDK(status) if err != nil { output.StopSpinner(s) return err }
req := &status_reportv1.AddStatusReportUpdateRequest{ StatusReportId: reportId, Status: sdkStatus, Message: message, }
if date != "" { req.SetDate(date) }
if notify { req.SetNotify(true) }
resp, err := client.AddStatusReportUpdate(ctx, req) output.StopSpinner(s) if err != nil { return output.FormatError(err, "status-report", reportId) }
report := resp.GetStatusReport() fmt.Printf("Status report %s updated to %s\n", report.GetId(), statusColor(statusToString(report.GetStatus())))
if status == "resolved" { fmt.Println("Report resolved.") }
return nil}
func AddStatusReportUpdateWithHTTPClient(ctx context.Context, httpClient *http.Client, apiKey string, reportId, status, message, date string, notify bool) error { client := NewStatusReportClientWithHTTPClient(httpClient, apiKey) return AddStatusReportUpdate(ctx, client, reportId, status, message, date, notify, nil)}
func GetStatusReportAddUpdateCmd() *cli.Command { return &cli.Command{ Name: "add-update", Usage: "Add an update to a status report", UsageText: "openstatus status-report add-update <ReportID> --status resolved --message \"Issue has been resolved\"", Flags: []cli.Flag{ &cli.StringFlag{ Name: "access-token", Usage: "OpenStatus API Access Token", Aliases: []string{"t"}, Sources: cli.EnvVars("OPENSTATUS_API_TOKEN"), }, &cli.StringFlag{ Name: "status", Usage: "New status (investigating, identified, monitoring, resolved)", }, &cli.StringFlag{ Name: "message", Usage: "Message describing what changed", }, &cli.StringFlag{ Name: "date", Usage: "Date for the update (RFC 3339 format, defaults to now)", }, &cli.BoolFlag{ Name: "notify", Usage: "Notify subscribers about this update", }, }, Action: func(ctx context.Context, cmd *cli.Command) error { apiKey, err := auth.ResolveAccessToken(cmd) if err != nil { return cli.Exit(err.Error(), 1) }
inputs := &addUpdateInputs{ ReportID: cmd.Args().Get(0), Status: cmd.String("status"), Message: cmd.String("message"), Notify: cmd.Bool("notify"), }
needsWizard := inputs.ReportID == "" || inputs.Status == "" || inputs.Message == ""
if needsWizard { if output.IsJSONOutput() || !output.IsStdinTerminal() { var missing []string if inputs.ReportID == "" { missing = append(missing, "<report-id>") } if inputs.Status == "" { missing = append(missing, "--status") } if inputs.Message == "" { missing = append(missing, "--message") } return cli.Exit(fmt.Sprintf("missing required arguments: %s", strings.Join(missing, ", ")), 1) } inputs, err = runAddUpdateWizard(ctx, apiKey, inputs) if err != nil { return cli.Exit(err.Error(), 1) } }
date := cmd.String("date") if date == "" { date = time.Now().UTC().Format(time.RFC3339) }
s := output.StartSpinner("Adding update...") client := NewStatusReportClient(apiKey) err = AddStatusReportUpdate( ctx, client, inputs.ReportID, inputs.Status, inputs.Message, date, inputs.Notify, s, ) if err != nil { return cli.Exit(err.Error(), 1) } return nil }, }}