app.services.user_points_analytics_service module

Analytics service for user points.

Aggregations, temporal queries and metrics over user_points records. Extracted from UserPointsService so CRUD/write paths and analytic queries have separate, focused services.

These methods are thin pass-throughs over UserPointsRepository analytics queries; they are consumed primarily by strategy engines (app/engine) to compute rewards based on historical user behaviour.

class app.services.user_points_analytics_service.UserPointsAnalyticsService(user_points_repository)

Bases: BaseService

Parameters:

user_points_repository (UserPointsRepository)

async count_measurements_by_external_task_id(external_task_id)

Count all points rows recorded for an external task.

Return type:

Any

async get_user_task_measurements_count(externalTaskId, externalUserId)

Count a user’s awards on a given external task.

Return type:

Any

async get_user_task_measurements_count_the_last_seconds(externalTaskId, externalUserId, seconds)

Count a user’s awards on a task within the last seconds.

Return type:

Any

async get_avg_time_between_tasks_by_user_and_game_task(externalGameId, externalTaskId, externalUserId)

Average seconds between a user’s consecutive awards on a task (-1 with fewer than two awards).

Return type:

Any

async get_avg_time_between_tasks_for_all_users(externalGameId, externalTaskId)

Average seconds between consecutive awards on a task across all users (-1 with fewer than two awards).

Return type:

Any

async get_last_window_time_diff(externalTaskId, externalUserId)

Seconds between a user’s two most recent awards on a task.

Return type:

Any

async get_new_last_window_time_diff(externalTaskId, externalUserId, externalGameId)

Seconds elapsed since a user’s most recent award on a task.

Return type:

Any

async get_user_task_measurements(externalTaskId, externalUserId)

Return the ordered timestamps of a user’s awards on a task.

Return type:

Any

async count_personal_records_by_external_game_id(external_game_id, externalUserId)

Count the number of records for a user in a game.

Return type:

Any

async user_has_record_before_in_externalTaskId_last_min(externalTaskId, externalUserId, minutes)

Check if a user has a record in the task in the last minutes minutes.

Return type:

Any

async get_global_avg_by_external_game_id(external_game_id)

Get the global average time rewarded. Ignores entries with 0 minutes.

Return type:

Any

async get_personal_avg_by_external_game_id(external_game_id, externalUserId)

Get the personal average time rewarded. Ignores entries with 0 minutes.

Return type:

Any