1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
package services
import (
"encoding/json"
"io"
"net/http"
"os"
"path/filepath"
)
var (
ServiceList []Service
FallbackMap map[string]string
)
const (
baseRepoLink = "https://raw.githubusercontent.com/benbusby/farside/refs/heads/main/"
noCFServicesJSON = "services.json"
fullServicesJSON = "services-full.json"
)
type Service struct {
Type string `json:"type"`
TestURL string `json:"test_url,omitempty"`
Fallback string `json:"fallback,omimtempty"`
Instances []string `json:"instances"`
}
func GetServicesFileName() string {
cloudflareEnabled := false
cfEnabledVar := os.Getenv("FARSIDE_CF_ENABLED")
if len(cfEnabledVar) > 0 && cfEnabledVar == "1" {
cloudflareEnabled = true
}
servicesDir := os.Getenv("FARSIDE_SERVICES_DIR")
serviceJSON := filepath.Join(servicesDir, noCFServicesJSON)
if cloudflareEnabled {
serviceJSON = filepath.Join(servicesDir, fullServicesJSON)
}
return serviceJSON
}
func FetchServicesFile(serviceJSON string) ([]byte, error) {
servJSON := filepath.Base(serviceJSON)
resp, err := http.Get(baseRepoLink + servJSON)
if err != nil {
return nil, err
}
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
if err != nil {
return nil, err
}
err = os.WriteFile(serviceJSON, bodyBytes, 0666)
if err != nil {
return nil, err
}
return bodyBytes, nil
}
func InitializeServices() error {
serviceJSON := GetServicesFileName()
fileBytes, err := os.ReadFile(serviceJSON)
if err != nil {
fileBytes, err = FetchServicesFile(serviceJSON)
if err != nil {
return err
}
}
err = json.Unmarshal(fileBytes, &ServiceList)
if err != nil {
return err
}
FallbackMap = make(map[string]string)
for _, serviceElement := range ServiceList {
FallbackMap[serviceElement.Type] = serviceElement.Fallback
}
return nil
}
|
