app.services package

Service layer - business logic and orchestration.

Services own domain rules, transactional behavior, and multi-repository workflows. They are the only layer that composes persistence operations into units of work; endpoints orchestrate them, repositories serve them. Each service is provided by the DI container (app/core/container.py) with its dependencies injected, so it can be unit-tested in isolation.

Subpackages

• app.services.user_points package
  • Submodules
    • app.services.user_points.assignment module
      • PointsAssignmentMixin
    • app.services.user_points.persistence module
      • PointsPersistenceMixin
    • app.services.user_points.queries module
      • PointsQueryMixin
    • app.services.user_points.simulation module
      • PointsSimulationMixin

Submodules

• app.services.abuse_prevention_service module
  • AbusePreventionService
    • AbusePreventionService.extract_client_ip()
    • AbusePreventionService.enforce_task_mutation_limits()
• app.services.api_requests_service module
  • ApiRequestsService
    • ApiRequestsService.api_requests_repository
    • ApiRequestsService.__init__()
• app.services.apikey_cache_backend module
  • ApiKeyCacheBackend
    • ApiKeyCacheBackend.get()
    • ApiKeyCacheBackend.set()
    • ApiKeyCacheBackend.delete()
    • ApiKeyCacheBackend.clear()
  • InMemoryApiKeyCacheBackend
    • InMemoryApiKeyCacheBackend.get()
    • InMemoryApiKeyCacheBackend.set()
    • InMemoryApiKeyCacheBackend.delete()
    • InMemoryApiKeyCacheBackend.clear()
    • InMemoryApiKeyCacheBackend.sync_clear()
  • RedisApiKeyCacheBackend
    • RedisApiKeyCacheBackend.get()
    • RedisApiKeyCacheBackend.set()
    • RedisApiKeyCacheBackend.delete()
    • RedisApiKeyCacheBackend.clear()
  • build_apikey_cache_backend()
• app.services.apikey_service module
  • ApiKeyService
    • ApiKeyService.apikey_repository
    • ApiKeyService.cache_backend
    • ApiKeyService.__init__()
    • ApiKeyService.generate_api_key_service()
    • ApiKeyService.create_api_key()
    • ApiKeyService.get_all_api_keys()
    • ApiKeyService.revoke_api_key_by_prefix()
    • ApiKeyService.get_api_key_header()
    • ApiKeyService.clear_header_cache()
• app.services.base_service module
  • BaseService
    • BaseService.get_list()
    • BaseService.get_by_id()
    • BaseService.add()
    • BaseService.patch()
    • BaseService.patch_attr()
    • BaseService.put_update()
    • BaseService.remove_by_id()
• app.services.dashboard_service module
  • DashboardService
    • DashboardService.dashboard_repository
    • DashboardService.__init__()
    • DashboardService.get_dashboard_summary()
    • DashboardService.get_dashboard_summary_logs()
• app.services.dsl_observability_service module
  • DslExecutionObserver
    • DslExecutionObserver.record()
    • DslExecutionObserver.drain()
    • DslExecutionObserver.aclose()
  • NoopDslExecutionObserver
    • NoopDslExecutionObserver.record()
• app.services.dsl_simulation_service module
  • DslSimulationService
    • DslSimulationService.simulate()
    • DslSimulationService.simulate_inline()
• app.services.export_service module
  • ExportService
    • ExportService.audit_start()
    • ExportService.audit_finish()
    • ExportService.list_history()
    • ExportService.iter_users()
    • ExportService.iter_user_points()
    • ExportService.iter_user_interactions()
    • ExportService.iter_wallet_transactions()
    • ExportService.iter_dataset()
    • ExportService.format_as_csv()
    • ExportService.format_as_json()
    • ExportService.format_as_xlsx()
    • ExportService.format_iterator()
    • ExportService.media_type_for()
    • ExportService.filename_for()
• app.services.game_access module
  • can_access_user()
  • get_authorized_user()
  • can_access_game()
  • get_authorized_game()
• app.services.game_params_service module
  • GameParamsService
    • GameParamsService.game_params_repository
    • GameParamsService.__init__()
• app.services.game_service module
  • GameService
    • GameService.game_repository
    • GameService.game_params_repository
    • GameService.task_repository
    • GameService.strategy_service
    • GameService.__init__()
    • GameService.get_by_gameId()
    • GameService.delete_game_by_id()
    • GameService.get_all_games()
    • GameService.get_by_externalId()
    • GameService.create()
    • GameService.duplicate_game()
    • GameService.patch_game_by_externalGameId()
    • GameService.patch_game_by_id()
    • GameService.get_strategy_by_externalGameId()
    • GameService.get_strategy_by_gameId()
    • GameService.get_tasks_by_gameId()
    • GameService.get_game_by_external_id()
• app.services.kpi_metrics_service module
  • KpiMetricsService
    • KpiMetricsService.kpi_metrics_repository
    • KpiMetricsService.__init__()
• app.services.logs_service module
  • LogsService
    • LogsService.logs_repository
    • LogsService.__init__()
• app.services.oauth_users_service module
  • OAuthUsersService
    • OAuthUsersService.oauth_users_repository
    • OAuthUsersService.__init__()
    • OAuthUsersService.get_user_by_sub()
• app.services.rate_limit_counter_backend module
  • RateLimitCounterBackend
    • RateLimitCounterBackend.increment_and_get()
  • DatabaseRateLimitCounterBackend
    • DatabaseRateLimitCounterBackend.increment_and_get()
  • RedisRateLimitCounterBackend
    • RedisRateLimitCounterBackend.increment_and_get()
  • build_redis_client_from_url()
  • build_rate_limit_counter_backend()
