rocksky.app
A decentralized music tracking and discovery platform built on AT Protocol 🎵
rocksky.app
spotify
atproto
lastfm
musicbrainz
scrobbling
listenbrainz
refactor: improve code formatting and update wait time in sync process
tsiry-sandratraina.com
+13
-13
apps/api/src/scripts/sync.ts
+13
-13
apps/api/src/scripts/sync.ts
···
25
equals(
26
createHash("sha256")
27
.update(
28
-
`${track.title} - ${track.artist} - ${track.album}`.toLowerCase(),
29
)
30
-
.digest("hex"),
31
-
),
32
)
33
.getFirst();
34
···
40
equals(
41
createHash("sha256")
42
.update(`${track.album} - ${track.album_artist}`.toLowerCase())
43
-
.digest("hex"),
44
-
),
45
)
46
.getFirst();
47
if (album) {
···
59
equals(
60
createHash("sha256")
61
.update(track.album_artist.toLowerCase())
62
-
.digest("hex"),
63
-
),
64
)
65
.getFirst();
66
if (artist) {
···
76
equals(
77
createHash("sha256")
78
.update(`${track.album} - ${track.album_artist}`.toLowerCase())
79
-
.digest("hex"),
80
-
),
81
)
82
.getFirst();
83
···
89
equals(
90
createHash("sha256")
91
.update(track.album_artist.toLowerCase())
92
-
.digest("hex"),
93
-
),
94
)
95
.getFirst();
96
if (artist) {
···
107
const sub = ctx.nc.subscribe("rocksky.user.scrobble.sync");
108
for await (const m of sub) {
109
const did = new TextDecoder().decode(m.data);
110
-
// wait for 10 seconds to ensure the scrobble is fully created
111
-
await new Promise((resolve) => setTimeout(resolve, 10000));
112
console.log(`Syncing scrobbles ${chalk.magenta(did)} ...`);
113
await updateUris(did);
114
const { records } = await ctx.client.db.scrobbles
···
25
equals(
26
createHash("sha256")
27
.update(
28
+
`${track.title} - ${track.artist} - ${track.album}`.toLowerCase()
29
)
30
+
.digest("hex")
31
+
)
32
)
33
.getFirst();
34
···
40
equals(
41
createHash("sha256")
42
.update(`${track.album} - ${track.album_artist}`.toLowerCase())
43
+
.digest("hex")
44
+
)
45
)
46
.getFirst();
47
if (album) {
···
59
equals(
60
createHash("sha256")
61
.update(track.album_artist.toLowerCase())
62
+
.digest("hex")
63
+
)
64
)
65
.getFirst();
66
if (artist) {
···
76
equals(
77
createHash("sha256")
78
.update(`${track.album} - ${track.album_artist}`.toLowerCase())
79
+
.digest("hex")
80
+
)
81
)
82
.getFirst();
83
···
89
equals(
90
createHash("sha256")
91
.update(track.album_artist.toLowerCase())
92
+
.digest("hex")
93
+
)
94
)
95
.getFirst();
96
if (artist) {
···
107
const sub = ctx.nc.subscribe("rocksky.user.scrobble.sync");
108
for await (const m of sub) {
109
const did = new TextDecoder().decode(m.data);
110
+
// wait for 15 seconds to ensure the scrobble is fully created
111
+
await new Promise((resolve) => setTimeout(resolve, 15000));
112
console.log(`Syncing scrobbles ${chalk.magenta(did)} ...`);
113
await updateUris(did);
114
const { records } = await ctx.client.db.scrobbles