diff --git a/crates/analytics/src/subscriber/mod.rs b/crates/analytics/src/subscriber/mod.rs index 48647def..cf0b3cc3 100644 --- a/crates/analytics/src/subscriber/mod.rs +++ b/crates/analytics/src/subscriber/mod.rs @@ -503,7 +503,7 @@ pub async fn save_scrobble(conn: Arc>, payload: ScrobblePayloa payload.scrobble.album_id.xata_id, payload.scrobble.artist_id.xata_id, payload.scrobble.uri, - payload.scrobble.xata_createdat, + payload.scrobble.timestamp, ], ) { Ok(_) => (), diff --git a/crates/analytics/src/subscriber/types.rs b/crates/analytics/src/subscriber/types.rs index 6d640b37..bf3ca9de 100644 --- a/crates/analytics/src/subscriber/types.rs +++ b/crates/analytics/src/subscriber/types.rs @@ -91,6 +91,7 @@ pub struct Scrobble { pub track_id: TrackId, pub uri: String, pub user_id: UserId, + pub timestamp: DateTime, pub xata_createdat: DateTime, pub xata_id: String, pub xata_updatedat: DateTime, diff --git a/crates/analytics/src/xata/scrobble.rs b/crates/analytics/src/xata/scrobble.rs index 3ca5f387..ba574762 100644 --- a/crates/analytics/src/xata/scrobble.rs +++ b/crates/analytics/src/xata/scrobble.rs @@ -11,4 +11,6 @@ pub struct Scrobble { pub uri: Option, #[serde(with = "chrono::serde::ts_seconds")] pub xata_createdat: DateTime, + #[serde(with = "chrono::serde::ts_seconds")] + pub timestamp: DateTime, }