auto-invest-manager — API

AdminServiceError

src/app/admin/errors.py

class AdminServiceError(Exception):

ResourceNotFoundError

src/app/admin/errors.py

class ResourceNotFoundError(AdminServiceError):

ResourceConflictError

src/app/admin/errors.py

class ResourceConflictError(AdminServiceError):

AdminRepository:

src/app/admin/repository.py

class AdminRepository:

ORMModel

src/app/admin/schemas.py

class ORMModel(BaseModel):

SystemSettingsResponse

src/app/admin/schemas.py

class SystemSettingsResponse(ORMModel):

SystemSettingsUpdate

src/app/admin/schemas.py

class SystemSettingsUpdate(BaseModel):

InstrumentReference

src/app/admin/schemas.py

class InstrumentReference(BaseModel):

InstrumentResponse

src/app/admin/schemas.py

class InstrumentResponse(ORMModel):

InstrumentSyncRequest

src/app/admin/schemas.py

class InstrumentSyncRequest(BaseModel):

WatchlistItemCreate

src/app/admin/schemas.py

class WatchlistItemCreate(InstrumentReference):

WatchlistItemUpdate

src/app/admin/schemas.py

class WatchlistItemUpdate(BaseModel):

WatchlistItemResponse

src/app/admin/schemas.py

class WatchlistItemResponse(ORMModel):

RiskProfileUpdate

src/app/admin/schemas.py

class RiskProfileUpdate(BaseModel):

RiskProfileResponse

src/app/admin/schemas.py

class RiskProfileResponse(ORMModel):

StrategyProfileUpdate

src/app/admin/schemas.py

class StrategyProfileUpdate(BaseModel):

StrategyProfileResponse

src/app/admin/schemas.py

class StrategyProfileResponse(ORMModel):

AccountsResponse

src/app/admin/schemas.py

class AccountsResponse(BaseModel):

SignalResponse

src/app/admin/schemas.py

class SignalResponse(ORMModel):

AnalysisRunResponse

src/app/admin/schemas.py

class AnalysisRunResponse(BaseModel):

TargetAllocationResponse

src/app/admin/schemas.py

class TargetAllocationResponse(ORMModel):

RebalancePlanResponse

src/app/admin/schemas.py

class RebalancePlanResponse(ORMModel):

PlannedOrderResponse

src/app/admin/schemas.py

class PlannedOrderResponse(ORMModel):

VirtualTradeResponse

src/app/admin/schemas.py

class VirtualTradeResponse(ORMModel):

ExecutionOrderResponse

src/app/admin/schemas.py

class ExecutionOrderResponse(ORMModel):

AuditLogResponse

src/app/admin/schemas.py

class AuditLogResponse(ORMModel):

AdminService:

src/app/admin/service.py

class AdminService:

def

src/app/api/admin.py

async def get_accounts(service: AdminServiceDependency) -> AccountsResponse:

def

src/app/api/admin.py

async def get_audit_logs(service: AdminServiceDependency) -> list[AuditLogResponse]:

def

src/app/api/admin.py

async def get_system_settings(service: AdminServiceDependency) -> SystemSettingsResponse:

def

src/app/api/admin.py

async def get_watchlist(service: AdminServiceDependency) -> list[WatchlistItemResponse]:

def

src/app/api/admin.py

async def remove_watchlist_item(item_id: UUID, service: AdminServiceDependency) -> Response:

def

src/app/api/admin.py

async def get_risk_profile(service: AdminServiceDependency) -> RiskProfileResponse:

def

src/app/api/admin.py

async def get_strategy_profile(service: AdminServiceDependency) -> StrategyProfileResponse:

def

src/app/api/admin.py

async def run_analysis(service: SignalServiceDependency) -> AnalysisRunResponse:

def

src/app/api/automation.py

async def list_runs(session: SessionDependency) -> list[AutomationRunResponse]:

def

src/app/api/automation.py

async def get_run(run_id: UUID, session: SessionDependency) -> AutomationRunResponse:

HealthResponse

src/app/api/health.py

class HealthResponse(BaseModel):

WorkerHealthResponse

src/app/api/health.py

class WorkerHealthResponse(BaseModel):

get_engine

