extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-06-21 10:17:51 +02:00
Code Issues Packages Projects Releases Wiki Activity

get zids from local identity configs (#131)

Browse Source
This commit is contained in:
Michael Quigley 2022-12-05 14:00:51 -05:00
parent e0a734be2e
commit d238809481
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
controller/bootstrap.go
View File

@ -4,9 +4,12 @@ import (
"context" "context"
"fmt" "fmt"
"github.com/openziti-test-kitchen/zrok/model" "github.com/openziti-test-kitchen/zrok/model"
"github.com/openziti-test-kitchen/zrok/zrokdir"
"github.com/openziti/edge/rest_management_api_client" "github.com/openziti/edge/rest_management_api_client"
"github.com/openziti/edge/rest_management_api_client/config" "github.com/openziti/edge/rest_management_api_client/config"
"github.com/openziti/edge/rest_model" "github.com/openziti/edge/rest_model"
"github.com/openziti/sdk-golang/ziti"
config2 "github.com/openziti/sdk-golang/ziti/config"
"github.com/pkg/errors" "github.com/pkg/errors"
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
"time" "time"
@ -15,6 +18,18 @@ import (
func Bootstrap(inCfg *Config) error { func Bootstrap(inCfg *Config) error {
cfg = inCfg cfg = inCfg
if ctrlZId, err := getIdentityId("ctrl"); err == nil {
logrus.Infof("controller identity: %v", ctrlZId)
} else {
panic(err)
}
if frontendZId, err := getIdentityId("frontend"); err == nil {
logrus.Infof("frontend identity: %v", frontendZId)
} else {
panic(err)
}
edge, err := edgeClient() edge, err := edgeClient()
if err != nil { if err != nil {
return err return err
@ -59,3 +74,20 @@ func assertZrokProxyConfigType(edge *rest_management_api_client.ZitiEdgeManageme
} }
return nil return nil
} }
func getIdentityId(identityName string) (string, error) {
zif, err := zrokdir.ZitiIdentityFile(identityName)
if err != nil {
return "", errors.Wrapf(err, "error opening identity '%v' from zrokdir: %v", identityName)
}
zcfg, err := config2.NewFromFile(zif)
if err != nil {
return "", errors.Wrapf(err, "error loading ziti config from file '%v': %v", zif)
}
zctx := ziti.NewContextWithConfig(zcfg)
id, err := zctx.GetCurrentIdentity()
if err != nil {
return "", errors.Wrapf(err, "error getting current identity from '%v': %v", zif)
}
return id.Id, nil
}