7e385fc126
Some checks failed
SonarQube / SonarQube (push) Failing after 5m28s
E2e test on main branch push / server and client test (map[name:admin port:8080]) (push) Failing after 3m33s
Server and lib tests / Library test (js) (push) Failing after 1m36s
Server and lib tests / Library test (vue) (push) Successful in 2m24s
Server and lib tests / Web client test (admin) (push) Successful in 2m52s
Server and lib tests / Web client test (compose) (push) Successful in 3m23s
Server and lib tests / Web client test (discovery) (push) Successful in 2m49s
Server and lib tests / Web client test (one) (push) Successful in 2m52s
Server and lib tests / Web client test (privacy) (push) Successful in 2m44s
Server and lib tests / Web client test (reporter) (push) Successful in 2m56s
Server and lib tests / Web client test (workflow) (push) Successful in 3m0s
Server and lib tests / Server tests (push) Failing after 4m55s
E2e test on main branch push / notify-failure (push) Failing after 9s
Server and lib tests / Send matrix testing notification (push) Successful in 2s
Mark stale issues and pull requests / stale (push) Successful in 40s
100 lines
2.0 KiB
Go
100 lines
2.0 KiB
Go
package resource
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
|
|
"github.com/cortezaproject/corteza/server/system/types"
|
|
)
|
|
|
|
type (
|
|
APIGateway struct {
|
|
*base
|
|
Res *types.ApigwRoute
|
|
|
|
Filters []*APIGatewayFilter
|
|
}
|
|
|
|
APIGatewayFilter struct {
|
|
*base
|
|
Res *types.ApigwFilter
|
|
}
|
|
)
|
|
|
|
func NewAPIGateway(res *types.ApigwRoute) *APIGateway {
|
|
// @todo we could use method + path combo to uniquely identify them also
|
|
r := &APIGateway{
|
|
base: &base{},
|
|
}
|
|
r.SetResourceType(types.ApigwRouteResourceType)
|
|
r.Res = res
|
|
|
|
r.AddIdentifier(identifiers(res.ID)...)
|
|
|
|
// Initial stamps
|
|
r.SetTimestamps(MakeTimestampsCUDA(&res.CreatedAt, res.UpdatedAt, res.DeletedAt, nil))
|
|
us := MakeUserstampsCUDO(res.CreatedBy, res.UpdatedBy, res.DeletedBy, 0)
|
|
r.SetUserstamps(us)
|
|
|
|
return r
|
|
}
|
|
|
|
func (r *APIGateway) Resource() interface{} {
|
|
return r.Res
|
|
}
|
|
|
|
func (r *APIGateway) RBACParts() (resource string, ref *Ref, path []*Ref) {
|
|
ref = r.Ref()
|
|
path = nil
|
|
resource = fmt.Sprintf(types.ApigwRouteRbacResourceTpl(), types.ApigwRouteResourceType, firstOkString(strconv.FormatUint(r.Res.ID, 10)))
|
|
|
|
return
|
|
}
|
|
|
|
func (r *APIGateway) AddGatewayFilter(res *types.ApigwFilter) *APIGatewayFilter {
|
|
f := &APIGatewayFilter{
|
|
base: &base{},
|
|
}
|
|
|
|
f.Res = res
|
|
|
|
// Initial stamps
|
|
f.SetTimestamps(MakeTimestampsCUDA(&res.CreatedAt, res.UpdatedAt, res.DeletedAt, nil))
|
|
f.SetUserstamps(MakeUserstampsCUDO(res.CreatedBy, res.UpdatedBy, res.DeletedBy, 0))
|
|
|
|
r.Filters = append(r.Filters, f)
|
|
|
|
return f
|
|
}
|
|
|
|
func (r *APIGateway) SysID() uint64 {
|
|
return r.Res.ID
|
|
}
|
|
|
|
// FindAPIGateway looks for the ApigwRoute in the resource set
|
|
func FindAPIGateway(rr InterfaceSet, ii Identifiers) (ns *types.ApigwRoute) {
|
|
var wfRes *APIGateway
|
|
|
|
rr.Walk(func(r Interface) error {
|
|
wr, ok := r.(*APIGateway)
|
|
if !ok {
|
|
return nil
|
|
}
|
|
|
|
if wr.Identifiers().HasAny(ii) {
|
|
wfRes = wr
|
|
}
|
|
return nil
|
|
})
|
|
|
|
// Found it
|
|
if wfRes != nil {
|
|
return wfRes.Res
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func APIGatewayErrUnresolved(ii Identifiers) error {
|
|
return fmt.Errorf("automation apu gateway unresolved %v", ii.StringSlice())
|
|
}
|