Add support for retries in uptimerobot (#625)

* Add support for retries in uptimerobot

* #minor bump

.gitignore

@@ -1,6 +1,5 @@
 vendor
 .idea
-\.vscode/
 out
 /IngressMonitorController
 /build/_output/bin/

.vscode/launch.json

@@ -0,0 +1,19 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Launch Package",
+            "type": "go",
+            "request": "launch",
+            "mode": "auto",
+            "program": "${workspaceFolder}/main.go",
+            "env": {
+              "OPERATOR_NAMESPACE": "stakater-ingress-monitor-controller"
+            }
+        }
+
+    ]
+}

pkg/http/httpClient.go

@@ -17,6 +17,7 @@ type HttpClient struct {
 type HttpResponse struct {
 	StatusCode int
 	Bytes      []byte
+	Header     http.Header
 }
 
 func CreateHttpClient(url string) *HttpClient {
@@ -53,7 +54,10 @@ func (client *HttpClient) RequestWithHeaders(requestType string, body []byte, he
 		log.Error(nil, "got empty response")
 	}
 
-	httpResponse := HttpResponse{StatusCode: response.StatusCode}
+	httpResponse := HttpResponse{
+		StatusCode: response.StatusCode,
+		Header:     response.Header,
+	}
 
 	defer response.Body.Close()
 	responseBytes, _ := io.ReadAll(response.Body)

pkg/monitors/uptimerobot/uptime-monitor.go

@@ -9,6 +9,7 @@ import (
 	"reflect"
 	"strconv"
 	"strings"
+	"time"
 
 	endpointmonitorv1alpha1 "github.com/stakater/IngressMonitorController/v2/api/v1alpha1"
 	"github.com/stakater/IngressMonitorController/v2/pkg/config"
@@ -67,6 +68,17 @@ func (monitor *UpTimeMonitorService) GetByName(name string) (*models.Monitor, er
 		}
 
 		return nil, nil
+	} else if response.StatusCode == Http.StatusTooManyRequests {
+		log.Info("Too many requests, Monitor waiting for timeout: " + name)
+		retryAfter := response.Header.Get("Retry-After")
+		if retryAfter != "" {
+			seconds, err := strconv.Atoi(retryAfter)
+			if err == nil {
+				time.Sleep(time.Duration(seconds) * time.Second)
+				return monitor.GetByName(name) // Retry after the specified delay
+
+			}
+		}
 	}
 
 	errorString := "GetByName Request failed for name: " + name + ". Status Code: " + strconv.Itoa(response.StatusCode)
@@ -152,6 +164,16 @@ func (monitor *UpTimeMonitorService) Add(m models.Monitor) {
 		} else {
 			log.Info("Monitor couldn't be added: " + m.Name + ". Error: " + f.Error.Message)
 		}
+	} else if response.StatusCode == Http.StatusTooManyRequests {
+		log.Info("Too many requests, Monitor waiting for timeout: " + m.Name)
+		retryAfter := response.Header.Get("Retry-After")
+		if retryAfter != "" {
+			seconds, err := strconv.Atoi(retryAfter)
+			if err == nil {
+				time.Sleep(time.Duration(seconds) * time.Second)
+				monitor.Add(m) // Retry after the specified delay
+			}
+		}
 	} else {
 		log.Info("AddMonitor Request failed. Status Code: " + strconv.Itoa(response.StatusCode))
 	}
@@ -178,6 +200,16 @@ func (monitor *UpTimeMonitorService) Update(m models.Monitor) {
 		} else {
 			log.Info("Monitor couldn't be updated: " + m.Name + ". Error: " + f.Error.Message)
 		}
+	} else if response.StatusCode == Http.StatusTooManyRequests {
+		log.Info("Too many requests, Monitor waiting for timeout: " + m.Name)
+		retryAfter := response.Header.Get("Retry-After")
+		if retryAfter != "" {
+			seconds, err := strconv.Atoi(retryAfter)
+			if err == nil {
+				time.Sleep(time.Duration(seconds) * time.Second)
+				monitor.Update(m) // Retry after the specified delay
+			}
+		}
 	} else {
 		log.Info("UpdateMonitor Request failed. Status Code: " + strconv.Itoa(response.StatusCode))
 	}