get_buildpack.go 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. package gitinstallation
  2. import (
  3. "context"
  4. "net/http"
  5. "github.com/google/go-github/github"
  6. "github.com/porter-dev/porter/api/server/authz"
  7. "github.com/porter-dev/porter/api/server/handlers"
  8. "github.com/porter-dev/porter/api/server/shared"
  9. "github.com/porter-dev/porter/api/server/shared/apierrors"
  10. "github.com/porter-dev/porter/api/server/shared/config"
  11. "github.com/porter-dev/porter/api/server/shared/requestutils"
  12. "github.com/porter-dev/porter/api/types"
  13. )
  14. type GithubGetBuildpackHandler struct {
  15. handlers.PorterHandlerReadWriter
  16. authz.KubernetesAgentGetter
  17. }
  18. func NewGithubGetBuildpackHandler(
  19. config *config.Config,
  20. decoderValidator shared.RequestDecoderValidator,
  21. writer shared.ResultWriter,
  22. ) *GithubGetBuildpackHandler {
  23. return &GithubGetBuildpackHandler{
  24. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  25. }
  26. }
  27. func (c *GithubGetBuildpackHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  28. request := &types.GetBuildpackRequest{}
  29. ok := c.DecodeAndValidate(w, r, request)
  30. if !ok {
  31. return
  32. }
  33. owner, name, ok := GetOwnerAndNameParams(c, w, r)
  34. if !ok {
  35. return
  36. }
  37. branch, reqErr := requestutils.GetURLParamString(r, types.URLParamGitBranch)
  38. if reqErr != nil {
  39. c.HandleAPIError(w, r, reqErr)
  40. return
  41. }
  42. client, err := GetGithubAppClientFromRequest(c.Config(), r)
  43. if err != nil {
  44. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  45. return
  46. }
  47. repoContentOptions := github.RepositoryContentGetOptions{}
  48. repoContentOptions.Ref = branch
  49. _, directoryContents, _, err := client.Repositories.GetContents(
  50. context.Background(),
  51. owner,
  52. name,
  53. request.Dir,
  54. &repoContentOptions,
  55. )
  56. if err != nil {
  57. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  58. return
  59. }
  60. var BREQS = map[string]string{
  61. "requirements.txt": "Python",
  62. "Gemfile": "Ruby",
  63. "package.json": "Node.js",
  64. "pom.xml": "Java",
  65. "composer.json": "PHP",
  66. }
  67. res := &types.GetBuildpackResponse{
  68. Valid: true,
  69. }
  70. matches := 0
  71. for i := range directoryContents {
  72. name := *directoryContents[i].Name
  73. bname, ok := BREQS[name]
  74. if ok {
  75. matches++
  76. res.Name = bname
  77. }
  78. }
  79. if matches != 1 {
  80. res.Valid = false
  81. res.Name = ""
  82. }
  83. c.WriteResult(w, r, res)
  84. }