fix(auth): stabilize manual flows and tab focus

Author: izzzzzi

.github/workflows/ci.yml

@@ -1,8 +1,6 @@
 name: CI
 
 on:
-  push:
-    branches: [main]
   pull_request:
     branches: [main]
   workflow_call:

README.md

@@ -94,6 +94,22 @@ npm cache clean --force && npm install -g izteamslots@latest
 
 > Chrome и chromedriver скачиваются автоматически при первом запуске через SeleniumBase.
 
+### Где лежат данные после `npm install -g`
+
+При глобальной установке runtime-данные сохраняются не в папку пакета, а в пользовательскую директорию `~/.izteamslots`.
+
+- `codex/`:
+  - Windows: `C:\Users\<USER>\.izteamslots\codex`
+  - macOS / Linux: `~/.izteamslots/codex`
+- `.env`:
+  - Windows: `C:\Users\<USER>\.izteamslots\.env`
+  - macOS / Linux: `~/.izteamslots/.env`
+- аккаунты и профили браузера:
+  - Windows: `C:\Users\<USER>\.izteamslots\accounts`
+  - macOS / Linux: `~/.izteamslots/accounts`
+
+Если вы обновляете старую версию, `codex`-файлы могут временно лежать ещё и внутри директории пакета. В актуальной версии основным путём считается именно `~/.izteamslots`.
+
 ### Из исходников
 
 ```bash
@@ -237,4 +253,3 @@ flowchart TD
 - Проект хранит токены и браузерные профили локально на диске.
 - Не публикуйте папки `accounts/` и `codex/` в публичные репозитории.
 - Для стабильной работы перелогина у worker должен быть `openai_password`.
-

backend/openai_web_auth.py

@@ -151,12 +151,17 @@ def __init__(self, driver: Any, context: BrowserContext) -> None:
     @property
     def url(self) -> str:
         try:
-            return self._driver.current_url
+            current_url = self._driver.current_url
+            if current_url.startswith("chrome://") or current_url in {"about:blank", "data:,"}:
+                _activate_best_tab(self._driver)
+                current_url = self._driver.current_url
+            return current_url
         except Exception:
             return ""
 
     def goto(self, url: str, wait_until: str | None = None, timeout: int | None = None) -> None:
         self._driver.get(url)
+        _activate_best_tab(self._driver, [url, urllib.parse.urlparse(url).netloc])
         if wait_until in {"domcontentloaded", "load"}:
             t = (timeout or 30000) / 1000
             WebDriverWait(self._driver, t).until(
@@ -1184,20 +1189,13 @@ def oauth_login_manual(
             _log(f"В браузере завершите вход вручную для {expected_email}.")
         else:
             _log("В браузере завершите вход вручную.")
-        _log("Можно ввести email, пароль или код подтверждения вручную прямо в открытом окне.")
-        _log("После успешного входа дождусь OAuth callback и сохраню сессию автоматически.")
+        _log("Я больше ничего не нажимаю: email, пароль, код и consent подтверждайте сами в браузере.")
+        _log("Как только произойдёт переход на localhost callback, я перехвачу код и сохраню сессию.")
 
-        _handle_consent_and_wait(page, _log, callback_wait_seconds=timeout_seconds)
         auth_code = _wait_for_callback(holder, timeout=timeout_seconds)
         _log("Authorization code получен")
 
         session_result = _exchange_oauth_code(auth_code, redirect_uri, code_verifier)
-        _bootstrap_chatgpt_session(
-            page,
-            _log,
-            timeout_seconds=min(timeout_seconds, 300),
-            interactive=True,
-        )
         return page, session_result
     except Exception:
         try:

backend/slot_orchestrator.py

@@ -101,7 +101,13 @@ def _get_api(self, page: Page) -> ChatGPTWorkspaceAPI:
             raise RuntimeError("account_id/access_token не установлены — сначала login_admin()")
         return ChatGPTWorkspaceAPI(page, self.account_id, self.access_token)
 
-    def _finalize_admin_login(self, page: Page, session: dict[str, Any]) -> None:
+    def _finalize_admin_login(
+        self,
+        page: Page,
+        session: dict[str, Any],
+        *,
+        manual_web_flow: bool = False,
+    ) -> None:
         if not self._admin:
             raise RuntimeError(f"Админ {self.admin_email} не найден в AccountStore")
 
@@ -115,38 +121,41 @@ def _finalize_admin_login(self, page: Page, session: dict[str, Any]) -> None:
             workspaces = get_workspaces(page, log=self._log)
             if workspaces:
                 self._admin.workspaces = workspaces
-                available_ids = {str(ws["workspace_id"]) for ws in workspaces if ws.get("workspace_id")}
                 self._log(
                     "Доступные workspace: "
                     + ", ".join(f"{ws.get('name', '?')} [{ws.get('workspace_id', '?')}]" for ws in workspaces)
                 )
 
-                target_workspace_id = self._admin.workspace_id if self._admin.workspace_id in available_ids else None
-                if self._admin.workspace_id and not target_workspace_id:
-                    self._log(
-                        f"[предупреждение] Workspace из OAuth ({self._admin.workspace_id}) не найден среди кнопок на странице"
-                    )
-
-                if not target_workspace_id:
-                    for ws in workspaces:
-                        name = str(ws.get("name", ""))
-                        workspace_id = str(ws.get("workspace_id", ""))
-                        if workspace_id and "Личная" not in name and "Personal" not in name:
-                            target_workspace_id = workspace_id
-                            break
-
-                if not target_workspace_id and workspaces:
-                    target_workspace_id = str(workspaces[0]["workspace_id"])
-
-                self._admin.workspace_id = target_workspace_id
-                if target_workspace_id:
-                    select_workspace(page, target_workspace_id, log=self._log)
-                    self._admin.account_id = target_workspace_id
-                    if not ensure_chatgpt_web_session(page, self._log, timeout_seconds=45, open_home=True):
-                        raise RuntimeError(
-                            "Не удалось подтвердить web-сессию chatgpt.com после выбора workspace"
+                if manual_web_flow:
+                    self._log("Ручной режим: workspace не выбираю автоматически.")
+                else:
+                    available_ids = {str(ws["workspace_id"]) for ws in workspaces if ws.get("workspace_id")}
+                    target_workspace_id = self._admin.workspace_id if self._admin.workspace_id in available_ids else None
+                    if self._admin.workspace_id and not target_workspace_id:
+                        self._log(
+                            f"[предупреждение] Workspace из OAuth ({self._admin.workspace_id}) не найден среди кнопок на странице"
                         )
 
+                    if not target_workspace_id:
+                        for ws in workspaces:
+                            name = str(ws.get("name", ""))
+                            workspace_id = str(ws.get("workspace_id", ""))
+                            if workspace_id and "Личная" not in name and "Personal" not in name:
+                                target_workspace_id = workspace_id
+                                break
+
+                    if not target_workspace_id and workspaces:
+                        target_workspace_id = str(workspaces[0]["workspace_id"])
+
+                    self._admin.workspace_id = target_workspace_id
+                    if target_workspace_id:
+                        select_workspace(page, target_workspace_id, log=self._log)
+                        self._admin.account_id = target_workspace_id
+                        if not ensure_chatgpt_web_session(page, self._log, timeout_seconds=45, open_home=True):
+                            raise RuntimeError(
+                                "Не удалось подтвердить web-сессию chatgpt.com после выбора workspace"
+                            )
+
         close_browser(page, log=self._log)
         self._admin.last_login = datetime.now(timezone.utc).isoformat()
         self.store.update_admin(self._admin)
@@ -161,7 +170,7 @@ def _finalize_admin_login(self, page: Page, session: dict[str, Any]) -> None:
         self._log("Админ авторизован!")
 
     def finalize_admin_session(self, page: Page, session: dict[str, Any]) -> None:
-        self._finalize_admin_login(page, session)
+        self._finalize_admin_login(page, session, manual_web_flow=True)
 
     def login_admin(self) -> None:
         """Логин админа через OAuth PKCE — получаем все токены (access, id, refresh)."""
@@ -198,7 +207,7 @@ def login_admin_manual(self) -> None:
         )
         if session.get("email") and session["email"] != self._admin.email:
             self._log(f"[предупреждение] Вошли как {session['email']}, а не как {self._admin.email}")
-        self._finalize_admin_login(page, session)
+        self._finalize_admin_login(page, session, manual_web_flow=True)
 
     def create_slots(self, count: int) -> list[WorkerAccount]:
         """Создать N временных почт."""