This commit is contained in:
parent
692dd9cfe0
commit
d0ce4dd3d3
|
@ -279,9 +279,9 @@ async def rate_author(_, info, rated_slug, value):
|
||||||
return {}
|
return {}
|
||||||
|
|
||||||
|
|
||||||
async def create_author(user_id: str, slug: str):
|
async def create_author(user_id: str, slug: str, name: str = ""):
|
||||||
with local_session() as session:
|
with local_session() as session:
|
||||||
new_author = Author(user=user_id, slug=slug)
|
new_author = Author(user=user_id, slug=slug, name=name)
|
||||||
session.add(new_author)
|
session.add(new_author)
|
||||||
session.commit()
|
session.commit()
|
||||||
print(f"[resolvers.author] created by webhook {new_author.dict()}")
|
print(f"[resolvers.author] created by webhook {new_author.dict()}")
|
||||||
|
|
|
@ -19,13 +19,14 @@ class WebhookEndpoint(HTTPEndpoint):
|
||||||
if auth:
|
if auth:
|
||||||
if auth == os.environ.get("WEBHOOK_SECRET"):
|
if auth == os.environ.get("WEBHOOK_SECRET"):
|
||||||
user_id: str = data["user"]["id"]
|
user_id: str = data["user"]["id"]
|
||||||
|
name: str = data["user"]["given_name"]
|
||||||
slug: str = data["user"]["email"].split("@")[0]
|
slug: str = data["user"]["email"].split("@")[0]
|
||||||
slug: str = re.sub("[^0-9a-z]+", "-", slug.lower())
|
slug: str = re.sub("[^0-9a-z]+", "-", slug.lower())
|
||||||
with local_session() as session:
|
with local_session() as session:
|
||||||
author = session.query(Author).filter(Author.slug == slug).first()
|
author = session.query(Author).filter(Author.slug == slug).first()
|
||||||
if author:
|
if author:
|
||||||
slug = slug + "-" + user_id.split("-").pop()
|
slug = slug + "-" + user_id.split("-").pop()
|
||||||
await create_author(user_id, slug)
|
await create_author(user_id, slug, name)
|
||||||
|
|
||||||
return JSONResponse({"status": "success"})
|
return JSONResponse({"status": "success"})
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user