Update app.py

app.py

@@ -34,6 +34,70 @@ if not 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()