extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2024-12-24 23:59:50 +01:00
Code Issues Packages Projects Releases Wiki Activity

hackery

Browse Source
This commit is contained in:
Michael Quigley 2023-02-24 09:21:07 -05:00
parent e68de29302
commit ac4b0bf6c9
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
controller/usageAgent.go
View File

@ -12,17 +12,19 @@ import (
"github.com/openziti/fabric/event" "github.com/openziti/fabric/event"
"github.com/openziti/fabric/pb/mgmt_pb" "github.com/openziti/fabric/pb/mgmt_pb"
"github.com/openziti/identity" "github.com/openziti/identity"
"github.com/openziti/sdk-golang/ziti/constants"
"github.com/pkg/errors" "github.com/pkg/errors"
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
"io" "io"
"net/http" "net/http"
"net/url"
"time" "time"
) )
type usageAgent struct{} type usageAgent struct{}
func RunUsageAgent(cfg *Config) error { func RunUsageAgent(cfg *Config) error {
wsUrl := "wss://127.0.0.1:1280/ws-api" wsUrl := "wss://127.0.0.1:1280/fabric/v1/ws-api"
caCerts, err := rest_util.GetControllerWellKnownCas(cfg.Ziti.ApiEndpoint) caCerts, err := rest_util.GetControllerWellKnownCas(cfg.Ziti.ApiEndpoint)
if err != nil { if err != nil {
@ -33,6 +35,17 @@ func RunUsageAgent(cfg *Config) error {
caPool.AddCert(ca) caPool.AddCert(ca)
} }
authenticator := rest_util.NewAuthenticatorUpdb(cfg.Ziti.Username, cfg.Ziti.Password)
authenticator.RootCas = caPool
ctrlUrl, err := url.Parse(cfg.Ziti.ApiEndpoint)
if err != nil {
return err
}
apiSession, err := authenticator.Authenticate(ctrlUrl)
if err != nil {
return err
}
dialer := &websocket.Dialer{ dialer := &websocket.Dialer{
TLSClientConfig: &tls.Config{ TLSClientConfig: &tls.Config{
RootCAs: caPool, RootCAs: caPool,
@ -40,7 +53,7 @@ func RunUsageAgent(cfg *Config) error {
HandshakeTimeout: 5 * time.Second, HandshakeTimeout: 5 * time.Second,
} }
conn, resp, err := dialer.Dial(wsUrl, http.Header{}) conn, resp, err := dialer.Dial(wsUrl, http.Header{constants.ZitiSession: []string{*apiSession.Token}})
if err != nil { if err != nil {
if resp != nil { if resp != nil {
if body, rerr := io.ReadAll(resp.Body); rerr == nil { if body, rerr := io.ReadAll(resp.Body); rerr == nil {