feat: improve error handling, some docs, stubs

This commit is contained in:
janishutz committed 2026-09-19 16:30:35 +02:00
1 parent 2a936ea2a2
commit b349716d2d
6 files changed
+94 -20

No files matched your search

+8
View File
@@ -1,2 +1,10 @@
# oidclogin # oidclogin
OpenID Connect Login SDK written in Go for Gin. OpenID Connect Login SDK written in Go for Gin.
The following environment variables are expected to be set:
```env
OIDC_CLIENT_ID=<client id>
OIDC_CLIENT_SECRET=<client secret>
OIDC_ISSUE=<issuer url>
```
If these env vars are not present, then depending on configuration, stubs will be used for the endpoints or the program will crash
+35 -10
View File
@@ -15,7 +15,11 @@ func LoginHandler(c *gin.Context) {
state := rand.Text() state := rand.Text()
nonce := rand.Text() nonce := rand.Text()
codeVerifier := oauth2.GenerateVerifier() codeVerifier := oauth2.GenerateVerifier()
session := sessions.Default(c) session := sessions.Default(c)
if c.Query("returnTo") != "" {
session.Set("redirect", c.Query("returnTo"))
}
session.Set("jhid_oauth_state", state) session.Set("jhid_oauth_state", state)
session.Set("jhid_oauth_nonce", nonce) session.Set("jhid_oauth_nonce", nonce)
session.Set("jhid_oauth_code_verifier", codeVerifier) session.Set("jhid_oauth_code_verifier", codeVerifier)
@@ -27,23 +31,26 @@ func CallbackHandler(c *gin.Context) {
session := sessions.Default(c) session := sessions.Default(c)
state := session.Get("jhid_oauth_state") state := session.Get("jhid_oauth_state")
nonce := session.Get("jhid_oauth_nonce") nonce := session.Get("jhid_oauth_nonce")
codeVerifier := session.Get("jhid_oauth_code_verifier").(string) codeVerifier := session.Get("jhid_oauth_code_verifier")
if c.Query("state") != state { if c.Query("state") != state || codeVerifier == nil {
log.Println("State invalid") log.Println("State invalid or verifier was not stored")
// TODO: Proper pages // TODO: Proper pages
c.HTML(500, "oidcerror.tmpl", gin.H{ c.HTML(500, "oidcerror.tmpl", gin.H{
"error": "", "error": "ERR_INVALID_STATE",
}) })
c.AbortWithStatus(500) c.Abort()
return return
} }
// Token exchange // Token exchange
tok, err := config.Exchange(c, c.Query("code"), oauth2.VerifierOption(codeVerifier)) tok, err := config.Exchange(c, c.Query("code"), oauth2.VerifierOption(codeVerifier.(string)))
if err != nil { if err != nil {
log.Println("Token exchange failed with error", err) log.Println("Token exchange failed with error", err)
c.AbortWithStatus(500) c.HTML(500, "oidcerror.tmpl", gin.H{
"error": "ERR_AUTH",
})
c.Abort()
return return
} }
@@ -51,13 +58,19 @@ func CallbackHandler(c *gin.Context) {
rawIdToken, ok := tok.Extra("id_token").(string) rawIdToken, ok := tok.Extra("id_token").(string)
if !ok { if !ok {
log.Println("Failed to get ID token", err) log.Println("Failed to get ID token", err)
c.AbortWithStatus(500) c.HTML(500, "oidcerror.tmpl", gin.H{
"error": "ERR_AUTH",
})
c.Abort()
return return
} }
idToken, err := verifier.Verify(c, rawIdToken) idToken, err := verifier.Verify(c, rawIdToken)
if err != nil { if err != nil {
log.Println("Token verification failed", err) log.Println("Token verification failed", err)
c.AbortWithStatus(500) c.HTML(500, "oidcerror.tmpl", gin.H{
"error": "ERR_AUTH",
})
c.Abort()
return return
} }
@@ -85,12 +98,21 @@ func CallbackHandler(c *gin.Context) {
userFunc(claims.Uid, claims.Name, claims.Email) userFunc(claims.Uid, claims.Name, claims.Email)
} }
// Clear session data of oauth related state
session.Delete("jhid_oauth_nonce") session.Delete("jhid_oauth_nonce")
session.Delete("jhid_oauth_state") session.Delete("jhid_oauth_state")
session.Delete("jhid_oauth_code_verifier") session.Delete("jhid_oauth_code_verifier")
redir := session.Get("redirect")
session.Delete("redirect")
session.Set("jhid_auth", true) session.Set("jhid_auth", true)
session.Save() session.Save()
if redir != nil {
c.Redirect(307, redir.(string))
} else {
c.Redirect(307, defaultRedirect)
}
} }
func EnsureLogin(redirectFail bool) func(c *gin.Context) { func EnsureLogin(redirectFail bool) func(c *gin.Context) {
@@ -104,7 +126,10 @@ func EnsureLogin(redirectFail bool) func(c *gin.Context) {
c.Abort() c.Abort()
return return
} else { } else {
c.AbortWithStatus(401) c.HTML(401, "autherror.tmpl", gin.H{
"error": "ERR_AUTH",
})
c.Abort()
return return
} }
} }
+28 -10
View File
@@ -21,27 +21,45 @@ func createRandomString(n int) (string, error) {
} }
var ( var (
config oauth2.Config config oauth2.Config
userFunc func(userid string, name string, email string) userFunc func(userid string, name string, email string)
verifier oidc.IDTokenVerifier verifier oidc.IDTokenVerifier
defaultRedirect string
) )
func Configure(r *gin.Engine, app_url string, scopes []string) { func Configure(r *gin.Engine, app_url string, default_redirect string, stubs_on_unconfigured bool) {
r.GET("/auth/v2/login", LoginHandler) issuer := os.Getenv("OIDC_ISSUER")
r.GET("/auth/v2/verify", CallbackHandler)
provider, err := oidc.NewProvider(context.Background(), os.Getenv("OIDC_ISSUER"))
clientID := os.Getenv("OIDC_CLIENT_ID") clientID := os.Getenv("OIDC_CLIENT_ID")
clientSecret := os.Getenv("OIDC_CLIENT_SECRET")
if issuer == "" || clientID == "" || clientSecret == "" {
if stubs_on_unconfigured {
log.Println("[JHID] WARNING: OIDC not set up due to missing environment variables. Falling back to stubs")
startStubs(r)
return
} else {
log.Fatal("[JHID] One or more requried environment variables are missing. See docs for more information")
}
}
provider, err := oidc.NewProvider(context.Background(), issuer)
verifier = *provider.Verifier(&oidc.Config{ClientID: clientID}) verifier = *provider.Verifier(&oidc.Config{ClientID: clientID})
defaultRedirect = default_redirect
if err != nil { if err != nil {
log.Fatal("Provider resolution failed with error", err) log.Fatal("[JHID] Provider resolution failed with error", err)
} }
config = oauth2.Config{ config = oauth2.Config{
ClientID: clientID, ClientID: clientID,
ClientSecret: os.Getenv("OIDC_CLIENT_SECRET"), ClientSecret: clientSecret,
Endpoint: provider.Endpoint(), Endpoint: provider.Endpoint(),
RedirectURL: app_url + "/auth/v2/verify", RedirectURL: app_url + "/auth/v2/verify",
Scopes: []string{oidc.ScopeOpenID, "email", "profile"}, Scopes: []string{oidc.ScopeOpenID, "email", "profile"},
} }
r.GET("/auth/v2/login", LoginHandler)
r.GET("/auth/v2/verify", CallbackHandler)
log.Println("[JHID] Configured successfully")
} }
View File
Whitespace-only changes.
+1
View File
@@ -4,5 +4,6 @@
</head> </head>
<body> <body>
<h1>Login Failed!</h1> <h1>Login Failed!</h1>
<p>{{ .error }}</p>
</body> </body>
</html> </html>
+22
View File
@@ -0,0 +1,22 @@
package oidclogin
import "github.com/gin-gonic/gin"
func startStubs(r *gin.Engine) {
r.GET("/auth/v2/login", func(ctx *gin.Context) {
redir := ctx.Query("returnTo")
if redir != "" {
ctx.Redirect(307, redir)
} else {
ctx.Redirect(307, defaultRedirect)
}
})
r.GET("/auth/v2/verify", func(ctx *gin.Context) {
redir := ctx.Query("returnTo")
if redir != "" {
ctx.Redirect(307, redir)
} else {
ctx.Redirect(307, defaultRedirect)
}
})
}