t1c.dev / rocksky
forked from rocksky.app/rocksky
A decentralized music tracking and discovery platform built on AT Protocol 🎵
fork atom

fix: standardize "sha_256" to "sha256" in scrobble publishing and track saving

tsiry-sandratraina.com 6b0c0a4b 95f1e758

+15 -4
unified split
+11 -3
apps/api/src/nowplaying/nowplaying.service.ts
··· 335 335 album_id: { 336 336 ...scrobble.album, 337 337 xata_id: scrobble.album.id, 338 + createdAt: scrobble.album.createdAt.toISOString(), 339 + updatedAt: scrobble.album.updatedAt.toISOString(), 338 340 xata_createdat: scrobble.album.createdAt.toISOString(), 339 341 xata_updatedat: scrobble.album.updatedAt.toISOString(), 340 342 }, 341 343 artist_id: { 342 344 ...scrobble.artist, 343 345 xata_id: scrobble.artist.id, 346 + createdAt: scrobble.artist.createdAt.toISOString(), 347 + updatedAt: scrobble.artist.updatedAt.toISOString(), 344 348 xata_createdat: scrobble.artist.createdAt.toISOString(), 345 349 xata_updatedat: scrobble.artist.updatedAt.toISOString(), 346 350 }, 347 351 track_id: { 348 352 ...scrobble.track, 349 353 xata_id: scrobble.track.id, 354 + createdAt: scrobble.track.createdAt.toISOString(), 355 + updatedAt: scrobble.track.updatedAt.toISOString(), 350 356 xata_createdat: scrobble.track.createdAt.toISOString(), 351 357 xata_updatedat: scrobble.track.updatedAt.toISOString(), 352 358 }, 353 359 user_id: { 354 360 ...scrobble.user, 355 361 xata_id: scrobble.user.id, 362 + createdAt: scrobble.user.createdAt.toISOString(), 363 + updatedAt: scrobble.user.updatedAt.toISOString(), 356 364 xata_createdat: scrobble.user.createdAt.toISOString(), 357 365 xata_updatedat: scrobble.user.updatedAt.toISOString(), 358 366 }, 359 367 xata_id: scrobble.scrobble.id, 360 368 xata_createdat: scrobble.scrobble.createdAt.toISOString(), 361 369 xata_updatedat: scrobble.scrobble.updatedAt.toISOString(), 370 + timestamp: scrobble.scrobble.timestamp 371 + ? scrobble.scrobble.timestamp.toISOString() 372 + : scrobble.scrobble.createdAt.toISOString(), 362 373 }, 363 374 user_album: { 364 375 ...user_album, ··· 436 447 null, 437 448 2 438 449 ); 439 - 440 - console.log("Publishing scrobble to NATS"); 441 - console.log(message.replaceAll("sha_256", "sha256")); 442 450 443 451 ctx.nc.publish( 444 452 "rocksky.scrobble",
+4 -1
apps/api/src/tracks/tracks.service.ts
··· 267 267 }) 268 268 ); 269 269 270 - ctx.nc.publish("rocksky.track", Buffer.from(message)); 270 + ctx.nc.publish( 271 + "rocksky.track", 272 + Buffer.from(message.replaceAll("sha_256", "sha256")) 273 + ); 271 274 break; 272 275 } 273 276