discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

webhook-fix
All checks were successful
Deploy to core / deploy (push) Successful in 1m28s
Details

Browse Source
This commit is contained in:
Untone 2024-02-22 21:18:20 +03:00
parent ce736e2624
commit ebf342c73b
1 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
services/webhook.py
View File

@ -8,6 +8,7 @@ from starlette.responses import JSONResponse
from orm.author import Author
from resolvers.author import create_author
from services.db import local_session
from services.logger import root_logger as logger
class WebhookEndpoint(HTTPEndpoint):
@ -18,19 +19,22 @@ class WebhookEndpoint(HTTPEndpoint):
auth = request.headers.get('Authorization')
if auth:
if auth == os.environ.get('WEBHOOK_SECRET'):
user_id: str = data['user']['id']
name: str = data['user']['given_name']
slug: str = data['user']['email'].split('@')[0]
slug: str = re.sub('[^0-9a-z]+', '-', slug.lower())
with local_session() as session:
author = (
session.query(Author)
.filter(Author.slug == slug)
.first()
)
if author:
slug = slug + '-' + user_id.split('-').pop()
await create_author(user_id, slug, name)
logger.debug(data)
user = data.get('user')
if isinstance(user, dict):
user_id: str = user.get('id')
name: str = user.get('given_name', user.get('slug'))
slug: str = user.get('email', '').split('@')[0]
slug: str = re.sub('[^0-9a-z]+', '-', slug.lower())
with local_session() as session:
author = (
session.query(Author)
.filter(Author.slug == slug)
.first()
)
if author:
slug = slug + '-' + user_id.split('-').pop()
await create_author(user_id, slug, name)
return JSONResponse({'status': 'success'})
except Exception as e: