From cb990b61a3c704ac68870eff4c050d043ab9087b Mon Sep 17 00:00:00 2001
From: Untone <anton.rewin@gmail.com>
Date: Sun, 26 Jan 2025 18:01:04 +0300
Subject: [PATCH] gqldata

---
 services/schema.py | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)

diff --git a/services/schema.py b/services/schema.py
index 32fb1525..448b63b5 100644
--- a/services/schema.py
+++ b/services/schema.py
@@ -1,5 +1,41 @@
+from asyncio.log import logger
+
+import httpx
 from ariadne import MutationType, QueryType
 
+from settings import AUTH_URL
+
 query = QueryType()
 mutation = MutationType()
 resolvers = [query, mutation]
+
+
+async def request_graphql_data(gql, url=AUTH_URL, headers=None):
+    """
+    Выполняет GraphQL запрос к указанному URL
+    
+    :param gql: GraphQL запрос
+    :param url: URL для запроса, по умолчанию AUTH_URL
+    :param headers: Заголовки запроса
+    :return: Результат запроса или None в случае ошибки
+    """
+    if not url:
+        return None
+    if headers is None:
+        headers = {"Content-Type": "application/json"}
+    try:
+        async with httpx.AsyncClient() as client:
+            response = await client.post(url, json=gql, headers=headers)
+            if response.status_code == 200:
+                data = response.json()
+                errors = data.get("errors")
+                if errors:
+                    logger.error(f"{url} response: {data}")
+                else:
+                    return data
+            else:
+                logger.error(f"{url}: {response.status_code} {response.text}")
+    except Exception as _e:
+        import traceback
+        logger.error(f"request_graphql_data error: {traceback.format_exc()}")
+    return None