router.go 25 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228
  1. package router
  2. import (
  3. "net/http"
  4. "os"
  5. "github.com/go-chi/chi"
  6. "github.com/porter-dev/porter/internal/auth/token"
  7. "github.com/porter-dev/porter/server/api"
  8. "github.com/porter-dev/porter/server/requestlog"
  9. mw "github.com/porter-dev/porter/server/router/middleware"
  10. )
  11. // New creates a new Chi router instance and registers all routes supported by the
  12. // API
  13. func New(a *api.App) *chi.Mux {
  14. l := a.Logger
  15. r := chi.NewRouter()
  16. auth := mw.NewAuth(a.Store, a.ServerConf.CookieName, &token.TokenGeneratorConf{
  17. TokenSecret: a.ServerConf.TokenGeneratorSecret,
  18. }, a.Repo)
  19. r.Route("/api", func(r chi.Router) {
  20. r.Use(mw.ContentTypeJSON)
  21. // health checks
  22. r.Method("GET", "/livez", http.HandlerFunc(a.HandleLive))
  23. r.Method("GET", "/readyz", http.HandlerFunc(a.HandleReady))
  24. // /api/users routes
  25. r.Method(
  26. "GET",
  27. "/users/{user_id}",
  28. auth.DoesUserIDMatch(
  29. requestlog.NewHandler(a.HandleReadUser, l),
  30. mw.URLParam,
  31. ),
  32. )
  33. r.Method(
  34. "GET",
  35. "/users/{user_id}/projects",
  36. auth.DoesUserIDMatch(
  37. requestlog.NewHandler(a.HandleListUserProjects, l),
  38. mw.URLParam,
  39. ),
  40. )
  41. r.Method(
  42. "POST",
  43. "/users",
  44. requestlog.NewHandler(a.HandleCreateUser, l),
  45. )
  46. r.Method(
  47. "DELETE",
  48. "/users/{user_id}",
  49. auth.DoesUserIDMatch(
  50. requestlog.NewHandler(a.HandleDeleteUser, l),
  51. mw.URLParam,
  52. ),
  53. )
  54. r.Method(
  55. "GET",
  56. "/cli/login",
  57. auth.BasicAuthenticateWithRedirect(
  58. requestlog.NewHandler(a.HandleCLILoginUser, l),
  59. ),
  60. )
  61. r.Method(
  62. "GET",
  63. "/cli/login/exchange",
  64. requestlog.NewHandler(a.HandleCLILoginExchangeToken, l),
  65. )
  66. r.Method(
  67. "POST",
  68. "/login",
  69. requestlog.NewHandler(a.HandleLoginUser, l),
  70. )
  71. r.Method(
  72. "GET",
  73. "/auth/check",
  74. auth.BasicAuthenticate(
  75. requestlog.NewHandler(a.HandleAuthCheck, l),
  76. ),
  77. )
  78. r.Method(
  79. "POST",
  80. "/logout",
  81. auth.BasicAuthenticate(
  82. requestlog.NewHandler(a.HandleLogoutUser, l),
  83. ),
  84. )
  85. r.Method(
  86. "POST",
  87. "/email/verify/initiate",
  88. auth.BasicAuthenticate(
  89. requestlog.NewHandler(a.InitiateEmailVerifyUser, l),
  90. ),
  91. )
  92. r.Method(
  93. "GET",
  94. "/email/verify/finalize",
  95. auth.BasicAuthenticateWithRedirect(
  96. requestlog.NewHandler(a.FinalizEmailVerifyUser, l),
  97. ),
  98. )
  99. r.Method(
  100. "POST",
  101. "/password/reset/initiate",
  102. requestlog.NewHandler(a.InitiatePWResetUser, l),
  103. )
  104. r.Method(
  105. "POST",
  106. "/password/reset/verify",
  107. requestlog.NewHandler(a.VerifyPWResetUser, l),
  108. )
  109. r.Method(
  110. "POST",
  111. "/password/reset/finalize",
  112. requestlog.NewHandler(a.FinalizPWResetUser, l),
  113. )
  114. // /api/integrations routes
  115. r.Method(
  116. "GET",
  117. "/integrations/cluster",
  118. auth.BasicAuthenticate(
  119. requestlog.NewHandler(a.HandleListClusterIntegrations, l),
  120. ),
  121. )
  122. r.Method(
  123. "GET",
  124. "/integrations/registry",
  125. auth.BasicAuthenticate(
  126. requestlog.NewHandler(a.HandleListRegistryIntegrations, l),
  127. ),
  128. )
  129. r.Method(
  130. "GET",
  131. "/integrations/helm",
  132. auth.BasicAuthenticate(
  133. requestlog.NewHandler(a.HandleListHelmRepoIntegrations, l),
  134. ),
  135. )
  136. r.Method(
  137. "GET",
  138. "/integrations/repo",
  139. auth.BasicAuthenticate(
  140. requestlog.NewHandler(a.HandleListRepoIntegrations, l),
  141. ),
  142. )
  143. // /api/templates routes
  144. r.Method(
  145. "GET",
  146. "/templates",
  147. auth.BasicAuthenticate(
  148. requestlog.NewHandler(a.HandleListTemplates, l),
  149. ),
  150. )
  151. r.Method(
  152. "GET",
  153. "/templates/{name}/{version}",
  154. auth.BasicAuthenticate(
  155. requestlog.NewHandler(a.HandleReadTemplate, l),
  156. ),
  157. )
  158. // /api/oauth routes
  159. r.Method(
  160. "GET",
  161. "/oauth/projects/{project_id}/github",
  162. auth.DoesUserHaveProjectAccess(
  163. requestlog.NewHandler(a.HandleGithubOAuthStartProject, l),
  164. mw.URLParam,
  165. mw.WriteAccess,
  166. ),
  167. )
  168. r.Method(
  169. "GET",
  170. "/oauth/login/github",
  171. requestlog.NewHandler(a.HandleGithubOAuthStartUser, l),
  172. )
  173. r.Method(
  174. "GET",
  175. "/oauth/github/callback",
  176. requestlog.NewHandler(a.HandleGithubOAuthCallback, l),
  177. )
  178. r.Method(
  179. "GET",
  180. "/oauth/projects/{project_id}/digitalocean",
  181. auth.DoesUserHaveProjectAccess(
  182. requestlog.NewHandler(a.HandleDOOAuthStartProject, l),
  183. mw.URLParam,
  184. mw.WriteAccess,
  185. ),
  186. )
  187. r.Method(
  188. "GET",
  189. "/oauth/digitalocean/callback",
  190. requestlog.NewHandler(a.HandleDOOAuthCallback, l),
  191. )
  192. // /api/projects routes
  193. r.Method(
  194. "GET",
  195. "/projects/{project_id}",
  196. auth.DoesUserHaveProjectAccess(
  197. requestlog.NewHandler(a.HandleReadProject, l),
  198. mw.URLParam,
  199. mw.ReadAccess,
  200. ),
  201. )
  202. r.Method(
  203. "POST",
  204. "/projects",
  205. auth.BasicAuthenticate(
  206. requestlog.NewHandler(a.HandleCreateProject, l),
  207. ),
  208. )
  209. r.Method(
  210. "DELETE",
  211. "/projects/{project_id}",
  212. auth.DoesUserHaveProjectAccess(
  213. requestlog.NewHandler(a.HandleDeleteProject, l),
  214. mw.URLParam,
  215. mw.WriteAccess,
  216. ),
  217. )
  218. // /api/projects/{project_id}/ci routes
  219. r.Method(
  220. "POST",
  221. "/projects/{project_id}/ci/actions",
  222. auth.DoesUserHaveProjectAccess(
  223. auth.DoesUserHaveClusterAccess(
  224. requestlog.NewHandler(a.HandleCreateGitAction, l),
  225. mw.URLParam,
  226. mw.QueryParam,
  227. ),
  228. mw.URLParam,
  229. mw.ReadAccess,
  230. ),
  231. )
  232. // /api/projects/{project_id}/invites routes
  233. r.Method(
  234. "POST",
  235. "/projects/{project_id}/invites",
  236. auth.DoesUserHaveProjectAccess(
  237. requestlog.NewHandler(a.HandleCreateInvite, l),
  238. mw.URLParam,
  239. mw.WriteAccess,
  240. ),
  241. )
  242. r.Method(
  243. "GET",
  244. "/projects/{project_id}/invites",
  245. auth.DoesUserHaveProjectAccess(
  246. requestlog.NewHandler(a.HandleListProjectInvites, l),
  247. mw.URLParam,
  248. mw.ReadAccess,
  249. ),
  250. )
  251. r.Method(
  252. "GET",
  253. "/projects/{project_id}/invites/{token}",
  254. auth.BasicAuthenticateWithRedirect(
  255. requestlog.NewHandler(a.HandleAcceptInvite, l),
  256. ),
  257. )
  258. r.Method(
  259. "DELETE",
  260. "/projects/{project_id}/invites/{invite_id}",
  261. auth.DoesUserHaveProjectAccess(
  262. auth.DoesUserHaveInviteAccess(
  263. requestlog.NewHandler(a.HandleDeleteProjectInvite, l),
  264. mw.URLParam,
  265. mw.URLParam,
  266. ),
  267. mw.URLParam,
  268. mw.WriteAccess,
  269. ),
  270. )
  271. // /api/projects/{project_id}/infra routes
  272. r.Method(
  273. "GET",
  274. "/projects/{project_id}/infra",
  275. auth.DoesUserHaveProjectAccess(
  276. requestlog.NewHandler(a.HandleListProjectInfra, l),
  277. mw.URLParam,
  278. mw.ReadAccess,
  279. ),
  280. )
  281. // /api/projects/{project_id}/provision routes
  282. r.Method(
  283. "POST",
  284. "/projects/{project_id}/provision/test",
  285. auth.DoesUserHaveProjectAccess(
  286. requestlog.NewHandler(a.HandleProvisionTestInfra, l),
  287. mw.URLParam,
  288. mw.ReadAccess,
  289. ),
  290. )
  291. r.Method(
  292. "POST",
  293. "/projects/{project_id}/provision/ecr",
  294. auth.DoesUserHaveProjectAccess(
  295. auth.DoesUserHaveAWSIntegrationAccess(
  296. requestlog.NewHandler(a.HandleProvisionAWSECRInfra, l),
  297. mw.URLParam,
  298. mw.BodyParam,
  299. false,
  300. ),
  301. mw.URLParam,
  302. mw.ReadAccess,
  303. ),
  304. )
  305. r.Method(
  306. "POST",
  307. "/projects/{project_id}/provision/eks",
  308. auth.DoesUserHaveProjectAccess(
  309. auth.DoesUserHaveAWSIntegrationAccess(
  310. requestlog.NewHandler(a.HandleProvisionAWSEKSInfra, l),
  311. mw.URLParam,
  312. mw.BodyParam,
  313. false,
  314. ),
  315. mw.URLParam,
  316. mw.ReadAccess,
  317. ),
  318. )
  319. r.Method(
  320. "POST",
  321. "/projects/{project_id}/provision/gcr",
  322. auth.DoesUserHaveProjectAccess(
  323. auth.DoesUserHaveGCPIntegrationAccess(
  324. requestlog.NewHandler(a.HandleProvisionGCPGCRInfra, l),
  325. mw.URLParam,
  326. mw.BodyParam,
  327. false,
  328. ),
  329. mw.URLParam,
  330. mw.ReadAccess,
  331. ),
  332. )
  333. r.Method(
  334. "POST",
  335. "/projects/{project_id}/provision/gke",
  336. auth.DoesUserHaveProjectAccess(
  337. auth.DoesUserHaveGCPIntegrationAccess(
  338. requestlog.NewHandler(a.HandleProvisionGCPGKEInfra, l),
  339. mw.URLParam,
  340. mw.BodyParam,
  341. false,
  342. ),
  343. mw.URLParam,
  344. mw.ReadAccess,
  345. ),
  346. )
  347. r.Method(
  348. "POST",
  349. "/projects/{project_id}/provision/docr",
  350. auth.DoesUserHaveProjectAccess(
  351. auth.DoesUserHaveDOIntegrationAccess(
  352. requestlog.NewHandler(a.HandleProvisionDODOCRInfra, l),
  353. mw.URLParam,
  354. mw.BodyParam,
  355. false,
  356. ),
  357. mw.URLParam,
  358. mw.ReadAccess,
  359. ),
  360. )
  361. r.Method(
  362. "POST",
  363. "/projects/{project_id}/provision/doks",
  364. auth.DoesUserHaveProjectAccess(
  365. auth.DoesUserHaveDOIntegrationAccess(
  366. requestlog.NewHandler(a.HandleProvisionDODOKSInfra, l),
  367. mw.URLParam,
  368. mw.BodyParam,
  369. false,
  370. ),
  371. mw.URLParam,
  372. mw.ReadAccess,
  373. ),
  374. )
  375. r.Method(
  376. "GET",
  377. "/projects/{project_id}/provision/{kind}/{infra_id}/logs",
  378. auth.DoesUserHaveProjectAccess(
  379. auth.DoesUserHaveInfraAccess(
  380. requestlog.NewHandler(a.HandleGetProvisioningLogs, l),
  381. mw.URLParam,
  382. mw.URLParam,
  383. ),
  384. mw.URLParam,
  385. mw.ReadAccess,
  386. ),
  387. )
  388. r.Method(
  389. "POST",
  390. "/projects/{project_id}/provision/{kind}/{infra_id}/logs",
  391. auth.DoesUserHaveProjectAccess(
  392. auth.DoesUserHaveInfraAccess(
  393. requestlog.NewHandler(a.HandleGetProvisioningLogs, l),
  394. mw.URLParam,
  395. mw.URLParam,
  396. ),
  397. mw.URLParam,
  398. mw.ReadAccess,
  399. ),
  400. )
  401. r.Method(
  402. "POST",
  403. "/projects/{project_id}/infra/{infra_id}/ecr/destroy",
  404. auth.DoesUserHaveProjectAccess(
  405. auth.DoesUserHaveInfraAccess(
  406. requestlog.NewHandler(a.HandleDestroyAWSECRInfra, l),
  407. mw.URLParam,
  408. mw.URLParam,
  409. ),
  410. mw.URLParam,
  411. mw.ReadAccess,
  412. ),
  413. )
  414. r.Method(
  415. "POST",
  416. "/projects/{project_id}/infra/{infra_id}/test/destroy",
  417. auth.DoesUserHaveProjectAccess(
  418. auth.DoesUserHaveInfraAccess(
  419. requestlog.NewHandler(a.HandleDestroyTestInfra, l),
  420. mw.URLParam,
  421. mw.URLParam,
  422. ),
  423. mw.URLParam,
  424. mw.ReadAccess,
  425. ),
  426. )
  427. r.Method(
  428. "POST",
  429. "/projects/{project_id}/infra/{infra_id}/eks/destroy",
  430. auth.DoesUserHaveProjectAccess(
  431. auth.DoesUserHaveInfraAccess(
  432. requestlog.NewHandler(a.HandleDestroyAWSEKSInfra, l),
  433. mw.URLParam,
  434. mw.URLParam,
  435. ),
  436. mw.URLParam,
  437. mw.ReadAccess,
  438. ),
  439. )
  440. r.Method(
  441. "POST",
  442. "/projects/{project_id}/infra/{infra_id}/gke/destroy",
  443. auth.DoesUserHaveProjectAccess(
  444. auth.DoesUserHaveInfraAccess(
  445. requestlog.NewHandler(a.HandleDestroyGCPGKEInfra, l),
  446. mw.URLParam,
  447. mw.URLParam,
  448. ),
  449. mw.URLParam,
  450. mw.ReadAccess,
  451. ),
  452. )
  453. r.Method(
  454. "POST",
  455. "/projects/{project_id}/infra/{infra_id}/docr/destroy",
  456. auth.DoesUserHaveProjectAccess(
  457. auth.DoesUserHaveInfraAccess(
  458. requestlog.NewHandler(a.HandleDestroyDODOCRInfra, l),
  459. mw.URLParam,
  460. mw.URLParam,
  461. ),
  462. mw.URLParam,
  463. mw.ReadAccess,
  464. ),
  465. )
  466. r.Method(
  467. "POST",
  468. "/projects/{project_id}/infra/{infra_id}/doks/destroy",
  469. auth.DoesUserHaveProjectAccess(
  470. auth.DoesUserHaveInfraAccess(
  471. requestlog.NewHandler(a.HandleDestroyDODOKSInfra, l),
  472. mw.URLParam,
  473. mw.URLParam,
  474. ),
  475. mw.URLParam,
  476. mw.ReadAccess,
  477. ),
  478. )
  479. // /api/projects/{project_id}/clusters routes
  480. r.Method(
  481. "GET",
  482. "/projects/{project_id}/clusters",
  483. auth.DoesUserHaveProjectAccess(
  484. requestlog.NewHandler(a.HandleListProjectClusters, l),
  485. mw.URLParam,
  486. mw.ReadAccess,
  487. ),
  488. )
  489. r.Method(
  490. "POST",
  491. "/projects/{project_id}/clusters",
  492. auth.DoesUserHaveProjectAccess(
  493. auth.DoesUserHaveAWSIntegrationAccess(
  494. auth.DoesUserHaveGCPIntegrationAccess(
  495. requestlog.NewHandler(a.HandleCreateProjectCluster, l),
  496. mw.URLParam,
  497. mw.BodyParam,
  498. true,
  499. ),
  500. mw.URLParam,
  501. mw.BodyParam,
  502. true,
  503. ),
  504. mw.URLParam,
  505. mw.WriteAccess,
  506. ),
  507. )
  508. r.Method(
  509. "GET",
  510. "/projects/{project_id}/clusters/{cluster_id}",
  511. auth.DoesUserHaveProjectAccess(
  512. auth.DoesUserHaveClusterAccess(
  513. requestlog.NewHandler(a.HandleReadProjectCluster, l),
  514. mw.URLParam,
  515. mw.URLParam,
  516. ),
  517. mw.URLParam,
  518. mw.ReadAccess,
  519. ),
  520. )
  521. r.Method(
  522. "POST",
  523. "/projects/{project_id}/clusters/{cluster_id}",
  524. auth.DoesUserHaveProjectAccess(
  525. auth.DoesUserHaveClusterAccess(
  526. requestlog.NewHandler(a.HandleUpdateProjectCluster, l),
  527. mw.URLParam,
  528. mw.URLParam,
  529. ),
  530. mw.URLParam,
  531. mw.WriteAccess,
  532. ),
  533. )
  534. r.Method(
  535. "DELETE",
  536. "/projects/{project_id}/clusters/{cluster_id}",
  537. auth.DoesUserHaveProjectAccess(
  538. auth.DoesUserHaveClusterAccess(
  539. requestlog.NewHandler(a.HandleDeleteProjectCluster, l),
  540. mw.URLParam,
  541. mw.URLParam,
  542. ),
  543. mw.URLParam,
  544. mw.WriteAccess,
  545. ),
  546. )
  547. // /api/projects/{project_id}/clusters/candidates routes
  548. r.Method(
  549. "POST",
  550. "/projects/{project_id}/clusters/candidates",
  551. auth.DoesUserHaveProjectAccess(
  552. requestlog.NewHandler(a.HandleCreateProjectClusterCandidates, l),
  553. mw.URLParam,
  554. mw.WriteAccess,
  555. ),
  556. )
  557. r.Method(
  558. "GET",
  559. "/projects/{project_id}/clusters/candidates",
  560. auth.DoesUserHaveProjectAccess(
  561. requestlog.NewHandler(a.HandleListProjectClusterCandidates, l),
  562. mw.URLParam,
  563. mw.WriteAccess,
  564. ),
  565. )
  566. r.Method(
  567. "POST",
  568. "/projects/{project_id}/clusters/candidates/{candidate_id}/resolve",
  569. auth.DoesUserHaveProjectAccess(
  570. requestlog.NewHandler(a.HandleResolveClusterCandidate, l),
  571. mw.URLParam,
  572. mw.WriteAccess,
  573. ),
  574. )
  575. // /api/projects/{project_id}/integrations routes
  576. r.Method(
  577. "POST",
  578. "/projects/{project_id}/integrations/gcp",
  579. auth.DoesUserHaveProjectAccess(
  580. requestlog.NewHandler(a.HandleCreateGCPIntegration, l),
  581. mw.URLParam,
  582. mw.WriteAccess,
  583. ),
  584. )
  585. r.Method(
  586. "POST",
  587. "/projects/{project_id}/integrations/aws",
  588. auth.DoesUserHaveProjectAccess(
  589. requestlog.NewHandler(a.HandleCreateAWSIntegration, l),
  590. mw.URLParam,
  591. mw.WriteAccess,
  592. ),
  593. )
  594. r.Method(
  595. "POST",
  596. "/projects/{project_id}/integrations/basic",
  597. auth.DoesUserHaveProjectAccess(
  598. requestlog.NewHandler(a.HandleCreateBasicAuthIntegration, l),
  599. mw.URLParam,
  600. mw.WriteAccess,
  601. ),
  602. )
  603. r.Method(
  604. "GET",
  605. "/projects/{project_id}/integrations/oauth",
  606. auth.DoesUserHaveProjectAccess(
  607. requestlog.NewHandler(a.HandleListProjectOAuthIntegrations, l),
  608. mw.URLParam,
  609. mw.WriteAccess,
  610. ),
  611. )
  612. // /api/projects/{project_id}/helmrepos routes
  613. r.Method(
  614. "POST",
  615. "/projects/{project_id}/helmrepos",
  616. auth.DoesUserHaveProjectAccess(
  617. auth.DoesUserHaveAWSIntegrationAccess(
  618. auth.DoesUserHaveGCPIntegrationAccess(
  619. requestlog.NewHandler(a.HandleCreateHelmRepo, l),
  620. mw.URLParam,
  621. mw.BodyParam,
  622. true,
  623. ),
  624. mw.URLParam,
  625. mw.BodyParam,
  626. true,
  627. ),
  628. mw.URLParam,
  629. mw.WriteAccess,
  630. ),
  631. )
  632. r.Method(
  633. "GET",
  634. "/projects/{project_id}/helmrepos",
  635. auth.DoesUserHaveProjectAccess(
  636. requestlog.NewHandler(a.HandleListProjectHelmRepos, l),
  637. mw.URLParam,
  638. mw.WriteAccess,
  639. ),
  640. )
  641. r.Method(
  642. "GET",
  643. "/projects/{project_id}/helmrepos/{helm_id}/charts",
  644. auth.DoesUserHaveProjectAccess(
  645. requestlog.NewHandler(a.HandleListHelmRepoCharts, l),
  646. mw.URLParam,
  647. mw.WriteAccess,
  648. ),
  649. )
  650. // /api/projects/{project_id}/registries routes
  651. r.Method(
  652. "POST",
  653. "/projects/{project_id}/registries",
  654. auth.DoesUserHaveProjectAccess(
  655. auth.DoesUserHaveAWSIntegrationAccess(
  656. auth.DoesUserHaveGCPIntegrationAccess(
  657. auth.DoesUserHaveDOIntegrationAccess(
  658. requestlog.NewHandler(a.HandleCreateRegistry, l),
  659. mw.URLParam,
  660. mw.BodyParam,
  661. true,
  662. ),
  663. mw.URLParam,
  664. mw.BodyParam,
  665. true,
  666. ),
  667. mw.URLParam,
  668. mw.BodyParam,
  669. true,
  670. ),
  671. mw.URLParam,
  672. mw.WriteAccess,
  673. ),
  674. )
  675. r.Method(
  676. "GET",
  677. "/projects/{project_id}/registries",
  678. auth.DoesUserHaveProjectAccess(
  679. requestlog.NewHandler(a.HandleListProjectRegistries, l),
  680. mw.URLParam,
  681. mw.WriteAccess,
  682. ),
  683. )
  684. r.Method(
  685. "POST",
  686. "/projects/{project_id}/registries/{registry_id}",
  687. auth.DoesUserHaveProjectAccess(
  688. auth.DoesUserHaveRegistryAccess(
  689. requestlog.NewHandler(a.HandleUpdateProjectRegistry, l),
  690. mw.URLParam,
  691. mw.URLParam,
  692. ),
  693. mw.URLParam,
  694. mw.WriteAccess,
  695. ),
  696. )
  697. r.Method(
  698. "GET",
  699. "/projects/{project_id}/registries/ecr/{region}/token",
  700. auth.DoesUserHaveProjectAccess(
  701. requestlog.NewHandler(a.HandleGetProjectRegistryECRToken, l),
  702. mw.URLParam,
  703. mw.WriteAccess,
  704. ),
  705. )
  706. r.Method(
  707. "GET",
  708. "/projects/{project_id}/registries/gcr/token",
  709. auth.DoesUserHaveProjectAccess(
  710. requestlog.NewHandler(a.HandleGetProjectRegistryGCRToken, l),
  711. mw.URLParam,
  712. mw.WriteAccess,
  713. ),
  714. )
  715. r.Method(
  716. "GET",
  717. "/projects/{project_id}/registries/dockerhub/token",
  718. auth.DoesUserHaveProjectAccess(
  719. requestlog.NewHandler(a.HandleGetProjectRegistryDockerhubToken, l),
  720. mw.URLParam,
  721. mw.WriteAccess,
  722. ),
  723. )
  724. r.Method(
  725. "GET",
  726. "/projects/{project_id}/registries/docr/token",
  727. auth.DoesUserHaveProjectAccess(
  728. requestlog.NewHandler(a.HandleGetProjectRegistryDOCRToken, l),
  729. mw.URLParam,
  730. mw.WriteAccess,
  731. ),
  732. )
  733. r.Method(
  734. "DELETE",
  735. "/projects/{project_id}/registries/{registry_id}",
  736. auth.DoesUserHaveProjectAccess(
  737. auth.DoesUserHaveRegistryAccess(
  738. requestlog.NewHandler(a.HandleDeleteProjectRegistry, l),
  739. mw.URLParam,
  740. mw.URLParam,
  741. ),
  742. mw.URLParam,
  743. mw.WriteAccess,
  744. ),
  745. )
  746. // /api/projects/{project_id}/registries/{registry_id}/repositories routes
  747. r.Method(
  748. "GET",
  749. "/projects/{project_id}/registries/{registry_id}/repositories",
  750. auth.DoesUserHaveProjectAccess(
  751. auth.DoesUserHaveRegistryAccess(
  752. requestlog.NewHandler(a.HandleListRepositories, l),
  753. mw.URLParam,
  754. mw.URLParam,
  755. ),
  756. mw.URLParam,
  757. mw.WriteAccess,
  758. ),
  759. )
  760. r.Method(
  761. "GET",
  762. // * is the repo name, which can itself be nested
  763. // for example, for GCR this is project-id/repo
  764. // need to use wildcard, see https://github.com/go-chi/chi/issues/243
  765. "/projects/{project_id}/registries/{registry_id}/repositories/*",
  766. auth.DoesUserHaveProjectAccess(
  767. auth.DoesUserHaveRegistryAccess(
  768. requestlog.NewHandler(a.HandleListImages, l),
  769. mw.URLParam,
  770. mw.URLParam,
  771. ),
  772. mw.URLParam,
  773. mw.WriteAccess,
  774. ),
  775. )
  776. // /api/projects/{project_id}/releases routes
  777. r.Method(
  778. "GET",
  779. "/projects/{project_id}/releases",
  780. auth.DoesUserHaveProjectAccess(
  781. auth.DoesUserHaveClusterAccess(
  782. requestlog.NewHandler(a.HandleListReleases, l),
  783. mw.URLParam,
  784. mw.QueryParam,
  785. ),
  786. mw.URLParam,
  787. mw.ReadAccess,
  788. ),
  789. )
  790. r.Method(
  791. "GET",
  792. "/projects/{project_id}/releases/{name}/{revision}/components",
  793. auth.DoesUserHaveProjectAccess(
  794. auth.DoesUserHaveClusterAccess(
  795. requestlog.NewHandler(a.HandleGetReleaseComponents, l),
  796. mw.URLParam,
  797. mw.QueryParam,
  798. ),
  799. mw.URLParam,
  800. mw.ReadAccess,
  801. ),
  802. )
  803. r.Method(
  804. "GET",
  805. "/projects/{project_id}/releases/{name}/{revision}/controllers",
  806. auth.DoesUserHaveProjectAccess(
  807. auth.DoesUserHaveClusterAccess(
  808. requestlog.NewHandler(a.HandleGetReleaseControllers, l),
  809. mw.URLParam,
  810. mw.QueryParam,
  811. ),
  812. mw.URLParam,
  813. mw.ReadAccess,
  814. ),
  815. )
  816. r.Method(
  817. "GET",
  818. "/projects/{project_id}/releases/{name}/history",
  819. auth.DoesUserHaveProjectAccess(
  820. auth.DoesUserHaveClusterAccess(
  821. requestlog.NewHandler(a.HandleListReleaseHistory, l),
  822. mw.URLParam,
  823. mw.QueryParam,
  824. ),
  825. mw.URLParam,
  826. mw.ReadAccess,
  827. ),
  828. )
  829. r.Method(
  830. "GET",
  831. "/projects/{project_id}/releases/{name}/webhook_token",
  832. auth.DoesUserHaveProjectAccess(
  833. auth.DoesUserHaveClusterAccess(
  834. requestlog.NewHandler(a.HandleGetReleaseToken, l),
  835. mw.URLParam,
  836. mw.QueryParam,
  837. ),
  838. mw.URLParam,
  839. mw.ReadAccess,
  840. ),
  841. )
  842. r.Method(
  843. "POST",
  844. "/projects/{project_id}/releases/{name}/upgrade",
  845. auth.DoesUserHaveProjectAccess(
  846. auth.DoesUserHaveClusterAccess(
  847. requestlog.NewHandler(a.HandleUpgradeRelease, l),
  848. mw.URLParam,
  849. mw.QueryParam,
  850. ),
  851. mw.URLParam,
  852. mw.ReadAccess,
  853. ),
  854. )
  855. r.Method(
  856. "GET",
  857. "/projects/{project_id}/releases/{name}/{revision}",
  858. auth.DoesUserHaveProjectAccess(
  859. auth.DoesUserHaveClusterAccess(
  860. requestlog.NewHandler(a.HandleGetRelease, l),
  861. mw.URLParam,
  862. mw.QueryParam,
  863. ),
  864. mw.URLParam,
  865. mw.ReadAccess,
  866. ),
  867. )
  868. r.Method(
  869. "POST",
  870. "/projects/{project_id}/releases/{name}/rollback",
  871. auth.DoesUserHaveProjectAccess(
  872. auth.DoesUserHaveClusterAccess(
  873. requestlog.NewHandler(a.HandleRollbackRelease, l),
  874. mw.URLParam,
  875. mw.QueryParam,
  876. ),
  877. mw.URLParam,
  878. mw.ReadAccess,
  879. ),
  880. )
  881. r.Method(
  882. "POST",
  883. "/webhooks/deploy/{token}",
  884. requestlog.NewHandler(a.HandleReleaseDeployWebhook, l),
  885. )
  886. // /api/projects/{project_id}/gitrepos routes
  887. r.Method(
  888. "GET",
  889. "/projects/{project_id}/gitrepos",
  890. auth.DoesUserHaveProjectAccess(
  891. requestlog.NewHandler(a.HandleListProjectGitRepos, l),
  892. mw.URLParam,
  893. mw.ReadAccess,
  894. ),
  895. )
  896. r.Method(
  897. "DELETE",
  898. "/projects/{project_id}/gitrepos/{git_repo_id}",
  899. auth.DoesUserHaveProjectAccess(
  900. auth.DoesUserHaveGitRepoAccess(
  901. requestlog.NewHandler(a.HandleDeleteProjectGitRepo, l),
  902. mw.URLParam,
  903. mw.URLParam,
  904. ),
  905. mw.URLParam,
  906. mw.WriteAccess,
  907. ),
  908. )
  909. r.Method(
  910. "GET",
  911. "/projects/{project_id}/gitrepos/{git_repo_id}/repos",
  912. auth.DoesUserHaveProjectAccess(
  913. auth.DoesUserHaveGitRepoAccess(
  914. requestlog.NewHandler(a.HandleListRepos, l),
  915. mw.URLParam,
  916. mw.URLParam,
  917. ),
  918. mw.URLParam,
  919. mw.ReadAccess,
  920. ),
  921. )
  922. r.Method(
  923. "GET",
  924. "/projects/{project_id}/gitrepos/{git_repo_id}/repos/{kind}/{owner}/{name}/branches",
  925. auth.DoesUserHaveProjectAccess(
  926. auth.DoesUserHaveGitRepoAccess(
  927. requestlog.NewHandler(a.HandleGetBranches, l),
  928. mw.URLParam,
  929. mw.URLParam,
  930. ),
  931. mw.URLParam,
  932. mw.ReadAccess,
  933. ),
  934. )
  935. r.Method(
  936. "GET",
  937. "/projects/{project_id}/gitrepos/{git_repo_id}/repos/{kind}/{owner}/{name}/{branch}/contents",
  938. auth.DoesUserHaveProjectAccess(
  939. auth.DoesUserHaveGitRepoAccess(
  940. requestlog.NewHandler(a.HandleGetBranchContents, l),
  941. mw.URLParam,
  942. mw.URLParam,
  943. ),
  944. mw.URLParam,
  945. mw.ReadAccess,
  946. ),
  947. )
  948. // /api/projects/{project_id}/deploy routes
  949. r.Method(
  950. "POST",
  951. "/projects/{project_id}/deploy/{name}/{version}",
  952. auth.DoesUserHaveProjectAccess(
  953. auth.DoesUserHaveClusterAccess(
  954. requestlog.NewHandler(a.HandleDeployTemplate, l),
  955. mw.URLParam,
  956. mw.QueryParam,
  957. ),
  958. mw.URLParam,
  959. mw.ReadAccess,
  960. ),
  961. )
  962. // /api/projects/{project_id}/deploy routes
  963. r.Method(
  964. "POST",
  965. "/projects/{project_id}/delete/{name}",
  966. auth.DoesUserHaveProjectAccess(
  967. auth.DoesUserHaveClusterAccess(
  968. requestlog.NewHandler(a.HandleUninstallTemplate, l),
  969. mw.URLParam,
  970. mw.QueryParam,
  971. ),
  972. mw.URLParam,
  973. mw.ReadAccess,
  974. ),
  975. )
  976. // /api/projects/{project_id}/k8s routes
  977. r.Method(
  978. "GET",
  979. "/projects/{project_id}/k8s/namespaces",
  980. auth.DoesUserHaveProjectAccess(
  981. auth.DoesUserHaveClusterAccess(
  982. requestlog.NewHandler(a.HandleListNamespaces, l),
  983. mw.URLParam,
  984. mw.QueryParam,
  985. ),
  986. mw.URLParam,
  987. mw.ReadAccess,
  988. ),
  989. )
  990. r.Method(
  991. "GET",
  992. "/projects/{project_id}/k8s/prometheus/detect",
  993. auth.DoesUserHaveProjectAccess(
  994. auth.DoesUserHaveClusterAccess(
  995. requestlog.NewHandler(a.HandleDetectPrometheusInstalled, l),
  996. mw.URLParam,
  997. mw.QueryParam,
  998. ),
  999. mw.URLParam,
  1000. mw.ReadAccess,
  1001. ),
  1002. )
  1003. r.Method(
  1004. "GET",
  1005. "/projects/{project_id}/k8s/prometheus/ingresses",
  1006. auth.DoesUserHaveProjectAccess(
  1007. auth.DoesUserHaveClusterAccess(
  1008. requestlog.NewHandler(a.HandleListNGINXIngresses, l),
  1009. mw.URLParam,
  1010. mw.QueryParam,
  1011. ),
  1012. mw.URLParam,
  1013. mw.ReadAccess,
  1014. ),
  1015. )
  1016. r.Method(
  1017. "GET",
  1018. "/projects/{project_id}/k8s/metrics",
  1019. auth.DoesUserHaveProjectAccess(
  1020. auth.DoesUserHaveClusterAccess(
  1021. requestlog.NewHandler(a.HandleGetPodMetrics, l),
  1022. mw.URLParam,
  1023. mw.QueryParam,
  1024. ),
  1025. mw.URLParam,
  1026. mw.ReadAccess,
  1027. ),
  1028. )
  1029. r.Method(
  1030. "GET",
  1031. "/projects/{project_id}/k8s/{namespace}/pod/{name}/logs",
  1032. auth.DoesUserHaveProjectAccess(
  1033. auth.DoesUserHaveClusterAccess(
  1034. requestlog.NewHandler(a.HandleGetPodLogs, l),
  1035. mw.URLParam,
  1036. mw.QueryParam,
  1037. ),
  1038. mw.URLParam,
  1039. mw.ReadAccess,
  1040. ),
  1041. )
  1042. r.Method(
  1043. "GET",
  1044. "/projects/{project_id}/k8s/{namespace}/ingress/{name}",
  1045. auth.DoesUserHaveProjectAccess(
  1046. auth.DoesUserHaveClusterAccess(
  1047. requestlog.NewHandler(a.HandleGetIngress, l),
  1048. mw.URLParam,
  1049. mw.QueryParam,
  1050. ),
  1051. mw.URLParam,
  1052. mw.ReadAccess,
  1053. ),
  1054. )
  1055. r.Method(
  1056. "GET",
  1057. "/projects/{project_id}/k8s/{kind}/status",
  1058. auth.DoesUserHaveProjectAccess(
  1059. auth.DoesUserHaveClusterAccess(
  1060. requestlog.NewHandler(a.HandleStreamControllerStatus, l),
  1061. mw.URLParam,
  1062. mw.QueryParam,
  1063. ),
  1064. mw.URLParam,
  1065. mw.ReadAccess,
  1066. ),
  1067. )
  1068. r.Method(
  1069. "GET",
  1070. "/projects/{project_id}/k8s/pods",
  1071. auth.DoesUserHaveProjectAccess(
  1072. auth.DoesUserHaveClusterAccess(
  1073. requestlog.NewHandler(a.HandleListPods, l),
  1074. mw.URLParam,
  1075. mw.QueryParam,
  1076. ),
  1077. mw.URLParam,
  1078. mw.ReadAccess,
  1079. ),
  1080. )
  1081. r.Method(
  1082. "DELETE",
  1083. "/projects/{project_id}/k8s/pods/{namespace}/{name}",
  1084. auth.DoesUserHaveProjectAccess(
  1085. auth.DoesUserHaveClusterAccess(
  1086. requestlog.NewHandler(a.HandleDeletePod, l),
  1087. mw.URLParam,
  1088. mw.QueryParam,
  1089. ),
  1090. mw.URLParam,
  1091. mw.ReadAccess,
  1092. ),
  1093. )
  1094. // /api/projects/{project_id}/subdomain routes
  1095. r.Method(
  1096. "POST",
  1097. "/projects/{project_id}/k8s/subdomain",
  1098. auth.DoesUserHaveProjectAccess(
  1099. auth.DoesUserHaveClusterAccess(
  1100. requestlog.NewHandler(a.HandleCreateDNSRecord, l),
  1101. mw.URLParam,
  1102. mw.QueryParam,
  1103. ),
  1104. mw.URLParam,
  1105. mw.ReadAccess,
  1106. ),
  1107. )
  1108. })
  1109. staticFilePath := a.ServerConf.StaticFilePath
  1110. fs := http.FileServer(http.Dir(staticFilePath))
  1111. r.Get("/*", func(w http.ResponseWriter, r *http.Request) {
  1112. if _, err := os.Stat(staticFilePath + r.RequestURI); os.IsNotExist(err) {
  1113. http.StripPrefix(r.URL.Path, fs).ServeHTTP(w, r)
  1114. } else {
  1115. fs.ServeHTTP(w, r)
  1116. }
  1117. })
  1118. return r
  1119. }