porter_app.go 35 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303
  1. package router
  2. import (
  3. "fmt"
  4. "github.com/go-chi/chi/v5"
  5. "github.com/porter-dev/porter/api/server/handlers/porter_app"
  6. "github.com/porter-dev/porter/api/server/shared"
  7. "github.com/porter-dev/porter/api/server/shared/config"
  8. "github.com/porter-dev/porter/api/server/shared/router"
  9. "github.com/porter-dev/porter/api/types"
  10. )
  11. func NewPorterAppScopedRegisterer(children ...*router.Registerer) *router.Registerer {
  12. return &router.Registerer{
  13. GetRoutes: GetPorterAppScopedRoutes,
  14. Children: children,
  15. }
  16. }
  17. func GetPorterAppScopedRoutes(
  18. r chi.Router,
  19. config *config.Config,
  20. basePath *types.Path,
  21. factory shared.APIEndpointFactory,
  22. children ...*router.Registerer,
  23. ) []*router.Route {
  24. routes, projPath := getPorterAppRoutes(r, config, basePath, factory)
  25. if len(children) > 0 {
  26. r.Route(projPath.RelativePath, func(r chi.Router) {
  27. for _, child := range children {
  28. childRoutes := child.GetRoutes(r, config, basePath, factory, child.Children...)
  29. routes = append(routes, childRoutes...)
  30. }
  31. })
  32. }
  33. return routes
  34. }
  35. func getPorterAppRoutes(
  36. r chi.Router,
  37. config *config.Config,
  38. basePath *types.Path,
  39. factory shared.APIEndpointFactory,
  40. ) ([]*router.Route, *types.Path) {
  41. relPath := "/applications"
  42. relPathV2 := "/apps"
  43. newPath := &types.Path{
  44. Parent: basePath,
  45. RelativePath: relPath,
  46. }
  47. var routes []*router.Route
  48. // GET /api/projects/{project_id}/clusters/{cluster_id}/applications/{name} -> porter_app.NewPorterAppGetHandler
  49. getPorterAppEndpoint := factory.NewAPIEndpoint(
  50. &types.APIRequestMetadata{
  51. Verb: types.APIVerbGet,
  52. Method: types.HTTPVerbGet,
  53. Path: &types.Path{
  54. Parent: basePath,
  55. RelativePath: fmt.Sprintf("%s/{%s}", relPath, types.URLParamPorterAppName),
  56. },
  57. Scopes: []types.PermissionScope{
  58. types.UserScope,
  59. types.ProjectScope,
  60. types.ClusterScope,
  61. },
  62. },
  63. )
  64. getPorterAppHandler := porter_app.NewGetPorterAppHandler(
  65. config,
  66. factory.GetResultWriter(),
  67. )
  68. routes = append(routes, &router.Route{
  69. Endpoint: getPorterAppEndpoint,
  70. Handler: getPorterAppHandler,
  71. Router: r,
  72. })
  73. // GET /api/projects/{project_id}/clusters/{cluster_id}/applications/{name}/releases/{version} -> porter_app.NewPorterAppReleaseGetHandler
  74. getPorterAppHelmReleaseEndpoint := factory.NewAPIEndpoint(
  75. &types.APIRequestMetadata{
  76. Verb: types.APIVerbList,
  77. Method: types.HTTPVerbGet,
  78. Path: &types.Path{
  79. Parent: basePath,
  80. RelativePath: fmt.Sprintf("%s/{%s}/releases/{%s}", relPath, types.URLParamPorterAppName, types.URLParamReleaseVersion),
  81. },
  82. Scopes: []types.PermissionScope{
  83. types.UserScope,
  84. types.ProjectScope,
  85. types.ClusterScope,
  86. },
  87. },
  88. )
  89. getPorterAppHelmReleaseHandler := porter_app.NewPorterAppHelmReleaseGetHandler(
  90. config,
  91. factory.GetResultWriter(),
  92. )
  93. routes = append(routes, &router.Route{
  94. Endpoint: getPorterAppHelmReleaseEndpoint,
  95. Handler: getPorterAppHelmReleaseHandler,
  96. Router: r,
  97. })
  98. // GET /api/projects/{project_id}/clusters/{cluster_id}/applications/{name}/release-history -> porter_app.NewPorterAppHelmReleaseHistoryGetHandler
  99. getPorterAppHelmReleaseHistoryGetEndpoint := factory.NewAPIEndpoint(
  100. &types.APIRequestMetadata{
  101. Verb: types.APIVerbList,
  102. Method: types.HTTPVerbGet,
  103. Path: &types.Path{
  104. Parent: basePath,
  105. RelativePath: fmt.Sprintf("%s/{%s}/release-history", relPath, types.URLParamPorterAppName),
  106. },
  107. Scopes: []types.PermissionScope{
  108. types.UserScope,
  109. types.ProjectScope,
  110. types.ClusterScope,
  111. },
  112. },
  113. )
  114. getPorterAppHelmReleaseHistoryGetHandler := porter_app.NewPorterAppHelmReleaseHistoryGetHandler(
  115. config,
  116. factory.GetResultWriter(),
  117. )
  118. routes = append(routes, &router.Route{
  119. Endpoint: getPorterAppHelmReleaseHistoryGetEndpoint,
  120. Handler: getPorterAppHelmReleaseHistoryGetHandler,
  121. Router: r,
  122. })
  123. // GET /api/projects/{project_id}/clusters/{cluster_id}/applications/{name}/releases/{version}/pods/all -> porter_app.NewPorterAppPodsGetHandler
  124. getPorterAppPodsEndpoint := factory.NewAPIEndpoint(
  125. &types.APIRequestMetadata{
  126. Verb: types.APIVerbList,
  127. Method: types.HTTPVerbGet,
  128. Path: &types.Path{
  129. Parent: basePath,
  130. RelativePath: fmt.Sprintf("%s/{%s}/releases/{%s}/pods/all", relPath, types.URLParamPorterAppName, types.URLParamReleaseVersion),
  131. },
  132. Scopes: []types.PermissionScope{
  133. types.UserScope,
  134. types.ProjectScope,
  135. types.ClusterScope,
  136. },
  137. },
  138. )
  139. getPorterAppPodsHandler := porter_app.NewPorterAppPodsGetHandler(
  140. config,
  141. factory.GetResultWriter(),
  142. )
  143. routes = append(routes, &router.Route{
  144. Endpoint: getPorterAppPodsEndpoint,
  145. Handler: getPorterAppPodsHandler,
  146. Router: r,
  147. })
  148. // GET /api/projects/{project_id}/clusters/{cluster_id}/applications -> porter_app.NewPorterAppListHandler
  149. listPorterAppEndpoint := factory.NewAPIEndpoint(
  150. &types.APIRequestMetadata{
  151. Verb: types.APIVerbList,
  152. Method: types.HTTPVerbGet,
  153. Path: &types.Path{
  154. Parent: basePath,
  155. RelativePath: relPath,
  156. },
  157. Scopes: []types.PermissionScope{
  158. types.UserScope,
  159. types.ProjectScope,
  160. types.ClusterScope,
  161. },
  162. },
  163. )
  164. listPorterAppHandler := porter_app.NewPorterAppListHandler(
  165. config,
  166. factory.GetResultWriter(),
  167. )
  168. routes = append(routes, &router.Route{
  169. Endpoint: listPorterAppEndpoint,
  170. Handler: listPorterAppHandler,
  171. Router: r,
  172. })
  173. // DELETE /api/projects/{project_id}/clusters/{cluster_id}/applications/{porter_app_name} -> release.NewDeletePorterAppByNameHandler
  174. deletePorterAppByNameEndpoint := factory.NewAPIEndpoint(
  175. &types.APIRequestMetadata{
  176. Verb: types.APIVerbDelete,
  177. Method: types.HTTPVerbDelete,
  178. Path: &types.Path{
  179. Parent: basePath,
  180. RelativePath: fmt.Sprintf("%s/{%s}", relPath, types.URLParamPorterAppName),
  181. },
  182. Scopes: []types.PermissionScope{
  183. types.UserScope,
  184. types.ProjectScope,
  185. types.ClusterScope,
  186. },
  187. },
  188. )
  189. deletePorterAppByNameHandler := porter_app.NewDeletePorterAppByNameHandler(
  190. config,
  191. factory.GetDecoderValidator(),
  192. factory.GetResultWriter(),
  193. )
  194. routes = append(routes, &router.Route{
  195. Endpoint: deletePorterAppByNameEndpoint,
  196. Handler: deletePorterAppByNameHandler,
  197. Router: r,
  198. })
  199. // POST /api/projects/{project_id}/clusters/{cluster_id}/applications/{porter_app_name} -> porter_app.NewCreatePorterAppHandler
  200. createPorterAppEndpoint := factory.NewAPIEndpoint(
  201. &types.APIRequestMetadata{
  202. Verb: types.APIVerbCreate,
  203. Method: types.HTTPVerbPost,
  204. Path: &types.Path{
  205. Parent: basePath,
  206. RelativePath: fmt.Sprintf("%s/{%s}", relPath, types.URLParamPorterAppName),
  207. },
  208. Scopes: []types.PermissionScope{
  209. types.UserScope,
  210. types.ProjectScope,
  211. types.ClusterScope,
  212. },
  213. },
  214. )
  215. createPorterAppHandler := porter_app.NewCreatePorterAppHandler(
  216. config,
  217. factory.GetDecoderValidator(),
  218. factory.GetResultWriter(),
  219. )
  220. routes = append(routes, &router.Route{
  221. Endpoint: createPorterAppEndpoint,
  222. Handler: createPorterAppHandler,
  223. Router: r,
  224. })
  225. // POST /api/projects/{project_id}/clusters/{cluster_id}/applications/{porter_app_name}/rollback -> porter_app.NewRollbackPorterAppHandler
  226. rollbackPorterAppEndpoint := factory.NewAPIEndpoint(
  227. &types.APIRequestMetadata{
  228. Verb: types.APIVerbCreate,
  229. Method: types.HTTPVerbPost,
  230. Path: &types.Path{
  231. Parent: basePath,
  232. RelativePath: fmt.Sprintf("%s/{%s}/rollback", relPath, types.URLParamPorterAppName),
  233. },
  234. Scopes: []types.PermissionScope{
  235. types.UserScope,
  236. types.ProjectScope,
  237. types.ClusterScope,
  238. },
  239. },
  240. )
  241. rollbackPorterAppHandler := porter_app.NewRollbackPorterAppHandler(
  242. config,
  243. factory.GetDecoderValidator(),
  244. factory.GetResultWriter(),
  245. )
  246. routes = append(routes, &router.Route{
  247. Endpoint: rollbackPorterAppEndpoint,
  248. Handler: rollbackPorterAppHandler,
  249. Router: r,
  250. })
  251. // POST /api/projects/{project_id}/clusters/{cluster_id}/applications/{porter_app_name}/pr -> porter_app.NewOpenStackPRHandler
  252. createSecretAndOpenGitHubPullRequestEndpoint := factory.NewAPIEndpoint(
  253. &types.APIRequestMetadata{
  254. Verb: types.APIVerbCreate,
  255. Method: types.HTTPVerbPost,
  256. Path: &types.Path{
  257. Parent: basePath,
  258. RelativePath: fmt.Sprintf("%s/{%s}/pr", relPath, types.URLParamPorterAppName),
  259. },
  260. Scopes: []types.PermissionScope{
  261. types.UserScope,
  262. types.ProjectScope,
  263. types.ClusterScope,
  264. },
  265. },
  266. )
  267. createSecretAndOpenGitHubPullRequestHandler := porter_app.NewOpenStackPRHandler(
  268. config,
  269. factory.GetDecoderValidator(),
  270. factory.GetResultWriter(),
  271. )
  272. routes = append(routes, &router.Route{
  273. Endpoint: createSecretAndOpenGitHubPullRequestEndpoint,
  274. Handler: createSecretAndOpenGitHubPullRequestHandler,
  275. Router: r,
  276. })
  277. // GET /api/projects/{project_id}/clusters/{cluster_id}/applications/{porter_app_name}/events -> porter_app.NewPorterAppEventListHandler
  278. listPorterAppEventsEndpoint := factory.NewAPIEndpoint(
  279. &types.APIRequestMetadata{
  280. Verb: types.APIVerbList,
  281. Method: types.HTTPVerbGet,
  282. Path: &types.Path{
  283. Parent: basePath,
  284. RelativePath: fmt.Sprintf("%s/{%s}/events", relPath, types.URLParamPorterAppName),
  285. },
  286. Scopes: []types.PermissionScope{
  287. types.UserScope,
  288. types.ProjectScope,
  289. types.ClusterScope,
  290. },
  291. },
  292. )
  293. listPorterAppEventsHandler := porter_app.NewPorterAppEventListHandler(
  294. config,
  295. factory.GetResultWriter(),
  296. )
  297. routes = append(routes, &router.Route{
  298. Endpoint: listPorterAppEventsEndpoint,
  299. Handler: listPorterAppEventsHandler,
  300. Router: r,
  301. })
  302. // POST /api/projects/{project_id}/clusters/{cluster_id}/applications/{name}/events -> porter_app.NewCreatePorterAppEventHandler
  303. createPorterAppEventEndpoint := factory.NewAPIEndpoint(
  304. &types.APIRequestMetadata{
  305. Verb: types.APIVerbCreate,
  306. Method: types.HTTPVerbPost,
  307. Path: &types.Path{
  308. Parent: basePath,
  309. RelativePath: fmt.Sprintf("%s/{%s}/events", relPath, types.URLParamPorterAppName),
  310. },
  311. Scopes: []types.PermissionScope{
  312. types.UserScope,
  313. types.ProjectScope,
  314. types.ClusterScope,
  315. },
  316. },
  317. )
  318. createPorterAppEventHandler := porter_app.NewCreateUpdatePorterAppEventHandler(
  319. config,
  320. factory.GetDecoderValidator(),
  321. factory.GetResultWriter(),
  322. )
  323. routes = append(routes, &router.Route{
  324. Endpoint: createPorterAppEventEndpoint,
  325. Handler: createPorterAppEventHandler,
  326. Router: r,
  327. })
  328. // GET /api/projects/{project_id}/clusters/{cluster_id}/events/id -> porter_app.NewGetPorterAppEventHandler
  329. getPorterAppEventEndpoint := factory.NewAPIEndpoint(
  330. &types.APIRequestMetadata{
  331. Verb: types.APIVerbCreate,
  332. Method: types.HTTPVerbGet,
  333. Path: &types.Path{
  334. Parent: basePath,
  335. RelativePath: fmt.Sprintf("/events/{%s}", types.URLParamPorterAppEventID),
  336. },
  337. Scopes: []types.PermissionScope{
  338. types.UserScope,
  339. types.ProjectScope,
  340. types.ClusterScope,
  341. },
  342. },
  343. )
  344. getPorterAppEventHandler := porter_app.NewGetPorterAppEventHandler(
  345. config,
  346. factory.GetResultWriter(),
  347. )
  348. routes = append(routes, &router.Route{
  349. Endpoint: getPorterAppEventEndpoint,
  350. Handler: getPorterAppEventHandler,
  351. Router: r,
  352. })
  353. // POST /api/projects/{project_id}/clusters/{cluster_id}/applications/analytics -> porter_app.NewPorterAppAnalyticsHandler
  354. porterAppAnalyticsEndpoint := factory.NewAPIEndpoint(
  355. &types.APIRequestMetadata{
  356. Verb: types.APIVerbUpdate,
  357. Method: types.HTTPVerbPost,
  358. Path: &types.Path{
  359. Parent: basePath,
  360. RelativePath: fmt.Sprintf("%s/analytics", relPath),
  361. },
  362. Scopes: []types.PermissionScope{
  363. types.UserScope,
  364. types.ProjectScope,
  365. types.ClusterScope,
  366. },
  367. },
  368. )
  369. porterAppAnalyticsHandler := porter_app.NewPorterAppAnalyticsHandler(
  370. config,
  371. factory.GetDecoderValidator(),
  372. factory.GetResultWriter(),
  373. )
  374. routes = append(routes, &router.Route{
  375. Endpoint: porterAppAnalyticsEndpoint,
  376. Handler: porterAppAnalyticsHandler,
  377. Router: r,
  378. })
  379. // GET /api/projects/{project_id}/clusters/{cluster_id}/applications/logs -> cluster.NewGetChartLogsWithinTimeRangeHandler
  380. getChartLogsWithinTimeRangeEndpoint := factory.NewAPIEndpoint(
  381. &types.APIRequestMetadata{
  382. Verb: types.APIVerbGet,
  383. Method: types.HTTPVerbGet,
  384. Path: &types.Path{
  385. Parent: basePath,
  386. RelativePath: fmt.Sprintf("%s/logs", relPath),
  387. },
  388. Scopes: []types.PermissionScope{
  389. types.UserScope,
  390. types.ProjectScope,
  391. types.ClusterScope,
  392. },
  393. },
  394. )
  395. getChartLogsWithinTimeRangeHandler := porter_app.NewGetLogsWithinTimeRangeHandler(
  396. config,
  397. factory.GetDecoderValidator(),
  398. factory.GetResultWriter(),
  399. )
  400. routes = append(routes, &router.Route{
  401. Endpoint: getChartLogsWithinTimeRangeEndpoint,
  402. Handler: getChartLogsWithinTimeRangeHandler,
  403. Router: r,
  404. })
  405. // POST /api/projects/{project_id}/clusters/{cluster_id}/applications/{porter_app_name}/run -> porter_app.NewRunPorterAppCommandHandler
  406. runPorterAppCommandEndpoint := factory.NewAPIEndpoint(
  407. &types.APIRequestMetadata{
  408. Verb: types.APIVerbCreate,
  409. Method: types.HTTPVerbPost,
  410. Path: &types.Path{
  411. Parent: basePath,
  412. RelativePath: fmt.Sprintf("%s/{%s}/run", relPath, types.URLParamPorterAppName),
  413. },
  414. Scopes: []types.PermissionScope{
  415. types.UserScope,
  416. types.ProjectScope,
  417. types.ClusterScope,
  418. },
  419. },
  420. )
  421. runPorterAppCommandHandler := porter_app.NewRunPorterAppCommandHandler(
  422. config,
  423. factory.GetDecoderValidator(),
  424. factory.GetResultWriter(),
  425. )
  426. routes = append(routes, &router.Route{
  427. Endpoint: runPorterAppCommandEndpoint,
  428. Handler: runPorterAppCommandHandler,
  429. Router: r,
  430. })
  431. // TODO: remove these three endpoints once these three 'stacks' routes are no longer used in telemetry
  432. // GET /api/projects/{project_id}/clusters/{cluster_id}/stacks/{name} -> porter_app.NewPorterAppGetHandler
  433. LEGACY_getPorterAppEndpoint := factory.NewAPIEndpoint(
  434. &types.APIRequestMetadata{
  435. Verb: types.APIVerbGet,
  436. Method: types.HTTPVerbGet,
  437. Path: &types.Path{
  438. Parent: basePath,
  439. RelativePath: fmt.Sprintf("/stacks/{%s}", types.URLParamPorterAppName),
  440. },
  441. Scopes: []types.PermissionScope{
  442. types.UserScope,
  443. types.ProjectScope,
  444. types.ClusterScope,
  445. },
  446. },
  447. )
  448. LEGACY_getPorterAppHandler := porter_app.NewGetPorterAppHandler(
  449. config,
  450. factory.GetResultWriter(),
  451. )
  452. routes = append(routes, &router.Route{
  453. Endpoint: LEGACY_getPorterAppEndpoint,
  454. Handler: LEGACY_getPorterAppHandler,
  455. Router: r,
  456. })
  457. // POST /api/projects/{project_id}/clusters/{cluster_id}/stacks/{porter_app_name} -> porter_app.NewCreatePorterAppHandler
  458. LEGACY_createPorterAppEndpoint := factory.NewAPIEndpoint(
  459. &types.APIRequestMetadata{
  460. Verb: types.APIVerbCreate,
  461. Method: types.HTTPVerbPost,
  462. Path: &types.Path{
  463. Parent: basePath,
  464. RelativePath: fmt.Sprintf("/stacks/{%s}", types.URLParamPorterAppName),
  465. },
  466. Scopes: []types.PermissionScope{
  467. types.UserScope,
  468. types.ProjectScope,
  469. types.ClusterScope,
  470. },
  471. },
  472. )
  473. LEGACY_createPorterAppHandler := porter_app.NewCreatePorterAppHandler(
  474. config,
  475. factory.GetDecoderValidator(),
  476. factory.GetResultWriter(),
  477. )
  478. routes = append(routes, &router.Route{
  479. Endpoint: LEGACY_createPorterAppEndpoint,
  480. Handler: LEGACY_createPorterAppHandler,
  481. Router: r,
  482. })
  483. // POST /api/projects/{project_id}/clusters/{cluster_id}/stacks/{name}/events -> porter_app.NewCreatePorterAppEventHandler
  484. LEGACY_createPorterAppEventEndpoint := factory.NewAPIEndpoint(
  485. &types.APIRequestMetadata{
  486. Verb: types.APIVerbCreate,
  487. Method: types.HTTPVerbPost,
  488. Path: &types.Path{
  489. Parent: basePath,
  490. RelativePath: fmt.Sprintf("/stacks/{%s}/events", types.URLParamPorterAppName),
  491. },
  492. Scopes: []types.PermissionScope{
  493. types.UserScope,
  494. types.ProjectScope,
  495. types.ClusterScope,
  496. },
  497. },
  498. )
  499. LEGACY_createPorterAppEventHandler := porter_app.NewCreateUpdatePorterAppEventHandler(
  500. config,
  501. factory.GetDecoderValidator(),
  502. factory.GetResultWriter(),
  503. )
  504. routes = append(routes, &router.Route{
  505. Endpoint: LEGACY_createPorterAppEventEndpoint,
  506. Handler: LEGACY_createPorterAppEventHandler,
  507. Router: r,
  508. })
  509. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/parse -> porter_app.NewParsePorterYAMLToProtoHandler
  510. parsePorterYAMLToProtoEndpoint := factory.NewAPIEndpoint(
  511. &types.APIRequestMetadata{
  512. Verb: types.APIVerbGet,
  513. Method: types.HTTPVerbPost,
  514. Path: &types.Path{
  515. Parent: basePath,
  516. RelativePath: fmt.Sprintf("%s/parse", relPathV2),
  517. },
  518. Scopes: []types.PermissionScope{
  519. types.UserScope,
  520. types.ProjectScope,
  521. types.ClusterScope,
  522. },
  523. },
  524. )
  525. parsePorterYAMLToProtoHandler := porter_app.NewParsePorterYAMLToProtoHandler(
  526. config,
  527. factory.GetDecoderValidator(),
  528. factory.GetResultWriter(),
  529. )
  530. routes = append(routes, &router.Route{
  531. Endpoint: parsePorterYAMLToProtoEndpoint,
  532. Handler: parsePorterYAMLToProtoHandler,
  533. Router: r,
  534. })
  535. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/validate -> porter_app.NewValidatePorterAppHandler
  536. validatePorterAppEndpoint := factory.NewAPIEndpoint(
  537. &types.APIRequestMetadata{
  538. Verb: types.APIVerbGet,
  539. Method: types.HTTPVerbPost,
  540. Path: &types.Path{
  541. Parent: basePath,
  542. RelativePath: fmt.Sprintf("%s/validate", relPathV2),
  543. },
  544. Scopes: []types.PermissionScope{
  545. types.UserScope,
  546. types.ProjectScope,
  547. types.ClusterScope,
  548. },
  549. },
  550. )
  551. validatePorterAppHandler := porter_app.NewValidatePorterAppHandler(
  552. config,
  553. factory.GetDecoderValidator(),
  554. factory.GetResultWriter(),
  555. )
  556. routes = append(routes, &router.Route{
  557. Endpoint: validatePorterAppEndpoint,
  558. Handler: validatePorterAppHandler,
  559. Router: r,
  560. })
  561. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/create -> porter_app.NewCreateAppHandler
  562. createAppEndpoint := factory.NewAPIEndpoint(
  563. &types.APIRequestMetadata{
  564. Verb: types.APIVerbCreate,
  565. Method: types.HTTPVerbPost,
  566. Path: &types.Path{
  567. Parent: basePath,
  568. RelativePath: fmt.Sprintf("%s/create", relPathV2),
  569. },
  570. Scopes: []types.PermissionScope{
  571. types.UserScope,
  572. types.ProjectScope,
  573. types.ClusterScope,
  574. },
  575. },
  576. )
  577. createAppHandler := porter_app.NewCreateAppHandler(
  578. config,
  579. factory.GetDecoderValidator(),
  580. factory.GetResultWriter(),
  581. )
  582. routes = append(routes, &router.Route{
  583. Endpoint: createAppEndpoint,
  584. Handler: createAppHandler,
  585. Router: r,
  586. })
  587. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/apply -> porter_app.NewApplyPorterAppHandler
  588. applyPorterAppEndpoint := factory.NewAPIEndpoint(
  589. &types.APIRequestMetadata{
  590. Verb: types.APIVerbUpdate,
  591. Method: types.HTTPVerbPost,
  592. Path: &types.Path{
  593. Parent: basePath,
  594. RelativePath: fmt.Sprintf("%s/apply", relPathV2),
  595. },
  596. Scopes: []types.PermissionScope{
  597. types.UserScope,
  598. types.ProjectScope,
  599. types.ClusterScope,
  600. },
  601. },
  602. )
  603. applyPorterAppHandler := porter_app.NewApplyPorterAppHandler(
  604. config,
  605. factory.GetDecoderValidator(),
  606. factory.GetResultWriter(),
  607. )
  608. routes = append(routes, &router.Route{
  609. Endpoint: applyPorterAppEndpoint,
  610. Handler: applyPorterAppHandler,
  611. Router: r,
  612. })
  613. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/update-image -> porter_app.NewUpdateImageHandler
  614. updatePorterAppImageEndpoint := factory.NewAPIEndpoint(
  615. &types.APIRequestMetadata{
  616. Verb: types.APIVerbUpdate,
  617. Method: types.HTTPVerbPost,
  618. Path: &types.Path{
  619. Parent: basePath,
  620. RelativePath: fmt.Sprintf("%s/{%s}/update-image", relPathV2, types.URLParamPorterAppName),
  621. },
  622. Scopes: []types.PermissionScope{
  623. types.UserScope,
  624. types.ProjectScope,
  625. types.ClusterScope,
  626. },
  627. },
  628. )
  629. updatePorterAppImageHandler := porter_app.NewUpdateImageHandler(
  630. config,
  631. factory.GetDecoderValidator(),
  632. factory.GetResultWriter(),
  633. )
  634. routes = append(routes, &router.Route{
  635. Endpoint: updatePorterAppImageEndpoint,
  636. Handler: updatePorterAppImageHandler,
  637. Router: r,
  638. })
  639. // GET /api/projects/{project_id}/clusters/{cluster_id}/default-deployment-target -> porter_app.NewDefaultDeploymentTargetHandler
  640. defaultDeploymentTargetEndpoint := factory.NewAPIEndpoint(
  641. &types.APIRequestMetadata{
  642. Verb: types.APIVerbGet,
  643. Method: types.HTTPVerbGet,
  644. Path: &types.Path{
  645. Parent: basePath,
  646. RelativePath: "/default-deployment-target",
  647. },
  648. Scopes: []types.PermissionScope{
  649. types.UserScope,
  650. types.ProjectScope,
  651. types.ClusterScope,
  652. },
  653. },
  654. )
  655. defaultDeploymentTargetHandler := porter_app.NewDefaultDeploymentTargetHandler(
  656. config,
  657. factory.GetDecoderValidator(),
  658. factory.GetResultWriter(),
  659. )
  660. routes = append(routes, &router.Route{
  661. Endpoint: defaultDeploymentTargetEndpoint,
  662. Handler: defaultDeploymentTargetHandler,
  663. Router: r,
  664. })
  665. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/latest -> porter_app.NewCurrentAppRevisionHandler
  666. currentAppRevisionEndpoint := factory.NewAPIEndpoint(
  667. &types.APIRequestMetadata{
  668. Verb: types.APIVerbGet,
  669. Method: types.HTTPVerbGet,
  670. Path: &types.Path{
  671. Parent: basePath,
  672. RelativePath: fmt.Sprintf("%s/{%s}/latest", relPathV2, types.URLParamPorterAppName),
  673. },
  674. Scopes: []types.PermissionScope{
  675. types.UserScope,
  676. types.ProjectScope,
  677. types.ClusterScope,
  678. },
  679. },
  680. )
  681. currentAppRevisionHandler := porter_app.NewLatestAppRevisionHandler(
  682. config,
  683. factory.GetDecoderValidator(),
  684. factory.GetResultWriter(),
  685. )
  686. routes = append(routes, &router.Route{
  687. Endpoint: currentAppRevisionEndpoint,
  688. Handler: currentAppRevisionHandler,
  689. Router: r,
  690. })
  691. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/revisions -> porter_app.NewCurrentAppRevisionHandler
  692. listAppRevisionsEndpoint := factory.NewAPIEndpoint(
  693. &types.APIRequestMetadata{
  694. Verb: types.APIVerbGet,
  695. Method: types.HTTPVerbGet,
  696. Path: &types.Path{
  697. Parent: basePath,
  698. RelativePath: fmt.Sprintf("%s/{%s}/revisions", relPathV2, types.URLParamPorterAppName),
  699. },
  700. Scopes: []types.PermissionScope{
  701. types.UserScope,
  702. types.ProjectScope,
  703. types.ClusterScope,
  704. },
  705. },
  706. )
  707. listAppRevisionsHandler := porter_app.NewListAppRevisionsHandler(
  708. config,
  709. factory.GetDecoderValidator(),
  710. factory.GetResultWriter(),
  711. )
  712. routes = append(routes, &router.Route{
  713. Endpoint: listAppRevisionsEndpoint,
  714. Handler: listAppRevisionsHandler,
  715. Router: r,
  716. })
  717. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/revisions -> porter_app.NewCurrentAppRevisionHandler
  718. latestAppRevisionsEndpoint := factory.NewAPIEndpoint(
  719. &types.APIRequestMetadata{
  720. Verb: types.APIVerbGet,
  721. Method: types.HTTPVerbGet,
  722. Path: &types.Path{
  723. Parent: basePath,
  724. RelativePath: fmt.Sprintf("%s/revisions", relPathV2),
  725. },
  726. Scopes: []types.PermissionScope{
  727. types.UserScope,
  728. types.ProjectScope,
  729. types.ClusterScope,
  730. },
  731. },
  732. )
  733. latestAppRevisionsHandler := porter_app.NewLatestAppRevisionsHandler(
  734. config,
  735. factory.GetDecoderValidator(),
  736. factory.GetResultWriter(),
  737. )
  738. routes = append(routes, &router.Route{
  739. Endpoint: latestAppRevisionsEndpoint,
  740. Handler: latestAppRevisionsHandler,
  741. Router: r,
  742. })
  743. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/subdomain -> porter_app.NewCreateSubdomainHandler
  744. createSubdomainEndpoint := factory.NewAPIEndpoint(
  745. &types.APIRequestMetadata{
  746. Verb: types.APIVerbUpdate,
  747. Method: types.HTTPVerbPost,
  748. Path: &types.Path{
  749. Parent: basePath,
  750. RelativePath: fmt.Sprintf("%s/{%s}/subdomain", relPathV2, types.URLParamPorterAppName),
  751. },
  752. Scopes: []types.PermissionScope{
  753. types.UserScope,
  754. types.ProjectScope,
  755. types.ClusterScope,
  756. },
  757. },
  758. )
  759. createSubdomainHandler := porter_app.NewCreateSubdomainHandler(
  760. config,
  761. factory.GetDecoderValidator(),
  762. factory.GetResultWriter(),
  763. )
  764. routes = append(routes, &router.Route{
  765. Endpoint: createSubdomainEndpoint,
  766. Handler: createSubdomainHandler,
  767. Router: r,
  768. })
  769. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/{app_revision_id}/predeploy-status -> porter_app.NewPredeployStatusHandler
  770. predeployStatusEndpoint := factory.NewAPIEndpoint(
  771. &types.APIRequestMetadata{
  772. Verb: types.APIVerbGet,
  773. Method: types.HTTPVerbGet,
  774. Path: &types.Path{
  775. Parent: basePath,
  776. RelativePath: fmt.Sprintf("%s/{%s}/{%s}/predeploy-status", relPathV2, types.URLParamPorterAppName, types.URLParamAppRevisionID),
  777. },
  778. Scopes: []types.PermissionScope{
  779. types.UserScope,
  780. types.ProjectScope,
  781. types.ClusterScope,
  782. },
  783. },
  784. )
  785. predeployStatusHandler := porter_app.NewPredeployStatusHandler(
  786. config,
  787. factory.GetDecoderValidator(),
  788. factory.GetResultWriter(),
  789. )
  790. routes = append(routes, &router.Route{
  791. Endpoint: predeployStatusEndpoint,
  792. Handler: predeployStatusHandler,
  793. Router: r,
  794. })
  795. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/logs -> cluster.NewAppLogsHandler
  796. appLogsEndpoint := factory.NewAPIEndpoint(
  797. &types.APIRequestMetadata{
  798. Verb: types.APIVerbGet,
  799. Method: types.HTTPVerbGet,
  800. Path: &types.Path{
  801. Parent: basePath,
  802. RelativePath: fmt.Sprintf("%s/{%s}/logs", relPathV2, types.URLParamPorterAppName),
  803. },
  804. Scopes: []types.PermissionScope{
  805. types.UserScope,
  806. types.ProjectScope,
  807. types.ClusterScope,
  808. },
  809. },
  810. )
  811. appLogsHandler := porter_app.NewAppLogsHandler(
  812. config,
  813. factory.GetDecoderValidator(),
  814. factory.GetResultWriter(),
  815. )
  816. routes = append(routes, &router.Route{
  817. Endpoint: appLogsEndpoint,
  818. Handler: appLogsHandler,
  819. Router: r,
  820. })
  821. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/logs/loki -> namespace.NewStreamLogsLokiHandler
  822. streamLogsLokiEndpoint := factory.NewAPIEndpoint(
  823. &types.APIRequestMetadata{
  824. Verb: types.APIVerbGet,
  825. Method: types.HTTPVerbGet,
  826. Path: &types.Path{
  827. Parent: basePath,
  828. RelativePath: fmt.Sprintf("%s/{%s}/logs/loki", relPathV2, types.URLParamPorterAppName),
  829. },
  830. Scopes: []types.PermissionScope{
  831. types.UserScope,
  832. types.ProjectScope,
  833. types.ClusterScope,
  834. },
  835. IsWebsocket: true,
  836. },
  837. )
  838. streamLogsLokiHandler := porter_app.NewStreamLogsLokiHandler(
  839. config,
  840. factory.GetDecoderValidator(),
  841. factory.GetResultWriter(),
  842. )
  843. routes = append(routes, &router.Route{
  844. Endpoint: streamLogsLokiEndpoint,
  845. Handler: streamLogsLokiHandler,
  846. Router: r,
  847. })
  848. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/metrics -> cluster.NewGetPodMetricsHandler
  849. appMetricsEndpoint := factory.NewAPIEndpoint(
  850. &types.APIRequestMetadata{
  851. Verb: types.APIVerbGet,
  852. Method: types.HTTPVerbGet,
  853. Path: &types.Path{
  854. Parent: basePath,
  855. RelativePath: fmt.Sprintf("%s/metrics", relPathV2),
  856. },
  857. Scopes: []types.PermissionScope{
  858. types.UserScope,
  859. types.ProjectScope,
  860. types.ClusterScope,
  861. },
  862. },
  863. )
  864. appMetricsHandler := porter_app.NewAppMetricsHandler(
  865. config,
  866. factory.GetDecoderValidator(),
  867. factory.GetResultWriter(),
  868. )
  869. routes = append(routes, &router.Route{
  870. Endpoint: appMetricsEndpoint,
  871. Handler: appMetricsHandler,
  872. Router: r,
  873. })
  874. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/status -> cluster.NewAppStatusHandler
  875. appStatusEndpoint := factory.NewAPIEndpoint(
  876. &types.APIRequestMetadata{
  877. Verb: types.APIVerbGet,
  878. Method: types.HTTPVerbGet,
  879. Path: &types.Path{
  880. Parent: basePath,
  881. RelativePath: fmt.Sprintf("%s/{%s}/status", relPathV2, types.URLParamKind),
  882. },
  883. Scopes: []types.PermissionScope{
  884. types.UserScope,
  885. types.ProjectScope,
  886. types.ClusterScope,
  887. },
  888. IsWebsocket: true,
  889. },
  890. )
  891. appStatusHandler := porter_app.NewAppStatusHandler(
  892. config,
  893. factory.GetDecoderValidator(),
  894. factory.GetResultWriter(),
  895. )
  896. routes = append(routes, &router.Route{
  897. Endpoint: appStatusEndpoint,
  898. Handler: appStatusHandler,
  899. Router: r,
  900. })
  901. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/pods -> cluster.NewPodStatusHandler
  902. appPodStatusEndpoint := factory.NewAPIEndpoint(
  903. &types.APIRequestMetadata{
  904. Verb: types.APIVerbGet,
  905. Method: types.HTTPVerbGet,
  906. Path: &types.Path{
  907. Parent: basePath,
  908. RelativePath: fmt.Sprintf("%s/{%s}/pods", relPathV2, types.URLParamPorterAppName),
  909. },
  910. Scopes: []types.PermissionScope{
  911. types.UserScope,
  912. types.ProjectScope,
  913. types.ClusterScope,
  914. },
  915. },
  916. )
  917. appPodStatusHandler := porter_app.NewPodStatusHandler(
  918. config,
  919. factory.GetDecoderValidator(),
  920. factory.GetResultWriter(),
  921. )
  922. routes = append(routes, &router.Route{
  923. Endpoint: appPodStatusEndpoint,
  924. Handler: appPodStatusHandler,
  925. Router: r,
  926. })
  927. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/jobs -> cluster.NewJobStatusHandler
  928. appJobStatusEndpoint := factory.NewAPIEndpoint(
  929. &types.APIRequestMetadata{
  930. Verb: types.APIVerbGet,
  931. Method: types.HTTPVerbGet,
  932. Path: &types.Path{
  933. Parent: basePath,
  934. RelativePath: fmt.Sprintf("%s/{%s}/jobs", relPathV2, types.URLParamPorterAppName),
  935. },
  936. Scopes: []types.PermissionScope{
  937. types.UserScope,
  938. types.ProjectScope,
  939. types.ClusterScope,
  940. },
  941. },
  942. )
  943. appJobStatusHandler := porter_app.NewJobStatusHandler(
  944. config,
  945. factory.GetDecoderValidator(),
  946. factory.GetResultWriter(),
  947. )
  948. routes = append(routes, &router.Route{
  949. Endpoint: appJobStatusEndpoint,
  950. Handler: appJobStatusHandler,
  951. Router: r,
  952. })
  953. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/revisions/{app_revision_id} -> porter_app.NewGetAppRevisionHandler
  954. getAppRevisionEndpoint := factory.NewAPIEndpoint(
  955. &types.APIRequestMetadata{
  956. Verb: types.APIVerbGet,
  957. Method: types.HTTPVerbGet,
  958. Path: &types.Path{
  959. Parent: basePath,
  960. RelativePath: fmt.Sprintf("/apps/{%s}/revisions/{%s}", types.URLParamPorterAppName, types.URLParamAppRevisionID),
  961. },
  962. Scopes: []types.PermissionScope{
  963. types.UserScope,
  964. types.ProjectScope,
  965. types.ClusterScope,
  966. },
  967. },
  968. )
  969. getAppRevisionHandler := porter_app.NewGetAppRevisionHandler(
  970. config,
  971. factory.GetDecoderValidator(),
  972. factory.GetResultWriter(),
  973. )
  974. routes = append(routes, &router.Route{
  975. Endpoint: getAppRevisionEndpoint,
  976. Handler: getAppRevisionHandler,
  977. Router: r,
  978. })
  979. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/revisions/{app_revision_id} -> porter_app.NewUpdateAppRevisionStatusHandler
  980. updateAppRevisionStatusEndpoint := factory.NewAPIEndpoint(
  981. &types.APIRequestMetadata{
  982. Verb: types.APIVerbUpdate,
  983. Method: types.HTTPVerbPost,
  984. Path: &types.Path{
  985. Parent: basePath,
  986. RelativePath: fmt.Sprintf("/apps/{%s}/revisions/{%s}", types.URLParamPorterAppName, types.URLParamAppRevisionID),
  987. },
  988. Scopes: []types.PermissionScope{
  989. types.UserScope,
  990. types.ProjectScope,
  991. types.ClusterScope,
  992. },
  993. },
  994. )
  995. updateAppRevisionStatusHandler := porter_app.NewUpdateAppRevisionStatusHandler(
  996. config,
  997. factory.GetDecoderValidator(),
  998. factory.GetResultWriter(),
  999. )
  1000. routes = append(routes, &router.Route{
  1001. Endpoint: updateAppRevisionStatusEndpoint,
  1002. Handler: updateAppRevisionStatusHandler,
  1003. Router: r,
  1004. })
  1005. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/revisions/{app_revision_id}/build-env -> porter_app.NewGetBuildEnvHandler
  1006. getBuildEnvEndpoint := factory.NewAPIEndpoint(
  1007. &types.APIRequestMetadata{
  1008. Verb: types.APIVerbGet,
  1009. Method: types.HTTPVerbGet,
  1010. Path: &types.Path{
  1011. Parent: basePath,
  1012. RelativePath: fmt.Sprintf("/apps/{%s}/revisions/{%s}/build-env", types.URLParamPorterAppName, types.URLParamAppRevisionID),
  1013. },
  1014. Scopes: []types.PermissionScope{
  1015. types.UserScope,
  1016. types.ProjectScope,
  1017. types.ClusterScope,
  1018. },
  1019. },
  1020. )
  1021. getBuildEnvHandler := porter_app.NewGetBuildEnvHandler(
  1022. config,
  1023. factory.GetDecoderValidator(),
  1024. factory.GetResultWriter(),
  1025. )
  1026. routes = append(routes, &router.Route{
  1027. Endpoint: getBuildEnvEndpoint,
  1028. Handler: getBuildEnvHandler,
  1029. Router: r,
  1030. })
  1031. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/update-environment -> porter_app.NewUpdateAppEnvironmentHandler
  1032. updateAppEnvironmentGroupEndpoint := factory.NewAPIEndpoint(
  1033. &types.APIRequestMetadata{
  1034. Verb: types.APIVerbUpdate,
  1035. Method: types.HTTPVerbPost,
  1036. Path: &types.Path{
  1037. Parent: basePath,
  1038. RelativePath: fmt.Sprintf("/apps/{%s}/update-environment", types.URLParamPorterAppName),
  1039. },
  1040. Scopes: []types.PermissionScope{
  1041. types.UserScope,
  1042. types.ProjectScope,
  1043. types.ClusterScope,
  1044. },
  1045. },
  1046. )
  1047. updateAppEnvironmentGroupHandler := porter_app.NewUpdateAppEnvironmentHandler(
  1048. config,
  1049. factory.GetDecoderValidator(),
  1050. factory.GetResultWriter(),
  1051. )
  1052. routes = append(routes, &router.Route{
  1053. Endpoint: updateAppEnvironmentGroupEndpoint,
  1054. Handler: updateAppEnvironmentGroupHandler,
  1055. Router: r,
  1056. })
  1057. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/revisions/{app_revision_id}/env -> porter_app.NewGetAppEnvHandler
  1058. getAppEnvEndpoint := factory.NewAPIEndpoint(
  1059. &types.APIRequestMetadata{
  1060. Verb: types.APIVerbGet,
  1061. Method: types.HTTPVerbGet,
  1062. Path: &types.Path{
  1063. Parent: basePath,
  1064. RelativePath: fmt.Sprintf("/apps/{%s}/revisions/{%s}/env", types.URLParamPorterAppName, types.URLParamAppRevisionID),
  1065. },
  1066. Scopes: []types.PermissionScope{
  1067. types.UserScope,
  1068. types.ProjectScope,
  1069. types.ClusterScope,
  1070. },
  1071. },
  1072. )
  1073. getAppEnvHandler := porter_app.NewGetAppEnvHandler(
  1074. config,
  1075. factory.GetDecoderValidator(),
  1076. factory.GetResultWriter(),
  1077. )
  1078. routes = append(routes, &router.Route{
  1079. Endpoint: getAppEnvEndpoint,
  1080. Handler: getAppEnvHandler,
  1081. Router: r,
  1082. })
  1083. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/events -> porter_app.NewPorterAppV2EventListHandler
  1084. listPorterAppV2EventsEndpoint := factory.NewAPIEndpoint(
  1085. &types.APIRequestMetadata{
  1086. Verb: types.APIVerbList,
  1087. Method: types.HTTPVerbGet,
  1088. Path: &types.Path{
  1089. Parent: basePath,
  1090. RelativePath: fmt.Sprintf("%s/{%s}/events", relPathV2, types.URLParamPorterAppName),
  1091. },
  1092. Scopes: []types.PermissionScope{
  1093. types.UserScope,
  1094. types.ProjectScope,
  1095. types.ClusterScope,
  1096. },
  1097. },
  1098. )
  1099. listPorterAppV2EventsHandler := porter_app.NewPorterAppV2EventListHandler(
  1100. config,
  1101. factory.GetDecoderValidator(),
  1102. factory.GetResultWriter(),
  1103. )
  1104. routes = append(routes, &router.Route{
  1105. Endpoint: listPorterAppV2EventsEndpoint,
  1106. Handler: listPorterAppV2EventsHandler,
  1107. Router: r,
  1108. })
  1109. // GET /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/templates -> porter_app.NewGetAppTemplateHandler
  1110. getAppTemplateEndpoint := factory.NewAPIEndpoint(
  1111. &types.APIRequestMetadata{
  1112. Verb: types.APIVerbGet,
  1113. Method: types.HTTPVerbGet,
  1114. Path: &types.Path{
  1115. Parent: basePath,
  1116. RelativePath: fmt.Sprintf("%s/{%s}/templates", relPathV2, types.URLParamPorterAppName),
  1117. },
  1118. Scopes: []types.PermissionScope{
  1119. types.UserScope,
  1120. types.ProjectScope,
  1121. types.ClusterScope,
  1122. },
  1123. },
  1124. )
  1125. getAppTemplateHandler := porter_app.NewGetAppTemplateHandler(
  1126. config,
  1127. factory.GetDecoderValidator(),
  1128. factory.GetResultWriter(),
  1129. )
  1130. routes = append(routes, &router.Route{
  1131. Endpoint: getAppTemplateEndpoint,
  1132. Handler: getAppTemplateHandler,
  1133. Router: r,
  1134. })
  1135. // POST /api/projects/{project_id}/clusters/{cluster_id}/apps/{porter_app_name}/templates -> porter_app.NewCreateAppTemplateHandler
  1136. createAppTemplateEndpoint := factory.NewAPIEndpoint(
  1137. &types.APIRequestMetadata{
  1138. Verb: types.APIVerbCreate,
  1139. Method: types.HTTPVerbPost,
  1140. Path: &types.Path{
  1141. Parent: basePath,
  1142. RelativePath: fmt.Sprintf("%s/{%s}/templates", relPathV2, types.URLParamPorterAppName),
  1143. },
  1144. Scopes: []types.PermissionScope{
  1145. types.UserScope,
  1146. types.ProjectScope,
  1147. types.ClusterScope,
  1148. },
  1149. },
  1150. )
  1151. createAppTemplateHandler := porter_app.NewCreateAppTemplateHandler(
  1152. config,
  1153. factory.GetDecoderValidator(),
  1154. factory.GetResultWriter(),
  1155. )
  1156. routes = append(routes, &router.Route{
  1157. Endpoint: createAppTemplateEndpoint,
  1158. Handler: createAppTemplateHandler,
  1159. Router: r,
  1160. })
  1161. return routes, newPath
  1162. }