Update app.py

app.py

@@ -17,87 +17,26 @@ TELEGRAM_API_HASH = "102edf31d404cb72d17ee4831d4e8c7b"
 TELEGRAM_STRING_SESSION = "1ApWapzMBu8a9o9Wu1GexPdkO7Jsr6po1xym67EcfAxkEbVx1oxw6wW7LINb9Xf0VYcyEAP-b-D0RQ_4x0RDAW8Di_0P2r4bj7xNeV9xO3wBMcaeq7FJux3UMq5buq89gqG8JarZG04tIyWoVnH__dq1_6G2Zkr0GF4WJCS2UN7mmwBacIIUEjUryEA97tXYC8jD14J-1MDgFsNNZTJ6uurD5RzH2DIhphChebxOkDBdXmpLGlanEzYzVOlx4p6Mo2zYorRG968o64CxKEh-WiJaPSNrS3IEfIVWFVd_tHKWzQSPD1zHHhcw0v2_ZjCKbZnTMcT3uMYuyLwA55_dckzcw0wZgAZQ="
 
 # ----------- Настройки ВКонтакте -----------
-# Вставляем ваши токены
-VK_ACCESS_TOKEN = os.environ.get("VK_ACCESS_TOKEN", "")
-VK_REFRESH_TOKEN = os.environ.get("VK_REFRESH_TOKEN", "")
-VK_DEVICE_ID = os.environ.get("VK_DEVICE_ID", "")  # Добавляем device_id
+# Инициализация токенов в session_state
+if "VK_ACCESS_TOKEN" not in st.session_state:
+    st.session_state["VK_ACCESS_TOKEN"] = os.environ.get("VK_ACCESS_TOKEN", "")
+if "VK_REFRESH_TOKEN" not in st.session_state:
+    st.session_state["VK_REFRESH_TOKEN"] = os.environ.get("VK_REFRESH_TOKEN", "")
+if "VK_DEVICE_ID" not in st.session_state:
+    st.session_state["VK_DEVICE_ID"] = os.environ.get("VK_DEVICE_ID", "")
 
 # Остальные настройки ВКонтакте
 VK_CLIENT_ID = os.environ.get("VK_CLIENT_ID", "")
 VK_CLIENT_SECRET = os.environ.get("VK_CLIENT_SECRET", "")
 VK_API_VERSION = "5.131"
 
-if not VK_ACCESS_TOKEN:
+if not st.session_state["VK_ACCESS_TOKEN"]:
     st.warning("Не найден VK_ACCESS_TOKEN. Добавьте его в Secrets или переменные окружения!")
-if not VK_REFRESH_TOKEN:
+if not st.session_state["VK_REFRESH_TOKEN"]:
     st.warning("Не найден VK_REFRESH_TOKEN. Без него не сможем обновлять токен!")
 if not VK_CLIENT_ID or not VK_CLIENT_SECRET:
     st.warning("Не найдены VK_CLIENT_ID / VK_CLIENT_SECRET. Без них не сможем обновлять токен!")
 
-def refresh_vk_token() -> bool:
-    """
-    Отправляем запрос на обновление токена через refresh_token.
-    По новой схеме VK ID: 
-    grant_type=refresh_token, endpoint может быть https://id.vk.com/oauth2/auth (или другой, согласно документации).
-    """
-    st.write("Пытаемся обновить токен...")  # Отладочное сообщение
-
-    # Берём текущие значения из session_state
-    current_refresh = st.session_state["VK_REFRESH_TOKEN"]
-    device_id = st.session_state.get("VK_DEVICE_ID", "")  # Получаем device_id
-
-    st.write(f"Текущий refresh_token: {current_refresh}")  # Отладочное сообщение
-    st.write(f"Текущий device_id: {device_id}")  # Отладочное сообщение
-
-    if not current_refresh or not VK_CLIENT_ID or not VK_CLIENT_SECRET or not device_id:
-        st.error("Невозможно обновить токен: нет refresh_token, client_id, client_secret или device_id.")
-        return False
-
-    url = "https://id.vk.com/oauth2/auth"  # Endpoint для обновления токена
-    data = {
-        "grant_type": "refresh_token",
-        "client_id": VK_CLIENT_ID,
-        "client_secret": VK_CLIENT_SECRET,
-        "refresh_token": current_refresh,
-        "device_id": device_id  # Передаем device_id
-    }
-
-    st.write(f"Отправляем запрос на обновление токена: {url}")  # Отладочное сообщение
-    st.write(f"Данные запроса: {data}")  # Отладочное сообщение
-
-    resp = requests.post(url, data=data)
-    st.write(f"Статус ответа: {resp.status_code}")  # Отладочное сообщение
-    st.write(f"Текст ответа: {resp.text}")  # Отладочное сообщение
-
-    if resp.status_code != 200:
-        st.error(f"Ошибка обновления токена (HTTP {resp.status_code}): {resp.text}")
-        return False
-
-    try:
-        result = resp.json()
-        st.write(f"Ответ от VK API: {result}")  # Отладочное сообщение
-    except Exception as e:
-        st.error(f"Не удалось распарсить ответ при обновлении токена: {e}")
-        return False
-
-    if "access_token" not in result:
-        err_desc = result.get("error_description", result)
-        st.error(f"Не удалось получить новый access_token: {err_desc}")
-        return False
-
-    # Сохраняем новые значения
-    new_access = result["access_token"]
-    st.session_state["VK_ACCESS_TOKEN"] = new_access
-    if "refresh_token" in result:
-        st.session_state["VK_REFRESH_TOKEN"] = result["refresh_token"]
-
-    st.success("VK-токен обновлён успешно!")
-    st.write(f"Новый access_token: {new_access}")  # Отладочное сообщение
-    if "refresh_token" in result:
-        st.write(f"Новый refresh_token: {result['refresh_token']}")  # Отладочное сообщение
-
-    return True
-
 # --- Инициализация Telethon-клиента (Telegram) ---
 def init_telethon():
     loop = asyncio.new_event_loop()
