From c638f2cceca48fa1c66f52861c8df7abf7660c95 Mon Sep 17 00:00:00 2001
From: Tsiry Sandratraina <tsiry.sndr@fluentci.io>
Date: Mon, 14 Apr 2025 00:01:40 +0300
Subject: [PATCH] [analytics] use scrobble timestamp new field instead of
 xata_createdat

---
 crates/analytics/src/subscriber/mod.rs   | 2 +-
 crates/analytics/src/subscriber/types.rs | 1 +
 crates/analytics/src/xata/scrobble.rs    | 2 ++
 3 files changed, 4 insertions(+), 1 deletion(-)

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<Mutex<Connection>>, 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<Utc>,
     pub xata_createdat: DateTime<Utc>,
     pub xata_id: String,
     pub xata_updatedat: DateTime<Utc>,
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<String>,
     #[serde(with = "chrono::serde::ts_seconds")]
     pub xata_createdat: DateTime<Utc>,
+    #[serde(with = "chrono::serde::ts_seconds")]
+    pub timestamp: DateTime<Utc>,
 }
-- 
2.51.2