diff options
Diffstat (limited to 'pkg/vpn/bonafide/eip_service.go')
| -rw-r--r-- | pkg/vpn/bonafide/eip_service.go | 24 |
1 files changed, 21 insertions, 3 deletions
diff --git a/pkg/vpn/bonafide/eip_service.go b/pkg/vpn/bonafide/eip_service.go index c097e8a..148b052 100644 --- a/pkg/vpn/bonafide/eip_service.go +++ b/pkg/vpn/bonafide/eip_service.go @@ -23,6 +23,7 @@ type eipService struct { Gateways []gatewayV3 Locations map[string]location OpenvpnConfiguration openvpnConfig `json:"openvpn_configuration"` + auth string defaultGateway string } @@ -65,6 +66,22 @@ type transportV3 struct { Options map[string]string } +func (b *Bonafide) setupAuthentication(i interface{}) { + switch i.(type) { + case eipService: + switch auth := b.eip.auth; auth { + case "anon": + // Do nothing, we're set on initialization. + case "sip": + b.auth = &SipAuthentication{b} + default: + log.Printf("BUG: unknown authentication method %s", auth) + } + case eipServiceV1: + // Do nothing, no auth on v1. + } +} + func (b *Bonafide) fetchEipJSON() error { resp, err := b.client.Post(eip3API, "", nil) for err != nil { @@ -80,24 +97,25 @@ func (b *Bonafide) fetchEipJSON() error { case 404: buf := make([]byte, 128) resp.Body.Read(buf) - log.Printf("Error fetching eip v3 json: %s", buf) + log.Printf("Error fetching eip v3 json") resp, err = b.client.Post(eip1API, "", nil) if err != nil { return err } defer resp.Body.Close() if resp.StatusCode != 200 { - return fmt.Errorf("get eip json has failed with status: %s", resp.Status) + return fmt.Errorf("Get eip json has failed with status: %s", resp.Status) } b.eip, err = decodeEIP1(resp.Body) default: - return fmt.Errorf("get eip json has failed with status: %s", resp.Status) + return fmt.Errorf("Get eip json has failed with status: %s", resp.Status) } if err != nil { return err } + b.setupAuthentication(b.eip) b.sortGateways() return nil } |