routes-fix
Some checks failed
deploy / deploy (push) Has been cancelled

This commit is contained in:
Untone 2023-11-29 00:19:33 +03:00
parent 6cd2fc0f80
commit 4ca9491824
2 changed files with 10 additions and 10 deletions

View File

@ -35,7 +35,7 @@ poetry run python server.py
### Auth ### Auth
Put the header 'Authorization' with token from signIn query or registerUser mutation. Put the header 'Authorization' with token from signIn query or registerUser mutation. Setup `WEBHOOK_SECRET` env var
### Viewed ### Viewed

View File

@ -6,6 +6,7 @@ from ariadne.asgi import GraphQL
from starlette.applications import Starlette from starlette.applications import Starlette
from starlette.endpoints import HTTPEndpoint, Request from starlette.endpoints import HTTPEndpoint, Request
from starlette.responses import JSONResponse from starlette.responses import JSONResponse
from starlette.routing import Route
from resolvers.author import create_author from resolvers.author import create_author
from services.rediscache import redis from services.rediscache import redis
@ -46,7 +47,7 @@ class WebhookEndpoint(HTTPEndpoint):
if data: if data:
auth = request.headers.get("Authorization") auth = request.headers.get("Authorization")
if auth: if auth:
# TODO: check Authorization header if auth == os.environ.get("WEBHOOK_SECRET"):
# Extract user_id and slug # Extract user_id and slug
user_id = data["user"]["id"] user_id = data["user"]["id"]
email_slug = data["user"]["email"].replace(".", "-").split("@").pop() email_slug = data["user"]["email"].replace(".", "-").split("@").pop()
@ -57,6 +58,5 @@ class WebhookEndpoint(HTTPEndpoint):
return JSONResponse({"status": "error", "message": str(e)}, status_code=500) return JSONResponse({"status": "error", "message": str(e)}, status_code=500)
app = Starlette(debug=True, on_startup=[start_up], on_shutdown=[shutdown]) routes = [Route("/", GraphQL(schema, debug=True)), Route("/new-author", WebhookEndpoint)]
app.mount("/", GraphQL(schema, debug=True)) app = Starlette(routes=routes, debug=True, on_startup=[start_up], on_shutdown=[shutdown])
app.mount("/new-author", WebhookEndpoint)