forked from AkkomaGang/akkoma
Make OAuth token endpoint work with HTTP Basic auth
client_id/client_secret can now be supplied in an Authorization header
This commit is contained in:
parent
04c584391c
commit
73904e8f78
1 changed files with 26 additions and 12 deletions
|
@ -56,12 +56,7 @@ def create_authorization(conn, %{
|
||||||
# TODO
|
# TODO
|
||||||
# - proper scope handling
|
# - proper scope handling
|
||||||
def token_exchange(conn, %{"grant_type" => "authorization_code"} = params) do
|
def token_exchange(conn, %{"grant_type" => "authorization_code"} = params) do
|
||||||
with %App{} = app <-
|
with %App{} = app <- get_app_from_request(conn, params),
|
||||||
Repo.get_by(
|
|
||||||
App,
|
|
||||||
client_id: params["client_id"],
|
|
||||||
client_secret: params["client_secret"]
|
|
||||||
),
|
|
||||||
fixed_token = fix_padding(params["code"]),
|
fixed_token = fix_padding(params["code"]),
|
||||||
%Authorization{} = auth <-
|
%Authorization{} = auth <-
|
||||||
Repo.get_by(Authorization, token: fixed_token, app_id: app.id),
|
Repo.get_by(Authorization, token: fixed_token, app_id: app.id),
|
||||||
|
@ -86,12 +81,7 @@ def token_exchange(
|
||||||
conn,
|
conn,
|
||||||
%{"grant_type" => "password", "name" => name, "password" => password} = params
|
%{"grant_type" => "password", "name" => name, "password" => password} = params
|
||||||
) do
|
) do
|
||||||
with %App{} = app <-
|
with %App{} = app <- get_app_from_request(conn, params),
|
||||||
Repo.get_by(
|
|
||||||
App,
|
|
||||||
client_id: params["client_id"],
|
|
||||||
client_secret: params["client_secret"]
|
|
||||||
),
|
|
||||||
%User{} = user <- User.get_cached_by_nickname(name),
|
%User{} = user <- User.get_cached_by_nickname(name),
|
||||||
true <- Pbkdf2.checkpw(password, user.password_hash),
|
true <- Pbkdf2.checkpw(password, user.password_hash),
|
||||||
{:ok, auth} <- Authorization.create_authorization(app, user),
|
{:ok, auth} <- Authorization.create_authorization(app, user),
|
||||||
|
@ -115,4 +105,28 @@ defp fix_padding(token) do
|
||||||
|> Base.url_decode64!(padding: false)
|
|> Base.url_decode64!(padding: false)
|
||||||
|> Base.url_encode64()
|
|> Base.url_encode64()
|
||||||
end
|
end
|
||||||
|
|
||||||
|
defp get_app_from_request(conn, params) do
|
||||||
|
# Per RFC 6749, HTTP Basic is preferred to body params
|
||||||
|
{client_id, client_secret} =
|
||||||
|
with ["Basic " <> encoded] <- get_req_header(conn, "authorization"),
|
||||||
|
{:ok, decoded} <- Base.decode64(encoded),
|
||||||
|
[id, secret] <-
|
||||||
|
String.split(decoded, ":")
|
||||||
|
|> Enum.map(fn s -> URI.decode_www_form(s) end) do
|
||||||
|
{id, secret}
|
||||||
|
else
|
||||||
|
_ -> {params["client_id"], params["client_secret"]}
|
||||||
|
end
|
||||||
|
|
||||||
|
if client_id && client_secret do
|
||||||
|
Repo.get_by(
|
||||||
|
App,
|
||||||
|
client_id: client_id,
|
||||||
|
client_secret: client_secret
|
||||||
|
)
|
||||||
|
else
|
||||||
|
nil
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in a new issue