get_procfile.go 2.0 KB

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