[analytics] use scrobble timestamp new field instead of xata_createdat

rocksky.app / rocksky

fork atom

A decentralized music tracking and discovery platform built on AT Protocol 🎵 rocksky.app

spotify atproto lastfm musicbrainz scrobbling listenbrainz

fork atom

[analytics] use scrobble timestamp new field instead of xata_createdat

tsiry-sandratraina.com 11 months ago c638f2cc 1db30c23

+4 -1

3 changed files

expand all

unified split

crates

analytics

src

subscriber

mod.rs

types.rs

xata

scrobble.rs

+1 -1

crates/analytics/src/subscriber/mod.rs

··· 503 payload.scrobble.album_id.xata_id, 504 payload.scrobble.artist_id.xata_id, 505 payload.scrobble.uri, 506 - payload.scrobble.xata_createdat, 507 ], 508 ) { 509 Ok(_) => (),

··· 503 payload.scrobble.album_id.xata_id, 504 payload.scrobble.artist_id.xata_id, 505 payload.scrobble.uri, 506 + payload.scrobble.timestamp, 507 ], 508 ) { 509 Ok(_) => (),

crates/analytics/src/subscriber/types.rs

··· 91 pub track_id: TrackId, 92 pub uri: String, 93 pub user_id: UserId, 94 pub xata_createdat: DateTime<Utc>, 95 pub xata_id: String, 96 pub xata_updatedat: DateTime<Utc>,

··· 91 pub track_id: TrackId, 92 pub uri: String, 93 pub user_id: UserId, 94 + pub timestamp: DateTime<Utc>, 95 pub xata_createdat: DateTime<Utc>, 96 pub xata_id: String, 97 pub xata_updatedat: DateTime<Utc>,

crates/analytics/src/xata/scrobble.rs

··· 11 pub uri: Option<String>, 12 #[serde(with = "chrono::serde::ts_seconds")] 13 pub xata_createdat: DateTime<Utc>, 14 }

··· 11 pub uri: Option<String>, 12 #[serde(with = "chrono::serde::ts_seconds")] 13 pub xata_createdat: DateTime<Utc>, 14 + #[serde(with = "chrono::serde::ts_seconds")] 15 + pub timestamp: DateTime<Utc>, 16 }