|
@ -45,7 +45,8 @@ class KeycloakAdmin: |
|
|
|
|
|
|
|
|
PAGE_SIZE = 100 |
|
|
PAGE_SIZE = 100 |
|
|
|
|
|
|
|
|
def __init__(self, server_url, username, password, realm_name='master', client_id='admin-cli', verify=True, client_secret_key=None): |
|
|
|
|
|
|
|
|
def __init__(self, server_url, username, password, realm_name='master', client_id='admin-cli', verify=True, |
|
|
|
|
|
client_secret_key=None, custom_headers=None): |
|
|
""" |
|
|
""" |
|
|
|
|
|
|
|
|
:param server_url: Keycloak server url |
|
|
:param server_url: Keycloak server url |
|
@ -55,6 +56,7 @@ class KeycloakAdmin: |
|
|
:param client_id: client id |
|
|
:param client_id: client id |
|
|
:param verify: True if want check connection SSL |
|
|
:param verify: True if want check connection SSL |
|
|
:param client_secret_key: client secret key |
|
|
:param client_secret_key: client secret key |
|
|
|
|
|
:param custom_headers: dict of custom header to pass to each HTML request |
|
|
""" |
|
|
""" |
|
|
self._username = username |
|
|
self._username = username |
|
|
self._password = password |
|
|
self._password = password |
|
@ -63,15 +65,23 @@ class KeycloakAdmin: |
|
|
|
|
|
|
|
|
# Get token Admin |
|
|
# Get token Admin |
|
|
keycloak_openid = KeycloakOpenID(server_url=server_url, client_id=client_id, realm_name=realm_name, |
|
|
keycloak_openid = KeycloakOpenID(server_url=server_url, client_id=client_id, realm_name=realm_name, |
|
|
verify=verify, client_secret_key=client_secret_key) |
|
|
|
|
|
|
|
|
verify=verify, client_secret_key=client_secret_key, |
|
|
|
|
|
custom_headers=custom_headers) |
|
|
|
|
|
|
|
|
grant_type = ["password"] |
|
|
grant_type = ["password"] |
|
|
if client_secret_key: |
|
|
if client_secret_key: |
|
|
grant_type = ["client_credentials"] |
|
|
grant_type = ["client_credentials"] |
|
|
self._token = keycloak_openid.token(username, password, grant_type=grant_type) |
|
|
self._token = keycloak_openid.token(username, password, grant_type=grant_type) |
|
|
|
|
|
headers = { |
|
|
|
|
|
'Authorization': 'Bearer ' + self.token.get('access_token'), |
|
|
|
|
|
'Content-Type': 'application/json' |
|
|
|
|
|
} |
|
|
|
|
|
if custom_headers is not None: |
|
|
|
|
|
# merge custom headers to main headers |
|
|
|
|
|
headers.update(custom_headers) |
|
|
|
|
|
|
|
|
self._connection = ConnectionManager(base_url=server_url, |
|
|
self._connection = ConnectionManager(base_url=server_url, |
|
|
headers={'Authorization': 'Bearer ' + self.token.get('access_token'), |
|
|
|
|
|
'Content-Type': 'application/json'}, |
|
|
|
|
|
|
|
|
headers=headers, |
|
|
timeout=60, |
|
|
timeout=60, |
|
|
verify=verify) |
|
|
verify=verify) |
|
|
|
|
|
|
|
|