extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2024-11-21 23:53:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

rough policies, just to wire things up (#3)

Browse Source
This commit is contained in:
Michael Quigley 2022-07-26 17:26:39 -04:00
parent 73718804e1
commit 7b7da0f6ac
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 22 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
controller/tunnel.go
View File

@ -6,6 +6,7 @@ import (
"github.com/go-openapi/runtime/middleware"
"github.com/openziti-test-kitchen/zrok/rest_model_zrok"
"github.com/openziti-test-kitchen/zrok/rest_server_zrok/operations/tunnel"
"github.com/openziti/edge/rest_management_api_client/edge_router_policy"
"github.com/openziti/edge/rest_management_api_client/service"
"github.com/openziti/edge/rest_management_api_client/service_edge_router_policy"
"github.com/openziti/edge/rest_management_api_client/service_policy"
@ -77,7 +78,6 @@ func tunnelHandler(params tunnel.TunnelParams) middleware.Responder {
// Service Edge Router Policy
serpErRoles := []string{"@tDnhG8jkG9"} // @linux-edge-router
serpSvcRoles := []string{fmt.Sprintf("@%v", svcResp.Payload.Data.ID)}
serp := &rest_model.ServiceEdgeRouterPolicyCreate{
EdgeRouterRoles: serpErRoles,
@ -97,6 +97,27 @@ func tunnelHandler(params tunnel.TunnelParams) middleware.Responder {
}
logrus.Infof("created service edge router policy '%v'", serviceId)
// Edge Router Policy
erpErRoles := []string{"@tDnhG8jkG9"} // @linux-edge-router
erpIdRoles := []string{fmt.Sprintf("@%v", params.Body.Identity)}
erp := &rest_model.EdgeRouterPolicyCreate{
EdgeRouterRoles: erpErRoles,
IdentityRoles: erpIdRoles,
Name: &serviceId,
Semantic: &semantic,
}
erpParams := &edge_router_policy.CreateEdgeRouterPolicyParams{
Policy: erp,
Context: context.Background(),
}
erpParams.SetTimeout(30 * time.Second)
_, err = edge.EdgeRouterPolicy.CreateEdgeRouterPolicy(erpParams, nil)
if err != nil {
logrus.Error(err)
return middleware.Error(500, err.Error())
}
logrus.Infof("created edge router policy '%v'", serviceId)
resp := tunnel.NewTunnelCreated().WithPayload(&rest_model_zrok.TunnelResponse{
Service: serviceId,
})