src/app/api/health.py

def get_engine() -> AsyncEngine:

def

src/app/api/health.py

async def liveness() -> HealthResponse:

def

src/app/api/streams.py

async def stream_event(event_id: UUID, session: SessionDependency) -> StreamEventResponse:

def

src/app/api/streams.py

async def account_event(event_id: UUID, session: SessionDependency) -> AccountEventResponse:

def

src/app/api/streams.py

async def reconcile_account(account_id: str, settings: SettingsDependency) -> dict[str, str]:

RetryingBrokerProvider:

src/app/automation/broker.py

class RetryingBrokerProvider:

AutomationCycleRequest:

src/app/automation/dto.py

class AutomationCycleRequest:

AutomationCycleResult:

src/app/automation/dto.py

class AutomationCycleResult:

def

src/app/automation/healthcheck.py

async def check_scheduler() -> None:

main

src/app/automation/healthcheck.py

def main() -> None:

LockLease:

src/app/automation/lock.py

class LockLease:

RedisCycleLock:

src/app/automation/lock.py

class RedisCycleLock:

AutomationRepository:

src/app/automation/repository.py

class AutomationRepository:

RetryPolicy:

src/app/automation/retry.py

class RetryPolicy:

def

src/app/automation/scheduler.py

async def run_scheduler() -> None:

main

src/app/automation/scheduler.py

def main() -> None:

AutomationRunResponse

src/app/automation/schemas.py

class AutomationRunResponse(BaseModel):

AutomationStatusResponse

src/app/automation/schemas.py

class AutomationStatusResponse(BaseModel):

AutomationCycleService:

src/app/automation/service.py

class AutomationCycleService:

def

src/app/automation/worker.py

async def sync_accounts(ctx: dict[str, Any]) -> dict[str, int]:

def

src/app/automation/worker.py

async def sync_instruments(ctx: dict[str, Any]) -> dict[str, int]:

def

src/app/automation/worker.py

async def process_broker_stream_event(ctx: dict[str, Any], event_id: str) -> dict[str, bool]:

def

src/app/automation/worker.py

async def reconcile_account(ctx: dict[str, Any], account_id: str, state_key: str) -> dict[str, Any]:

def

src/app/automation/worker.py

async def cleanup_processed_stream_events(ctx: dict[str, Any]) -> dict[str, int]:

def

src/app/automation/worker.py

async def startup(ctx: dict[str, Any]) -> None:

WorkerSettings:

src/app/automation/worker.py

class WorkerSettings:

CandleInterval

src/app/broker/dto.py

class CandleInterval(StrEnum):

BrokerAccountData:

src/app/broker/dto.py

class BrokerAccountData:

MoneyData:

src/app/broker/dto.py

class MoneyData:

PositionData:

src/app/broker/dto.py

class PositionData:

PortfolioData:

src/app/broker/dto.py

class PortfolioData:

InstrumentData:

src/app/broker/dto.py

class InstrumentData:

CandleData:

src/app/broker/dto.py

class CandleData:

LastPriceData:

src/app/broker/dto.py

class LastPriceData:

TradingStatusData:

src/app/broker/dto.py

class TradingStatusData:

SandboxOrderRequest:

src/app/broker/dto.py

class SandboxOrderRequest:

SandboxOrderResult:

src/app/broker/dto.py

class SandboxOrderResult:

BrokerCapabilities:

src/app/broker/dto.py

class BrokerCapabilities:

BrokerStreamEvent:

src/app/broker/dto.py

class BrokerStreamEvent:

OperationsCursorRequest:

src/app/broker/dto.py

class OperationsCursorRequest:

BrokerOperation:

src/app/broker/dto.py

class BrokerOperation:

OperationsCursorPage:

src/app/broker/dto.py

class OperationsCursorPage:

BrokerError

src/app/broker/errors.py

class BrokerError(Exception):

BrokerConfigurationError

src/app/broker/errors.py

class BrokerConfigurationError(BrokerError):

InstrumentNotFoundError

src/app/broker/errors.py

class InstrumentNotFoundError(BrokerError):

BrokerTemporaryError

src/app/broker/errors.py

class BrokerTemporaryError(BrokerError):

BrokerRateLimitError

