mirror of
https://github.com/langgenius/dify.git
synced 2026-08-24 12:32:54 -04:00
Byron.wang
76 lines
2.3 KiB
Python
76 lines
2.3 KiB
Python
"""Persistence ports used by account application services."""
|
|
|
|
from collections.abc import Sequence
|
|
from typing import Protocol
|
|
|
|
from services.entities.account_entities import (
|
|
AccountCredentials,
|
|
AccountDeletionChallenge,
|
|
AccountEmailResetResult,
|
|
AccountInitialization,
|
|
AccountInitializationResult,
|
|
AccountIntegrationSnapshot,
|
|
AccountPasswordDigest,
|
|
AccountProfileChanges,
|
|
AccountSnapshot,
|
|
)
|
|
|
|
|
|
class AccountRepository(Protocol):
|
|
def get(self, account_id: str) -> AccountSnapshot | None: ...
|
|
|
|
def get_credentials(self, account_id: str) -> AccountCredentials | None: ...
|
|
|
|
def update_profile(self, account_id: str, changes: AccountProfileChanges) -> AccountSnapshot | None: ...
|
|
|
|
def update_password(self, account_id: str, password: AccountPasswordDigest) -> AccountSnapshot | None: ...
|
|
|
|
def initialize(
|
|
self,
|
|
account_id: str,
|
|
initialization: AccountInitialization,
|
|
*,
|
|
invitation_code: str | None,
|
|
workspace_id: str | None,
|
|
) -> AccountInitializationResult: ...
|
|
|
|
def email_exists(self, email: str) -> bool: ...
|
|
|
|
def reset_email(self, account_id: str, *, expected_old_email: str, new_email: str) -> AccountEmailResetResult: ...
|
|
|
|
|
|
class AccountIntegrationRepository(Protocol):
|
|
def list_for_account(self, account_id: str) -> list[AccountIntegrationSnapshot]: ...
|
|
|
|
|
|
class AccountWorkspaceMembershipQuery(Protocol):
|
|
def list_ids_for_account(self, account_id: str) -> Sequence[str]: ...
|
|
|
|
|
|
class AccountAvatarFileGateway(Protocol):
|
|
def get_owned_signed_url(self, *, account_id: str, upload_file_id: str) -> str | None: ...
|
|
|
|
|
|
class AccountPasswordHasher(Protocol):
|
|
def verify(self, password: str, *, password_hash: str, password_salt: str) -> bool: ...
|
|
|
|
def hash(self, password: str) -> AccountPasswordDigest: ...
|
|
|
|
|
|
class AccountDeletionVerificationGateway(Protocol):
|
|
def create(self, *, account_id: str, email: str) -> AccountDeletionChallenge: ...
|
|
|
|
def verify(self, *, account_id: str, token: str, code: str) -> bool: ...
|
|
|
|
|
|
class AccountDeletionVerificationNotifier(Protocol):
|
|
def send(self, *, email: str, code: str) -> None: ...
|
|
|
|
|
|
class AccountDeletionSyncGateway(Protocol):
|
|
def sync(self, *, account_id: str, workspace_ids: Sequence[str]) -> bool: ...
|
|
|
|
|
|
class AccountDeletionScheduler(Protocol):
|
|
def schedule(self, account_id: str) -> None: ...
|