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
package guestnet
import (
"cmp"
"fmt"
"net/url"
"regexp"
"strings"
)
const (
EventsPath = "/v1/events"
RelayHost = "relay.localhost"
)
var (
bundleOnNetworkURL = regexp.MustCompile(`"guest_onnetwork_url"\s*:\s*"([^"]+)"`)
relayAddress = regexp.MustCompile(`(\d+\.\d+\.\d+\.\d+)\s+relay\.localhost`)
)
type RelayTarget struct {
URL string
Resolve string
}
func GuestOnNetworkURL(ingressURL string) (string, error) {
trimmed := strings.TrimRight(strings.TrimSpace(ingressURL), "/")
if trimmed == "" {
return "", fmt.Errorf("guestnet: no ingress URL")
}
u, err := url.Parse(trimmed)
if err != nil || u.Host == "" || (u.Scheme != "https" && u.Scheme != "http") {
return "", fmt.Errorf("guestnet: ingress URL %q is not an absolute http or https URL", ingressURL)
}
if u.User != nil || u.RawQuery != "" || u.Fragment != "" {
return "", fmt.Errorf("guestnet: ingress URL %q carries a user, query or fragment", ingressURL)
}
return trimmed + EventsPath, nil
}
func OnNetworkURLFromBundle(userData, fallback string) string {
if m := bundleOnNetworkURL.FindStringSubmatch(userData); m != nil {
return m[1]
}
url, err := GuestOnNetworkURL(fallback)
if err != nil {
return ""
}
return url
}
func RelayTargets(userData, fallback string) []RelayTarget {
target := OnNetworkURLFromBundle(userData, fallback)
targets := []RelayTarget{{URL: target}}
address, ok := RequesterRelayAddress(userData)
if !ok || target == "" {
return targets
}
u, err := url.Parse(target)
if err != nil || !strings.HasSuffix(u.Hostname(), "."+RelayHost) {
return targets
}
port := u.Port()
port = cmp.Or(port, "80")
targets = append(targets, RelayTarget{URL: target, Resolve: u.Hostname() + ":" + port + ":" + address})
return targets
}
func RequesterRelayAddress(userData string) (string, bool) {
m := relayAddress.FindStringSubmatch(userData)
if m == nil {
return "", false
}
return m[1], true
}
