创建新账户
(
db: Session,
email: str,
email_service: str,
password: Optional[str] = None,
client_id: Optional[str] = None,
session_token: Optional[str] = None,
email_service_id: Optional[str] = None,
account_id: Optional[str] = None,
workspace_id: Optional[str] = None,
access_token: Optional[str] = None,
refresh_token: Optional[str] = None,
id_token: Optional[str] = None,
cookies: Optional[str] = None,
proxy_used: Optional[str] = None,
expires_at: Optional['datetime'] = None,
extra_data: Optional[Dict[str, Any]] = None,
status: Optional[str] = None,
source: Optional[str] = None,
priority: Optional[int] = None,
last_used_at: Optional['datetime'] = None,
)
| 29 | # ============================================================================ |
| 30 | |
| 31 | def create_account( |
| 32 | db: Session, |
| 33 | email: str, |
| 34 | email_service: str, |
| 35 | password: Optional[str] = None, |
| 36 | client_id: Optional[str] = None, |
| 37 | session_token: Optional[str] = None, |
| 38 | email_service_id: Optional[str] = None, |
| 39 | account_id: Optional[str] = None, |
| 40 | workspace_id: Optional[str] = None, |
| 41 | access_token: Optional[str] = None, |
| 42 | refresh_token: Optional[str] = None, |
| 43 | id_token: Optional[str] = None, |
| 44 | cookies: Optional[str] = None, |
| 45 | proxy_used: Optional[str] = None, |
| 46 | expires_at: Optional['datetime'] = None, |
| 47 | extra_data: Optional[Dict[str, Any]] = None, |
| 48 | status: Optional[str] = None, |
| 49 | source: Optional[str] = None, |
| 50 | priority: Optional[int] = None, |
| 51 | last_used_at: Optional['datetime'] = None, |
| 52 | ) -> Account: |
| 53 | """创建新账户""" |
| 54 | db_account = Account( |
| 55 | email=email, |
| 56 | password=password, |
| 57 | client_id=client_id, |
| 58 | session_token=session_token, |
| 59 | email_service=email_service, |
| 60 | email_service_id=email_service_id, |
| 61 | account_id=account_id, |
| 62 | workspace_id=workspace_id, |
| 63 | access_token=access_token, |
| 64 | refresh_token=refresh_token, |
| 65 | id_token=id_token, |
| 66 | cookies=cookies, |
| 67 | proxy_used=proxy_used, |
| 68 | expires_at=expires_at, |
| 69 | extra_data=extra_data or {}, |
| 70 | status=status or 'active', |
| 71 | source=source or 'register', |
| 72 | priority=int(priority) if priority is not None else 50, |
| 73 | last_used_at=last_used_at, |
| 74 | registered_at=utcnow_naive() |
| 75 | ) |
| 76 | db.add(db_account) |
| 77 | db.commit() |
| 78 | db.refresh(db_account) |
| 79 | return db_account |
| 80 | |
| 81 | |
| 82 | def get_account_by_id(db: Session, account_id: int) -> Optional[Account]: |
nothing calls this directly
no test coverage detected