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.

1006 lines
38 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
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. result = self.get_subgroups(subgroup, path)
  353. if result:
  354. return result
  355. # went through the tree without hits
  356. return None
  357. def get_group_members(self, group_id, **query):
  358. """
  359. Get members by group id. Returns group members
  360. GroupRepresentation
  361. http://www.keycloak.org/docs-api/3.2/rest-api/#_userrepresentation
  362. :return: Keycloak server response (UserRepresentation)
  363. """
  364. params_path = {"realm-name": self.realm_name, "id": group_id}
  365. return self.__fetch_all(URL_ADMIN_GROUP_MEMBERS.format(**params_path), query)
  366. def get_group_by_path(self, path, search_in_subgroups=False):
  367. """
  368. Get group id based on name or path.
  369. A straight name or path match with a top-level group will return first.
  370. Subgroups are traversed, the first to match path (or name with path) is returned.
  371. GroupRepresentation
  372. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  373. :param path: group path
  374. :param search_in_subgroups: True if want search in the subgroups
  375. :return: Keycloak server response (GroupRepresentation)
  376. """
  377. groups = self.get_groups()
  378. # TODO: Review this code is necessary
  379. for group in groups:
  380. if group['path'] == path:
  381. return group
  382. elif search_in_subgroups and group["subGroups"]:
  383. for group in group["subGroups"]:
  384. if group['path'] == path:
  385. return group
  386. res = self.get_subgroups(group, path)
  387. if res != None:
  388. return res
  389. return None
  390. def create_group(self, payload, parent=None, skip_exists=False):
  391. """
  392. Creates a group in the Realm
  393. :param payload: GroupRepresentation
  394. :param parent: parent group's id. Required to create a sub-group.
  395. GroupRepresentation
  396. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  397. :return: Http response
  398. """
  399. if parent is None:
  400. params_path = {"realm-name": self.realm_name}
  401. data_raw = self.connection.raw_post(URL_ADMIN_GROUPS.format(**params_path),
  402. data=json.dumps(payload))
  403. else:
  404. params_path = {"realm-name": self.realm_name, "id": parent, }
  405. data_raw = self.connection.raw_post(URL_ADMIN_GROUP_CHILD.format(**params_path),
  406. data=json.dumps(payload))
  407. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  408. def update_group(self, group_id, payload):
  409. """
  410. Update group, ignores subgroups.
  411. :param group_id: id of group
  412. :param payload: GroupRepresentation with updated information.
  413. GroupRepresentation
  414. http://www.keycloak.org/docs-api/3.2/rest-api/#_grouprepresentation
  415. :return: Http response
  416. """
  417. params_path = {"realm-name": self.realm_name, "id": group_id}
  418. data_raw = self.connection.raw_put(URL_ADMIN_GROUP.format(**params_path),
  419. data=json.dumps(payload))
  420. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  421. def group_set_permissions(self, group_id, enabled=True):
  422. """
  423. Enable/Disable permissions for a group. Cannot delete group if disabled
  424. :param group_id: id of group
  425. :param enabled: boolean
  426. :return: Keycloak server response
  427. """
  428. params_path = {"realm-name": self.realm_name, "id": group_id}
  429. data_raw = self.connection.raw_put(URL_ADMIN_GROUP_PERMISSIONS.format(**params_path),
  430. data=json.dumps({"enabled": enabled}))
  431. return raise_error_from_response(data_raw, KeycloakGetError)
  432. def group_user_add(self, user_id, group_id):
  433. """
  434. Add user to group (user_id and group_id)
  435. :param group_id: id of group
  436. :param user_id: id of user
  437. :param group_id: id of group to add to
  438. :return: Keycloak server response
  439. """
  440. params_path = {"realm-name": self.realm_name, "id": user_id, "group-id": group_id}
  441. data_raw = self.connection.raw_put(URL_ADMIN_USER_GROUP.format(**params_path), data=None)
  442. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  443. def group_user_remove(self, user_id, group_id):
  444. """
  445. Remove user from group (user_id and group_id)
  446. :param group_id: id of group
  447. :param user_id: id of user
  448. :param group_id: id of group to add to
  449. :return: Keycloak server response
  450. """
  451. params_path = {"realm-name": self.realm_name, "id": user_id, "group-id": group_id}
  452. data_raw = self.connection.raw_delete(URL_ADMIN_USER_GROUP.format(**params_path))
  453. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  454. def delete_group(self, group_id):
  455. """
  456. Deletes a group in the Realm
  457. :param group_id: id of group to delete
  458. :return: Keycloak server response
  459. """
  460. params_path = {"realm-name": self.realm_name, "id": group_id}
  461. data_raw = self.connection.raw_delete(URL_ADMIN_GROUP.format(**params_path))
  462. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  463. def get_clients(self):
  464. """
  465. Get clients belonging to the realm Returns a list of clients belonging to the realm
  466. ClientRepresentation
  467. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  468. :return: Keycloak server response (ClientRepresentation)
  469. """
  470. params_path = {"realm-name": self.realm_name}
  471. data_raw = self.connection.raw_get(URL_ADMIN_CLIENTS.format(**params_path))
  472. return raise_error_from_response(data_raw, KeycloakGetError)
  473. def get_client(self, client_id):
  474. """
  475. Get representation of the client
  476. ClientRepresentation
  477. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  478. :param client_id: id of client (not client-id)
  479. :return: Keycloak server response (ClientRepresentation)
  480. """
  481. params_path = {"realm-name": self.realm_name, "id": client_id}
  482. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT.format(**params_path))
  483. return raise_error_from_response(data_raw, KeycloakGetError)
  484. def get_client_id(self, client_name):
  485. """
  486. Get internal keycloak client id from client-id.
  487. This is required for further actions against this client.
  488. :param client_name: name in ClientRepresentation
  489. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  490. :return: client_id (uuid as string)
  491. """
  492. clients = self.get_clients()
  493. for client in clients:
  494. if client_name == client.get('name') or client_name == client.get('clientId'):
  495. return client["id"]
  496. return None
  497. def get_client_authz_settings(self, client_id):
  498. """
  499. Get authorization json from client.
  500. :param client_id: id in ClientRepresentation
  501. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  502. :return: Keycloak server response
  503. """
  504. params_path = {"realm-name": self.realm_name, "id": client_id}
  505. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_AUTHZ_SETTINGS.format(**params_path))
  506. return data_raw
  507. def get_client_authz_resources(self, client_id):
  508. """
  509. Get resources from client.
  510. :param client_id: id in ClientRepresentation
  511. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  512. :return: Keycloak server response
  513. """
  514. params_path = {"realm-name": self.realm_name, "id": client_id}
  515. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_AUTHZ_RESOURCES.format(**params_path))
  516. return data_raw
  517. def create_client(self, payload, skip_exists=False):
  518. """
  519. Create a client
  520. ClientRepresentation: http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  521. :param skip_exists: Skip if client already exist.
  522. :param payload: ClientRepresentation
  523. :return: Keycloak server response (UserRepresentation)
  524. """
  525. params_path = {"realm-name": self.realm_name}
  526. data_raw = self.connection.raw_post(URL_ADMIN_CLIENTS.format(**params_path),
  527. data=json.dumps(payload))
  528. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  529. def delete_client(self, client_id):
  530. """
  531. Get representation of the client
  532. ClientRepresentation
  533. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_clientrepresentation
  534. :param client_id: keycloak client id (not oauth client-id)
  535. :return: Keycloak server response (ClientRepresentation)
  536. """
  537. params_path = {"realm-name": self.realm_name, "id": client_id}
  538. data_raw = self.connection.raw_delete(URL_ADMIN_CLIENT.format(**params_path))
  539. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  540. def get_realm_roles(self):
  541. """
  542. Get all roles for the realm or client
  543. RoleRepresentation
  544. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  545. :return: Keycloak server response (RoleRepresentation)
  546. """
  547. params_path = {"realm-name": self.realm_name}
  548. data_raw = self.connection.raw_get(URL_ADMIN_REALM_ROLES.format(**params_path))
  549. return raise_error_from_response(data_raw, KeycloakGetError)
  550. def get_client_roles(self, client_id):
  551. """
  552. Get all roles for the client
  553. :param client_id: id of client (not client-id)
  554. RoleRepresentation
  555. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  556. :return: Keycloak server response (RoleRepresentation)
  557. """
  558. params_path = {"realm-name": self.realm_name, "id": client_id}
  559. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_ROLES.format(**params_path))
  560. return raise_error_from_response(data_raw, KeycloakGetError)
  561. def get_client_role(self, client_id, role_name):
  562. """
  563. Get client role id by name
  564. This is required for further actions with this role.
  565. :param client_id: id of client (not client-id)
  566. :param role_name: roles name (not id!)
  567. RoleRepresentation
  568. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  569. :return: role_id
  570. """
  571. params_path = {"realm-name": self.realm_name, "id": client_id, "role-name": role_name}
  572. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_ROLE.format(**params_path))
  573. return raise_error_from_response(data_raw, KeycloakGetError)
  574. def get_client_role_id(self, client_id, role_name):
  575. """
  576. Warning: Deprecated
  577. Get client role id by name
  578. This is required for further actions with this role.
  579. :param client_id: id of client (not client-id)
  580. :param role_name: roles name (not id!)
  581. RoleRepresentation
  582. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  583. :return: role_id
  584. """
  585. role = self.get_client_role(client_id, role_name)
  586. return role.get("id")
  587. def create_client_role(self, client_role_id, payload, skip_exists=False):
  588. """
  589. Create a client role
  590. RoleRepresentation
  591. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  592. :param client_role_id: id of client (not client-id)
  593. :param payload: RoleRepresentation
  594. :return: Keycloak server response (RoleRepresentation)
  595. """
  596. params_path = {"realm-name": self.realm_name, "id": client_role_id}
  597. data_raw = self.connection.raw_post(URL_ADMIN_CLIENT_ROLES.format(**params_path),
  598. data=json.dumps(payload))
  599. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  600. def delete_client_role(self, client_role_id, role_name):
  601. """
  602. Create a client role
  603. RoleRepresentation
  604. http://www.keycloak.org/docs-api/3.3/rest-api/index.html#_rolerepresentation
  605. :param client_role_id: id of client (not client-id)
  606. :param role_name: roles name (not id!)
  607. """
  608. params_path = {"realm-name": self.realm_name, "id": client_role_id, "role-name": role_name}
  609. data_raw = self.connection.raw_delete(URL_ADMIN_CLIENT_ROLE.format(**params_path))
  610. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  611. def assign_client_role(self, user_id, client_id, roles):
  612. """
  613. Assign a client role to a user
  614. :param client_id: id of client (not client-id)
  615. :param user_id: id of user
  616. :param client_id: id of client containing role,
  617. :param roles: roles list or role (use RoleRepresentation)
  618. :return Keycloak server response
  619. """
  620. payload = roles if isinstance(roles, list) else [roles]
  621. params_path = {"realm-name": self.realm_name, "id": user_id, "client-id": client_id}
  622. data_raw = self.connection.raw_post(URL_ADMIN_USER_CLIENT_ROLES.format(**params_path),
  623. data=json.dumps(payload))
  624. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  625. def assign_realm_roles(self, user_id, client_id, roles):
  626. """
  627. Assign realm roles to a user
  628. :param client_id: id of client (not client-id)
  629. :param user_id: id of user
  630. :param client_id: id of client containing role,
  631. :param roles: roles list or role (use RoleRepresentation)
  632. :return Keycloak server response
  633. """
  634. payload = roles if isinstance(roles, list) else [roles]
  635. params_path = {"realm-name": self.realm_name, "id": user_id}
  636. data_raw = self.connection.raw_post(URL_ADMIN_USER_REALM_ROLES.format(**params_path),
  637. data=json.dumps(payload))
  638. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  639. def get_client_roles_of_user(self, user_id, client_id):
  640. """
  641. Get all client roles for a user.
  642. :param client_id: id of client (not client-id)
  643. :param user_id: id of user
  644. :return: Keycloak server response (array RoleRepresentation)
  645. """
  646. return self._get_client_roles_of_user(URL_ADMIN_USER_CLIENT_ROLES, user_id, client_id)
  647. def get_available_client_roles_of_user(self, user_id, client_id):
  648. """
  649. Get available client role-mappings for a user.
  650. :param client_id: id of client (not client-id)
  651. :param user_id: id of user
  652. :return: Keycloak server response (array RoleRepresentation)
  653. """
  654. return self._get_client_roles_of_user(URL_ADMIN_USER_CLIENT_ROLES_AVAILABLE, user_id, client_id)
  655. def get_composite_client_roles_of_user(self, user_id, client_id):
  656. """
  657. Get composite client role-mappings for a user.
  658. :param client_id: id of client (not client-id)
  659. :param user_id: id of user
  660. :return: Keycloak server response (array RoleRepresentation)
  661. """
  662. return self._get_client_roles_of_user(URL_ADMIN_USER_CLIENT_ROLES_COMPOSITE, user_id, client_id)
  663. def _get_client_roles_of_user(self, client_level_role_mapping_url, user_id, client_id):
  664. params_path = {"realm-name": self.realm_name, "id": user_id, "client-id": client_id}
  665. data_raw = self.connection.raw_get(client_level_role_mapping_url.format(**params_path))
  666. return raise_error_from_response(data_raw, KeycloakGetError)
  667. def delete_client_roles_of_user(self, user_id, client_id, roles):
  668. """
  669. Delete client roles from a user.
  670. :param client_id: id of client (not client-id)
  671. :param user_id: id of user
  672. :param client_id: id of client containing role,
  673. :param roles: roles list or role to delete (use RoleRepresentation)
  674. :return: Keycloak server response
  675. """
  676. payload = roles if isinstance(roles, list) else [roles]
  677. params_path = {"realm-name": self.realm_name, "id": user_id, "client-id": client_id}
  678. data_raw = self.connection.raw_delete(URL_ADMIN_USER_CLIENT_ROLES.format(**params_path),
  679. data=json.dumps(payload))
  680. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  681. def get_authentication_flows(self):
  682. """
  683. Get authentication flows. Returns all flow details
  684. AuthenticationFlowRepresentation
  685. https://www.keycloak.org/docs-api/4.1/rest-api/index.html#_authenticationflowrepresentation
  686. :return: Keycloak server response (AuthenticationFlowRepresentation)
  687. """
  688. params_path = {"realm-name": self.realm_name}
  689. data_raw = self.connection.raw_get(URL_ADMIN_FLOWS.format(**params_path))
  690. return raise_error_from_response(data_raw, KeycloakGetError)
  691. def create_authentication_flow(self, payload, skip_exists=False):
  692. """
  693. Create a new authentication flow
  694. AuthenticationFlowRepresentation
  695. https://www.keycloak.org/docs-api/4.1/rest-api/index.html#_authenticationflowrepresentation
  696. :param payload: AuthenticationFlowRepresentation
  697. :return: Keycloak server response (RoleRepresentation)
  698. """
  699. params_path = {"realm-name": self.realm_name}
  700. data_raw = self.connection.raw_post(URL_ADMIN_FLOWS.format(**params_path),
  701. data=payload)
  702. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201, skip_exists=skip_exists)
  703. def get_authentication_flow_executions(self, flow_alias):
  704. """
  705. Get authentication flow executions. Returns all execution steps
  706. :return: Response(json)
  707. """
  708. params_path = {"realm-name": self.realm_name, "flow-alias": flow_alias}
  709. data_raw = self.connection.raw_get(URL_ADMIN_FLOWS_EXECUTIONS.format(**params_path))
  710. return raise_error_from_response(data_raw, KeycloakGetError)
  711. def update_authentication_flow_executions(self, payload, flow_alias):
  712. """
  713. Update an authentication flow execution
  714. AuthenticationExecutionInfoRepresentation
  715. https://www.keycloak.org/docs-api/4.1/rest-api/index.html#_authenticationexecutioninforepresentation
  716. :param payload: AuthenticationExecutionInfoRepresentation
  717. :return: Keycloak server response
  718. """
  719. params_path = {"realm-name": self.realm_name, "flow-alias": flow_alias}
  720. data_raw = self.connection.raw_put(URL_ADMIN_FLOWS_EXECUTIONS.format(**params_path),
  721. data=payload)
  722. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=204)
  723. def sync_users(self, storage_id, action):
  724. """
  725. Function to trigger user sync from provider
  726. :param storage_id:
  727. :param action:
  728. :return:
  729. """
  730. data = {'action': action}
  731. params_query = {"action": action}
  732. params_path = {"realm-name": self.realm_name, "id": storage_id}
  733. data_raw = self.connection.raw_post(URL_ADMIN_USER_STORAGE.format(**params_path),
  734. data=json.dumps(data), **params_query)
  735. return raise_error_from_response(data_raw, KeycloakGetError)
  736. def get_client_scopes(self):
  737. """
  738. Get representation of the client scopes for the realm where we are connected to
  739. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_getclientscopes
  740. :return: Keycloak server response Array of (ClientScopeRepresentation)
  741. """
  742. params_path = {"realm-name": self.realm_name}
  743. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_SCOPES.format(**params_path))
  744. return raise_error_from_response(data_raw, KeycloakGetError)
  745. def get_client_scope(self, client_scope_id):
  746. """
  747. Get representation of the client scopes for the realm where we are connected to
  748. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_getclientscopes
  749. :return: Keycloak server response (ClientScopeRepresentation)
  750. """
  751. params_path = {"realm-name": self.realm_name, "scope-id": client_scope_id}
  752. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_SCOPE.format(**params_path))
  753. return raise_error_from_response(data_raw, KeycloakGetError)
  754. def add_mapper_to_client_scope(self, client_scope_id, payload):
  755. """
  756. Add a mapper to a client scope
  757. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_create_mapper
  758. :param payload: ProtocolMapperRepresentation
  759. :return: Keycloak server Response
  760. """
  761. params_path = {"realm-name": self.realm_name, "scope-id": client_scope_id}
  762. data_raw = self.connection.raw_post(URL_ADMIN_CLIENT_SCOPES_ADD_MAPPER.format(**params_path), data=json.dumps(payload))
  763. return raise_error_from_response(data_raw, KeycloakGetError, expected_code=201)
  764. def get_client_secrets(self, client_id):
  765. """
  766. Get representation of the client secrets
  767. https://www.keycloak.org/docs-api/4.5/rest-api/index.html#_getclientsecret
  768. :param client_id: id of client (not client-id)
  769. :return: Keycloak server response (ClientRepresentation)
  770. """
  771. params_path = {"realm-name": self.realm_name, "id": client_id}
  772. data_raw = self.connection.raw_get(URL_ADMIN_CLIENT_SECRETS.format(**params_path))
  773. return raise_error_from_response(data_raw, KeycloakGetError)