zrok/controller/share_private.go

40 lines
1.2 KiB
Go
Raw Normal View History

2022-11-22 21:31:02 +01:00
package controller
import (
"github.com/openziti-test-kitchen/zrok/model"
"github.com/openziti-test-kitchen/zrok/rest_server_zrok/operations/service"
"github.com/openziti/edge/rest_management_api_client"
)
type privateResourceAllocator struct{}
func newPrivateResourceAllocator() *privateResourceAllocator {
return &privateResourceAllocator{}
}
2022-11-30 18:10:00 +01:00
func (a *privateResourceAllocator) allocate(envZId, svcToken string, params service.ShareParams, edge *rest_management_api_client.ZitiEdgeManagement) (svcZId string, frontendEndpoints []string, err error) {
2022-11-22 21:31:02 +01:00
var authUsers []*model.AuthUser
for _, authUser := range params.Body.AuthUsers {
authUsers = append(authUsers, &model.AuthUser{authUser.Username, authUser.Password})
}
2022-11-30 18:10:00 +01:00
cfgId, err := createConfig(envZId, svcToken, params.Body.AuthScheme, authUsers, edge)
2022-11-22 21:31:02 +01:00
if err != nil {
return "", nil, err
}
2022-11-30 18:10:00 +01:00
svcZId, err = createService(envZId, svcToken, cfgId, edge)
2022-11-22 21:31:02 +01:00
if err != nil {
return "", nil, err
}
2022-11-30 18:10:00 +01:00
if err := createServicePolicyBind(envZId, svcToken, svcZId, edge); err != nil {
2022-11-22 21:31:02 +01:00
return "", nil, err
}
2022-11-30 18:10:00 +01:00
if err := createServiceEdgeRouterPolicy(envZId, svcToken, svcZId, edge); err != nil {
2022-11-22 21:31:02 +01:00
return "", nil, err
}
2022-11-30 18:10:00 +01:00
return svcZId, []string{proxyUrl(svcToken)}, nil
2022-11-22 21:31:02 +01:00
}