Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/cli. OpenStatus CLI www.openstatus.dev
cli cli-app synthetic-monitoring
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374package monitors_test
import ( "bytes" "context" "encoding/json" "io" "net/http" "testing"
"github.com/openstatusHQ/cli/internal/config" "github.com/openstatusHQ/cli/internal/monitors")
func Test_CreateMonitor(t *testing.T) { t.Parallel()
t.Run("Create HTTP monitor successfully", func(t *testing.T) { // Connect RPC response format body := `{"monitor":{"id":"123","name":"Test Monitor","url":"https://example.com","periodicity":"PERIODICITY_10M","method":"HTTP_METHOD_GET","regions":["REGION_FLY_IAD","REGION_FLY_AMS"],"active":true}}` r := io.NopCloser(bytes.NewReader([]byte(body)))
interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { if req.Header.Get("x-openstatus-key") != "test-api-key" { t.Errorf("Expected x-openstatus-key header, got %s", req.Header.Get("x-openstatus-key")) } return &http.Response{ StatusCode: http.StatusOK, Body: r, Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "Test Monitor", Active: true, Frequency: config.The10M, Kind: config.HTTP, Regions: []config.Region{config.Iad, config.Ams}, Request: config.Request{ URL: "https://example.com", Method: config.Get, }, }
result, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err != nil { t.Fatalf("Expected no error, got %v", err) }
if result.ID != 123 { t.Errorf("Expected ID 123, got %d", result.ID) } if result.Name != "Test Monitor" { t.Errorf("Expected name 'Test Monitor', got %s", result.Name) } })
t.Run("Create TCP monitor successfully", func(t *testing.T) { // Connect RPC response format for TCP monitor body := `{"monitor":{"id":"456","name":"TCP Monitor","uri":"example.com:443","periodicity":"PERIODICITY_5M","regions":["REGION_FLY_IAD"],"active":true}}` r := io.NopCloser(bytes.NewReader([]byte(body)))
interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { if req.Header.Get("x-openstatus-key") != "test-api-key" { t.Errorf("Expected x-openstatus-key header, got %s", req.Header.Get("x-openstatus-key")) } return &http.Response{ StatusCode: http.StatusOK, Body: r, Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "TCP Monitor", Active: true, Frequency: config.The5M, Kind: config.TCP, Regions: []config.Region{config.Iad}, Request: config.Request{ Host: "example.com", Port: 443, }, }
result, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err != nil { t.Fatalf("Expected no error, got %v", err) }
if result.ID != 456 { t.Errorf("Expected ID 456, got %d", result.ID) } if result.Name != "TCP Monitor" { t.Errorf("Expected name 'TCP Monitor', got %s", result.Name) } if result.JobType != "tcp" { t.Errorf("Expected jobType 'tcp', got %s", result.JobType) } })
t.Run("Create ICMP monitor successfully", func(t *testing.T) { body := `{"monitor":{"id":"789","name":"ICMP Monitor","uri":"8.8.8.8","periodicity":"PERIODICITY_5M","regions":["REGION_FLY_IAD"],"active":true}}` r := io.NopCloser(bytes.NewReader([]byte(body)))
interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { return &http.Response{ StatusCode: http.StatusOK, Body: r, Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "ICMP Monitor", Active: true, Frequency: config.The5M, Kind: config.ICMP, Regions: []config.Region{config.Iad}, Request: config.Request{ Host: "8.8.8.8", }, }
result, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err != nil { t.Fatalf("Expected no error, got %v", err) }
if result.ID != 789 { t.Errorf("Expected ID 789, got %d", result.ID) } if result.Name != "ICMP Monitor" { t.Errorf("Expected name 'ICMP Monitor', got %s", result.Name) } if result.URL != "8.8.8.8" { t.Errorf("Expected URL '8.8.8.8', got %s", result.URL) } if result.JobType != "icmp" { t.Errorf("Expected jobType 'icmp', got %s", result.JobType) } })
t.Run("Create ICMP monitor fails without host", func(t *testing.T) { monitor := config.Monitor{ Name: "ICMP Monitor", Kind: config.ICMP, Active: true, Request: config.Request{ Host: "", }, }
_, err := monitors.CreateMonitor(context.Background(), &http.Client{}, "test-api-key", monitor) if err == nil { t.Error("Expected error for missing ICMP host, got nil") } })
t.Run("Create monitor fails with non-200 status", func(t *testing.T) { body := `{"code":"internal","message":"internal error"}` r := io.NopCloser(bytes.NewReader([]byte(body)))
interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { return &http.Response{ StatusCode: http.StatusInternalServerError, Body: r, Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "Test Monitor", Kind: config.HTTP, }
_, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err == nil { t.Error("Expected error for non-200 status, got nil") } })
t.Run("Create HTTP monitor returns correct Monitor struct", func(t *testing.T) { // Connect RPC response format with all fields body := `{"monitor":{"id":"789","name":"Full Monitor","description":"Test description","url":"https://test.example.com","periodicity":"PERIODICITY_5M","method":"HTTP_METHOD_POST","regions":["REGION_FLY_IAD","REGION_FLY_AMS","REGION_FLY_SYD"],"active":true,"public":true,"timeout":30000,"retry":2}}` r := io.NopCloser(bytes.NewReader([]byte(body)))
interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { return &http.Response{ StatusCode: http.StatusOK, Body: r, Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "Full Monitor", Kind: config.HTTP, }
result, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err != nil { t.Fatalf("Expected no error, got %v", err) }
if result.ID != 789 { t.Errorf("Expected ID 789, got %d", result.ID) } if result.Name != "Full Monitor" { t.Errorf("Expected name 'Full Monitor', got %s", result.Name) } if result.Description != "Test description" { t.Errorf("Expected description 'Test description', got %s", result.Description) } if result.URL != "https://test.example.com" { t.Errorf("Expected URL 'https://test.example.com', got %s", result.URL) } if result.Periodicity != "5m" { t.Errorf("Expected periodicity '5m', got %s", result.Periodicity) } if result.Method != http.MethodPost { t.Errorf("Expected method 'POST', got %s", result.Method) } if result.Active != true { t.Errorf("Expected active true, got %v", result.Active) } if result.Public != true { t.Errorf("Expected public true, got %v", result.Public) } if result.Timeout != 30000 { t.Errorf("Expected timeout 30000, got %d", result.Timeout) } if result.Retry != 2 { t.Errorf("Expected retry 2, got %d", result.Retry) } if result.JobType != "http" { t.Errorf("Expected jobType 'http', got %s", result.JobType) } })
t.Run("Unsupported monitor kind returns error", func(t *testing.T) { interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { return &http.Response{ StatusCode: http.StatusOK, Body: io.NopCloser(bytes.NewReader([]byte(`{}`))), Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "Test Monitor", Kind: "unsupported", }
_, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err == nil { t.Error("Expected error for unsupported monitor kind, got nil") } })}
func boolPtr(b bool) *bool { return &b}
func Test_CreateMonitor_FollowRedirects(t *testing.T) { t.Parallel()
t.Run("followRedirects false is sent in request body", func(t *testing.T) { var capturedBody map[string]json.RawMessage
interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { bodyBytes, _ := io.ReadAll(req.Body) json.Unmarshal(bodyBytes, &capturedBody)
respBody := `{"monitor":{"id":"100","name":"Redirect Monitor","url":"https://example.com","periodicity":"PERIODICITY_10M","method":"HTTP_METHOD_GET","regions":["REGION_FLY_IAD"],"active":true,"followRedirects":false}}` return &http.Response{ StatusCode: http.StatusOK, Body: io.NopCloser(bytes.NewReader([]byte(respBody))), Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "Redirect Monitor", Active: true, Frequency: config.The10M, Kind: config.HTTP, Regions: []config.Region{config.Iad}, Request: config.Request{ URL: "https://example.com", Method: config.Get, FollowRedirects: boolPtr(false), }, }
_, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err != nil { t.Fatalf("Expected no error, got %v", err) }
var monitorPayload map[string]json.RawMessage json.Unmarshal(capturedBody["monitor"], &monitorPayload)
followRedirectsRaw, exists := monitorPayload["followRedirects"] if !exists { t.Fatal("Expected followRedirects to be present in request body") }
var followRedirects bool json.Unmarshal(followRedirectsRaw, &followRedirects) if followRedirects != false { t.Errorf("Expected followRedirects to be false, got %v", followRedirects) } })
t.Run("followRedirects nil is omitted from request body", func(t *testing.T) { var capturedBody map[string]json.RawMessage
interceptor := &interceptorHTTPClient{ f: func(req *http.Request) (*http.Response, error) { bodyBytes, _ := io.ReadAll(req.Body) json.Unmarshal(bodyBytes, &capturedBody)
respBody := `{"monitor":{"id":"101","name":"Default Monitor","url":"https://example.com","periodicity":"PERIODICITY_10M","method":"HTTP_METHOD_GET","regions":["REGION_FLY_IAD"],"active":true}}` return &http.Response{ StatusCode: http.StatusOK, Body: io.NopCloser(bytes.NewReader([]byte(respBody))), Header: http.Header{"Content-Type": []string{"application/json"}}, }, nil }, }
monitor := config.Monitor{ Name: "Default Monitor", Active: true, Frequency: config.The10M, Kind: config.HTTP, Regions: []config.Region{config.Iad}, Request: config.Request{ URL: "https://example.com", Method: config.Get, }, }
_, err := monitors.CreateMonitor(context.Background(), interceptor.GetHTTPClient(), "test-api-key", monitor) if err != nil { t.Fatalf("Expected no error, got %v", err) }
var monitorPayload map[string]json.RawMessage json.Unmarshal(capturedBody["monitor"], &monitorPayload)
if _, exists := monitorPayload["followRedirects"]; exists { t.Error("Expected followRedirects to be absent from request body when nil") } })}