mirrors/postgsail
1
0
Fork 0
mirror of https://github.com/xbgmsharp/postgsail.git synced 2025-09-17 11:17:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update keycloak_py, make uri and host,user,pass dynamic form config

Browse Source
This commit is contained in:
xbgmsharp
2024-01-12 17:40:59 +01:00
parent 14cc4f5ed2
commit 0a09d7bbfc
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
initdb/02_3_3_signalk_public_functions_py.sql
View File

@@ -634,17 +634,27 @@ AS $keycloak_py$
""" """
import requests import requests
import json import json
import urllib.parse
keycloak_uri = None safe_uri = host = user = pwd = None
if 'app.keycloak_uri' in app and app['app.keycloak_uri']: if 'app.keycloak_uri' in app and app['app.keycloak_uri']:
keycloak_uri = app['app.keycloak_uri'] safe_uri = urllib.parse.quote(app['app.keycloak_uri'], safe=':/?&=')
_ = urllib.parse.urlparse(safe_uri)
host = _.netloc.split('@')[-1]
user = _.netloc.split('@')[0].split(':')[0]
pwd = _.netloc.split('@')[0].split(':')[1]
else: else:
plpy.error('Error no keycloak_uri defined, check app settings') plpy.error('Error no keycloak_uri defined, check app settings')
return None return None
if not host or not user or not pwd:
plpy.error('Error parsing keycloak_uri, check app settings')
return None
if 'app.keycloak_uri' in app and app['app.keycloak_uri']:
_headers = {'User-Agent': 'PostgSail', 'From': 'xbgmsharp@gmail.com'} _headers = {'User-Agent': 'PostgSail', 'From': 'xbgmsharp@gmail.com'}
_payload = {'client_id':'admin-cli','grant_type':'password','username':'admin','password':'admin'} _payload = {'client_id':'admin-cli','grant_type':'password','username':user,'password':pwd}
url = f'{keycloak_uri}/realms/master/protocol/openid-connect/token'.format(keycloak_uri) url = f'{_.scheme}://{host}/realms/master/protocol/openid-connect/token'.format(_.scheme, host)
r = requests.post(url, headers=_headers, data=_payload, timeout=(5, 60)) r = requests.post(url, headers=_headers, data=_payload, timeout=(5, 60))
#print(r.text) #print(r.text)
#plpy.notice(url) #plpy.notice(url)