-
Notifications
You must be signed in to change notification settings - Fork 20
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
918242c
commit b719c35
Showing
3 changed files
with
240 additions
and
76 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -5,6 +5,8 @@ | |
| ### Changes | ||
|
|
||
| - remove **runstatus** commands | ||
| - **status** command shows new status page | ||
|
|
||
|
|
||
|
|
||
| ## 1.71.2 | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,190 @@ | ||
| package status | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "fmt" | ||
| "net/http" | ||
| "sort" | ||
| "time" | ||
| ) | ||
|
|
||
| // https://www.statuspal.io/api-docs | ||
| const ( | ||
| statusPalURL = "https://statuspal.eu/api/v1/status_pages/" | ||
| statusContentPage = "application/json; charset=utf-8" | ||
| dateLayout = "2006-01-02T15:04:05" | ||
| IncidentTypeScheduled = "scheduled" | ||
| ) | ||
|
|
||
| // https://www.statuspal.io/api-docs#tag/Status/operation/getStatusPageStatus | ||
| type StatusPalStatus struct { | ||
| // Services: all the (parent) services of the StatusPage with the current incident type | ||
| Services Services `json:"services"` | ||
|
|
||
| // Maintenances only contains the future scheduled maintenances | ||
| // Ongoing maintenances are in Incidents | ||
| // Incidents | ||
| Incidents []Incident `json:"incidents"` | ||
| } | ||
|
|
||
| // Get the status of global services (status of global or zones, no details of impacted services) | ||
| func (s StatusPalStatus) GetStatusByZone() ([][]string, error) { | ||
| global := make([][]string, len(s.Services)) | ||
| for _, svc := range s.Services { | ||
| state := svc.getIncidentType() | ||
| global = append(global, []string{*svc.Name, state}) | ||
| } | ||
| return global, nil | ||
| } | ||
|
|
||
| func (s StatusPalStatus) GetIncidents() ([][]string, [][]string, error) { | ||
| var incidents IncidentsDetails | ||
| var maintenances IncidentsDetails | ||
|
|
||
| services := s.Services | ||
| // In Incidents, we have maintenances and incidents currently taking place | ||
| // We need to show them in different tables | ||
| for _, event := range s.Incidents { | ||
| // Get all the services impacted by the incident (name and id) | ||
| // Child and parent are all mixed, we need to rebuild the dependency | ||
| for _, impacted := range event.Services { | ||
| if services.isParentService(*impacted.Id) { | ||
| continue | ||
| } | ||
| svcName, err := services.getServiceNamebyId(*impacted.Id) | ||
| if err != nil { | ||
| return nil, nil, err | ||
| } | ||
| started, err := time.Parse(dateLayout, *event.StartsAt) | ||
| if err != nil { | ||
| return nil, nil, err | ||
| } | ||
| startTimeUTC := started.Format(time.RFC822) | ||
| eventDetails := []string{svcName, *event.Title} | ||
| if *event.Type == IncidentTypeScheduled { | ||
| eventDetails = append(eventDetails, "scheduled at "+startTimeUTC) | ||
| maintenances = append(maintenances, eventDetails) | ||
| } else { | ||
|
|
||
| eventDetails = append(eventDetails, fmt.Sprint(*event.Type), "since "+startTimeUTC) | ||
| incidents = append(incidents, eventDetails) | ||
| } | ||
| } | ||
| } | ||
| // Sort by zones | ||
| sort.Sort(incidents) | ||
| sort.Sort(maintenances) | ||
| return incidents, maintenances, nil | ||
| } | ||
|
|
||
| // A service can contains several child services | ||
| // In our case: | ||
| // - Parent services = Global and all the zones | ||
| // - Child services = products available in a zone or globally | ||
| type Service struct { | ||
| Id *int `json:"id,omitempty"` | ||
| Name *string `json:"name,omitempty"` | ||
|
|
||
| // The type of the current incident: | ||
| // * `major` - A minor incident is currently taking place. | ||
| // * `minor` - A major incident is currently taking place. | ||
| // * `scheduled` - A scheduled maintenance is currently taking place. | ||
| // * null - No incident is taking place. | ||
| IncidentType *string `json:"current_incident_type,omitempty"` | ||
|
|
||
| // Each product available in the zone | ||
| Children Services `json:"children,omitempty"` | ||
| } | ||
|
|
||
| func (s *Service) getIncidentType() string { | ||
| if s.IncidentType == nil { | ||
| return "operational" | ||
| } | ||
| switch *s.IncidentType { | ||
| case IncidentTypeScheduled: | ||
| return "scheduled maintenance" | ||
| default: | ||
| return fmt.Sprint(*s.IncidentType) | ||
| } | ||
| } | ||
|
|
||
| type Incident struct { | ||
| Id *int `json:"id,omitempty"` | ||
| Title *string `json:"title,omitempty"` | ||
| // The time at which the incident/maintenance started(UTC). | ||
| StartsAt *string `json:"starts_at"` | ||
| // Type of current incident (major, minor, scheduled) | ||
| Type *string `json:"type"` | ||
| // Services impacted (only id and name) | ||
| Services Services `json:"services"` | ||
| } | ||
|
|
||
| type Services []Service | ||
|
|
||
| // We have 2 levels of services, check if a service is a parent | ||
| func (s Services) isParentService(id int) bool { | ||
| for _, service := range s { | ||
| if service.Id != nil && *service.Id == id { | ||
| return true | ||
| } | ||
| } | ||
| return false | ||
|
|
||
| } | ||
|
|
||
| // Return the Zone and the impacted service = fullname (parent svc + child svc) | ||
| func (s Services) getServiceNamebyId(id int) (string, error) { | ||
| // For all zones / global services | ||
| for _, parentService := range s { | ||
| // id provided is a parent service, return the name | ||
| if *parentService.Id == id { | ||
| return *parentService.Name, nil | ||
| } | ||
| // Try to find the Service Id in the child services | ||
| for _, childService := range parentService.Children { | ||
| // In this case, we returen the Parent and the Child names | ||
| if *childService.Id == id { | ||
| return *parentService.Name + " " + *childService.Name, nil | ||
| } | ||
| } | ||
| } | ||
|
|
||
| return "", fmt.Errorf("Service ID %d not found", id) | ||
| } | ||
|
|
||
| // Details of incident: zone, service, description, start time and type | ||
| type IncidentsDetails [][]string | ||
|
|
||
| // Implement Sort interface | ||
| func (t IncidentsDetails) Less(i, j int) bool { | ||
| return t[i][0] < t[j][0] | ||
| } | ||
| func (t IncidentsDetails) Len() int { | ||
| return len(t) | ||
| } | ||
| func (t IncidentsDetails) Swap(i, j int) { | ||
| t[i], t[j] = t[j], t[i] | ||
| } | ||
|
|
||
| // Get the status of a status page | ||
| func GetStatusPage(subdomain string) (*StatusPalStatus, error) { | ||
| url := statusPalURL + subdomain + "/status" | ||
| resp, err := http.Get(url) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| defer resp.Body.Close() | ||
|
|
||
| contentType := resp.Header.Get("content-type") | ||
| if contentType != statusContentPage { | ||
| return nil, fmt.Errorf("status page content type expected %q, but got %q", statusContentPage, contentType) | ||
| } | ||
|
|
||
| response := &StatusPalStatus{} | ||
| if err := json.NewDecoder(resp.Body).Decode(response); err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return response, nil | ||
| } |