Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/cli. OpenStatus CLI www.openstatus.dev
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180package run
import ( "context" "encoding/json" "errors" "fmt" "io" "net/http" "os" "strings" "sync" "time"
"github.com/fatih/color" "github.com/logrusorgru/aurora/v4" "github.com/openstatusHQ/cli/internal/config" "github.com/openstatusHQ/cli/internal/monitors" "github.com/rodaine/table" "github.com/urfave/cli/v3")
func MonitorTrigger(httpClient *http.Client, apiKey string, monitorId string) error {
if monitorId == "" { return fmt.Errorf("Monitor ID is required") }
url := fmt.Sprintf("https://api.openstatus.dev/v1/monitor/%s/run", monitorId)
httpClient.Timeout = 2 * time.Minute
payload := strings.NewReader("{}")
req, err := http.NewRequest("POST", url, payload) if err != nil { return err } req.Header.Add("x-openstatus-key", apiKey) res, err := httpClient.Do(req) if err != nil { return err }
if res.StatusCode != http.StatusOK { return fmt.Errorf("Failed to trigger monitor test") }
defer res.Body.Close() body, _ := io.ReadAll(res.Body)
var result []json.RawMessage err = json.Unmarshal(body, &result) if err != nil { return err } fmt.Println(aurora.Bold(fmt.Sprintf("Monitor: %s", monitorId))) headerFmt := color.New(color.FgGreen, color.Underline).SprintfFunc() columnFmt := color.New(color.FgYellow).SprintfFunc()
tbl := table.New("Region", "Latency (ms)", "Status") tbl.WithHeaderFormatter(headerFmt).WithFirstColumnFormatter(columnFmt)
var inError bool for _, r := range result { result := monitors.RunResult{}
if err := json.Unmarshal(r, &result); err != nil {
return fmt.Errorf("unable to unmarshal : %w", err) } switch result.JobType { case "tcp": { var tcp monitors.TCPRunResult if err := json.Unmarshal(r, &result); err != nil { return fmt.Errorf("unable to unmarshal : %w", err) } if tcp.ErrorMessage != "" { inError = true tbl.AddRow(result.Region, result.Latency, color.RedString("❌")) continue }
} case "http": { var http monitors.HTTPRunResult if err := json.Unmarshal(r, &http); err != nil { fmt.Println("Error", err) return fmt.Errorf("unable to unmarshal : %w", err) } if http.Error != "" { inError = true tbl.AddRow(result.Region, result.Latency, color.RedString("❌")) continue } } default: return fmt.Errorf("Unknown job type") }
tbl.AddRow(result.Region, result.Latency, color.GreenString("✔"))
} tbl.Print()
if inError { fmt.Println(color.RedString("Some regions failed")) return fmt.Errorf("Some regions failed") } else { fmt.Println(color.GreenString("All regions passed")) } return nil}
func RunCmd() *cli.Command { runCmd := cli.Command{ Name: "run", Aliases: []string{"r"}, Usage: "Run your synthetics tests", UsageText: "openstatus run [options]", Description: "Run the synthetic tests defined in the config.openstatus.yaml", Action: func(ctx context.Context, cmd *cli.Command) error {
path := cmd.String("config") if path != "" { if _, err := os.Stat(path); errors.Is(err, os.ErrNotExist) { return cli.Exit("Config does not exist", 1) } }
conf, err := config.ReadConfig(path) if err != nil { return err } size := len(conf.Tests.Ids) ch := make(chan error, size)
fmt.Print("Tests are running\n\n")
var wg sync.WaitGroup
for _, id := range conf.Tests.Ids { wg.Add(1) go func(id int) { defer wg.Done() if err := MonitorTrigger(http.DefaultClient, cmd.String("access-token"), fmt.Sprintf("%d", id)); err != nil { ch <- err }
}(id) } wg.Wait() close(ch) // Close the channel when all workers have finished
if len(ch) > 0 { return cli.Exit("Some tests failed", 1) } return nil }, Flags: []cli.Flag{ &cli.StringFlag{ Name: "config", Usage: "The configuration file", DefaultText: "config.openstatus.yaml", Value: "config.openstatus.yaml", }, &cli.StringFlag{ Name: "access-token", Usage: "OpenStatus API Access Token", Aliases: []string{"t"}, Sources: cli.EnvVars("OPENSTATUS_API_TOKEN"), Required: true, }, }, } return &runCmd}