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

create serp (#3)

Browse Source
This commit is contained in:
Michael Quigley 2022-07-26 16:36:47 -04:00
parent 2d4299984e
commit f44599e9c2
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 26 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
controller/tunnel.go
View File

@ -2,10 +2,12 @@ package controller
import (
"context"
"fmt"
"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/service"
"github.com/openziti/edge/rest_management_api_client/service_edge_router_policy"
"github.com/openziti/edge/rest_model"
"github.com/sirupsen/logrus"
"time"
@ -25,6 +27,7 @@ func tunnelHandler(params tunnel.TunnelParams) middleware.Responder {
}
logrus.Infof("using service '%v'", serviceId)
// Service
svcConfigs := make([]string, 0)
svcEnc := true
svc := &rest_model.ServiceCreate{
@ -37,13 +40,35 @@ func tunnelHandler(params tunnel.TunnelParams) middleware.Responder {
Context: context.Background(),
}
svcParams.SetTimeout(30 * time.Second)
_, err = edge.Service.CreateService(svcParams, nil)
svcResp, err := edge.Service.CreateService(svcParams, nil)
if err != nil {
logrus.Error(err)
return middleware.Error(500, err.Error())
}
logrus.Infof("created service '%v'", serviceId)
// Service Edge Router Policy
serpErRoles := []string{"@tDnhG8jkG9"} // @linux-edge-router
serpSemantic := rest_model.SemanticAllOf
serpSvcRoles := []string{fmt.Sprintf("@%v", svcResp.Payload.Data.ID)}
serp := &rest_model.ServiceEdgeRouterPolicyCreate{
EdgeRouterRoles: serpErRoles,
Name: &serviceId,
Semantic: &serpSemantic,
ServiceRoles: serpSvcRoles,
}
serpParams := &service_edge_router_policy.CreateServiceEdgeRouterPolicyParams{
Policy: serp,
Context: context.Background(),
}
serpParams.SetTimeout(30 * time.Second)
_, err = edge.ServiceEdgeRouterPolicy.CreateServiceEdgeRouterPolicy(serpParams, nil)
if err != nil {
logrus.Error(err)
return middleware.Error(500, err.Error())
}
logrus.Infof("created service edge router policy '%v'", serviceId)
resp := tunnel.NewTunnelCreated().WithPayload(&rest_model_zrok.TunnelResponse{
Service: serviceId,
})