app.repository package

Repository layer - persistence abstraction.

Repositories wrap SQLAlchemy 2.0 AsyncSession access behind a small CRUD vocabulary (see app.repository.base_repository.BaseRepository). They contain no business logic and make no domain decisions: services decide what to do, repositories decide how to read/write it. Because persistence is abstracted here, the same service code runs against PostgreSQL in production and SQLite in tests.

Submodules

• app.repository.abuse_limit_counter_repository module
  • AbuseLimitCounterRepository
    • AbuseLimitCounterRepository.increment_and_get()
• app.repository.api_requests_repository module
  • ApiRequestsRepository
    • ApiRequestsRepository.session_factory
    • ApiRequestsRepository.model
    • ApiRequestsRepository.__init__()
• app.repository.apikey_repository module
  • ApiKeyRepository
    • ApiKeyRepository.read_all()
• app.repository.base_repository module
  • BaseRepository
    • BaseRepository.read_by_options()
    • BaseRepository.read_by_id()
    • BaseRepository.read_by_column()
    • BaseRepository.create()
    • BaseRepository.update()
    • BaseRepository.update_attr()
    • BaseRepository.whole_update()
    • BaseRepository.delete_by_id()
    • BaseRepository.read_by_columns()
• app.repository.dashboard_repository module
  • DashboardRepository
    • DashboardRepository.__init__()
    • DashboardRepository.process_query()
    • DashboardRepository.get_dashboard_summary()
    • DashboardRepository.get_dashboard_summary_logs()
• app.repository.export_audit_log_repository module
  • ExportAuditLogRepository
    • ExportAuditLogRepository.mark_finished()
    • ExportAuditLogRepository.list_recent()
• app.repository.game_params_repository module
  • GameParamsRepository
    • GameParamsRepository.session_factory
    • GameParamsRepository.model
    • GameParamsRepository.__init__()
    • GameParamsRepository.patch_game_params_by_id()
• app.repository.game_repository module
  • GameRepository
    • GameRepository.get_all_games()
    • GameRepository.get_game_by_id()
    • GameRepository.patch_game_by_id()
    • GameRepository.list_by_strategy_id()
    • GameRepository.list_external_ids()
    • GameRepository.bulk_update_strategy_id()
    • GameRepository.delete_game_by_id()
• app.repository.kpi_metrics_repository module
  • KpiMetricsRepository
    • KpiMetricsRepository.session_factory
    • KpiMetricsRepository.model
    • KpiMetricsRepository.__init__()
• app.repository.logs_repository module
  • LogsRepository
    • LogsRepository.session_factory
    • LogsRepository.model
    • LogsRepository.__init__()
• app.repository.oauth_users_repository module
  • OAuthUsersRepository
    • OAuthUsersRepository.session_factory
    • OAuthUsersRepository.model
    • OAuthUsersRepository.__init__()
    • OAuthUsersRepository.get_user_by_sub()
• app.repository.strategy_definition_repository module
  • StrategyDefinitionRepository
    • StrategyDefinitionRepository.list_for_realm()
    • StrategyDefinitionRepository.get_for_realm()
    • StrategyDefinitionRepository.list_versions()
    • StrategyDefinitionRepository.get_max_version()
    • StrategyDefinitionRepository.get_published()
    • StrategyDefinitionRepository.get_version()
    • StrategyDefinitionRepository.set_status()
• app.repository.strategy_execution_log_repository module
  • StrategyExecutionLogRepository
    • StrategyExecutionLogRepository.insert_row()
    • StrategyExecutionLogRepository.list_for_strategy()
    • StrategyExecutionLogRepository.count_by_status()
    • StrategyExecutionLogRepository.count_by_error_code()
    • StrategyExecutionLogRepository.count_by_case_name()
    • StrategyExecutionLogRepository.duration_and_nodes_summary()
    • StrategyExecutionLogRepository.sample_durations()
    • StrategyExecutionLogRepository.sample_points()