src/app/broker/errors.py

class BrokerRateLimitError(BrokerTemporaryError):

create_broker_provider

src/app/broker/factory.py

def create_broker_provider(settings: Settings) -> BrokerProvider:

BrokerProvider

src/app/broker/interface.py

class BrokerProvider(Protocol):

MockBrokerProvider:

src/app/broker/mock.py

class MockBrokerProvider:

TInvestClient:

src/app/broker/tinvest.py

class TInvestClient:

def

src/app/commands/seed.py

async def seed_defaults() -> None:

main

src/app/commands/seed.py

def main() -> None:

Settings

src/app/core/config.py

class Settings(BaseSettings):

get_settings

src/app/core/config.py

def get_settings() -> Settings:

Base

src/app/db/base.py

class Base(DeclarativeBase):

UUIDPrimaryKeyMixin:

src/app/db/base.py

class UUIDPrimaryKeyMixin:

TimestampMixin:

src/app/db/base.py

class TimestampMixin:

def

src/app/db/session.py

async def get_session() -> AsyncIterator[AsyncSession]:

ExecutionAllocation:

src/app/execution/dto.py

class ExecutionAllocation:

PlannedOrderData:

src/app/execution/dto.py

class PlannedOrderData:

RiskContext:

src/app/execution/dto.py

class RiskContext:

RiskDecision:

src/app/execution/dto.py

class RiskDecision:

ExecutionPlanningError

src/app/execution/errors.py

class ExecutionPlanningError(Exception):

RiskRejectedError

src/app/execution/errors.py

class RiskRejectedError(Exception):

ExecutionPlanner:

src/app/execution/planner.py

class ExecutionPlanner:

initial_order_status

src/app/execution/repository.py

def initial_order_status(trade_mode: TradeMode) -> PlannedOrderStatus:

ExecutionRepository:

src/app/execution/repository.py

class ExecutionRepository:

RiskManager:

src/app/execution/risk.py

class RiskManager:

ExecutionService:

src/app/execution/service.py

class ExecutionService:

create_app

src/app/main.py

def create_app() -> FastAPI:

SystemSettings

src/app/models/entities.py

class SystemSettings(UUIDPrimaryKeyMixin, TimestampMixin, Base):

BrokerAccount

src/app/models/entities.py

class BrokerAccount(UUIDPrimaryKeyMixin, TimestampMixin, Base):

Instrument

src/app/models/entities.py

class Instrument(UUIDPrimaryKeyMixin, TimestampMixin, Base):

WatchlistItem

src/app/models/entities.py

class WatchlistItem(UUIDPrimaryKeyMixin, TimestampMixin, Base):

RiskProfile

src/app/models/entities.py

class RiskProfile(UUIDPrimaryKeyMixin, TimestampMixin, Base):

StrategyProfile

src/app/models/entities.py

class StrategyProfile(UUIDPrimaryKeyMixin, TimestampMixin, Base):

PortfolioSnapshot

src/app/models/entities.py

class PortfolioSnapshot(UUIDPrimaryKeyMixin, Base):

CashSnapshot

src/app/models/entities.py

class CashSnapshot(UUIDPrimaryKeyMixin, Base):

Position

src/app/models/entities.py

class Position(UUIDPrimaryKeyMixin, Base):

MarketCandle

src/app/models/entities.py

class MarketCandle(UUIDPrimaryKeyMixin, Base):

MarketPrice

src/app/models/entities.py

class MarketPrice(UUIDPrimaryKeyMixin, Base):

Signal

src/app/models/entities.py

class Signal(UUIDPrimaryKeyMixin, Base):

RebalancePlan

src/app/models/entities.py

class RebalancePlan(UUIDPrimaryKeyMixin, Base):

TargetAllocation

src/app/models/entities.py

class TargetAllocation(UUIDPrimaryKeyMixin, Base):

PlannedOrder

src/app/models/entities.py

class PlannedOrder(UUIDPrimaryKeyMixin, Base):

VirtualTrade

src/app/models/entities.py

class VirtualTrade(UUIDPrimaryKeyMixin, Base):

ExecutionOrder

src/app/models/entities.py

class ExecutionOrder(UUIDPrimaryKeyMixin, TimestampMixin, Base):

