snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-06-13 15:37:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

add analytics on the task route

Browse Source 
* Add all the missing fields of the new task query type
* Create a new analytics for the task deletion
* Create a new analytics for the task creation
This commit is contained in:
Tamo 2022-11-16 16:08:21 +01:00
parent 637ca7b9fa
commit 0e6394fafc
No known key found for this signature in database
GPG Key ID: 20CD8020AFA88D69
1 changed files with 51 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
meilisearch-http/src/routes/tasks.rs
View File

@ -442,8 +442,9 @@ pub struct TaskDeletionOrCancelationQuery {
async fn cancel_tasks( async fn cancel_tasks(
index_scheduler: GuardedData<ActionPolicy<{ actions::TASKS_CANCEL }>, Data<IndexScheduler>>, index_scheduler: GuardedData<ActionPolicy<{ actions::TASKS_CANCEL }>, Data<IndexScheduler>>,
req: HttpRequest,
params: web::Query<TaskDeletionOrCancelationQueryRaw>, params: web::Query<TaskDeletionOrCancelationQueryRaw>,
req: HttpRequest,
analytics: web::Data<dyn Analytics>,
) -> Result<HttpResponse, ResponseError> { ) -> Result<HttpResponse, ResponseError> {
let query = params.into_inner().validate()?; let query = params.into_inner().validate()?;
let TaskDeletionOrCancelationQuery { let TaskDeletionOrCancelationQuery {
@ -459,6 +460,24 @@ async fn cancel_tasks(
}, },
} = query; } = query;
analytics.publish(
"Tasks Canceled".to_string(),
json!({
"filtered_by_uid": uids.is_some(),
"filtered_by_index_uid": index_uids.is_some(),
"filtered_by_type": types.is_some(),
"filtered_by_status": statuses.is_some(),
"filtered_by_canceled_by": canceled_by.is_some(),
"filtered_by_before_enqueued_at": before_enqueued_at.is_some(),
"filtered_by_after_enqueued_at": after_enqueued_at.is_some(),
"filtered_by_before_started_at": before_started_at.is_some(),
"filtered_by_after_started_at": after_started_at.is_some(),
"filtered_by_before_finished_at": before_finished_at.is_some(),
"filtered_by_after_finished_at": after_finished_at.is_some(),
}),
Some(&req),
);
let query = Query { let query = Query {
limit: None, limit: None,
from: None, from: None,
@ -495,8 +514,9 @@ async fn cancel_tasks(
async fn delete_tasks( async fn delete_tasks(
index_scheduler: GuardedData<ActionPolicy<{ actions::TASKS_DELETE }>, Data<IndexScheduler>>, index_scheduler: GuardedData<ActionPolicy<{ actions::TASKS_DELETE }>, Data<IndexScheduler>>,
req: HttpRequest,
params: web::Query<TaskDeletionOrCancelationQueryRaw>, params: web::Query<TaskDeletionOrCancelationQueryRaw>,
req: HttpRequest,
analytics: web::Data<dyn Analytics>,
) -> Result<HttpResponse, ResponseError> { ) -> Result<HttpResponse, ResponseError> {
let TaskDeletionOrCancelationQuery { let TaskDeletionOrCancelationQuery {
common: TaskCommonQuery { types, uids, canceled_by, statuses, index_uids }, common: TaskCommonQuery { types, uids, canceled_by, statuses, index_uids },
@ -511,6 +531,24 @@ async fn delete_tasks(
}, },
} = params.into_inner().validate()?; } = params.into_inner().validate()?;
analytics.publish(
"Tasks Deleted".to_string(),
json!({
"filtered_by_uid": uids.is_some(),
"filtered_by_index_uid": index_uids.is_some(),
"filtered_by_type": types.is_some(),
"filtered_by_status": statuses.is_some(),
"filtered_by_canceled_by": canceled_by.is_some(),
"filtered_by_before_enqueued_at": before_enqueued_at.is_some(),
"filtered_by_after_enqueued_at": after_enqueued_at.is_some(),
"filtered_by_before_started_at": before_started_at.is_some(),
"filtered_by_after_started_at": after_started_at.is_some(),
"filtered_by_before_finished_at": before_finished_at.is_some(),
"filtered_by_after_finished_at": after_finished_at.is_some(),
}),
Some(&req),
);
let query = Query { let query = Query {
limit: None, limit: None,
from: None, from: None,
@ -577,9 +615,17 @@ async fn get_tasks(
analytics.publish( analytics.publish(
"Tasks Seen".to_string(), "Tasks Seen".to_string(),
json!({ json!({
"filtered_by_index_uid": index_uids.as_ref().map_or(false, |v| !v.is_empty()), "filtered_by_uid": uids.is_some(),
"filtered_by_type": types.as_ref().map_or(false, |v| !v.is_empty()), "filtered_by_index_uid": index_uids.is_some(),
"filtered_by_status": statuses.as_ref().map_or(false, |v| !v.is_empty()), "filtered_by_type": types.is_some(),
"filtered_by_status": statuses.is_some(),
"filtered_by_canceled_by": canceled_by.is_some(),
"filtered_by_before_enqueued_at": before_enqueued_at.is_some(),
"filtered_by_after_enqueued_at": after_enqueued_at.is_some(),
"filtered_by_before_started_at": before_started_at.is_some(),
"filtered_by_after_started_at": after_started_at.is_some(),
"filtered_by_before_finished_at": before_finished_at.is_some(),
"filtered_by_after_finished_at": after_finished_at.is_some(),
}), }),
Some(&req), Some(&req),
); );