get_procfile.go 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. package gitinstallation
  2. import (
  3. "context"
  4. "net/http"
  5. "regexp"
  6. "strings"
  7. "github.com/google/go-github/github"
  8. "github.com/porter-dev/porter/api/server/authz"
  9. "github.com/porter-dev/porter/api/server/handlers"
  10. "github.com/porter-dev/porter/api/server/shared"
  11. "github.com/porter-dev/porter/api/server/shared/apierrors"
  12. "github.com/porter-dev/porter/api/server/shared/config"
  13. "github.com/porter-dev/porter/api/server/shared/requestutils"
  14. "github.com/porter-dev/porter/api/types"
  15. )
  16. var procfileRegex = regexp.MustCompile("^([A-Za-z0-9_]+):\\s*(.+)$")
  17. type GithubGetProcfileHandler struct {
  18. handlers.PorterHandlerReadWriter
  19. authz.KubernetesAgentGetter
  20. }
  21. func NewGithubGetProcfileHandler(
  22. config *config.Config,
  23. decoderValidator shared.RequestDecoderValidator,
  24. writer shared.ResultWriter,
  25. ) *GithubGetProcfileHandler {
  26. return &GithubGetProcfileHandler{
  27. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  28. }
  29. }
  30. func (c *GithubGetProcfileHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  31. request := &types.GetProcfileRequest{}
  32. ok := c.DecodeAndValidate(w, r, request)
  33. if !ok {
  34. return
  35. }
  36. owner, name, ok := GetOwnerAndNameParams(c, w, r)
  37. if !ok {
  38. return
  39. }
  40. branch, reqErr := requestutils.GetURLParamString(r, types.URLParamGitBranch)
  41. if reqErr != nil {
  42. c.HandleAPIError(w, r, reqErr)
  43. return
  44. }
  45. client, err := GetGithubAppClientFromRequest(c.Config(), r)
  46. if err != nil {
  47. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  48. return
  49. }
  50. resp, _, _, err := client.Repositories.GetContents(
  51. context.TODO(),
  52. owner,
  53. name,
  54. request.Path,
  55. &github.RepositoryContentGetOptions{
  56. Ref: branch,
  57. },
  58. )
  59. if err != nil {
  60. http.NotFound(w, r)
  61. return
  62. }
  63. fileData, err := resp.GetContent()
  64. if err != nil {
  65. c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  66. return
  67. }
  68. parsedContents := make(types.GetProcfileResponse)
  69. // parse the procfile information
  70. for _, line := range strings.Split(fileData, "\n") {
  71. if matches := procfileRegex.FindStringSubmatch(line); matches != nil {
  72. parsedContents[matches[1]] = matches[2]
  73. }
  74. }
  75. c.WriteResult(w, r, parsedContents)
  76. }