diff --git a/meilisearch-http/Cargo.toml b/meilisearch-http/Cargo.toml index 0a248f702..74b3f3ad8 100644 --- a/meilisearch-http/Cargo.toml +++ b/meilisearch-http/Cargo.toml @@ -57,6 +57,7 @@ platform-dirs = "0.3.0" rand = "0.8.5" rayon = "1.5.1" regex = "1.5.5" +reqwest = { version = "0.11.9", features = ["rustls-tls"], default-features = false, optional = true } rustls = "0.20.4" rustls-pemfile = "0.3.0" segment = { version = "0.2.0", optional = true } diff --git a/meilisearch-http/src/analytics/segment_analytics.rs b/meilisearch-http/src/analytics/segment_analytics.rs index 3d3b23d70..b13bcd6bb 100644 --- a/meilisearch-http/src/analytics/segment_analytics.rs +++ b/meilisearch-http/src/analytics/segment_analytics.rs @@ -78,7 +78,15 @@ impl SegmentAnalytics { let user_id = user_id.unwrap_or_else(|| Uuid::new_v4().to_string()); write_user_id(&opt.db_path, &user_id); - let client = HttpClient::default(); + + let reqwest_client = reqwest::Client::builder() + .connect_timeout(Duration::new(10, 0)) + .build() + // this unwrap can't fail + .unwrap(); + + // let client = HttpClient::new(reqwest_client, "https://analytics.meilisearch.com/".to_string()); + let client = HttpClient::new(reqwest_client, "https://api.segment.io/".to_string()); let user = User::UserId { user_id }; let mut batcher = AutoBatcher::new(client, Batcher::new(None), SEGMENT_API_KEY.to_string()); @@ -259,7 +267,7 @@ impl Segment { } async fn run(mut self, meilisearch: MeiliSearch) { - const INTERVAL: Duration = Duration::from_secs(60 * 60); // one hour + const INTERVAL: Duration = Duration::from_secs(30); // one hour // The first batch must be sent after one hour. let mut interval = tokio::time::interval_at(tokio::time::Instant::now() + INTERVAL, INTERVAL); @@ -284,6 +292,7 @@ impl Segment { } async fn tick(&mut self, meilisearch: MeiliSearch) { + println!("TRYING TO SEND SOMETHING"); if let Ok(stats) = meilisearch.get_all_stats(&SearchRules::default()).await { let _ = self .batcher