core/oc-lib
6
0
Fork 0
Code Issues 7 Pull Requests Packages Projects Releases Wiki Activity

casual http debug

Browse Source
This commit is contained in:
mr
2024-08-22 10:19:14 +02:00
parent fb80e05d6a
commit 4abf59a10d
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
models/peer/peer_cache.go
View File

@@ -4,6 +4,7 @@ import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
"regexp"
"strings" "strings"
"time" "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") { if strings.Contains(url, "localhost") || strings.Contains(url, "127.0.0.1") {
url = strings.ReplaceAll(url, "localhost", dt.API()) url = strings.ReplaceAll(url, "localhost", dt.API())
url = strings.ReplaceAll(url, "127.0.0.1", 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()) fmt.Println("LaunchPeerExecution AFT", url, dt.API())
var err error var err error

6
tools/api.go
View File

@@ -34,7 +34,8 @@ func (s State) String() string {
"some things boils in here, i'm probably a teapot", "dead"}[s] "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) { func (a *API) GetState() (State, int, error) {
// Check if the database is up // Check if the database is up
@@ -78,6 +79,9 @@ func (a *API) CheckRemoteAPIs(urls []string) (State, int, error) {
return REDUCED_SERVICE, 200, err return REDUCED_SERVICE, 200, err
} }
json.Unmarshal(b, &resp) json.Unmarshal(b, &resp)
if resp.Data == nil {
return DEAD, 200, errors.New(url + " -> is DEAD")
}
if resp.Data.Code != 0 { if resp.Data.Code != 0 {
return REDUCED_SERVICE, 200, errors.New(url + " -> " + resp.Error) return REDUCED_SERVICE, 200, errors.New(url + " -> " + resp.Error)
} }