router.go 25 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214
  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. // /api/projects/{project_id}/subdomain routes
  1082. r.Method(
  1083. "POST",
  1084. "/projects/{project_id}/k8s/subdomain",
  1085. auth.DoesUserHaveProjectAccess(
  1086. auth.DoesUserHaveClusterAccess(
  1087. requestlog.NewHandler(a.HandleCreateDNSRecord, l),
  1088. mw.URLParam,
  1089. mw.QueryParam,
  1090. ),
  1091. mw.URLParam,
  1092. mw.ReadAccess,
  1093. ),
  1094. )
  1095. })
  1096. staticFilePath := a.ServerConf.StaticFilePath
  1097. fs := http.FileServer(http.Dir(staticFilePath))
  1098. r.Get("/*", func(w http.ResponseWriter, r *http.Request) {
  1099. if _, err := os.Stat(staticFilePath + r.RequestURI); os.IsNotExist(err) {
  1100. http.StripPrefix(r.URL.Path, fs).ServeHTTP(w, r)
  1101. } else {
  1102. fs.ServeHTTP(w, r)
  1103. }
  1104. })
  1105. return r
  1106. }