• app.repository.task_params_repository module
  • TaskParamsRepository
    • TaskParamsRepository.session_factory
    • TaskParamsRepository.model
    • TaskParamsRepository.__init__()
    • TaskParamsRepository.patch_task_params_by_id()
• app.repository.task_repository module
  • TaskRepository
    • TaskRepository.read_by_gameId()
    • TaskRepository.read_by_gameId_and_externalTaskId()
    • TaskRepository.get_points_and_users_by_taskId()
    • TaskRepository.patch_by_id()
    • TaskRepository.delete_task_by_id()
    • TaskRepository.list_by_strategy_id()
    • TaskRepository.bulk_update_strategy_id()
• app.repository.uptime_logs_repository module
  • UptimeLogsRepository
    • UptimeLogsRepository.session_factory
    • UptimeLogsRepository.model
    • UptimeLogsRepository.__init__()
• app.repository.user_actions_repository module
  • UserActionsRepository
    • UserActionsRepository.session_factory
    • UserActionsRepository.model
    • UserActionsRepository.__init__()
    • UserActionsRepository.add_action_in_task()
• app.repository.user_game_config_repository module
  • UserGameConfigRepository
    • UserGameConfigRepository.session_factory
    • UserGameConfigRepository.model
    • UserGameConfigRepository.__init__()
    • UserGameConfigRepository.get_all_users_by_gameId()
    • UserGameConfigRepository.get_by_user_and_game()
    • UserGameConfigRepository.create_or_update()
    • UserGameConfigRepository.delete()
• app.repository.user_interactions_repository module
  • UserInteractionsRepository
    • UserInteractionsRepository.session_factory
    • UserInteractionsRepository.model
    • UserInteractionsRepository.__init__()
• app.repository.user_points_repository module
  • UserPointsRepository
    • UserPointsRepository.get_first_user_points_in_external_task_id_by_user_id()
    • UserPointsRepository.read_by_user_task_and_idempotency()
    • UserPointsRepository.get_all_UserPoints_by_gameId()
    • UserPointsRepository.get_all_UserPoints_by_taskId()
    • UserPointsRepository.get_all_UserPoints_by_taskId_with_details()
    • UserPointsRepository.get_points_and_users_by_taskId()
    • UserPointsRepository.get_task_by_externalUserId()
    • UserPointsRepository.get_task_and_sum_points_by_userId()
    • UserPointsRepository.get_user_measurement_count()
    • UserPointsRepository.get_time_taken_for_last_task()
    • UserPointsRepository.get_individual_calculation()
    • UserPointsRepository.get_global_calculation()
    • UserPointsRepository.get_start_time_for_last_task()
    • UserPointsRepository.count_measurements_by_external_task_id()
    • UserPointsRepository.get_user_task_measurements()
    • UserPointsRepository.get_user_task_measurements_count()
    • UserPointsRepository.get_user_task_measurements_count_the_last_seconds()
    • UserPointsRepository.get_avg_time_between_tasks_by_user_and_game_task()
    • UserPointsRepository.get_avg_time_between_tasks_for_all_users()
    • UserPointsRepository.get_last_window_time_diff()
    • UserPointsRepository.get_new_last_window_time_diff()
    • UserPointsRepository.count_personal_records_by_external_game_id()
    • UserPointsRepository.user_has_record_before_in_externalTaskId_last_min()
    • UserPointsRepository.get_global_avg_by_external_game_id()
    • UserPointsRepository.get_personal_avg_by_external_game_id()
    • UserPointsRepository.get_points_of_simulated_task()
    • UserPointsRepository.get_all_point_of_tasks_list()
    • UserPointsRepository.get_last_task_by_userId()
• app.repository.user_repository module
  • UserRepository
    • UserRepository.create_user_by_externalUserId()
    • UserRepository.get_or_create_by_externalUserId()
• app.repository.wallet_repository module
  • WalletRepository
    • WalletRepository.upsert_points_balance()
• app.repository.wallet_transaction_repository module
  • WalletTransactionRepository
    • WalletTransactionRepository.session_factory
    • WalletTransactionRepository.model
    • WalletTransactionRepository.__init__()