|
1 | 1 | import mimetypes |
2 | 2 | from typing import Optional |
3 | 3 |
|
4 | | -from keycloak import KeycloakOpenID |
5 | | - |
6 | 4 | from app.config import settings |
| 5 | +from app.keycloak_auth import keycloak_openid |
7 | 6 | from app.models.files import ContentType |
8 | 7 | from app.models.tokens import TokenDB |
9 | 8 | from app.models.users import UserDB |
@@ -41,29 +40,12 @@ async def save_refresh_token(refresh_token: str, email: str): |
41 | 40 | await token_created.insert() |
42 | 41 |
|
43 | 42 |
|
44 | | -async def get_token( |
45 | | - code: str, |
46 | | - *, |
47 | | - server_url=None, |
48 | | - client_id=None, |
49 | | - realm_name=None, |
50 | | - client_secret_key=None, |
51 | | - redirect_uri=None, |
52 | | - verify=True, |
53 | | -): |
54 | | - keycloak_openid = KeycloakOpenID( |
55 | | - server_url=server_url or settings.auth_server_url, |
56 | | - client_id=client_id or settings.auth_client_id, |
57 | | - realm_name=realm_name or settings.auth_realm, |
58 | | - client_secret_key=client_secret_key or settings.auth_client_secret, |
59 | | - verify=verify, |
60 | | - ) |
61 | | - |
| 43 | +async def get_token(code: str, *, redirect_uri: str = settings.auth_redirect_uri): |
62 | 44 | # get token from Keycloak |
63 | 45 | token_body = keycloak_openid.token( |
64 | 46 | grant_type="authorization_code", |
65 | 47 | code=code, |
66 | | - redirect_uri=redirect_uri or settings.auth_redirect_uri, |
| 48 | + redirect_uri=redirect_uri, |
67 | 49 | ) |
68 | 50 |
|
69 | 51 | access_token = token_body["access_token"] |
|
0 commit comments