OrderEvent

src/app/models/entities.py

class OrderEvent(UUIDPrimaryKeyMixin, Base):

AuditLog

src/app/models/entities.py

class AuditLog(UUIDPrimaryKeyMixin, Base):

AutomationRun

src/app/models/entities.py

class AutomationRun(UUIDPrimaryKeyMixin, TimestampMixin, Base):

BrokerStreamEventRecord

src/app/models/entities.py

class BrokerStreamEventRecord(UUIDPrimaryKeyMixin, TimestampMixin, Base):

BrokerStreamState

src/app/models/entities.py

class BrokerStreamState(UUIDPrimaryKeyMixin, TimestampMixin, Base):

BrokerOperationCursor

src/app/models/entities.py

class BrokerOperationCursor(UUIDPrimaryKeyMixin, TimestampMixin, Base):

AccountEvent

src/app/models/entities.py

class AccountEvent(UUIDPrimaryKeyMixin, TimestampMixin, Base):

AccountReconciliation

src/app/models/entities.py

class AccountReconciliation(UUIDPrimaryKeyMixin, TimestampMixin, Base):

TradeMode

src/app/models/enums.py

class TradeMode(StrEnum):

RiskMode

src/app/models/enums.py

class RiskMode(StrEnum):

RebalanceMode

src/app/models/enums.py

class RebalanceMode(StrEnum):

OrderType

src/app/models/enums.py

class OrderType(StrEnum):

SignalRecommendation

src/app/models/enums.py

class SignalRecommendation(StrEnum):

RebalancePlanStatus

src/app/models/enums.py

class RebalancePlanStatus(StrEnum):

AllocationAction

src/app/models/enums.py

class AllocationAction(StrEnum):

OrderDirection

src/app/models/enums.py

class OrderDirection(StrEnum):

PlannedOrderStatus

src/app/models/enums.py

class PlannedOrderStatus(StrEnum):

AutomationTrigger

src/app/models/enums.py

class AutomationTrigger(StrEnum):

AutomationRunStatus

src/app/models/enums.py

class AutomationRunStatus(StrEnum):

AutomationStep

src/app/models/enums.py

class AutomationStep(StrEnum):

BrokerStreamType

src/app/models/enums.py

class BrokerStreamType(StrEnum):

BrokerStreamEventKind

src/app/models/enums.py

class BrokerStreamEventKind(StrEnum):

StreamEventProcessingStatus

src/app/models/enums.py

class StreamEventProcessingStatus(StrEnum):

BrokerStreamStatus

src/app/models/enums.py

class BrokerStreamStatus(StrEnum):

AccountEventType

src/app/models/enums.py

class AccountEventType(StrEnum):

ReconciliationStatus

src/app/models/enums.py

class ReconciliationStatus(StrEnum):

ReconciliationReason

src/app/models/enums.py

class ReconciliationReason(StrEnum):

NotificationSeverity

src/app/notifications/dto.py

class NotificationSeverity(StrEnum):

Notification:

src/app/notifications/dto.py

class Notification:

create_notifier

src/app/notifications/factory.py

def create_notifier(settings: Settings) -> Notifier:

Notifier

src/app/notifications/interface.py

class Notifier(Protocol):

NullNotifier:

src/app/notifications/service.py

class NullNotifier:

BestEffortNotifier:

src/app/notifications/service.py

class BestEffortNotifier:

TelegramNotifier:

src/app/notifications/telegram.py

class TelegramNotifier:

AssetInput:

src/app/portfolio/dto.py

class AssetInput:

OptimizationConstraints:

src/app/portfolio/dto.py

class OptimizationConstraints:

TargetWeight:

src/app/portfolio/dto.py

class TargetWeight:

OptimizationResult:

src/app/portfolio/dto.py

class OptimizationResult:

PlannedAllocation:

src/app/portfolio/dto.py

class PlannedAllocation:

RebalanceResult:

src/app/portfolio/dto.py

class RebalanceResult:

PortfolioOptimizationError

src/app/portfolio/errors.py

class PortfolioOptimizationError(Exception):

PortfolioOptimizer:

src/app/portfolio/optimizer.py

class PortfolioOptimizer: