2
0

github_start.go 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package user
  2. import (
  3. "net/http"
  4. "github.com/porter-dev/porter/internal/telemetry"
  5. "golang.org/x/oauth2"
  6. "github.com/porter-dev/porter/api/server/handlers"
  7. "github.com/porter-dev/porter/api/server/shared"
  8. "github.com/porter-dev/porter/api/server/shared/apierrors"
  9. "github.com/porter-dev/porter/api/server/shared/config"
  10. "github.com/porter-dev/porter/internal/oauth"
  11. )
  12. type UserOAuthGithubHandler struct {
  13. handlers.PorterHandlerReadWriter
  14. }
  15. func NewUserOAuthGithubHandler(
  16. config *config.Config,
  17. decoderValidator shared.RequestDecoderValidator,
  18. writer shared.ResultWriter,
  19. ) *UserOAuthGithubHandler {
  20. return &UserOAuthGithubHandler{
  21. PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer),
  22. }
  23. }
  24. func (p *UserOAuthGithubHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  25. ctx, span := telemetry.NewSpan(r.Context(), "serve-project-oauth-github")
  26. defer span.End()
  27. r = r.Clone(ctx)
  28. state := oauth.CreateRandomState()
  29. if err := p.PopulateOAuthSession(ctx, w, r, state, false, false, "", 0); err != nil {
  30. p.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  31. return
  32. }
  33. // specify access type offline to get a refresh token
  34. url := p.Config().GithubConf.AuthCodeURL(state, oauth2.AccessTypeOffline)
  35. http.Redirect(w, r, url, 302)
  36. }