bugfixing push notification
This commit is contained in:
parent
25ac689673
commit
eea73a30f1
@ -76,14 +76,10 @@ def format_number(num, decimal=False):
|
|||||||
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, link=None):
|
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": url,
|
"url": f"{origin}/notifications" if link == None else f"{origin}/{link}",
|
||||||
"userId": user_id,
|
"userId": user_id,
|
||||||
"key": stocknear_api_key,
|
"key": stocknear_api_key,
|
||||||
}
|
}
|
||||||
@ -152,7 +148,16 @@ 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, link=f"{asset_type}/{symbol}")
|
if asset_type == 'stock':
|
||||||
|
link = f"stocks/{symbol}"
|
||||||
|
elif asset_type == 'etf':
|
||||||
|
link = f"etf/{symbol}"
|
||||||
|
elif asset_type == 'index':
|
||||||
|
link = f"index/{symbol}"
|
||||||
|
else:
|
||||||
|
link = None
|
||||||
|
|
||||||
|
await push_notification(f'Why Priced Moved for {symbol}', data['text'], user_id, link=link)
|
||||||
except:
|
except:
|
||||||
pass
|
pass
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user