delete.go 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. package environment
  2. import (
  3. "net/http"
  4. "github.com/porter-dev/porter/api/server/handlers"
  5. "github.com/porter-dev/porter/api/server/handlers/gitinstallation"
  6. "github.com/porter-dev/porter/api/server/shared"
  7. "github.com/porter-dev/porter/api/server/shared/apierrors"
  8. "github.com/porter-dev/porter/api/server/shared/config"
  9. "github.com/porter-dev/porter/api/types"
  10. "github.com/porter-dev/porter/internal/integrations/ci/actions"
  11. "github.com/porter-dev/porter/internal/models"
  12. "github.com/porter-dev/porter/internal/models/integrations"
  13. )
  14. type DeleteEnvironmentHandler struct {
  15. handlers.PorterHandlerReadWriter
  16. }
  17. func NewDeleteEnvironmentHandler(
  18. config *config.Config,
  19. decoderValidator shared.RequestDecoderValidator,
  20. writer shared.ResultWriter,
  21. ) *DeleteEnvironmentHandler {
  22. return &DeleteEnvironmentHandler{
  23. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  24. }
  25. }
  26. func (c *DeleteEnvironmentHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  27. ga, _ := r.Context().Value(types.GitInstallationScope).(*integrations.GithubAppInstallation)
  28. project, _ := r.Context().Value(types.ProjectScope).(*models.Project)
  29. cluster, _ := r.Context().Value(types.ClusterScope).(*models.Cluster)
  30. owner, name, ok := gitinstallation.GetOwnerAndNameParams(c, w, r)
  31. if !ok {
  32. return
  33. }
  34. // read the environment to get the environment id
  35. env, err := c.Repo().Environment().ReadEnvironment(project.ID, cluster.ID, uint(ga.InstallationID), owner, name)
  36. if err != nil {
  37. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  38. return
  39. }
  40. // delete Github actions files from the repo
  41. client, err := getGithubClientFromEnvironment(c.Config(), env)
  42. if err != nil {
  43. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  44. return
  45. }
  46. err = actions.DeleteEnv(&actions.EnvOpts{
  47. Client: client,
  48. ServerURL: c.Config().ServerConf.ServerURL,
  49. GitRepoOwner: env.GitRepoOwner,
  50. GitRepoName: env.GitRepoName,
  51. ProjectID: project.ID,
  52. ClusterID: cluster.ID,
  53. GitInstallationID: uint(ga.InstallationID),
  54. EnvironmentName: env.Name,
  55. })
  56. if err != nil {
  57. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  58. return
  59. }
  60. // delete the environment
  61. env, err = c.Repo().Environment().DeleteEnvironment(env)
  62. if err != nil {
  63. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  64. return
  65. }
  66. c.WriteResult(w, r, env.ToEnvironmentType())
  67. }