tangled
alpha
login
or
join now
rocksky.app
/
rocksky
96
fork
atom
A decentralized music tracking and discovery platform built on AT Protocol 🎵
rocksky.app
spotify
atproto
lastfm
musicbrainz
scrobbling
listenbrainz
96
fork
atom
overview
issues
7
pulls
pipelines
Increase Rocksky request timeouts to 120s
tsiry-sandratraina.com
2 months ago
dddf410d
be154ef2
+12
-12
12 changed files
expand all
collapse all
unified
split
apps
api
src
xrpc
app
rocksky
actor
getActorAlbums.ts
getActorArtists.ts
getActorLovedSongs.ts
getActorPlaylists.ts
getActorScrobbles.ts
getActorSongs.ts
getProfile.ts
album
getAlbum.ts
getAlbumTracks.ts
getAlbums.ts
charts
getScrobblesChart.ts
feed
getNowPlayings.ts
+1
-1
apps/api/src/xrpc/app/rocksky/actor/getActorAlbums.ts
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
-
Effect.timeout("10 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ artists: [] });
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
+
Effect.timeout("120 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ artists: [] });
+1
-1
apps/api/src/xrpc/app/rocksky/actor/getActorArtists.ts
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
-
Effect.timeout("10 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ artists: [] });
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
+
Effect.timeout("120 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ artists: [] });
+1
-1
apps/api/src/xrpc/app/rocksky/actor/getActorLovedSongs.ts
···
14
retrieve,
15
Effect.flatMap(presentation),
16
Effect.retry({ times: 3 }),
17
-
Effect.timeout("10 seconds"),
18
Effect.catchAll((err) => {
19
console.error(err);
20
return Effect.succeed({ tracks: [] });
···
14
retrieve,
15
Effect.flatMap(presentation),
16
Effect.retry({ times: 3 }),
17
+
Effect.timeout("120 seconds"),
18
Effect.catchAll((err) => {
19
console.error(err);
20
return Effect.succeed({ tracks: [] });
+1
-1
apps/api/src/xrpc/app/rocksky/actor/getActorPlaylists.ts
···
14
retrieve,
15
Effect.flatMap(presentation),
16
Effect.retry({ times: 3 }),
17
-
Effect.timeout("10 seconds"),
18
Effect.catchAll((err) => {
19
console.error(err);
20
return Effect.succeed({ playlists: [] });
···
14
retrieve,
15
Effect.flatMap(presentation),
16
Effect.retry({ times: 3 }),
17
+
Effect.timeout("120 seconds"),
18
Effect.catchAll((err) => {
19
console.error(err);
20
return Effect.succeed({ playlists: [] });
+1
-1
apps/api/src/xrpc/app/rocksky/actor/getActorScrobbles.ts
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
-
Effect.timeout("10 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ scrobbles: [] });
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
+
Effect.timeout("120 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ scrobbles: [] });
+1
-1
apps/api/src/xrpc/app/rocksky/actor/getActorSongs.ts
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
-
Effect.timeout("10 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ tracks: [] });
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
+
Effect.timeout("120 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ tracks: [] });
+1
-1
apps/api/src/xrpc/app/rocksky/actor/getProfile.ts
···
29
Effect.flatMap(refreshProfile),
30
Effect.flatMap(presentation),
31
Effect.retry({ times: 3 }),
32
-
Effect.timeout("10 seconds"),
33
Effect.catchAll((err) => {
34
console.error(err);
35
return Effect.succeed({});
···
29
Effect.flatMap(refreshProfile),
30
Effect.flatMap(presentation),
31
Effect.retry({ times: 3 }),
32
+
Effect.timeout("120 seconds"),
33
Effect.catchAll((err) => {
34
console.error(err);
35
return Effect.succeed({});
+1
-1
apps/api/src/xrpc/app/rocksky/album/getAlbum.ts
···
17
retrieve,
18
Effect.flatMap(presentation),
19
Effect.retry({ times: 3 }),
20
-
Effect.timeout("10 seconds"),
21
Effect.catchAll((err) => {
22
console.error(err);
23
return Effect.succeed({});
···
17
retrieve,
18
Effect.flatMap(presentation),
19
Effect.retry({ times: 3 }),
20
+
Effect.timeout("120 seconds"),
21
Effect.catchAll((err) => {
22
console.error(err);
23
return Effect.succeed({});
+1
-1
apps/api/src/xrpc/app/rocksky/album/getAlbumTracks.ts
···
15
retrieve,
16
Effect.flatMap(presentation),
17
Effect.retry({ times: 3 }),
18
-
Effect.timeout("10 seconds"),
19
Effect.catchAll((err) => {
20
console.error(err);
21
return Effect.succeed({});
···
15
retrieve,
16
Effect.flatMap(presentation),
17
Effect.retry({ times: 3 }),
18
+
Effect.timeout("120 seconds"),
19
Effect.catchAll((err) => {
20
console.error(err);
21
return Effect.succeed({});
+1
-1
apps/api/src/xrpc/app/rocksky/album/getAlbums.ts
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
-
Effect.timeout("10 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ albums: [] });
···
12
retrieve,
13
Effect.flatMap(presentation),
14
Effect.retry({ times: 3 }),
15
+
Effect.timeout("120 seconds"),
16
Effect.catchAll((err) => {
17
console.error(err);
18
return Effect.succeed({ albums: [] });
+1
-1
apps/api/src/xrpc/app/rocksky/charts/getScrobblesChart.ts
···
16
retrieve,
17
Effect.flatMap(presentation),
18
Effect.retry({ times: 3 }),
19
-
Effect.timeout("10 seconds"),
20
),
21
});
22
···
16
retrieve,
17
Effect.flatMap(presentation),
18
Effect.retry({ times: 3 }),
19
+
Effect.timeout("120 seconds"),
20
),
21
});
22
+1
-1
apps/api/src/xrpc/app/rocksky/feed/getNowPlayings.ts
···
15
retrieve,
16
Effect.flatMap(presentation),
17
Effect.retry({ times: 3 }),
18
-
Effect.timeout("10 seconds"),
19
),
20
});
21
···
15
retrieve,
16
Effect.flatMap(presentation),
17
Effect.retry({ times: 3 }),
18
+
Effect.timeout("120 seconds"),
19
),
20
});
21