Skip to content

Commit ec56547

Browse files
committed
wip #23 bring back task_queue thread for telegram notification
remove sleep todo poll until new site is ready see Subscribie/subscribie#742 todo update uwsgi to enable threads
1 parent a1a9a2d commit ec56547

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

Diff for: __init__.py

+5-5
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import requests
1414
from base64 import urlsafe_b64encode
1515
from subscribie.signals import journey_complete
16+
from subscribie.tasks import task_queue
1617
from .forms import SignupForm
1718
from subscribie.forms import LoginForm
1819
from subscribie.models import Plan
@@ -134,8 +135,10 @@ def save_plans():
134135
token = app.config.get("TELEGRAM_TOKEN", None)
135136
chat_id = app.config.get("TELEGRAM_CHAT_ID", None)
136137
new_site_url = session["site-url"]
137-
requests.get(
138-
f"https://api.telegram.org/bot{token}/sendMessage?chat_id={chat_id}&text=NewShop%20{new_site_url}" # noqa
138+
task_queue.put(
139+
lambda: requests.get(
140+
f"https://api.telegram.org/bot{token}/sendMessage?chat_id={chat_id}&text=NewShop%20{new_site_url}" # noqa
141+
)
139142
)
140143
except Exception as e:
141144
print(f"Telegram not sent: {e}")
@@ -146,9 +149,6 @@ def save_plans():
146149
con.execute(query, (session["site-url"], session["email"].lower()))
147150
con.commit()
148151

149-
from time import sleep
150-
151-
sleep(3)
152152
# Redirect to their site, auto login using login_token
153153
auto_login_url = f'{session["site-url"]}/auth/login/{login_token}'
154154
return redirect(auto_login_url)

0 commit comments

Comments
 (0)