From 4abf59a10d97232e9b16e2ce36a58d49d853df4c Mon Sep 17 00:00:00 2001 From: mr Date: Thu, 22 Aug 2024 10:19:14 +0200 Subject: [PATCH] casual http debug --- models/peer/peer_cache.go | 3 +++ tools/api.go | 6 +++++- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/models/peer/peer_cache.go b/models/peer/peer_cache.go index 2eb15af..39dd957 100644 --- a/models/peer/peer_cache.go +++ b/models/peer/peer_cache.go @@ -4,6 +4,7 @@ import ( "encoding/json" "errors" "fmt" + "regexp" "strings" "time" @@ -74,6 +75,8 @@ func (p *PeerCache) LaunchPeerExecution(peerID string, isMySelf bool, dataID str if strings.Contains(url, "localhost") || strings.Contains(url, "127.0.0.1") { url = strings.ReplaceAll(url, "localhost", dt.API()) url = strings.ReplaceAll(url, "127.0.0.1", dt.API()) + r := regexp.MustCompile("(:[0-9]{2,4})") + r.ReplaceAllString(url, ":8080") } fmt.Println("LaunchPeerExecution AFT", url, dt.API()) var err error diff --git a/tools/api.go b/tools/api.go index 1ad17b0..effb463 100644 --- a/tools/api.go +++ b/tools/api.go @@ -34,7 +34,8 @@ func (s State) String() string { "some things boils in here, i'm probably a teapot", "dead"}[s] } -type API struct{} +type API struct { +} func (a *API) GetState() (State, int, error) { // Check if the database is up @@ -78,6 +79,9 @@ func (a *API) CheckRemoteAPIs(urls []string) (State, int, error) { return REDUCED_SERVICE, 200, err } json.Unmarshal(b, &resp) + if resp.Data == nil { + return DEAD, 200, errors.New(url + " -> is DEAD") + } if resp.Data.Code != 0 { return REDUCED_SERVICE, 200, errors.New(url + " -> " + resp.Error) }