WIP

crates/meilisearch/src/routes/indexes/compact.rs

@@ -5,11 +5,12 @@ use meilisearch_types::error::ResponseError;
 use meilisearch_types::index_uid::IndexUid;
 use meilisearch_types::keys::actions;
 use meilisearch_types::tasks::KindWithContent;
+use serde::Serialize;
 use tracing::debug;
 use utoipa::OpenApi;
 
 use super::ActionPolicy;
-use crate::analytics::Analytics;
+use crate::analytics::{Aggregate, Analytics};
 use crate::extractors::authentication::GuardedData;
 use crate::extractors::sequential_extractor::SeqHandler;
 use crate::routes::SummarizedTaskView;
@@ -66,7 +67,7 @@ pub async fn compact(
 ) -> Result<HttpResponse, ResponseError> {
     let index_uid = IndexUid::try_from(index_uid.into_inner())?;
 
-    analytics.publish(IndexCompacted::default(), &req);
+    analytics.publish(IndexesCompactAggregator, &req);
 
     let task = KindWithContent::IndexCompaction { index_uid: index_uid.to_string() };
     let task =
@@ -81,4 +82,19 @@ pub async fn compact(
     Ok(HttpResponse::Accepted().json(SummarizedTaskView::from(task)))
 }
 
-crate::empty_analytics!(IndexCompacted, "Index Compacted");
+#[derive(Serialize)]
+pub struct IndexesCompactAggregator;
+
+impl Aggregate for IndexesCompactAggregator {
+    fn event_name(&self) -> &'static str {
+        "Indexes Compacted"
+    }
+
+    fn aggregate(self: Box<Self>, _new: Box<Self>) -> Box<Self> {
+        Box::new(Self)
+    }
+
+    fn into_event(self: Box<Self>) -> serde_json::Value {
+        serde_json::to_value(*self).unwrap_or_default()
+    }
+}