You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

979 lines
37 KiB

7 years ago
6 years ago
6 years ago
6 years ago
7 years ago
6 years ago
7 years ago
7 years ago
7 years ago
7 years ago
6 years ago
6 years ago
7 years ago
6 years ago
6 years ago
6 years ago
7 years ago
7 years ago
7 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
6 years ago
7 years ago
7 years ago
7 years ago
7 years ago
6 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
6 years ago
7 years ago
7 years ago
7 years ago
6 years ago
7 years ago
  1. # -*- coding: utf-8 -*-
  2. #
  3. # The MIT License (MIT)
  4. #
  5. # Copyright (C) 2017 Marcos Pereira <marcospereira.mpj@gmail.com>
  6. #
  7. # Permission is hereby granted, free of charge, to any person obtaining a copy of
  8. # this software and associated documentation files (the "Software"), to deal in
  9. # the Software without restriction, including without limitation the rights to
  10. # use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
  11. # the Software, and to permit persons to whom the Software is furnished to do so,
  12. # subject to the following conditions:
  13. #
  14. # The above copyright notice and this permission notice shall be included in all
  15. # copies or substantial portions of the Software.
  16. #
  17. # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  18. # IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
  19. # FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
  20. # COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
  21. # IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  22. # CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  23. # Unless otherwise stated in the comments, "id", in e.g. user_id, refers to the
  24. # internal Keycloak server ID, usually a uuid string
  25. import json
  26. from .connection import ConnectionManager
  27. from .exceptions import raise_error_from_response, KeycloakGetError
  28. from .keycloak_openid import KeycloakOpenID
  29. from .urls_patterns import URL_ADMIN_SERVER_INFO, URL_ADMIN_CLIENT_AUTHZ_RESOURCES, URL_ADMIN_CLIENT_ROLES, \
  30. URL_ADMIN_GET_SESSIONS, URL_ADMIN_RESET_PASSWORD, URL_ADMIN_SEND_UPDATE_ACCOUNT, \
  31. URL_ADMIN_USER_CLIENT_ROLES_COMPOSITE, URL_ADMIN_USER_GROUP, URL_ADMIN_REALM_ROLES, URL_ADMIN_GROUP_CHILD, \
  32. URL_ADMIN_USER_CONSENTS, URL_ADMIN_SEND_VERIFY_EMAIL, URL_ADMIN_CLIENT, URL_ADMIN_USER, URL_ADMIN_CLIENT_ROLE, \
  33. URL_ADMIN_USER_GROUPS, URL_ADMIN_CLIENTS, URL_ADMIN_FLOWS_EXECUTIONS, URL_ADMIN_GROUPS, URL_ADMIN_USER_CLIENT_ROLES, \
  34. URL_ADMIN_REALMS, URL_ADMIN_USERS_COUNT, URL_ADMIN_FLOWS, URL_ADMIN_GROUP, URL_ADMIN_CLIENT_AUTHZ_SETTINGS, \
  35. URL_ADMIN_GROUP_MEMBERS, URL_ADMIN_USER_STORAGE, URL_ADMIN_GROUP_PERMISSIONS, URL_ADMIN_IDPS, \
  36. URL_ADMIN_USER_CLIENT_ROLES_AVAILABLE, URL_ADMIN_USERS, URL_ADMIN_CLIENT_SCOPES, \
  37. URL_ADMIN_CLIENT_SCOPES_ADD_MAPPER, URL_ADMIN_CLIENT_SCOPE, URL_ADMIN_CLIENT_SECRETS
  38. class KeycloakAdmin:
  39. PAGE_SIZE = 100
  40. def __init__(self, server_url, username, password, realm_name='master', client_id='admin-cli', verify=True, client_secret_key=None):
  41. """
  42. :param server_url: Keycloak server url
  43. :param username: admin username
  44. :param password: admin password
  45. :param realm_name: realm name
  46. :param client_id: client id
  47. :param verify: True if want check connection SSL
  48. :param client_secret_key: client secret key
  49. """
  50. self._username = username
  51. self._password = password
  52. self._client_id = client_id
  53. self._realm_name = realm_name
  54. # Get token Admin
  55. keycloak_openid = KeycloakOpenID(server_url=server_url, client_id=client_id, realm_name=realm_name,
  56. verify=verify, client_secret_key=client_secret_key)
  57. grant_type = ["password"]
  58. if client_secret_key:
  59. grant_type = ["client_credentials"]
  60. self._token = keycloak_openid.token(username, password, grant_type=grant_type)
  61. self._connection = ConnectionManager(base_url=server_url,
  62. headers={'Authorization': 'Bearer ' + self.token.get('access_token'),
  63. 'Content-Type': 'application/json'},
  64. timeout=60,
  65. verify=verify)
  66. @property
  67. def realm_name(self):
  68. return self._realm_name
  69. @realm_name.setter
  70. def realm_name(self, value):
  71. self._realm_name = value
  72. @property
  73. def connection(self):
  74. return self._connection
  75. @connection.setter
  76. def connection(self, value):
  77. self._connection = value
  78. @property
  79. def client_id(self):
  80. return self._client_id
  81. @client_id.setter
  82. def client_id(self, value):
  83. self._client_id = value
  84. @property
  85. def username(self):
  86. return self._username
  87. @username.setter
  88. def username(self, value):
  89. self._username = value
  90. @property
  91. def password(self):
  92. return self._password
  93. @password.setter
  94. def password(self, value):
  95. self._password = value
  96. @property
  97. def token(self):
  98. return self._token
  99. @token.setter
  100. def token(self, value):
  101. self._token = value
  102. def __fetch_all(self, url, query=None):
  103. '''Wrapper function to paginate GET requests
  104. :param url: The url on which the query is executed
  105. :param query: Existing query parameters (optional)
  106. :return: Combined results of paginated queries
  107. '''
  108. results = []
  109. # initalize query if it was called with None
  110. if not query:
  111. query = {}
  112. page = 0
  113. query['max'] = self.PAGE_SIZE
  114. # fetch until we can
  115. while True:
  116. query['first'] = page*self.PAGE_SIZE
  117. partial_results = raise_error_from_response(
  118. self.connection.raw_get(url, **query),
  119. KeycloakGetError)
  120. if not partial_results:
  121. break
  122. results.extend(partial_results)
  123. page += 1
  124. return results
  125. def import_realm(self, payload):
  126. """
  127. Import a new realm from a RealmRepresentation. Realm name must be unique.
  128. RealmRepresentation
  129. https://www.keycloak.org/docs-api/4.4/rest-api/index.html#_realmrepresentation
  130. :param payload: RealmRepresentation
  131. :return: RealmRepresentation
  132. """
  133. data_raw = self.connection.raw_post(URL_ADMIN_REALMS,
  134. data=json.dumps(payload))
  135. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201)
  136. def get_realms(self):
  137. """
  138. Lists all realms in Keycloak deployment
  139. :return: realms list
  140. """
  141. data_raw = self.connection.raw_get(URL_ADMIN_REALMS)
  142. return raise_error_from_response(data_raw, KeycloakGetError)
  143. def create_realm(self, payload, skip_exists=False):
  144. """
  145. Create a client
  146. ClientRepresentation: http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_realmrepresentation
  147. :param skip_exists: Skip if Realm already exist.
  148. :param payload: RealmRepresentation
  149. :return: Keycloak server response (UserRepresentation)
  150. """
  151. data_raw = self.connection.raw_post(URL_ADMIN_REALMS,
  152. data=json.dumps(payload))
  153. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  154. def get_users(self, query=None):
  155. """
  156. Get users Returns a list of users, filtered according to query parameters
  157. :return: users list
  158. """
  159. params_path = {"realm-name": self.realm_name}
  160. return self.__fetch_all(URL_ADMIN_USERS.format(**params_path), query)
  161. def get_idps(self):
  162. """
  163. Returns a list of ID Providers,
  164. IdentityProviderRepresentation
  165. https://www.keycloak.org/docs-api/3.3/rest-api/index.html#_identityproviderrepresentation
  166. :return: array IdentityProviderRepresentation
  167. """
  168. params_path = {"realm-name": self.realm_name}
  169. data_raw = self.connection.raw_get(URL_ADMIN_IDPS.format(**params_path))
  170. return raise_error_from_response(data_raw, KeycloakGetError)
  171. def create_user(self, payload):
  172. """
  173. Create a new user Username must be unique
  174. UserRepresentation
  175. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_userrepresentation
  176. :param payload: UserRepresentation
  177. :return: UserRepresentation
  178. """
  179. params_path = {"realm-name": self.realm_name}
  180. exists = self.get_user_id(username=payload['username'])
  181. if exists is not None:
  182. return str(exists)
  183. data_raw = self.connection.raw_post(URL_ADMIN_USERS.format(**params_path),
  184. data=json.dumps(payload))
  185. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201)
  186. def users_count(self):
  187. """
  188. User counter
  189. :return: counter
  190. """
  191. params_path = {"realm-name": self.realm_name}
  192. data_raw = self.connection.raw_get(URL_ADMIN_USERS_COUNT.format(**params_path))
  193. return raise_error_from_response(data_raw, KeycloakGetError)
  194. def get_user_id(self, username):
  195. """
  196. Get internal keycloak user id from username
  197. This is required for further actions against this user.
  198. UserRepresentation
  199. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_userrepresentation
  200. :param username: id in UserRepresentation
  201. :return: user_id
  202. """
  203. users = self.get_users(query={"search": username})
  204. return next((user["id"] for user in users if user["username"] == username), None)
  205. def get_user(self, user_id):
  206. """
  207. Get representation of the user
  208. :param user_id: User id
  209. UserRepresentation: http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_userrepresentation
  210. :return: UserRepresentation
  211. """
  212. params_path = {"realm-name": self.realm_name, "id": user_id}
  213. data_raw = self.connection.raw_get(URL_ADMIN_USER.format(**params_path))
  214. return raise_error_from_response(data_raw, KeycloakGetError)
  215. def get_user_groups(self, user_id):
  216. """
  217. Get user groups Returns a list of groups of which the user is a member
  218. :param user_id: User id
  219. :return: user groups list
  220. """
  221. params_path = {"realm-name": self.realm_name, "id": user_id}
  222. data_raw = self.connection.raw_get(URL_ADMIN_USER_GROUPS.format(**params_path))
  223. return raise_error_from_response(data_raw, KeycloakGetError)
  224. def update_user(self, user_id, payload):
  225. """
  226. Update the user
  227. :param user_id: User id
  228. :param payload: UserRepresentation
  229. :return: Http response
  230. """
  231. params_path = {"realm-name": self.realm_name, "id": user_id}
  232. data_raw = self.connection.raw_put(URL_ADMIN_USER.format(**params_path),
  233. data=json.dumps(payload))
  234. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  235. def delete_user(self, user_id):
  236. """
  237. Delete the user
  238. :param user_id: User id
  239. :return: Http response
  240. """
  241. params_path = {"realm-name": self.realm_name, "id": user_id}
  242. data_raw = self.connection.raw_delete(URL_ADMIN_USER.format(**params_path))
  243. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  244. def set_user_password(self, user_id, password, temporary=True):
  245. """
  246. Set up a password for the user. If temporary is True, the user will have to reset
  247. the temporary password next time they log in.
  248. http://www.keycloak.org/docs-api/3.2/rest-api/#_users_resource
  249. http://www.keycloak.org/docs-api/3.2/rest-api/#_credentialrepresentation
  250. :param user_id: User id
  251. :param password: New password
  252. :param temporary: True if password is temporary
  253. :return:
  254. """
  255. payload = {"type": "password", "temporary": temporary, "value": password}
  256. params_path = {"realm-name": self.realm_name, "id": user_id}
  257. data_raw = self.connection.raw_put(URL_ADMIN_RESET_PASSWORD.format(**params_path),
  258. data=json.dumps(payload))
  259. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  260. def consents_user(self, user_id):
  261. """
  262. Get consents granted by the user
  263. :param user_id: User id
  264. :return: consents
  265. """
  266. params_path = {"realm-name": self.realm_name, "id": user_id}
  267. data_raw = self.connection.raw_get(URL_ADMIN_USER_CONSENTS.format(**params_path))
  268. return raise_error_from_response(data_raw, KeycloakGetError)
  269. def send_update_account(self, user_id, payload, client_id=None, lifespan=None, redirect_uri=None):
  270. """
  271. Send a update account email to the user An email contains a
  272. link the user can click to perform a set of required actions.
  273. :param user_id:
  274. :param payload:
  275. :param client_id:
  276. :param lifespan:
  277. :param redirect_uri:
  278. :return:
  279. """
  280. params_path = {"realm-name": self.realm_name, "id": user_id}
  281. params_query = {"client_id": client_id, "lifespan": lifespan, "redirect_uri": redirect_uri}
  282. data_raw = self.connection.raw_put(URL_ADMIN_SEND_UPDATE_ACCOUNT.format(**params_path),
  283. data=payload, **params_query)
  284. return raise_error_from_response(data_raw, KeycloakGetError)
  285. def send_verify_email(self, user_id, client_id=None, redirect_uri=None):
  286. """
  287. Send a update account email to the user An email contains a
  288. link the user can click to perform a set of required actions.
  289. :param user_id: User id
  290. :param client_id: Client id
  291. :param redirect_uri: Redirect uri
  292. :return:
  293. """
  294. params_path = {"realm-name": self.realm_name, "id": user_id}
  295. params_query = {"client_id": client_id, "redirect_uri": redirect_uri}
  296. data_raw = self.connection.raw_put(URL_ADMIN_SEND_VERIFY_EMAIL.format(**params_path),
  297. data={}, **params_query)
  298. return raise_error_from_response(data_raw, KeycloakGetError)
  299. def get_sessions(self, user_id):
  300. """
  301. Get sessions associated with the user
  302. :param user_id: id of user
  303. UserSessionRepresentation
  304. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_usersessionrepresentation
  305. :return: UserSessionRepresentation
  306. """
  307. params_path = {"realm-name": self.realm_name, "id": user_id}
  308. data_raw = self.connection.raw_get(URL_ADMIN_GET_SESSIONS.format(**params_path))
  309. return raise_error_from_response(data_raw, KeycloakGetError)
  310. def get_server_info(self):
  311. """
  312. Get themes, social providers, auth providers, and event listeners available on this server
  313. ServerInfoRepresentation
  314. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_serverinforepresentation
  315. :return: ServerInfoRepresentation
  316. """
  317. data_raw = self.connection.raw_get(URL_ADMIN_SERVER_INFO)
  318. return raise_error_from_response(data_raw, KeycloakGetError)
  319. def get_groups(self):
  320. """
  321. Get groups belonging to the realm. Returns a list of groups belonging to the realm
  322. GroupRepresentation
  323. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  324. :return: array GroupRepresentation
  325. """
  326. params_path = {"realm-name": self.realm_name}
  327. return self.__fetch_all(URL_ADMIN_GROUPS.format(**params_path))
  328. def get_group(self, group_id):
  329. """
  330. Get group by id. Returns full group details
  331. GroupRepresentation
  332. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  333. :return: Keycloak server response (GroupRepresentation)
  334. """
  335. params_path = {"realm-name": self.realm_name, "id": group_id}
  336. data_raw = self.connection.raw_get(URL_ADMIN_GROUP.format(**params_path))
  337. return raise_error_from_response(data_raw, KeycloakGetError)
  338. def get_subgroups(self, group, path):
  339. """
  340. Utility function to iterate through nested group structures
  341. GroupRepresentation
  342. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  343. :param name: group (GroupRepresentation)
  344. :param path: group path (string)
  345. :return: Keycloak server response (GroupRepresentation)
  346. """
  347. for subgroup in group["subGroups"]:
  348. if subgroup['path'] == path:
  349. return subgroup
  350. elif subgroup["subGroups"]:
  351. for subgroup in group["subGroups"]:
  352. return self.get_subgroups(subgroup, path)
  353. return None
  354. def get_group_members(self, group_id, **query):
  355. """
  356. Get members by group id. Returns group members
  357. GroupRepresentation
  358. http://www.keycloak.org/docs-api/3.2/rest-api/#_userrepresentation
  359. :return: Keycloak server response (UserRepresentation)
  360. """
  361. params_path = {"realm-name": self.realm_name, "id": group_id}
  362. return self.__fetch_all(URL_ADMIN_GROUP_MEMBERS.format(**params_path), query)
  363. def get_group_by_path(self, path, search_in_subgroups=False):
  364. """
  365. Get group id based on name or path.
  366. A straight name or path match with a top-level group will return first.
  367. Subgroups are traversed, the first to match path (or name with path) is returned.
  368. GroupRepresentation
  369. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  370. :param path: group path
  371. :param search_in_subgroups: True if want search in the subgroups
  372. :return: Keycloak server response (GroupRepresentation)
  373. """
  374. groups = self.get_groups()
  375. # TODO: Review this code is necessary
  376. for group in groups:
  377. if group['path'] == path:
  378. return group
  379. elif search_in_subgroups and group["subGroups"]:
  380. for group in group["subGroups"]:
  381. if group['path'] == path:
  382. return group
  383. res = self.get_subgroups(group, path)
  384. if res != None:
  385. return res
  386. return None
  387. def create_group(self, payload, parent=None, skip_exists=False):
  388. """
  389. Creates a group in the Realm
  390. :param payload: GroupRepresentation
  391. :param parent: parent group's id. Required to create a sub-group.
  392. GroupRepresentation
  393. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  394. :return: Http response
  395. """
  396. name = payload['name']
  397. path = payload['path']
  398. exists = None
  399. if name is None and path is not None:
  400. path = "/" + name
  401. elif path is not None:
  402. exists = self.get_group_by_path(path=path, search_in_subgroups=True)
  403. if exists is not None:
  404. return str(exists)
  405. if parent is None:
  406. params_path = {"realm-name": self.realm_name}
  407. data_raw = self.connection.raw_post(URL_ADMIN_GROUPS.format(**params_path),
  408. data=json.dumps(payload))
  409. else:
  410. params_path = {"realm-name": self.realm_name, "id": parent, }
  411. data_raw = self.connection.raw_post(URL_ADMIN_GROUP_CHILD.format(**params_path),
  412. data=json.dumps(payload))
  413. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  414. def group_set_permissions(self, group_id, enabled=True):
  415. """
  416. Enable/Disable permissions for a group. Cannot delete group if disabled
  417. :param group_id: id of group
  418. :param enabled: boolean
  419. :return: Keycloak server response
  420. """
  421. params_path = {"realm-name": self.realm_name, "id": group_id}
  422. data_raw = self.connection.raw_put(URL_ADMIN_GROUP_PERMISSIONS.format(**params_path),
  423. data=json.dumps({"enabled": enabled}))
  424. return raise_error_from_response(data_raw, KeycloakGetError)
  425. def group_user_add(self, user_id, group_id):
  426. """
  427. Add user to group (user_id and group_id)
  428. :param group_id: id of group
  429. :param user_id: id of user
  430. :param group_id: id of group to add to
  431. :return: Keycloak server response
  432. """
  433. params_path = {"realm-name": self.realm_name, "id": user_id, "group-id": group_id}
  434. data_raw = self.connection.raw_put(URL_ADMIN_USER_GROUP.format(**params_path), data=None)
  435. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  436. def group_user_remove(self, user_id, group_id):
  437. """
  438. Remove user from group (user_id and group_id)
  439. :param group_id: id of group
  440. :param user_id: id of user
  441. :param group_id: id of group to add to
  442. :return: Keycloak server response
  443. """
  444. params_path = {"realm-name": self.realm_name, "id": user_id, "group-id": group_id}
  445. data_raw = self.connection.raw_delete(URL_ADMIN_USER_GROUP.format(**params_path))
  446. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  447. def delete_group(self, group_id):
  448. """
  449. Deletes a group in the Realm
  450. :param group_id: id of group to delete
  451. :return: Keycloak server response
  452. """
  453. params_path = {"realm-name": self.realm_name, "id": group_id}
  454. data_raw = self.connection.raw_delete(URL_ADMIN_GROUP.format(**params_path))
  455. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  456. def get_clients(self):
  457. """
  458. Get clients belonging to the realm Returns a list of clients belonging to the realm
  459. ClientRepresentation
  460. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  461. :return: Keycloak server response (ClientRepresentation)
  462. """
  463. params_path = {"realm-name": self.realm_name}
  464. data_raw = self.connection.raw_get(URL_ADMIN_CLIENTS.format(**params_path))
  465. return raise_error_from_response(data_raw, KeycloakGetError)
  466. def get_client(self, client_id):
  467. """
  468. Get representation of the client
  469. ClientRepresentation
  470. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  471. :param client_id: id of client (not client-id)
  472. :return: Keycloak server response (ClientRepresentation)
  473. """
  474. params_path = {"realm-name": self.realm_name, "id": client_id}
  475. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT.format(**params_path))
  476. return raise_error_from_response(data_raw, KeycloakGetError)
  477. def get_client_id(self, client_name):
  478. """
  479. Get internal keycloak client id from client-id.
  480. This is required for further actions against this client.
  481. :param client_name: name in ClientRepresentation
  482. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  483. :return: client_id (uuid as string)
  484. """
  485. clients = self.get_clients()
  486. for client in clients:
  487. if client_name == client.get('name') or client_name == client.get('clientId'):
  488. return client["id"]
  489. return None
  490. def get_client_authz_settings(self, client_id):
  491. """
  492. Get authorization json from client.
  493. :param client_id: id in ClientRepresentation
  494. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  495. :return: Keycloak server response
  496. """
  497. params_path = {"realm-name": self.realm_name, "id": client_id}
  498. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_AUTHZ_SETTINGS.format(**params_path))
  499. return data_raw
  500. def get_client_authz_resources(self, client_id):
  501. """
  502. Get resources from client.
  503. :param client_id: id in ClientRepresentation
  504. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  505. :return: Keycloak server response
  506. """
  507. params_path = {"realm-name": self.realm_name, "id": client_id}
  508. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_AUTHZ_RESOURCES.format(**params_path))
  509. return data_raw
  510. def create_client(self, payload, skip_exists=False):
  511. """
  512. Create a client
  513. ClientRepresentation: http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  514. :param skip_exists: Skip if client already exist.
  515. :param payload: ClientRepresentation
  516. :return: Keycloak server response (UserRepresentation)
  517. """
  518. params_path = {"realm-name": self.realm_name}
  519. data_raw = self.connection.raw_post(URL_ADMIN_CLIENTS.format(**params_path),
  520. data=json.dumps(payload))
  521. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  522. def delete_client(self, client_id):
  523. """
  524. Get representation of the client
  525. ClientRepresentation
  526. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  527. :param client_id: keycloak client id (not oauth client-id)
  528. :return: Keycloak server response (ClientRepresentation)
  529. """
  530. params_path = {"realm-name": self.realm_name, "id": client_id}
  531. data_raw = self.connection.raw_delete(URL_ADMIN_CLIENT.format(**params_path))
  532. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  533. def get_realm_roles(self):
  534. """
  535. Get all roles for the realm or client
  536. RoleRepresentation
  537. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  538. :return: Keycloak server response (RoleRepresentation)
  539. """
  540. params_path = {"realm-name": self.realm_name}
  541. data_raw = self.connection.raw_get(URL_ADMIN_REALM_ROLES.format(**params_path))
  542. return raise_error_from_response(data_raw, KeycloakGetError)
  543. def get_client_roles(self, client_id):
  544. """
  545. Get all roles for the client
  546. :param client_id: id of client (not client-id)
  547. RoleRepresentation
  548. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  549. :return: Keycloak server response (RoleRepresentation)
  550. """
  551. params_path = {"realm-name": self.realm_name, "id": client_id}
  552. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_ROLES.format(**params_path))
  553. return raise_error_from_response(data_raw, KeycloakGetError)
  554. def get_client_role(self, client_id, role_name):
  555. """
  556. Get client role id by name
  557. This is required for further actions with this role.
  558. :param client_id: id of client (not client-id)
  559. :param role_name: roles name (not id!)
  560. RoleRepresentation
  561. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  562. :return: role_id
  563. """
  564. params_path = {"realm-name": self.realm_name, "id": client_id, "role-name": role_name}
  565. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_ROLE.format(**params_path))
  566. return raise_error_from_response(data_raw, KeycloakGetError)
  567. def get_client_role_id(self, client_id, role_name):
  568. """
  569. Warning: Deprecated
  570. Get client role id by name
  571. This is required for further actions with this role.
  572. :param client_id: id of client (not client-id)
  573. :param role_name: roles name (not id!)
  574. RoleRepresentation
  575. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  576. :return: role_id
  577. """
  578. role = self.get_client_role(client_id, role_name)
  579. return role.get("id")
  580. def create_client_role(self, client_role_id, payload, skip_exists=False):
  581. """
  582. Create a client role
  583. RoleRepresentation
  584. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  585. :param client_role_id: id of client (not client-id)
  586. :param payload: RoleRepresentation
  587. :return: Keycloak server response (RoleRepresentation)
  588. """
  589. params_path = {"realm-name": self.realm_name, "id": client_role_id}
  590. data_raw = self.connection.raw_post(URL_ADMIN_CLIENT_ROLES.format(**params_path),
  591. data=json.dumps(payload))
  592. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  593. def delete_client_role(self, client_role_id, role_name):
  594. """
  595. Create a client role
  596. RoleRepresentation
  597. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  598. :param client_role_id: id of client (not client-id)
  599. :param role_name: roles name (not id!)
  600. """
  601. params_path = {"realm-name": self.realm_name, "id": client_role_id, "role-name": role_name}
  602. data_raw = self.connection.raw_delete(URL_ADMIN_CLIENT_ROLE.format(**params_path))
  603. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  604. def assign_client_role(self, user_id, client_id, roles):
  605. """
  606. Assign a client role to a user
  607. :param client_id: id of client (not client-id)
  608. :param user_id: id of user
  609. :param client_id: id of client containing role,
  610. :param roles: roles list or role (use RoleRepresentation)
  611. :return Keycloak server response
  612. """
  613. payload = roles if isinstance(roles, list) else [roles]
  614. params_path = {"realm-name": self.realm_name, "id": user_id, "client-id": client_id}
  615. data_raw = self.connection.raw_post(URL_ADMIN_USER_CLIENT_ROLES.format(**params_path),
  616. data=json.dumps(payload))
  617. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  618. def get_client_roles_of_user(self, user_id, client_id):
  619. """
  620. Get all client roles for a user.
  621. :param client_id: id of client (not client-id)
  622. :param user_id: id of user
  623. :return: Keycloak server response (array RoleRepresentation)
  624. """
  625. return self._get_client_roles_of_user(URL_ADMIN_USER_CLIENT_ROLES, user_id, client_id)
  626. def get_available_client_roles_of_user(self, user_id, client_id):
  627. """
  628. Get available client role-mappings for a user.
  629. :param client_id: id of client (not client-id)
  630. :param user_id: id of user
  631. :return: Keycloak server response (array RoleRepresentation)
  632. """
  633. return self._get_client_roles_of_user(URL_ADMIN_USER_CLIENT_ROLES_AVAILABLE, user_id, client_id)
  634. def get_composite_client_roles_of_user(self, user_id, client_id):
  635. """
  636. Get composite client role-mappings for a user.
  637. :param client_id: id of client (not client-id)
  638. :param user_id: id of user
  639. :return: Keycloak server response (array RoleRepresentation)
  640. """
  641. return self._get_client_roles_of_user(URL_ADMIN_USER_CLIENT_ROLES_COMPOSITE, user_id, client_id)
  642. def _get_client_roles_of_user(self, client_level_role_mapping_url, user_id, client_id):
  643. params_path = {"realm-name": self.realm_name, "id": user_id, "client-id": client_id}
  644. data_raw = self.connection.raw_get(client_level_role_mapping_url.format(**params_path))
  645. return raise_error_from_response(data_raw, KeycloakGetError)
  646. def delete_client_roles_of_user(self, user_id, client_id, roles):
  647. """
  648. Delete client roles from a user.
  649. :param client_id: id of client (not client-id)
  650. :param user_id: id of user
  651. :param client_id: id of client containing role,
  652. :param roles: roles list or role to delete (use RoleRepresentation)
  653. :return: Keycloak server response
  654. """
  655. payload = roles if isinstance(roles, list) else [roles]
  656. params_path = {"realm-name": self.realm_name, "id": user_id, "client-id": client_id}
  657. data_raw = self.connection.raw_delete(URL_ADMIN_USER_CLIENT_ROLES.format(**params_path),
  658. data=json.dumps(payload))
  659. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  660. def get_authentication_flows(self):
  661. """
  662. Get authentication flows. Returns all flow details
  663. AuthenticationFlowRepresentation
  664. https://www.keycloak.org/docs-api/4.1/rest-api/index.html#_authenticationflowrepresentation
  665. :return: Keycloak server response (AuthenticationFlowRepresentation)
  666. """
  667. params_path = {"realm-name": self.realm_name}
  668. data_raw = self.connection.raw_get(URL_ADMIN_FLOWS.format(**params_path))
  669. return raise_error_from_response(data_raw, KeycloakGetError)
  670. def create_authentication_flow(self, payload, skip_exists=False):
  671. """
  672. Create a new authentication flow
  673. AuthenticationFlowRepresentation
  674. https://www.keycloak.org/docs-api/4.1/rest-api/index.html#_authenticationflowrepresentation
  675. :param payload: AuthenticationFlowRepresentation
  676. :return: Keycloak server response (RoleRepresentation)
  677. """
  678. params_path = {"realm-name": self.realm_name}
  679. data_raw = self.connection.raw_post(URL_ADMIN_FLOWS.format(**params_path),
  680. data=payload)
  681. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  682. def get_authentication_flow_executions(self, flow_alias):
  683. """
  684. Get authentication flow executions. Returns all execution steps
  685. :return: Response(json)
  686. """
  687. params_path = {"realm-name": self.realm_name, "flow-alias": flow_alias}
  688. data_raw = self.connection.raw_get(URL_ADMIN_FLOWS_EXECUTIONS.format(**params_path))
  689. return raise_error_from_response(data_raw, KeycloakGetError)
  690. def update_authentication_flow_executions(self, payload, flow_alias):
  691. """
  692. Update an authentication flow execution
  693. AuthenticationExecutionInfoRepresentation
  694. https://www.keycloak.org/docs-api/4.1/rest-api/index.html#_authenticationexecutioninforepresentation
  695. :param payload: AuthenticationExecutionInfoRepresentation
  696. :return: Keycloak server response
  697. """
  698. params_path = {"realm-name": self.realm_name, "flow-alias": flow_alias}
  699. data_raw = self.connection.raw_put(URL_ADMIN_FLOWS_EXECUTIONS.format(**params_path),
  700. data=payload)
  701. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  702. def sync_users(self, storage_id, action):
  703. """
  704. Function to trigger user sync from provider
  705. :param storage_id:
  706. :param action:
  707. :return:
  708. """
  709. data = {'action': action}
  710. params_query = {"action": action}
  711. params_path = {"realm-name": self.realm_name, "id": storage_id}
  712. data_raw = self.connection.raw_post(URL_ADMIN_USER_STORAGE.format(**params_path),
  713. data=json.dumps(data), **params_query)
  714. return raise_error_from_response(data_raw, KeycloakGetError)
  715. def get_client_scopes(self):
  716. """
  717. Get representation of the client scopes for the realm where we are connected to
  718. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_getclientscopes
  719. :return: Keycloak server response Array of (ClientScopeRepresentation)
  720. """
  721. params_path = {"realm-name": self.realm_name}
  722. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_SCOPES.format(**params_path))
  723. return raise_error_from_response(data_raw, KeycloakGetError)
  724. def get_client_scope(self, client_scope_id):
  725. """
  726. Get representation of the client scopes for the realm where we are connected to
  727. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_getclientscopes
  728. :return: Keycloak server response (ClientScopeRepresentation)
  729. """
  730. params_path = {"realm-name": self.realm_name, "scope-id": client_scope_id}
  731. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_SCOPE.format(**params_path))
  732. return raise_error_from_response(data_raw, KeycloakGetError)
  733. def add_mapper_to_client_scope(self, client_scope_id, payload):
  734. """
  735. Add a mapper to a client scope
  736. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_create_mapper
  737. :param payload: ProtocolMapperRepresentation
  738. :return: Keycloak server Response
  739. """
  740. params_path = {"realm-name": self.realm_name, "scope-id": client_scope_id}
  741. data_raw = self.connection.raw_post(URL_ADMIN_CLIENT_SCOPES_ADD_MAPPER.format(**params_path), data=json.dumps(payload))
  742. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201)
  743. def get_client_secrets(self, client_id):
  744. """
  745. Get representation of the client secrets
  746. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_getclientsecret
  747. :param client_id: id of client (not client-id)
  748. :return: Keycloak server response (ClientRepresentation)
  749. """
  750. params_path = {"realm-name": self.realm_name, "id": client_id}
  751. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_SECRETS.format(**params_path))
  752. return raise_error_from_response(data_raw, KeycloakGetError)