0x2620/phantasmobile
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

use listmonk token

Browse source
This commit is contained in:
j 2025-01-23 15:19:19 +05:30
parent bee761e0c4
commit e3ece477c0
2 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
app/listmonk/utils.py
View file

@ -12,6 +12,14 @@ headers = {
'Content-Type': 'application/json;charset=utf-8' 'Content-Type': 'application/json;charset=utf-8'
} }
def get_auth(headers):
if settings.LISTMON_TOKEN:
headers['Authorization'] = 'token ' + settings.LISTMON_TOKEN
auth = None
else:
auth = (settings.LISTMONK_USER, settings.LISTMONK_PASSWORD)
return auth
def send_week(date): def send_week(date):
from . import views from . import views
@ -39,7 +47,7 @@ def send_email(name, subject, body):
'body': body 'body': body
} }
url = settings.LISTMONK_API + 'campaigns' url = settings.LISTMONK_API + 'campaigns'
auth = (settings.LISTMONK_USER, settings.LISTMONK_PASSWORD) auth = get_auth(headers)
r = requests.post(url, json=data, headers=headers, auth=auth).json() r = requests.post(url, json=data, headers=headers, auth=auth).json()
list_id = r.get('data', {}).get('id') list_id = r.get('data', {}).get('id')
if list_id and settings.LISTMONK_SEND: if list_id and settings.LISTMONK_SEND:
@ -59,13 +67,13 @@ def email2name(email):
def is_subscribed(email): def is_subscribed(email):
url = settings.LISTMONK_API + 'subscribers' url = settings.LISTMONK_API + 'subscribers'
auth = (settings.LISTMONK_USER, settings.LISTMONK_PASSWORD) auth = get_auth(headers)
exists = url + '?' + "list_id=&query=email='%s'&page=1&order_by=id&order=desc" % email exists = url + '?' + "list_id=&query=email='%s'&page=1&order_by=id&order=desc" % email
return bool(len(requests.get(exists, auth=auth).json()['data']['results'])) return bool(len(requests.get(exists, headers=headers, auth=auth).json()['data']['results']))
def add_email(email): def add_email(email):
url = settings.LISTMONK_API + 'subscribers' url = settings.LISTMONK_API + 'subscribers'
auth = (settings.LISTMONK_USER, settings.LISTMONK_PASSWORD) auth = get_auth(headers)
if not is_subscribed(email): if not is_subscribed(email):
data = { data = {
"email": email, "email": email,

1
app/settings/common.py
View file

@ -165,6 +165,7 @@ CELERY_RESULT_BACKEND = 'django-db'
SIGNAL_MODERATORS = [] SIGNAL_MODERATORS = []
LISTMONK_USER = "listmonk" LISTMONK_USER = "listmonk"
LISTMONK_PASSWORD = "listmonk" LISTMONK_PASSWORD = "listmonk"
LISTMONK_TOKEN = None
LISTMONK_API = "http://localhost:9000/api/" LISTMONK_API = "http://localhost:9000/api/"
LISTMONK_LISTS = [] LISTMONK_LISTS = []
LISTMONK_SEND = False LISTMONK_SEND = False