• app.services.strategy_definition_service module
  • RollbackResult
  • StrategyDefinitionService
    • StrategyDefinitionService.__init__()
    • StrategyDefinitionService.name_exists()
    • StrategyDefinitionService.list_strategies()
    • StrategyDefinitionService.get_strategy()
    • StrategyDefinitionService.create()
    • StrategyDefinitionService.update()
    • StrategyDefinitionService.publish()
    • StrategyDefinitionService.archive()
    • StrategyDefinitionService.list_versions()
    • StrategyDefinitionService.get_usage()
    • StrategyDefinitionService.rollback()
• app.services.strategy_observability_service module
  • StrategyObservabilityService
    • StrategyObservabilityService.get_metrics()
    • StrategyObservabilityService.compare()
• app.services.strategy_service module
  • is_custom_strategy_id()
  • parse_custom_strategy_id()
  • resolve_realm_id()
  • StrategyService
    • StrategyService.__init__()
    • StrategyService.list_all_strategies()
    • StrategyService.get_strategy_by_id()
    • StrategyService.get_Class_by_id()
    • StrategyService.resolve()
    • StrategyService.get_strategy_instance()
• app.services.task_params_service module
  • TaskParamsService
    • TaskParamsService.task_params_repository
    • TaskParamsService.__init__()
• app.services.task_service module
  • TaskService
    • TaskService.strategy_service
    • TaskService.task_repository
    • TaskService.game_repository
    • TaskService.user_repository
    • TaskService.user_points_repository
    • TaskService.game_params_repository
    • TaskService.task_params_repository
    • TaskService.__init__()
    • TaskService.patch_task_by_id()
    • TaskService.delete_task_by_id()
    • TaskService.duplicate_task()
    • TaskService.get_tasks_list_by_externalGameId()
    • TaskService.get_tasks_list_by_gameId()
    • TaskService.get_task_by_gameId_externalTaskId()
    • TaskService.get_task_by_externalGameId_externalTaskId()
    • TaskService.create_task_by_externalGameId()
    • TaskService.create_task_by_game_id()
    • TaskService.get_task_detail_by_id()
    • TaskService.get_points_by_task_id()
    • TaskService.get_points_of_user_by_task_id()
    • TaskService.get_points_by_task_id_with_details()
    • TaskService.get_task_params_by_externalTaskId()
• app.services.uptime_logs_service module
  • UptimeLogsService
    • UptimeLogsService.uptime_logs_repository
    • UptimeLogsService.__init__()
• app.services.user_actions_service module
  • UserActionsService
    • UserActionsService.user_points_repository
    • UserActionsService.users_repository
    • UserActionsService.game_repository
    • UserActionsService.task_repository
    • UserActionsService.wallet_repository
    • UserActionsService.wallet_transaction_repository
    • UserActionsService.strategy_service
    • UserActionsService.__init__()
    • UserActionsService.user_add_action_in_task()
    • UserActionsService.user_add_action_default()
• app.services.user_game_config_service module
  • UserGameConfigService
    • UserGameConfigService.get_user_config()
    • UserGameConfigService.create_user_config()
    • UserGameConfigService.update_user_config()
    • UserGameConfigService.delete_user_config()
• app.services.user_interactions_service module
  • UserInteractionsService
    • UserInteractionsService.user_interactions_repository
    • UserInteractionsService.__init__()
• app.services.user_points_analytics_service module
  • UserPointsAnalyticsService
    • UserPointsAnalyticsService.count_measurements_by_external_task_id()
    • UserPointsAnalyticsService.get_user_task_measurements_count()
    • UserPointsAnalyticsService.get_user_task_measurements_count_the_last_seconds()
    • UserPointsAnalyticsService.get_avg_time_between_tasks_by_user_and_game_task()
    • UserPointsAnalyticsService.get_avg_time_between_tasks_for_all_users()
    • UserPointsAnalyticsService.get_last_window_time_diff()
    • UserPointsAnalyticsService.get_new_last_window_time_diff()
    • UserPointsAnalyticsService.get_user_task_measurements()
    • UserPointsAnalyticsService.count_personal_records_by_external_game_id()
    • UserPointsAnalyticsService.user_has_record_before_in_externalTaskId_last_min()
    • UserPointsAnalyticsService.get_global_avg_by_external_game_id()
    • UserPointsAnalyticsService.get_personal_avg_by_external_game_id()
• app.services.user_points_service module
  • UserPointsService
• app.services.user_service module
  • UserService
    • UserService.user_repository
    • UserService.user_points_repository
    • UserService.task_repository
    • UserService.wallet_repository
    • UserService.wallet_transaction_repository
    • UserService.__init__()
    • UserService.basic_engagement_points()
    • UserService.performance_penalty_points()
    • UserService.performance_bonus_points()
    • UserService.individual_over_global_points()
    • UserService.need_for_motivation_points()
    • UserService.peak_performer_bonus_points()
    • UserService.global_advantage_adjustment_points()
    • UserService.individual_adjustment_points()
    • UserService.create_user()
    • UserService.assign_points_to_user()
    • UserService.get_wallet_by_user_id()
    • UserService.get_user_by_externalUserId()
    • UserService.get_wallet_by_externalUserId()
    • UserService.get_points_by_user_id()
    • UserService.preview_points_to_coins_conversion()
    • UserService.preview_points_to_coins_conversion_externalUserId()
    • UserService.convert_points_to_coins()
    • UserService.convert_points_to_coins_externalUserId()
• app.services.wallet_service module
  • WalletService
    • WalletService.get_wallet_by_user_id()
    • WalletService.preview_convert()
• app.services.wallet_transaction_service module
  • WalletTransactionService
    • WalletTransactionService.wallet_transaction_repository
    • WalletTransactionService.__init__()