diff --git a/Documentation/authproxy.md b/Documentation/authproxy.md
new file mode 100644
index 00000000..10ff1980
--- /dev/null
+++ b/Documentation/authproxy.md
@@ -0,0 +1,87 @@
+# External authentication
+
+## Overview
+
+The authproxy connector returns identities based on authentication which your
+front-end web server performs.
+
+The connector does not support refresh tokens or groups at this point.
+
+## Configuration
+
+The following is an example config file that can be used by the external
+connector to authenticate a user.
+
+```yaml
+connectors:
+- type: authproxy
+ id: myBasicAuth
+ name: HTTP Basic Auth
+```
+
+The authproxy connector assumes that you configured your front-end web server
+such that it performs authentication for the `/dex/callback/myBasicAuth`
+location and provides the result in the X-Remote-User HTTP header. The following
+configuration will work for Apache 2.4.10+:
+
+```
+
+ AuthType Basic
+ AuthName "db.debian.org webPassword"
+ AuthBasicProvider file
+ AuthUserFile "/etc/apache2/debian-web-pw.htpasswd"
+ Require valid-user
+
+ # Defense in depth: clear the Authorization header so that
+ # Debian Web Passwords never even reach dex.
+ RequestHeader unset Authorization
+
+ # Requires Apache 2.4.10+
+ RequestHeader set X-Remote-User expr=%{REMOTE_USER}@debian.org
+
+ ProxyPass "http://localhost:5556/dex/callback/myBasicAuth"
+ ProxyPassReverse "http://localhost:5556/dex/callback/myBasicAuth"
+
+```
+
+## Full Apache2 setup
+
+After installing your Linux distribution’s Apache2 package, place the following
+virtual host configuration in e.g. `/etc/apache2/sites-available/sso.conf`:
+
+```
+
+ ServerName sso.example.net
+
+ ServerAdmin webmaster@localhost
+ DocumentRoot /var/www/html
+
+ ErrorLog ${APACHE_LOG_DIR}/error.log
+ CustomLog ${APACHE_LOG_DIR}/access.log combined
+
+
+ ProxyPass "http://localhost:5556/dex/"
+ ProxyPassReverse "http://localhost:5556/dex/"
+
+
+
+ AuthType Basic
+ AuthName "db.debian.org webPassword"
+ AuthBasicProvider file
+ AuthUserFile "/etc/apache2/debian-web-pw.htpasswd"
+ Require valid-user
+
+ # Defense in depth: clear the Authorization header so that
+ # Debian Web Passwords never even reach dex.
+ RequestHeader unset Authorization
+
+ # Requires Apache 2.4.10+
+ RequestHeader set X-Remote-User expr=%{REMOTE_USER}@debian.org
+
+ ProxyPass "http://localhost:5556/dex/callback/myBasicAuth"
+ ProxyPassReverse "http://localhost:5556/dex/callback/myBasicAuth"
+
+
+```
+
+Then, enable it using `a2ensite sso.conf`, followed by a restart of Apache2.
\ No newline at end of file
diff --git a/README.md b/README.md
index 1474b17a..84b39725 100644
--- a/README.md
+++ b/README.md
@@ -67,6 +67,7 @@ More docs for running dex as a Kubernetes authenticator can be found [here](Docu
* [GitLab](Documentation/gitlab-connector.md)
* [SAML 2.0](Documentation/saml-connector.md)
* [OpenID Connect](Documentation/oidc-connector.md) (includes Google, Salesforce, Azure, etc.)
+ * [authproxy](Documentation/authproxy.md) (Apache2 mod_auth, etc.)
* Client libraries
* [Go][go-oidc]
diff --git a/connector/authproxy/authproxy.go b/connector/authproxy/authproxy.go
new file mode 100644
index 00000000..a895789d
--- /dev/null
+++ b/connector/authproxy/authproxy.go
@@ -0,0 +1,56 @@
+// Package authproxy implements a connector which relies on external
+// authentication (e.g. mod_auth in Apache2) and returns an identity with the
+// HTTP header X-Remote-User as verified email.
+package authproxy
+
+import (
+ "fmt"
+ "net/http"
+ "net/url"
+
+ "github.com/coreos/dex/connector"
+ "github.com/sirupsen/logrus"
+)
+
+// Config holds the configuration parameters for a connector which returns an
+// identity with the HTTP header X-Remote-User as verified email.
+type Config struct{}
+
+// Open returns an authentication strategy which requires no user interaction.
+func (c *Config) Open(id string, logger logrus.FieldLogger) (connector.Connector, error) {
+ return &callback{logger: logger, pathSuffix: "/" + id}, nil
+}
+
+// Callback is a connector which returns an identity with the HTTP header
+// X-Remote-User as verified email.
+type callback struct {
+ logger logrus.FieldLogger
+ pathSuffix string
+}
+
+// LoginURL returns the URL to redirect the user to login with.
+func (m *callback) LoginURL(s connector.Scopes, callbackURL, state string) (string, error) {
+ u, err := url.Parse(callbackURL)
+ if err != nil {
+ return "", fmt.Errorf("failed to parse callbackURL %q: %v", callbackURL, err)
+ }
+ u.Path = u.Path + m.pathSuffix
+ v := u.Query()
+ v.Set("state", state)
+ u.RawQuery = v.Encode()
+ return u.String(), nil
+}
+
+// HandleCallback parses the request and returns the user's identity
+func (m *callback) HandleCallback(s connector.Scopes, r *http.Request) (connector.Identity, error) {
+ remoteUser := r.Header.Get("X-Remote-User")
+ if remoteUser == "" {
+ return connector.Identity{}, fmt.Errorf("required HTTP header X-Remote-User is not set")
+ }
+ // TODO: add support for X-Remote-Group, see
+ // https://kubernetes.io/docs/admin/authentication/#authenticating-proxy
+ return connector.Identity{
+ Email: remoteUser,
+ EmailVerified: true,
+ }, nil
+}
diff --git a/connector/github/github.go b/connector/github/github.go
index ae078412..fc578aeb 100644
--- a/connector/github/github.go
+++ b/connector/github/github.go
@@ -63,7 +63,7 @@ type Org struct {
}
// Open returns a strategy for logging in through GitHub.
-func (c *Config) Open(logger logrus.FieldLogger) (connector.Connector, error) {
+func (c *Config) Open(id string, logger logrus.FieldLogger) (connector.Connector, error) {
if c.Org != "" {
// Return error if both 'org' and 'orgs' fields are used.
diff --git a/connector/gitlab/gitlab.go b/connector/gitlab/gitlab.go
index a4da0197..f6cbbf09 100644
--- a/connector/gitlab/gitlab.go
+++ b/connector/gitlab/gitlab.go
@@ -51,7 +51,7 @@ type gitlabGroup struct {
}
// Open returns a strategy for logging in through GitLab.
-func (c *Config) Open(logger logrus.FieldLogger) (connector.Connector, error) {
+func (c *Config) Open(id string, logger logrus.FieldLogger) (connector.Connector, error) {
if c.BaseURL == "" {
c.BaseURL = "https://www.gitlab.com"
}
diff --git a/connector/ldap/ldap.go b/connector/ldap/ldap.go
index 01125ae7..5d19a51d 100644
--- a/connector/ldap/ldap.go
+++ b/connector/ldap/ldap.go
@@ -153,7 +153,7 @@ func parseScope(s string) (int, bool) {
}
// Open returns an authentication strategy using LDAP.
-func (c *Config) Open(logger logrus.FieldLogger) (connector.Connector, error) {
+func (c *Config) Open(id string, logger logrus.FieldLogger) (connector.Connector, error) {
conn, err := c.OpenConnector(logger)
if err != nil {
return nil, err
diff --git a/connector/mock/connectortest.go b/connector/mock/connectortest.go
index 7236230a..18abd820 100644
--- a/connector/mock/connectortest.go
+++ b/connector/mock/connectortest.go
@@ -69,7 +69,7 @@ func (m *Callback) Refresh(ctx context.Context, s connector.Scopes, identity con
type CallbackConfig struct{}
// Open returns an authentication strategy which requires no user interaction.
-func (c *CallbackConfig) Open(logger logrus.FieldLogger) (connector.Connector, error) {
+func (c *CallbackConfig) Open(id string, logger logrus.FieldLogger) (connector.Connector, error) {
return NewCallbackConnector(logger), nil
}
@@ -81,7 +81,7 @@ type PasswordConfig struct {
}
// Open returns an authentication strategy which prompts for a predefined username and password.
-func (c *PasswordConfig) Open(logger logrus.FieldLogger) (connector.Connector, error) {
+func (c *PasswordConfig) Open(id string, logger logrus.FieldLogger) (connector.Connector, error) {
if c.Username == "" {
return nil, errors.New("no username supplied")
}
diff --git a/connector/oidc/oidc.go b/connector/oidc/oidc.go
index 9cf7a3be..f0d8daf7 100644
--- a/connector/oidc/oidc.go
+++ b/connector/oidc/oidc.go
@@ -75,7 +75,7 @@ func registerBrokenAuthHeaderProvider(url string) {
// Open returns a connector which can be used to login users through an upstream
// OpenID Connect provider.
-func (c *Config) Open(logger logrus.FieldLogger) (conn connector.Connector, err error) {
+func (c *Config) Open(id string, logger logrus.FieldLogger) (conn connector.Connector, err error) {
ctx, cancel := context.WithCancel(context.Background())
provider, err := oidc.NewProvider(ctx, c.Issuer)
diff --git a/connector/oidc/oidc_test.go b/connector/oidc/oidc_test.go
index 305ab2ce..18838efa 100644
--- a/connector/oidc/oidc_test.go
+++ b/connector/oidc/oidc_test.go
@@ -1,12 +1,13 @@
package oidc
import (
- "github.com/coreos/dex/connector"
- "github.com/sirupsen/logrus"
"net/url"
"os"
"reflect"
"testing"
+
+ "github.com/coreos/dex/connector"
+ "github.com/sirupsen/logrus"
)
func TestKnownBrokenAuthHeaderProvider(t *testing.T) {
@@ -73,7 +74,7 @@ func TestOidcConnector_LoginURL(t *testing.T) {
HostedDomains: test.hostedDomains,
}
- conn, err := config.Open(logger)
+ conn, err := config.Open("oidc", logger)
if err != nil {
t.Errorf("failed to open connector: %v", err)
continue
diff --git a/connector/saml/saml.go b/connector/saml/saml.go
index f35f0a81..02b3fad7 100644
--- a/connector/saml/saml.go
+++ b/connector/saml/saml.go
@@ -125,7 +125,7 @@ func (c certStore) Certificates() (roots []*x509.Certificate, err error) {
// Open validates the config and returns a connector. It does not actually
// validate connectivity with the provider.
-func (c *Config) Open(logger logrus.FieldLogger) (connector.Connector, error) {
+func (c *Config) Open(id string, logger logrus.FieldLogger) (connector.Connector, error) {
return c.openConnector(logger)
}
diff --git a/server/handlers.go b/server/handlers.go
index a70858a9..345cd496 100644
--- a/server/handlers.go
+++ b/server/handlers.go
@@ -346,6 +346,12 @@ func (s *Server) handleConnectorCallback(w http.ResponseWriter, r *http.Request)
return
}
+ if connID := mux.Vars(r)["connector"]; connID != "" && connID != authReq.ConnectorID {
+ s.logger.Errorf("Connector mismatch: authentication started with id %q, but callback for id %q was triggered", authReq.ConnectorID, connID)
+ s.renderError(w, http.StatusInternalServerError, "Requested resource does not exist.")
+ return
+ }
+
conn, err := s.getConnector(authReq.ConnectorID)
if err != nil {
s.logger.Errorf("Failed to get connector with id %q : %v", authReq.ConnectorID, err)
diff --git a/server/server.go b/server/server.go
index aabe7abe..d1e1ff56 100644
--- a/server/server.go
+++ b/server/server.go
@@ -19,6 +19,7 @@ import (
"github.com/sirupsen/logrus"
"github.com/coreos/dex/connector"
+ "github.com/coreos/dex/connector/authproxy"
"github.com/coreos/dex/connector/github"
"github.com/coreos/dex/connector/gitlab"
"github.com/coreos/dex/connector/ldap"
@@ -240,6 +241,9 @@ func newServer(ctx context.Context, c Config, rotationStrategy rotationStrategy)
handleFunc("/auth", s.handleAuthorization)
handleFunc("/auth/{connector}", s.handleConnectorLogin)
handleFunc("/callback", s.handleConnectorCallback)
+ // For easier connector-specific web server configuration, e.g. for the
+ // "authproxy" connector.
+ handleFunc("/callback/{connector}", s.handleConnectorCallback)
handleFunc("/approval", s.handleApproval)
handleFunc("/healthz", s.handleHealth)
handlePrefix("/static", static)
@@ -381,7 +385,7 @@ func (s *Server) startGarbageCollection(ctx context.Context, frequency time.Dura
// ConnectorConfig is a configuration that can open a connector.
type ConnectorConfig interface {
- Open(logrus.FieldLogger) (connector.Connector, error)
+ Open(id string, logger logrus.FieldLogger) (connector.Connector, error)
}
// ConnectorsConfig variable provides an easy way to return a config struct
@@ -394,6 +398,7 @@ var ConnectorsConfig = map[string]func() ConnectorConfig{
"gitlab": func() ConnectorConfig { return new(gitlab.Config) },
"oidc": func() ConnectorConfig { return new(oidc.Config) },
"saml": func() ConnectorConfig { return new(saml.Config) },
+ "authproxy": func() ConnectorConfig { return new(authproxy.Config) },
// Keep around for backwards compatibility.
"samlExperimental": func() ConnectorConfig { return new(saml.Config) },
}
@@ -415,7 +420,7 @@ func openConnector(logger logrus.FieldLogger, conn storage.Connector) (connector
}
}
- c, err := connConfig.Open(logger)
+ c, err := connConfig.Open(conn.ID, logger)
if err != nil {
return c, fmt.Errorf("failed to create connector %s: %v", conn.ID, err)
}