kultmost/avtopost.kultmost.ru
SHA256
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
vladislav 2026-09-08 07:56:27 -04:00
parent 67e58c2dda
commit 01164bc9ac
Signed by: Vladislav
GPG Key ID: D97C9E5E4860EE45
2 changed files with 72 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
tasks.ipynb
View File

@ -69,7 +69,7 @@
"outputs": [],
"source": [
"async def notify_in_profile(item: NotifyItem):\n",
" doc = await notify_collection.update_one(\n",
" result = await notify_collection.update_one(\n",
" {\n",
" \"user_id\": item.user_id,\n",
" \"type\": item.type_item,\n",
@ -90,21 +90,42 @@
" },\n",
" upsert=True,\n",
" )\n",
" if doc.upserted_id:\n",
" user = await users_collection.find_one({'_id': ObjectId(str(item.user_id))},{'email':1})\n",
" login_link = f'{FULL_DOMAIN}/login/{await token_create(str(user['_id']), url=f'/profile')}'\n",
"\n",
" if result.upserted_id is None:\n",
" return result # Existing notification was updated; no email\n",
"\n",
" user = await users_collection.find_one(\n",
" {\"_id\": ObjectId(str(item.user_id))},\n",
" {\"email\": 1},\n",
" )\n",
"\n",
" if not user:\n",
" return result\n",
"\n",
" token = await token_create(\n",
" str(user[\"_id\"]),\n",
" url=\"/profile\",\n",
" )\n",
" login_link = f\"{FULL_DOMAIN}/login/{token}\"\n",
"\n",
" if PROD:\n",
" email_task.notify.delay(user['email'], {\n",
" 'text': item.text,\n",
" 'list': [[]],\n",
" 'primary': {\n",
" 'href': login_link,\n",
" 'text': 'Войти и посмотреть'\n",
" email_task.notify.delay(\n",
" user[\"email\"],\n",
" {\n",
" \"text\": item.text,\n",
" \"list\": [[]],\n",
" \"primary\": {\n",
" \"href\": login_link,\n",
" \"text\": \"Войти и посмотреть\",\n",
" },\n",
" 'title': item.title,\n",
" 'login_link': login_link,\n",
" }, 'Уведомление', 'main.html')\n",
" return doc\n"
" \"title\": item.title,\n",
" \"login_link\": login_link,\n",
" },\n",
" \"Уведомление\",\n",
" \"main.html\",\n",
" )\n",
"\n",
" return result\n"
],
"display_name": ".venv"
},

49
tasks.py
View File

@ -12,7 +12,7 @@ import asyncio
async def notify_in_profile(item: NotifyItem):
doc = await notify_collection.update_one(
result = await notify_collection.update_one(
{
"user_id": item.user_id,
"type": item.type_item,
@ -33,21 +33,42 @@ async def notify_in_profile(item: NotifyItem):
},
upsert=True,
)
if doc.upserted_id:
user = await users_collection.find_one({'_id': ObjectId(str(item.user_id))},{'email':1})
login_link = f'{FULL_DOMAIN}/login/{await token_create(str(user['_id']), url=f'/profile')}'
if result.upserted_id is None:
return result # Existing notification was updated; no email
user = await users_collection.find_one(
{"_id": ObjectId(str(item.user_id))},
{"email": 1},
)
if not user:
return result
token = await token_create(
str(user["_id"]),
url="/profile",
)
login_link = f"{FULL_DOMAIN}/login/{token}"
if PROD:
email_task.notify.delay(user['email'], {
'text': item.text,
'list': [[]],
'primary': {
'href': login_link,
'text': 'Войти и посмотреть'
email_task.notify.delay(
user["email"],
{
"text": item.text,
"list": [[]],
"primary": {
"href": login_link,
"text": "Войти и посмотреть",
},
'title': item.title,
'login_link': login_link,
}, 'Уведомление', 'main.html')
return doc
"title": item.title,
"login_link": login_link,
},
"Уведомление",
"main.html",
)
return result
async def email_new_post(new_post: Dict):