From f73f3608c0935ee9a2af1ded311512d199834541 Mon Sep 17 00:00:00 2001 From: Untone Date: Mon, 16 Dec 2024 19:50:25 +0300 Subject: [PATCH] webhook-fix2 --- services/webhook.py | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/services/webhook.py b/services/webhook.py index 3fa718de..1b353479 100644 --- a/services/webhook.py +++ b/services/webhook.py @@ -38,7 +38,7 @@ async def check_webhook_existence(): gql = { "query": f"query {operation}($params: PaginatedInput!)" + "{" - + f"{query_name}(params: $params) {{ webhooks {{ id event_name endpoint enabled }} }} " + + f"{query_name}(params: $params) {{ webhooks {{ id event_name endpoint }} }} " + "}", "variables": variables, "operationName": operation, @@ -47,7 +47,6 @@ async def check_webhook_existence(): if result: logger.info(result) webhooks = result.get("data", {}).get(query_name, {}).get("webhooks", []) - # Ищем точное совпадение user.login for webhook in webhooks: if webhook["event_name"].startswith("user.login"): return True, webhook["id"], webhook["endpoint"] @@ -77,7 +76,6 @@ async def create_webhook_endpoint(): if current_endpoint != endpoint or webhook_id: operation = "DeleteWebhook" query_name = "_delete_webhook" - # Исправляем тип на WebhookRequest variables = {"params": {"webhook_id": webhook_id}} # Изменено с id на webhook_id gql = { "query": f"mutation {operation}($params: WebhookRequest!)" @@ -99,7 +97,9 @@ async def create_webhook_endpoint(): return if not exists: - # Создаем новый вебхук + # https://docs.authorizer.dev/core/graphql-api#_add_webhook + operation = "AddWebhook" + query_name = "_add_webhook" variables = { "params": { "event_name": "user.login", @@ -108,8 +108,6 @@ async def create_webhook_endpoint(): "headers": {"Authorization": WEBHOOK_SECRET}, } } - operation = "AddWebhook" - query_name = "_add_webhook" gql = { "query": f"mutation {operation}($params: AddWebhookRequest!)" + "{"