package router import ( "github.com/go-chi/chi" "github.com/porter-dev/porter/api/server/handlers/infra" "github.com/porter-dev/porter/api/server/shared" "github.com/porter-dev/porter/api/server/shared/config" "github.com/porter-dev/porter/api/types" ) func NewInfraScopedRegisterer(children ...*Registerer) *Registerer { return &Registerer{ GetRoutes: GetInfraScopedRoutes, Children: children, } } func GetInfraScopedRoutes( r chi.Router, config *config.Config, basePath *types.Path, factory shared.APIEndpointFactory, children ...*Registerer, ) []*Route { routes, projPath := getInfraRoutes(r, config, basePath, factory) if len(children) > 0 { r.Route(projPath.RelativePath, func(r chi.Router) { for _, child := range children { childRoutes := child.GetRoutes(r, config, basePath, factory, child.Children...) routes = append(routes, childRoutes...) } }) } return routes } func getInfraRoutes( r chi.Router, config *config.Config, basePath *types.Path, factory shared.APIEndpointFactory, ) ([]*Route, *types.Path) { relPath := "/infras/{infra_id}" newPath := &types.Path{ Parent: basePath, RelativePath: relPath, } routes := make([]*Route, 0) // GET /api/projects/{project_id}/infra -> project.NewInfraListHandler listInfraEndpoint := factory.NewAPIEndpoint( &types.APIRequestMetadata{ Verb: types.APIVerbGet, Method: types.HTTPVerbGet, Path: &types.Path{ Parent: basePath, RelativePath: "/infra", }, Scopes: []types.PermissionScope{ types.UserScope, types.ProjectScope, }, }, ) listInfraHandler := infra.NewInfraListHandler( config, factory.GetResultWriter(), ) routes = append(routes, &Route{ Endpoint: listInfraEndpoint, Handler: listInfraHandler, Router: r, }) // GET /api/projects/{project_id}/infras/{infra_id} -> infra.NewInfraGetHandler getEndpoint := factory.NewAPIEndpoint( &types.APIRequestMetadata{ Verb: types.APIVerbGet, Method: types.HTTPVerbGet, Path: &types.Path{ Parent: basePath, RelativePath: relPath, }, Scopes: []types.PermissionScope{ types.UserScope, types.ProjectScope, types.InfraScope, }, }, ) getHandler := infra.NewInfraGetHandler( config, factory.GetResultWriter(), ) routes = append(routes, &Route{ Endpoint: getEndpoint, Handler: getHandler, Router: r, }) // GET /api/projects/{project_id}/infras/{infra_id}/logs -> infra.NewInfraStreamLogsHandler streamLogsEndpoint := factory.NewAPIEndpoint( &types.APIRequestMetadata{ Verb: types.APIVerbGet, Method: types.HTTPVerbGet, Path: &types.Path{ Parent: basePath, RelativePath: relPath + "/logs", }, Scopes: []types.PermissionScope{ types.UserScope, types.ProjectScope, types.InfraScope, }, IsWebsocket: true, }, ) streamLogsHandler := infra.NewInfraStreamLogsHandler( config, factory.GetResultWriter(), ) routes = append(routes, &Route{ Endpoint: streamLogsEndpoint, Handler: streamLogsHandler, Router: r, }) // GET /api/projects/{project_id}/infras/{infra_id}/current -> infra.NewInfraGetHandler getCurrentEndpoint := factory.NewAPIEndpoint( &types.APIRequestMetadata{ Verb: types.APIVerbGet, Method: types.HTTPVerbGet, Path: &types.Path{ Parent: basePath, RelativePath: relPath + "/current", }, Scopes: []types.PermissionScope{ types.UserScope, types.ProjectScope, types.InfraScope, }, }, ) getCurrentHandler := infra.NewInfraGetCurrentHandler( config, factory.GetResultWriter(), ) routes = append(routes, &Route{ Endpoint: getCurrentEndpoint, Handler: getCurrentHandler, Router: r, }) // GET /api/projects/{project_id}/infras/{infra_id}/desired -> infra.NewInfraGetHandler getDesiredEndpoint := factory.NewAPIEndpoint( &types.APIRequestMetadata{ Verb: types.APIVerbGet, Method: types.HTTPVerbGet, Path: &types.Path{ Parent: basePath, RelativePath: relPath + "/desired", }, Scopes: []types.PermissionScope{ types.UserScope, types.ProjectScope, types.InfraScope, }, }, ) getDesiredHandler := infra.NewInfraGetDesiredHandler( config, factory.GetResultWriter(), ) routes = append(routes, &Route{ Endpoint: getDesiredEndpoint, Handler: getDesiredHandler, Router: r, }) // DELETE /api/projects/{project_id}/infras/{infra_id} -> infra.NewInfraDeleteHandler deleteEndpoint := factory.NewAPIEndpoint( &types.APIRequestMetadata{ Verb: types.APIVerbDelete, Method: types.HTTPVerbDelete, Path: &types.Path{ Parent: basePath, RelativePath: relPath, }, Scopes: []types.PermissionScope{ types.UserScope, types.ProjectScope, types.InfraScope, }, }, ) deleteHandler := infra.NewInfraDeleteHandler( config, factory.GetDecoderValidator(), factory.GetResultWriter(), ) routes = append(routes, &Route{ Endpoint: deleteEndpoint, Handler: deleteHandler, Router: r, }) return routes, newPath }