AmineTMIRI/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfixing

Browse Source
This commit is contained in:
MuslemRahimi 2025-02-20 15:18:35 +01:00
parent 1049780b1f
commit 25ac689673
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
app/cron_push_notifications.py
View File

@ -75,11 +75,15 @@ def format_number(num, decimal=False):
return f"{num / 1_000_000:,.2f}M" return f"{num / 1_000_000:,.2f}M"
return f"{num:,.0f}" # Format smaller numbers with commas return f"{num:,.0f}" # Format smaller numbers with commas
async def push_notification(title, text, user_id): async def push_notification(title, text, user_id, link=None):
if link == None:
url = f"{origin}/notifications",
else:
url = f"{origin}/{link}",
data = { data = {
"title": title, "title": title,
"body": text, "body": text,
"url": f"{origin}/notifications", "url": url,
"userId": user_id, "userId": user_id,
"key": stocknear_api_key, "key": stocknear_api_key,
} }
@ -148,7 +152,7 @@ async def push_wiim(user_id):
user_subscribed = True user_subscribed = True
break break
if user_subscribed: if user_subscribed:
await push_notification(f'Why Priced Moved for {symbol}', data['text'], user_id) await push_notification(f'Why Priced Moved for {symbol}', data['text'], user_id, link=f"{asset_type}/{symbol}")
except: except:
pass pass
except Exception as e: except Exception as e:
@ -305,7 +309,6 @@ async def run():
result = pb.collection('notificationChannels').get_list(query_params={"filter": f"user='{user_id}'"}) result = pb.collection('notificationChannels').get_list(query_params={"filter": f"user='{user_id}'"})
channels = result.items channels = result.items
for channel in channels: for channel in channels:
if channel.wiim == True: if channel.wiim == True:
await push_wiim(user_id=user_id) await push_wiim(user_id=user_id)