Class AccountStateService

app/services/account_state.py:45–531

Manage local JSON-backed account state.

        self.tasks_store = JsonFileStore(settings.tasks_path, default_factory=list)

    def list_accounts(self) -> list[PublicAccountRecord]:
        accounts = [AccountRecord.model_validate(item) for item in self.accounts_store.read()]
        accounts.sort(key=lambda item: item.updated_at, reverse=True)
        return [self.to_public_account(account) for account in accounts]

    def get_account(self, account_id: str) -> AccountRecord:
        for item in self.accounts_store.read():
            account = AccountRecord.model_validate(item)
            if account.id == account_id:
                return account
        raise NotFoundError("账号不存在", details={"account_id": account_id})

    def import_account(self, request: AccountImportRequest) -> PublicAccountRecord:
        cookies = self._merge_cookies(request.token, request.cookie_header, request.cookies)
        token = (request.token or "").strip() or cookies.get(TOKEN_COOKIE_KEY, "")
        if not token:
            raise BadRequestError(
                f"凭据里缺少 `{TOKEN_COOKIE_KEY}`，后续请求没法发，别整这没头没尾的半截登录态。",
            )

        cookie_header = (request.cookie_header or "").strip() or self._cookies_to_header(cookies)
        now = utc_now_iso()
        resolved_account_id = {"value": (request.id or "").strip()}

        def updater(records: list[dict[str, Any]]) -> list[dict[str, Any]]:
            account_id = resolved_account_id["value"]
            index = -1
            if account_id:
                for idx, item in enumerate(records):
                    if item.get("id") == account_id:
                        index = idx
                        break
            else:
                for idx, item in enumerate(records):
                    if item.get("label") == request.label:
                        index = idx
                        account_id = str(item.get("id") or "")
                        break
            if not account_id:
                account_id = make_id("acct")
            resolved_account_id["value"] = account_id

            existing = records[index] if index >= 0 else None
            created_at = str(existing.get("created_at")) if existing else now
            last_bootstrap_at = existing.get("last_bootstrap_at") if existing else None
            existing_impersonate = str(existing.get("browser_impersonate") or "") if existing else ""
            requested_impersonate = (request.browser_impersonate or "").strip()
            if requested_impersonate:
                browser_impersonate = resolve_browser_impersonate(requested_impersonate)
            elif existing_impersonate:
                browser_impersonate = resolve_browser_impersonate(existing_impersonate)
            else:
                browser_impersonate = random_browser_impersonate()
            record = AccountRecord(
                id=account_id,
                label=request.label,
                token=token,
                cookie_header=cookie_header,