forge/authentik-listmonk-bridge
1
0
Fork 0
Code Issues 4 Pull requests Projects Releases Packages Wiki Activity Actions

main.py: add is_active syncing

Browse source
This commit is contained in:
Antoine Martin 2024-02-29 16:37:04 -05:00
parent f31ffa6726
commit e5c4c12ac6
Signed by: forge
GPG key ID: D62A472A4AA7D541
1 changed files with 17 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
main.py
View file

@ -27,7 +27,7 @@ def authentik_get_users():
def listmonk_create_subscriber(email, username, status, lists): def listmonk_create_subscriber(email, username, status, lists):
url = listmonk_api_url + '/subscribers' url = listmonk_api_url + '/subscribers'
payload = {"email": email, "name": username, "status": print(status), "lists": lists} payload = {"email": email, "name": username, "status": status, "lists": lists, "preconfirm_subscriptions": True}
headers = {'Content-Type': 'application/json'} headers = {'Content-Type': 'application/json'}
resp = requests.post(url, data=json.dumps(payload), headers=headers, auth=(listmonk_api_usr, listmonk_api_key)) resp = requests.post(url, data=json.dumps(payload), headers=headers, auth=(listmonk_api_usr, listmonk_api_key))
json_object = json.loads(resp._content) json_object = json.loads(resp._content)
@ -35,7 +35,7 @@ def listmonk_create_subscriber(email, username, status, lists):
def listmonk_set_subscriber(subscriber_id, email, username, status, lists): def listmonk_set_subscriber(subscriber_id, email, username, status, lists):
url = listmonk_api_url + '/subscribers/' + str(subscriber_id) url = listmonk_api_url + '/subscribers/' + str(subscriber_id)
payload = {"email": email, "name": username, "status": print(status), "lists": lists} payload = {"email": email, "name": username, "status": status, "lists": lists}
headers = {'Content-Type': 'application/json'} headers = {'Content-Type': 'application/json'}
resp = requests.put(url, data=json.dumps(payload), headers=headers, auth=(listmonk_api_usr, listmonk_api_key)) resp = requests.put(url, data=json.dumps(payload), headers=headers, auth=(listmonk_api_usr, listmonk_api_key))
json_object = json.loads(resp._content) json_object = json.loads(resp._content)
@ -56,19 +56,32 @@ def listmonk_get_subscriber(username):
for user_info in authentik_get_users(): for user_info in authentik_get_users():
print('>>> Checking ' + user_info['username']) print('>>> Checking ' + user_info['username'])
if user_info['is_active'] == True:
user_active = "enabled"
else:
user_active = "disabled"
try: try:
subscriber_info = listmonk_get_subscriber(user_info['username']) subscriber_info = listmonk_get_subscriber(user_info['username'])
print(subscriber_info) print(subscriber_info)
# if get user info fails, assume that we have to create a new one
# TOOD: only create if the error is indeed user-existence related
except Exception as e: except Exception as e:
print('> Failed to find username, creating subscriber') print('> Failed to find username, creating subscriber')
create_resp = listmonk_create_subscriber(user_info['email'], user_info['username'], user_info['is_active'], lists=[1]) create_resp = listmonk_create_subscriber(user_info['email'], user_info['username'], status=user_active, lists=[1])
print(create_resp) print(create_resp)
continue continue
# checks if user email matches subscriber email
if user_info['email'] != subscriber_info['email']: if user_info['email'] != subscriber_info['email']:
print('> Email check failed, updating') print('> Email check failed, updating')
set_resp = listmonk_set_subscriber(subscriber_info['id'], user_info['email'], user_info['username'], subscriber_info['status'], lists=[1]) set_resp = listmonk_set_subscriber(subscriber_info['id'], user_info['email'], user_info['username'], subscriber_info['status'], lists=[1])
print(set_resp) print(set_resp)
# check if user and subscriber info match as it relates to status
if user_active != subscriber_info['status'] and subscriber_info['status'] != "blocklisted":
print('> User status check failed, updating')
set_resp = listmonk_set_subscriber(subscriber_info['id'], user_info['email'], user_info['username'], status=user_active, lists=[1])
print(set_resp)