router.go 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200
  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/metrics",
  1006. auth.DoesUserHaveProjectAccess(
  1007. auth.DoesUserHaveClusterAccess(
  1008. requestlog.NewHandler(a.HandleGetPodMetrics, 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/{namespace}/pod/{name}/logs",
  1019. auth.DoesUserHaveProjectAccess(
  1020. auth.DoesUserHaveClusterAccess(
  1021. requestlog.NewHandler(a.HandleGetPodLogs, 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}/ingress/{name}",
  1032. auth.DoesUserHaveProjectAccess(
  1033. auth.DoesUserHaveClusterAccess(
  1034. requestlog.NewHandler(a.HandleGetIngress, 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/{kind}/status",
  1045. auth.DoesUserHaveProjectAccess(
  1046. auth.DoesUserHaveClusterAccess(
  1047. requestlog.NewHandler(a.HandleStreamControllerStatus, 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/pods",
  1058. auth.DoesUserHaveProjectAccess(
  1059. auth.DoesUserHaveClusterAccess(
  1060. requestlog.NewHandler(a.HandleListPods, l),
  1061. mw.URLParam,
  1062. mw.QueryParam,
  1063. ),
  1064. mw.URLParam,
  1065. mw.ReadAccess,
  1066. ),
  1067. )
  1068. // /api/projects/{project_id}/subdomain routes
  1069. r.Method(
  1070. "POST",
  1071. "/projects/{project_id}/k8s/subdomain",
  1072. auth.DoesUserHaveProjectAccess(
  1073. auth.DoesUserHaveClusterAccess(
  1074. requestlog.NewHandler(a.HandleCreateDNSRecord, l),
  1075. mw.URLParam,
  1076. mw.QueryParam,
  1077. ),
  1078. mw.URLParam,
  1079. mw.ReadAccess,
  1080. ),
  1081. )
  1082. })
  1083. staticFilePath := a.ServerConf.StaticFilePath
  1084. fs := http.FileServer(http.Dir(staticFilePath))
  1085. r.Get("/*", func(w http.ResponseWriter, r *http.Request) {
  1086. if _, err := os.Stat(staticFilePath + r.RequestURI); os.IsNotExist(err) {
  1087. http.StripPrefix(r.URL.Path, fs).ServeHTTP(w, r)
  1088. } else {
  1089. fs.ServeHTTP(w, r)
  1090. }
  1091. })
  1092. return r
  1093. }