mirror of
https://github.com/oauth2-proxy/oauth2-proxy.git
synced 2025-05-31 23:19:50 +02:00
Merge pull request #1043 from oauth2-proxy/sign-in-page
Refactor Sign In Page rendering and capture all page rendering code in pagewriter package
This commit is contained in:
commit
ce29b16d84
@ -8,6 +8,7 @@
|
||||
|
||||
## Changes since v7.0.1
|
||||
|
||||
- [#1043](https://github.com/oauth2-proxy/oauth2-proxy/pull/1043) Refactor Sign In Page rendering and capture all page rendering code in pagewriter package (@JoelSpeed)
|
||||
- [#1029](https://github.com/oauth2-proxy/oauth2-proxy/pull/1029) Refactor error page rendering and allow debug messages on error (@JoelSpeed)
|
||||
- [#1028](https://github.com/oauth2-proxy/oauth2-proxy/pull/1028) Refactor templates, update theme and provide styled error pages (@JoelSpeed)
|
||||
- [#1039](https://github.com/oauth2-proxy/oauth2-proxy/pull/1039) Ensure errors in tests are logged to the GinkgoWriter (@JoelSpeed)
|
||||
|
175
oauthproxy.go
175
oauthproxy.go
@ -5,7 +5,6 @@ import (
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"fmt"
|
||||
"html/template"
|
||||
"net"
|
||||
"net/http"
|
||||
"net/url"
|
||||
@ -18,7 +17,7 @@ import (
|
||||
middlewareapi "github.com/oauth2-proxy/oauth2-proxy/v7/pkg/apis/middleware"
|
||||
"github.com/oauth2-proxy/oauth2-proxy/v7/pkg/apis/options"
|
||||
sessionsapi "github.com/oauth2-proxy/oauth2-proxy/v7/pkg/apis/sessions"
|
||||
"github.com/oauth2-proxy/oauth2-proxy/v7/pkg/app"
|
||||
"github.com/oauth2-proxy/oauth2-proxy/v7/pkg/app/pagewriter"
|
||||
"github.com/oauth2-proxy/oauth2-proxy/v7/pkg/authentication/basic"
|
||||
"github.com/oauth2-proxy/oauth2-proxy/v7/pkg/cookies"
|
||||
"github.com/oauth2-proxy/oauth2-proxy/v7/pkg/encryption"
|
||||
@ -76,39 +75,33 @@ type OAuthProxy struct {
|
||||
AuthOnlyPath string
|
||||
UserInfoPath string
|
||||
|
||||
allowedRoutes []allowedRoute
|
||||
redirectURL *url.URL // the url to receive requests at
|
||||
whitelistDomains []string
|
||||
provider providers.Provider
|
||||
providerNameOverride string
|
||||
sessionStore sessionsapi.SessionStore
|
||||
ProxyPrefix string
|
||||
SignInMessage string
|
||||
basicAuthValidator basic.Validator
|
||||
displayHtpasswdForm bool
|
||||
serveMux http.Handler
|
||||
SetXAuthRequest bool
|
||||
PassBasicAuth bool
|
||||
SetBasicAuth bool
|
||||
SkipProviderButton bool
|
||||
PassUserHeaders bool
|
||||
BasicAuthPassword string
|
||||
PassAccessToken bool
|
||||
SetAuthorization bool
|
||||
PassAuthorization bool
|
||||
PreferEmailToUser bool
|
||||
skipAuthPreflight bool
|
||||
skipJwtBearerTokens bool
|
||||
templates *template.Template
|
||||
realClientIPParser ipapi.RealClientIPParser
|
||||
trustedIPs *ip.NetSet
|
||||
Banner string
|
||||
Footer string
|
||||
allowedRoutes []allowedRoute
|
||||
redirectURL *url.URL // the url to receive requests at
|
||||
whitelistDomains []string
|
||||
provider providers.Provider
|
||||
sessionStore sessionsapi.SessionStore
|
||||
ProxyPrefix string
|
||||
basicAuthValidator basic.Validator
|
||||
serveMux http.Handler
|
||||
SetXAuthRequest bool
|
||||
PassBasicAuth bool
|
||||
SetBasicAuth bool
|
||||
SkipProviderButton bool
|
||||
PassUserHeaders bool
|
||||
BasicAuthPassword string
|
||||
PassAccessToken bool
|
||||
SetAuthorization bool
|
||||
PassAuthorization bool
|
||||
PreferEmailToUser bool
|
||||
skipAuthPreflight bool
|
||||
skipJwtBearerTokens bool
|
||||
realClientIPParser ipapi.RealClientIPParser
|
||||
trustedIPs *ip.NetSet
|
||||
|
||||
sessionChain alice.Chain
|
||||
headersChain alice.Chain
|
||||
preAuthChain alice.Chain
|
||||
errorPage *app.ErrorPage
|
||||
pageWriter pagewriter.Writer
|
||||
}
|
||||
|
||||
// NewOAuthProxy creates a new instance of OAuthProxy from the options provided
|
||||
@ -118,20 +111,31 @@ func NewOAuthProxy(opts *options.Options, validator func(string) bool) (*OAuthPr
|
||||
return nil, fmt.Errorf("error initialising session store: %v", err)
|
||||
}
|
||||
|
||||
templates, err := app.LoadTemplates(opts.Templates.Path)
|
||||
var basicAuthValidator basic.Validator
|
||||
if opts.HtpasswdFile != "" {
|
||||
logger.Printf("using htpasswd file: %s", opts.HtpasswdFile)
|
||||
var err error
|
||||
basicAuthValidator, err = basic.NewHTPasswdValidator(opts.HtpasswdFile)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("could not load htpasswdfile: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
pageWriter, err := pagewriter.NewWriter(pagewriter.Opts{
|
||||
TemplatesPath: opts.Templates.Path,
|
||||
ProxyPrefix: opts.ProxyPrefix,
|
||||
Footer: opts.Templates.Footer,
|
||||
Version: VERSION,
|
||||
Debug: opts.Templates.Debug,
|
||||
ProviderName: buildProviderName(opts.GetProvider(), opts.ProviderName),
|
||||
SignInMessage: buildSignInMessage(opts),
|
||||
DisplayLoginForm: basicAuthValidator != nil && opts.Templates.DisplayLoginForm,
|
||||
})
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error loading templates: %v", err)
|
||||
return nil, fmt.Errorf("error initialising page writer: %v", err)
|
||||
}
|
||||
|
||||
errorPage := &app.ErrorPage{
|
||||
Template: templates.Lookup("error.html"),
|
||||
ProxyPrefix: opts.ProxyPrefix,
|
||||
Footer: opts.Templates.Footer,
|
||||
Version: VERSION,
|
||||
Debug: opts.Templates.Debug,
|
||||
}
|
||||
|
||||
upstreamProxy, err := upstream.NewProxy(opts.UpstreamServers, opts.GetSignatureData(), errorPage.ProxyErrorHandler)
|
||||
upstreamProxy, err := upstream.NewProxy(opts.UpstreamServers, opts.GetSignatureData(), pageWriter.ProxyErrorHandler)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error initialising upstream proxy: %v", err)
|
||||
}
|
||||
@ -164,16 +168,6 @@ func NewOAuthProxy(opts *options.Options, validator func(string) bool) (*OAuthPr
|
||||
}
|
||||
}
|
||||
|
||||
var basicAuthValidator basic.Validator
|
||||
if opts.HtpasswdFile != "" {
|
||||
logger.Printf("using htpasswd file: %s", opts.HtpasswdFile)
|
||||
var err error
|
||||
basicAuthValidator, err = basic.NewHTPasswdValidator(opts.HtpasswdFile)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("could not load htpasswdfile: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
allowedRoutes, err := buildRoutesAllowlist(opts)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
@ -210,30 +204,24 @@ func NewOAuthProxy(opts *options.Options, validator func(string) bool) (*OAuthPr
|
||||
AuthOnlyPath: fmt.Sprintf("%s/auth", opts.ProxyPrefix),
|
||||
UserInfoPath: fmt.Sprintf("%s/userinfo", opts.ProxyPrefix),
|
||||
|
||||
ProxyPrefix: opts.ProxyPrefix,
|
||||
provider: opts.GetProvider(),
|
||||
providerNameOverride: opts.ProviderName,
|
||||
sessionStore: sessionStore,
|
||||
serveMux: upstreamProxy,
|
||||
redirectURL: redirectURL,
|
||||
allowedRoutes: allowedRoutes,
|
||||
whitelistDomains: opts.WhitelistDomains,
|
||||
skipAuthPreflight: opts.SkipAuthPreflight,
|
||||
skipJwtBearerTokens: opts.SkipJwtBearerTokens,
|
||||
realClientIPParser: opts.GetRealClientIPParser(),
|
||||
SkipProviderButton: opts.SkipProviderButton,
|
||||
templates: templates,
|
||||
trustedIPs: trustedIPs,
|
||||
Banner: opts.Templates.Banner,
|
||||
Footer: opts.Templates.Footer,
|
||||
SignInMessage: buildSignInMessage(opts),
|
||||
ProxyPrefix: opts.ProxyPrefix,
|
||||
provider: opts.GetProvider(),
|
||||
sessionStore: sessionStore,
|
||||
serveMux: upstreamProxy,
|
||||
redirectURL: redirectURL,
|
||||
allowedRoutes: allowedRoutes,
|
||||
whitelistDomains: opts.WhitelistDomains,
|
||||
skipAuthPreflight: opts.SkipAuthPreflight,
|
||||
skipJwtBearerTokens: opts.SkipJwtBearerTokens,
|
||||
realClientIPParser: opts.GetRealClientIPParser(),
|
||||
SkipProviderButton: opts.SkipProviderButton,
|
||||
trustedIPs: trustedIPs,
|
||||
|
||||
basicAuthValidator: basicAuthValidator,
|
||||
displayHtpasswdForm: basicAuthValidator != nil && opts.Templates.DisplayLoginForm,
|
||||
sessionChain: sessionChain,
|
||||
headersChain: headersChain,
|
||||
preAuthChain: preAuthChain,
|
||||
errorPage: errorPage,
|
||||
basicAuthValidator: basicAuthValidator,
|
||||
sessionChain: sessionChain,
|
||||
headersChain: headersChain,
|
||||
preAuthChain: preAuthChain,
|
||||
pageWriter: pageWriter,
|
||||
}, nil
|
||||
}
|
||||
|
||||
@ -331,6 +319,13 @@ func buildSignInMessage(opts *options.Options) string {
|
||||
return msg
|
||||
}
|
||||
|
||||
func buildProviderName(p providers.Provider, override string) string {
|
||||
if override != "" {
|
||||
return override
|
||||
}
|
||||
return p.Data().ProviderName
|
||||
}
|
||||
|
||||
// buildRoutesAllowlist builds an []allowedRoute list from either the legacy
|
||||
// SkipAuthRegex option (paths only support) or newer SkipAuthRoutes option
|
||||
// (method=path support)
|
||||
@ -533,7 +528,7 @@ func (p *OAuthProxy) ErrorPage(rw http.ResponseWriter, req *http.Request, code i
|
||||
redirectURL = "/"
|
||||
}
|
||||
|
||||
p.errorPage.Render(rw, code, redirectURL, appError, messages...)
|
||||
p.pageWriter.WriteErrorPage(rw, code, redirectURL, appError, messages...)
|
||||
}
|
||||
|
||||
// IsAllowedRequest is used to check if auth should be skipped for this request
|
||||
@ -594,33 +589,7 @@ func (p *OAuthProxy) SignInPage(rw http.ResponseWriter, req *http.Request, code
|
||||
redirectURL = "/"
|
||||
}
|
||||
|
||||
// We allow unescaped template.HTML since it is user configured options
|
||||
/* #nosec G203 */
|
||||
t := struct {
|
||||
ProviderName string
|
||||
SignInMessage template.HTML
|
||||
CustomLogin bool
|
||||
Redirect string
|
||||
Version string
|
||||
ProxyPrefix string
|
||||
Footer template.HTML
|
||||
}{
|
||||
ProviderName: p.provider.Data().ProviderName,
|
||||
SignInMessage: template.HTML(p.SignInMessage),
|
||||
CustomLogin: p.displayHtpasswdForm,
|
||||
Redirect: redirectURL,
|
||||
Version: VERSION,
|
||||
ProxyPrefix: p.ProxyPrefix,
|
||||
Footer: template.HTML(p.Footer),
|
||||
}
|
||||
if p.providerNameOverride != "" {
|
||||
t.ProviderName = p.providerNameOverride
|
||||
}
|
||||
err = p.templates.ExecuteTemplate(rw, "sign_in.html", t)
|
||||
if err != nil {
|
||||
logger.Printf("Error rendering sign_in.html template: %v", err)
|
||||
p.ErrorPage(rw, req, http.StatusInternalServerError, err.Error())
|
||||
}
|
||||
p.pageWriter.WriteSignInPage(rw, redirectURL)
|
||||
}
|
||||
|
||||
// ManualSignIn handles basic auth logins to the proxy
|
||||
|
@ -1,4 +1,4 @@
|
||||
package app
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
@ -17,30 +17,30 @@ var errorMessages = map[int]string{
|
||||
http.StatusUnauthorized: "You need to be logged in to access this resource.",
|
||||
}
|
||||
|
||||
// ErrorPage is used to render error pages.
|
||||
type ErrorPage struct {
|
||||
// Template is the error page HTML template.
|
||||
Template *template.Template
|
||||
// errorPageWriter is used to render error pages.
|
||||
type errorPageWriter struct {
|
||||
// template is the error page HTML template.
|
||||
template *template.Template
|
||||
|
||||
// ProxyPrefix is the prefix under which OAuth2 Proxy pages are served.
|
||||
ProxyPrefix string
|
||||
// proxyPrefix is the prefix under which OAuth2 Proxy pages are served.
|
||||
proxyPrefix string
|
||||
|
||||
// Footer is the footer to be displayed at the bottom of the page.
|
||||
// footer is the footer to be displayed at the bottom of the page.
|
||||
// If not set, a default footer will be used.
|
||||
Footer string
|
||||
footer string
|
||||
|
||||
// Version is the OAuth2 Proxy version to be used in the default footer.
|
||||
Version string
|
||||
// version is the OAuth2 Proxy version to be used in the default footer.
|
||||
version string
|
||||
|
||||
// Debug determines whether errors pages should be rendered with detailed
|
||||
// debug determines whether errors pages should be rendered with detailed
|
||||
// errors.
|
||||
Debug bool
|
||||
debug bool
|
||||
}
|
||||
|
||||
// Render writes an error page to the given response writer.
|
||||
// WriteErrorPage writes an error page to the given response writer.
|
||||
// It uses the passed redirectURL to give users the option to go back to where
|
||||
// they originally came from or try signing in again.
|
||||
func (e *ErrorPage) Render(rw http.ResponseWriter, status int, redirectURL string, appError string, messages ...interface{}) {
|
||||
func (e *errorPageWriter) WriteErrorPage(rw http.ResponseWriter, status int, redirectURL string, appError string, messages ...interface{}) {
|
||||
rw.WriteHeader(status)
|
||||
|
||||
// We allow unescaped template.HTML since it is user configured options
|
||||
@ -56,14 +56,14 @@ func (e *ErrorPage) Render(rw http.ResponseWriter, status int, redirectURL strin
|
||||
}{
|
||||
Title: http.StatusText(status),
|
||||
Message: e.getMessage(status, appError, messages...),
|
||||
ProxyPrefix: e.ProxyPrefix,
|
||||
ProxyPrefix: e.proxyPrefix,
|
||||
StatusCode: status,
|
||||
Redirect: redirectURL,
|
||||
Footer: template.HTML(e.Footer),
|
||||
Version: e.Version,
|
||||
Footer: template.HTML(e.footer),
|
||||
Version: e.version,
|
||||
}
|
||||
|
||||
if err := e.Template.Execute(rw, data); err != nil {
|
||||
if err := e.template.Execute(rw, data); err != nil {
|
||||
logger.Printf("Error rendering error template: %v", err)
|
||||
http.Error(rw, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
|
||||
}
|
||||
@ -72,18 +72,18 @@ func (e *ErrorPage) Render(rw http.ResponseWriter, status int, redirectURL strin
|
||||
// ProxyErrorHandler is used by the upstream ReverseProxy to render error pages
|
||||
// when there are issues with upstream servers.
|
||||
// It is expected to always render a bad gateway error.
|
||||
func (e *ErrorPage) ProxyErrorHandler(rw http.ResponseWriter, req *http.Request, proxyErr error) {
|
||||
func (e *errorPageWriter) ProxyErrorHandler(rw http.ResponseWriter, req *http.Request, proxyErr error) {
|
||||
logger.Errorf("Error proxying to upstream server: %v", proxyErr)
|
||||
e.Render(rw, http.StatusBadGateway, "", proxyErr.Error(), "There was a problem connecting to the upstream server.")
|
||||
e.WriteErrorPage(rw, http.StatusBadGateway, "", proxyErr.Error(), "There was a problem connecting to the upstream server.")
|
||||
}
|
||||
|
||||
// getMessage creates the message for the template parameters.
|
||||
// If the ErrorPage.Debug is enabled, the application error takes precedence.
|
||||
// If the errorPagewriter.Debug is enabled, the application error takes precedence.
|
||||
// Otherwise, any messages will be used.
|
||||
// The first message is expected to be a format string.
|
||||
// If no messages are supplied, a default error message will be used.
|
||||
func (e *ErrorPage) getMessage(status int, appError string, messages ...interface{}) string {
|
||||
if e.Debug {
|
||||
func (e *errorPageWriter) getMessage(status int, appError string, messages ...interface{}) string {
|
||||
if e.debug {
|
||||
return appError
|
||||
}
|
||||
if len(messages) > 0 {
|
@ -1,4 +1,4 @@
|
||||
package app
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"errors"
|
||||
@ -10,25 +10,25 @@ import (
|
||||
. "github.com/onsi/gomega"
|
||||
)
|
||||
|
||||
var _ = Describe("Error Page", func() {
|
||||
var errorPage *ErrorPage
|
||||
var _ = Describe("Error Page Writer", func() {
|
||||
var errorPage *errorPageWriter
|
||||
|
||||
BeforeEach(func() {
|
||||
tmpl, err := template.New("").Parse("{{.Title}} {{.Message}} {{.ProxyPrefix}} {{.StatusCode}} {{.Redirect}} {{.Footer}} {{.Version}}")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
|
||||
errorPage = &ErrorPage{
|
||||
Template: tmpl,
|
||||
ProxyPrefix: "/prefix/",
|
||||
Footer: "Custom Footer Text",
|
||||
Version: "v0.0.0-test",
|
||||
errorPage = &errorPageWriter{
|
||||
template: tmpl,
|
||||
proxyPrefix: "/prefix/",
|
||||
footer: "Custom Footer Text",
|
||||
version: "v0.0.0-test",
|
||||
}
|
||||
})
|
||||
|
||||
Context("Render", func() {
|
||||
Context("WriteErrorPage", func() {
|
||||
It("Writes the template to the response writer", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
errorPage.Render(recorder, 403, "/redirect", "Access Denied")
|
||||
errorPage.WriteErrorPage(recorder, 403, "/redirect", "Access Denied")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
@ -37,7 +37,7 @@ var _ = Describe("Error Page", func() {
|
||||
|
||||
It("With a different code, uses the stock message for the correct code", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
errorPage.Render(recorder, 500, "/redirect", "Access Denied")
|
||||
errorPage.WriteErrorPage(recorder, 500, "/redirect", "Access Denied")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
@ -46,7 +46,7 @@ var _ = Describe("Error Page", func() {
|
||||
|
||||
It("With a message override, uses the message", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
errorPage.Render(recorder, 403, "/redirect", "Access Denied", "An extra message: %s", "with more context.")
|
||||
errorPage.WriteErrorPage(recorder, 403, "/redirect", "Access Denied", "An extra message: %s", "with more context.")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
@ -71,14 +71,14 @@ var _ = Describe("Error Page", func() {
|
||||
tmpl, err := template.New("").Parse("{{.Message}}")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
|
||||
errorPage.Template = tmpl
|
||||
errorPage.Debug = true
|
||||
errorPage.template = tmpl
|
||||
errorPage.debug = true
|
||||
})
|
||||
|
||||
Context("Render", func() {
|
||||
Context("WriteErrorPage", func() {
|
||||
It("Writes the detailed error in place of the message", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
errorPage.Render(recorder, 403, "/redirect", "Debug error")
|
||||
errorPage.WriteErrorPage(recorder, 403, "/redirect", "Debug error")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
85
pkg/app/pagewriter/pagewriter.go
Normal file
85
pkg/app/pagewriter/pagewriter.go
Normal file
@ -0,0 +1,85 @@
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
)
|
||||
|
||||
// Writer is an interface for rendering html templates for both sign-in and
|
||||
// error pages.
|
||||
// It can also be used to write errors for the http.ReverseProxy used in the
|
||||
// upstream package.
|
||||
type Writer interface {
|
||||
WriteSignInPage(rw http.ResponseWriter, redirectURL string)
|
||||
WriteErrorPage(rw http.ResponseWriter, status int, redirectURL string, appError string, messages ...interface{})
|
||||
ProxyErrorHandler(rw http.ResponseWriter, req *http.Request, proxyErr error)
|
||||
}
|
||||
|
||||
// pageWriter implements the Writer interface
|
||||
type pageWriter struct {
|
||||
*errorPageWriter
|
||||
*signInPageWriter
|
||||
}
|
||||
|
||||
// Opts contains all options required to configure the template
|
||||
// rendering within OAuth2 Proxy.
|
||||
type Opts struct {
|
||||
// TemplatesPath is the path from which to load custom templates for the sign-in and error pages.
|
||||
TemplatesPath string
|
||||
|
||||
// ProxyPrefix is the prefix under which OAuth2 Proxy pages are served.
|
||||
ProxyPrefix string
|
||||
|
||||
// Footer is the footer to be displayed at the bottom of the page.
|
||||
// If not set, a default footer will be used.
|
||||
Footer string
|
||||
|
||||
// Version is the OAuth2 Proxy version to be used in the default footer.
|
||||
Version string
|
||||
|
||||
// Debug determines whether errors pages should be rendered with detailed
|
||||
// errors.
|
||||
Debug bool
|
||||
|
||||
// DisplayLoginForm determines whether or not the basic auth password form is displayed on the sign-in page.
|
||||
DisplayLoginForm bool
|
||||
|
||||
// ProviderName is the name of the provider that should be displayed on the login button.
|
||||
ProviderName string
|
||||
|
||||
// SignInMessage is the messge displayed above the login button.
|
||||
SignInMessage string
|
||||
}
|
||||
|
||||
// NewWriter constructs a Writer from the options given to allow
|
||||
// rendering of sign-in and error pages.
|
||||
func NewWriter(opts Opts) (Writer, error) {
|
||||
templates, err := loadTemplates(opts.TemplatesPath)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error loading templates: %v", err)
|
||||
}
|
||||
|
||||
errorPage := &errorPageWriter{
|
||||
template: templates.Lookup("error.html"),
|
||||
proxyPrefix: opts.ProxyPrefix,
|
||||
footer: opts.Footer,
|
||||
version: opts.Version,
|
||||
debug: opts.Debug,
|
||||
}
|
||||
|
||||
signInPage := &signInPageWriter{
|
||||
template: templates.Lookup("sign_in.html"),
|
||||
errorPageWriter: errorPage,
|
||||
proxyPrefix: opts.ProxyPrefix,
|
||||
providerName: opts.ProviderName,
|
||||
signInMessage: opts.SignInMessage,
|
||||
footer: opts.Footer,
|
||||
version: opts.Version,
|
||||
displayLoginForm: opts.DisplayLoginForm,
|
||||
}
|
||||
|
||||
return &pageWriter{
|
||||
errorPageWriter: errorPage,
|
||||
signInPageWriter: signInPage,
|
||||
}, nil
|
||||
}
|
@ -1,4 +1,4 @@
|
||||
package app
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"testing"
|
126
pkg/app/pagewriter/pagewriter_test.go
Normal file
126
pkg/app/pagewriter/pagewriter_test.go
Normal file
@ -0,0 +1,126 @@
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"io/ioutil"
|
||||
"net/http/httptest"
|
||||
"os"
|
||||
"path/filepath"
|
||||
|
||||
. "github.com/onsi/ginkgo"
|
||||
. "github.com/onsi/gomega"
|
||||
)
|
||||
|
||||
var _ = Describe("Writer", func() {
|
||||
Context("NewWriter", func() {
|
||||
var writer Writer
|
||||
var opts Opts
|
||||
|
||||
BeforeEach(func() {
|
||||
opts = Opts{
|
||||
TemplatesPath: "",
|
||||
ProxyPrefix: "/prefix",
|
||||
Footer: "<Footer>",
|
||||
Version: "<Version>",
|
||||
Debug: false,
|
||||
DisplayLoginForm: false,
|
||||
ProviderName: "<ProviderName>",
|
||||
SignInMessage: "<SignInMessage>",
|
||||
}
|
||||
})
|
||||
|
||||
Context("With no custom templates", func() {
|
||||
BeforeEach(func() {
|
||||
var err error
|
||||
writer, err = NewWriter(opts)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
})
|
||||
|
||||
It("Writes the default error template", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
writer.WriteErrorPage(recorder, 500, "/redirect", "Some debug error")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
Expect(string(body)).To(HavePrefix("\n<!DOCTYPE html>"))
|
||||
})
|
||||
|
||||
It("Writes the default sign in template", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
writer.WriteSignInPage(recorder, "/redirect")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
Expect(string(body)).To(HavePrefix("\n<!DOCTYPE html>"))
|
||||
})
|
||||
})
|
||||
|
||||
Context("With custom templates", func() {
|
||||
var customDir string
|
||||
|
||||
BeforeEach(func() {
|
||||
var err error
|
||||
customDir, err = ioutil.TempDir("", "oauth2-proxy-pagewriter-test")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
|
||||
templateHTML := `Custom Template`
|
||||
signInFile := filepath.Join(customDir, signInTemplateName)
|
||||
Expect(ioutil.WriteFile(signInFile, []byte(templateHTML), 0600)).To(Succeed())
|
||||
errorFile := filepath.Join(customDir, errorTemplateName)
|
||||
Expect(ioutil.WriteFile(errorFile, []byte(templateHTML), 0600)).To(Succeed())
|
||||
|
||||
opts.TemplatesPath = customDir
|
||||
|
||||
writer, err = NewWriter(opts)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
})
|
||||
|
||||
AfterEach(func() {
|
||||
Expect(os.RemoveAll(customDir)).To(Succeed())
|
||||
})
|
||||
|
||||
It("Writes the custom error template", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
writer.WriteErrorPage(recorder, 500, "/redirect", "Some debug error")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
Expect(string(body)).To(Equal("Custom Template"))
|
||||
})
|
||||
|
||||
It("Writes the custom sign in template", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
writer.WriteSignInPage(recorder, "/redirect")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
Expect(string(body)).To(Equal("Custom Template"))
|
||||
})
|
||||
})
|
||||
|
||||
Context("With an invalid custom template", func() {
|
||||
var customDir string
|
||||
|
||||
BeforeEach(func() {
|
||||
var err error
|
||||
customDir, err = ioutil.TempDir("", "oauth2-proxy-pagewriter-test")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
|
||||
templateHTML := `{{ Custom Broken Template`
|
||||
signInFile := filepath.Join(customDir, signInTemplateName)
|
||||
Expect(ioutil.WriteFile(signInFile, []byte(templateHTML), 0600)).To(Succeed())
|
||||
|
||||
opts.TemplatesPath = customDir
|
||||
})
|
||||
|
||||
AfterEach(func() {
|
||||
Expect(os.RemoveAll(customDir)).To(Succeed())
|
||||
})
|
||||
|
||||
It("Should return an error", func() {
|
||||
writer, err := NewWriter(opts)
|
||||
Expect(err).To(MatchError(ContainSubstring("template: sign_in.html:1: function \"Custom\" not defined")))
|
||||
Expect(writer).To(BeNil())
|
||||
})
|
||||
})
|
||||
})
|
||||
})
|
66
pkg/app/pagewriter/sign_in_page.go
Normal file
66
pkg/app/pagewriter/sign_in_page.go
Normal file
@ -0,0 +1,66 @@
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"html/template"
|
||||
"net/http"
|
||||
|
||||
"github.com/oauth2-proxy/oauth2-proxy/v7/pkg/logger"
|
||||
)
|
||||
|
||||
// signInPageWriter is used to render sign-in pages.
|
||||
type signInPageWriter struct {
|
||||
// Template is the sign-in page HTML template.
|
||||
template *template.Template
|
||||
|
||||
// errorPageWriter is used to render an error if there are problems with rendering the sign-in page.
|
||||
errorPageWriter *errorPageWriter
|
||||
|
||||
// ProxyPrefix is the prefix under which OAuth2 Proxy pages are served.
|
||||
proxyPrefix string
|
||||
|
||||
// ProviderName is the name of the provider that should be displayed on the login button.
|
||||
providerName string
|
||||
|
||||
// SignInMessage is the messge displayed above the login button.
|
||||
signInMessage string
|
||||
|
||||
// Footer is the footer to be displayed at the bottom of the page.
|
||||
// If not set, a default footer will be used.
|
||||
footer string
|
||||
|
||||
// Version is the OAuth2 Proxy version to be used in the default footer.
|
||||
version string
|
||||
|
||||
// DisplayLoginForm determines whether or not the basic auth password form is displayed on the sign-in page.
|
||||
displayLoginForm bool
|
||||
}
|
||||
|
||||
// WriteSignInPage writes the sign-in page to the given response writer.
|
||||
// It uses the redirectURL to be able to set the final destination for the user post login.
|
||||
func (s *signInPageWriter) WriteSignInPage(rw http.ResponseWriter, redirectURL string) {
|
||||
// We allow unescaped template.HTML since it is user configured options
|
||||
/* #nosec G203 */
|
||||
t := struct {
|
||||
ProviderName string
|
||||
SignInMessage template.HTML
|
||||
CustomLogin bool
|
||||
Redirect string
|
||||
Version string
|
||||
ProxyPrefix string
|
||||
Footer template.HTML
|
||||
}{
|
||||
ProviderName: s.providerName,
|
||||
SignInMessage: template.HTML(s.signInMessage),
|
||||
CustomLogin: s.displayLoginForm,
|
||||
Redirect: redirectURL,
|
||||
Version: s.version,
|
||||
ProxyPrefix: s.proxyPrefix,
|
||||
Footer: template.HTML(s.footer),
|
||||
}
|
||||
|
||||
err := s.template.Execute(rw, t)
|
||||
if err != nil {
|
||||
logger.Printf("Error rendering sign-in template: %v", err)
|
||||
s.errorPageWriter.WriteErrorPage(rw, http.StatusInternalServerError, redirectURL, err.Error())
|
||||
}
|
||||
}
|
61
pkg/app/pagewriter/sign_in_page_test.go
Normal file
61
pkg/app/pagewriter/sign_in_page_test.go
Normal file
@ -0,0 +1,61 @@
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"html/template"
|
||||
"io/ioutil"
|
||||
"net/http/httptest"
|
||||
|
||||
. "github.com/onsi/ginkgo"
|
||||
. "github.com/onsi/gomega"
|
||||
)
|
||||
|
||||
var _ = Describe("SignIn Page Writer", func() {
|
||||
var signInPage *signInPageWriter
|
||||
|
||||
BeforeEach(func() {
|
||||
errorTmpl, err := template.New("").Parse("{{.Title}}")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
errorPage := &errorPageWriter{
|
||||
template: errorTmpl,
|
||||
}
|
||||
|
||||
tmpl, err := template.New("").Parse("{{.ProxyPrefix}} {{.ProviderName}} {{.SignInMessage}} {{.Footer}} {{.Version}} {{.Redirect}} {{.CustomLogin}}")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
|
||||
signInPage = &signInPageWriter{
|
||||
template: tmpl,
|
||||
errorPageWriter: errorPage,
|
||||
proxyPrefix: "/prefix/",
|
||||
providerName: "My Provider",
|
||||
signInMessage: "Sign In Here",
|
||||
footer: "Custom Footer Text",
|
||||
version: "v0.0.0-test",
|
||||
displayLoginForm: true,
|
||||
}
|
||||
})
|
||||
|
||||
Context("WriteSignInPage", func() {
|
||||
It("Writes the template to the response writer", func() {
|
||||
recorder := httptest.NewRecorder()
|
||||
signInPage.WriteSignInPage(recorder, "/redirect")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
Expect(string(body)).To(Equal("/prefix/ My Provider Sign In Here Custom Footer Text v0.0.0-test /redirect true"))
|
||||
})
|
||||
|
||||
It("Writes an error if the template can't be rendered", func() {
|
||||
// Overwrite the template with something bad
|
||||
tmpl, err := template.New("").Parse("{{.Unknown}}")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
signInPage.template = tmpl
|
||||
|
||||
recorder := httptest.NewRecorder()
|
||||
signInPage.WriteSignInPage(recorder, "/redirect")
|
||||
|
||||
body, err := ioutil.ReadAll(recorder.Result().Body)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
Expect(string(body)).To(Equal("Internal Server Error"))
|
||||
})
|
||||
})
|
||||
})
|
@ -1,4 +1,4 @@
|
||||
package app
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
@ -206,10 +206,10 @@ const (
|
||||
{{end}}`
|
||||
)
|
||||
|
||||
// LoadTemplates adds the Sign In and Error templates from the custom template
|
||||
// loadTemplates adds the Sign In and Error templates from the custom template
|
||||
// directory, or uses the defaults if they do not exist or the custom directory
|
||||
// is not provided.
|
||||
func LoadTemplates(customDir string) (*template.Template, error) {
|
||||
func loadTemplates(customDir string) (*template.Template, error) {
|
||||
t := template.New("").Funcs(template.FuncMap{
|
||||
"ToUpper": strings.ToUpper,
|
||||
"ToLower": strings.ToLower,
|
@ -1,4 +1,4 @@
|
||||
package app
|
||||
package pagewriter
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
@ -21,16 +21,16 @@ var _ = Describe("Templates", func() {
|
||||
|
||||
templateHTML := `{{.TestString}} {{.TestString | ToLower}} {{.TestString | ToUpper}}`
|
||||
signInFile := filepath.Join(customDir, signInTemplateName)
|
||||
Expect(ioutil.WriteFile(signInFile, []byte(templateHTML), 0666)).To(Succeed())
|
||||
Expect(ioutil.WriteFile(signInFile, []byte(templateHTML), 0600)).To(Succeed())
|
||||
errorFile := filepath.Join(customDir, errorTemplateName)
|
||||
Expect(ioutil.WriteFile(errorFile, []byte(templateHTML), 0666)).To(Succeed())
|
||||
Expect(ioutil.WriteFile(errorFile, []byte(templateHTML), 0600)).To(Succeed())
|
||||
})
|
||||
|
||||
AfterEach(func() {
|
||||
Expect(os.RemoveAll(customDir)).To(Succeed())
|
||||
})
|
||||
|
||||
Context("LoadTemplates", func() {
|
||||
Context("loadTemplates", func() {
|
||||
var data interface{}
|
||||
var t *template.Template
|
||||
|
||||
@ -73,7 +73,7 @@ var _ = Describe("Templates", func() {
|
||||
Context("With no custom directory", func() {
|
||||
BeforeEach(func() {
|
||||
var err error
|
||||
t, err = LoadTemplates("")
|
||||
t, err = loadTemplates("")
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
})
|
||||
|
||||
@ -94,7 +94,7 @@ var _ = Describe("Templates", func() {
|
||||
Context("With both templates", func() {
|
||||
BeforeEach(func() {
|
||||
var err error
|
||||
t, err = LoadTemplates(customDir)
|
||||
t, err = loadTemplates(customDir)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
})
|
||||
|
||||
@ -116,7 +116,7 @@ var _ = Describe("Templates", func() {
|
||||
Expect(os.Remove(filepath.Join(customDir, errorTemplateName))).To(Succeed())
|
||||
|
||||
var err error
|
||||
t, err = LoadTemplates(customDir)
|
||||
t, err = loadTemplates(customDir)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
})
|
||||
|
||||
@ -138,7 +138,7 @@ var _ = Describe("Templates", func() {
|
||||
Expect(os.Remove(filepath.Join(customDir, signInTemplateName))).To(Succeed())
|
||||
|
||||
var err error
|
||||
t, err = LoadTemplates(customDir)
|
||||
t, err = loadTemplates(customDir)
|
||||
Expect(err).ToNot(HaveOccurred())
|
||||
})
|
||||
|
||||
@ -158,11 +158,11 @@ var _ = Describe("Templates", func() {
|
||||
Context("With an invalid sign_in template", func() {
|
||||
BeforeEach(func() {
|
||||
signInFile := filepath.Join(customDir, signInTemplateName)
|
||||
Expect(ioutil.WriteFile(signInFile, []byte("{{"), 0666))
|
||||
Expect(ioutil.WriteFile(signInFile, []byte("{{"), 0600))
|
||||
})
|
||||
|
||||
It("Should return an error when loading templates", func() {
|
||||
t, err := LoadTemplates(customDir)
|
||||
t, err := loadTemplates(customDir)
|
||||
Expect(err).To(MatchError(HavePrefix("could not add Sign In template:")))
|
||||
Expect(t).To(BeNil())
|
||||
})
|
||||
@ -171,11 +171,11 @@ var _ = Describe("Templates", func() {
|
||||
Context("With an invalid error template", func() {
|
||||
BeforeEach(func() {
|
||||
errorFile := filepath.Join(customDir, errorTemplateName)
|
||||
Expect(ioutil.WriteFile(errorFile, []byte("{{"), 0666))
|
||||
Expect(ioutil.WriteFile(errorFile, []byte("{{"), 0600))
|
||||
})
|
||||
|
||||
It("Should return an error when loading templates", func() {
|
||||
t, err := LoadTemplates(customDir)
|
||||
t, err := loadTemplates(customDir)
|
||||
Expect(err).To(MatchError(HavePrefix("could not add Error template:")))
|
||||
Expect(t).To(BeNil())
|
||||
})
|
Loading…
x
Reference in New Issue
Block a user