@@ -125,14 +64,6 @@ if st.session_state.get("VK_REFRESH_TOKEN"):
 else:
     st.warning("Не найден refresh_token. Авторизуйтесь через workingtoken.py.")
 
-# Сохраняем в session_state, чтобы при обновлении токена переопределять
-if "VK_ACCESS_TOKEN" not in st.session_state:
-    st.session_state["VK_ACCESS_TOKEN"] = VK_ACCESS_TOKEN
-if "VK_REFRESH_TOKEN" not in st.session_state:
-    st.session_state["VK_REFRESH_TOKEN"] = VK_REFRESH_TOKEN
-if "VK_DEVICE_ID" not in st.session_state:
-    st.session_state["VK_DEVICE_ID"] = VK_DEVICE_ID
-
 def human_format_views(num: int) -> str:
     if num < 1000:
         return f"{num / 1000:.1f}K"
@@ -150,9 +81,15 @@ def refresh_vk_token() -> bool:
     По новой схеме VK ID: 
     grant_type=refresh_token, endpoint может быть https://id.vk.com/oauth2/auth (или другой, согласно документации).
     """
+    st.write("Пытаемся обновить токен...")  # Отладочное сообщение
+
     # Берём текущие значения из session_state
     current_refresh = st.session_state["VK_REFRESH_TOKEN"]
     device_id = st.session_state.get("VK_DEVICE_ID", "")  # Получаем device_id
+
+    st.write(f"Текущий refresh_token: {current_refresh}")  # Отладочное сообщение
+    st.write(f"Текущий device_id: {device_id}")  # Отладочное сообщение
+
     if not current_refresh or not VK_CLIENT_ID or not VK_CLIENT_SECRET or not device_id:
         st.error("Невозможно обновить токен: нет refresh_token, client_id, client_secret или device_id.")
         return False
@@ -166,13 +103,20 @@ def refresh_vk_token() -> bool:
         "device_id": device_id  # Передаем device_id
     }
 
+    st.write(f"Отправляем запрос на обновление токена: {url}")  # Отладочное сообщение
+    st.write(f"Данные запроса: {data}")  # Отладочное сообщение
+
     resp = requests.post(url, data=data)
+    st.write(f"Статус ответа: {resp.status_code}")  # Отладочное сообщение
+    st.write(f"Текст ответа: {resp.text}")  # Отладочное сообщение
+
     if resp.status_code != 200:
         st.error(f"Ошибка обновления токена (HTTP {resp.status_code}): {resp.text}")
         return False
 
     try:
         result = resp.json()
+        st.write(f"Ответ от VK API: {result}")  # Отладочное сообщение
     except Exception as e:
         st.error(f"Не удалось распарсить ответ при обновлении токена: {e}")
         return False
@@ -189,6 +133,10 @@ def refresh_vk_token() -> bool:
         st.session_state["VK_REFRESH_TOKEN"] = result["refresh_token"]
 
     st.success("VK-токен обновлён успешно!")
+    st.write(f"Новый access_token: {new_access}")  # Отладочное сообщение
+    if "refresh_token" in result:
+        st.write(f"Новый refresh_token: {result['refresh_token']}")  # Отладочное сообщение
+
     return True
 
 # ------------- Парсер Telegram -------------