58 lines
1.7 KiB
Rust
58 lines
1.7 KiB
Rust
|
use crate::config::analytics_token;
|
||
|
|
use chrono::Datelike;
|
||
|
|
use chrono::Timelike;
|
||
|
|
use reqwest::header::{ACCEPT, CONTENT_TYPE};
|
||
|
|
use serde_json::{json, Value};
|
||
|
|
use std::{
|
||
|
|
env,
|
||
|
|
time::{SystemTime, UNIX_EPOCH},
|
||
|
|
};
|
||
|
|
|
||
|
|
pub fn track(
|
||
|
|
event_name: String,
|
||
|
|
description: String,
|
||
|
|
ws_addr_string: &str,
|
||
|
|
event_properties: Value,
|
||
|
|
) {
|
||
|
|
println!("{}", description);
|
||
|
|
|
||
|
|
let token = analytics_token(ws_addr_string);
|
||
|
|
if token.is_empty() {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
let local_now = chrono::offset::Local::now();
|
||
|
|
let mut properties = json!({
|
||
|
|
"token": token,
|
||
|
|
"time": SystemTime::now().duration_since(UNIX_EPOCH).unwrap().as_millis(),
|
||
|
|
"distinct_id": event_properties["prover_id"],
|
||
|
|
"prover_type": "volunteer",
|
||
|
|
"client_type": "cli",
|
||
|
|
"operating_system": env::consts::OS,
|
||
|
|
"time_zone": iana_time_zone::get_timezone().unwrap(),
|
||
|
|
"local_hour": local_now.hour(),
|
||
|
|
"local_weekday_number_from_monday": local_now.weekday().number_from_monday(),
|
||
|
|
"ws_addr_string": ws_addr_string,
|
||
|
|
});
|
||
|
|
for (k, v) in event_properties.as_object().unwrap() {
|
||
|
|
properties[k] = v.clone();
|
||
|
|
}
|
||
|
|
let body = json!({
|
||
|
|
"event": event_name,
|
||
|
|
"properties": properties
|
||
|
|
});
|
||
|
|
tokio::spawn(async move {
|
||
|
|
let client = reqwest::Client::new();
|
||
|
|
let _ = client
|
||
|
|
.post("https://api.mixpanel.com/track?ip=1")
|
||
|
|
.body(format!("[{}]", body.to_string()))
|
||
|
|
.header(ACCEPT, "text/plain")
|
||
|
|
.header(CONTENT_TYPE, "application/json")
|
||
|
|
.send()
|
||
|
|
.await
|
||
|
|
.unwrap()
|
||
|
|
.text()
|
||
|
|
.await
|
||
|
|
.unwrap();
|
||
|
|
});
|
||
|
|
}
|