mirror of
https://github.com/davidallendj/opaal.git
synced 2026-02-04 00:36:26 -07:00
Compare commits
2 commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8570064235 | ||
|
|
2612978a98 |
2 changed files with 20 additions and 29 deletions
|
|
@ -118,5 +118,5 @@ func (client *Client) FetchTokenFromAuthenticationServer(code string, state stri
|
||||||
fmt.Printf("%s\n", string(b))
|
fmt.Printf("%s\n", string(b))
|
||||||
defer res.Body.Close()
|
defer res.Body.Close()
|
||||||
|
|
||||||
return b, nil
|
return io.ReadAll(res.Body)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -141,47 +141,38 @@ func (s *Server) StartLogin(clients []oauth.Client, params ServerParams) error {
|
||||||
p = params.AuthProvider
|
p = params.AuthProvider
|
||||||
jwks []byte
|
jwks []byte
|
||||||
)
|
)
|
||||||
|
// try and get the JWKS from param first
|
||||||
fetchAndMarshal := func() (err error) {
|
if p.Endpoints.JwksUri != "" {
|
||||||
err = p.FetchJwks()
|
err := p.FetchJwks()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("failed to fetch keys: %v\n", err)
|
fmt.Printf("failed to fetch keys using JWKS url...trying to fetch config and try again...\n")
|
||||||
return
|
|
||||||
}
|
}
|
||||||
jwks, err = json.Marshal(p.KeySet)
|
jwks, err = json.Marshal(p.KeySet)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("failed to marshal JWKS: %v\n", err)
|
fmt.Printf("failed to marshal JWKS: %v\n", err)
|
||||||
}
|
}
|
||||||
return
|
} else if p.Endpoints.Config != "" && jwks == nil {
|
||||||
}
|
// otherwise, try and fetch the whole config and try again
|
||||||
|
err := p.FetchServerConfig()
|
||||||
// try and get the JWKS from param first
|
if err != nil {
|
||||||
if p.Endpoints.JwksUri != "" {
|
|
||||||
if err := fetchAndMarshal(); err != nil {
|
|
||||||
w.Write(jwks)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// otherwise or if fetching the JWKS failed, try and fetch the whole config first and try again
|
|
||||||
if p.Endpoints.Config != "" {
|
|
||||||
if err := p.FetchServerConfig(); err != nil {
|
|
||||||
fmt.Printf("failed to fetch server config: %v\n", err)
|
fmt.Printf("failed to fetch server config: %v\n", err)
|
||||||
http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
|
http.Redirect(w, r, "/error", http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
err = p.FetchJwks()
|
||||||
|
if err != nil {
|
||||||
|
fmt.Printf("failed to fetch JWKS after fetching server config: %v\n", err)
|
||||||
|
http.Redirect(w, r, "/error", http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
fmt.Printf("getting JWKS from param failed and endpoints config unavailable\n")
|
|
||||||
http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
|
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := fetchAndMarshal(); err != nil {
|
// forward the JWKS from the authorization server
|
||||||
fmt.Printf("failed to fetch and marshal JWKS after config update: %v\n", err)
|
if jwks == nil {
|
||||||
http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
|
fmt.Printf("no JWKS was fetched from authorization server\n")
|
||||||
|
http.Redirect(w, r, "/error", http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
w.Write(jwks)
|
w.Write(jwks)
|
||||||
})
|
})
|
||||||
r.HandleFunc("/token", func(w http.ResponseWriter, r *http.Request) {
|
r.HandleFunc("/token", func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue