TeamPiped-mirror/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2024-08-14 23:51:41 +00:00
Code Issues Projects Releases Packages Wiki Activity

Add timeout for LBRY calls.

Browse source
This commit is contained in:
FireMaskterK 2021-10-12 11:44:21 +01:00
parent 022a0af007
commit 1c1dd05455
No known key found for this signature in database
GPG key ID: 49451E4482CC5BCD
1 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/main/java/me/kavin/piped/utils/ResponseHelper.java
View file

@ -148,7 +148,13 @@ public class ResponseHelper {
final List<PipedStream> videoStreams = new ObjectArrayList<>(); final List<PipedStream> videoStreams = new ObjectArrayList<>();
final List<PipedStream> audioStreams = new ObjectArrayList<>(); final List<PipedStream> audioStreams = new ObjectArrayList<>();
final String lbryURL = futureLBRY.get(); String lbryURL = null;
try {
lbryURL = futureLBRY.get(3, TimeUnit.SECONDS);
} catch (Exception e) {
// ignored
}
if (lbryURL != null) if (lbryURL != null)
videoStreams.add(new PipedStream(lbryURL, "MP4", "LBRY", "video/mp4", false)); videoStreams.add(new PipedStream(lbryURL, "MP4", "LBRY", "video/mp4", false));
@ -942,7 +948,12 @@ public class ResponseHelper {
private static final String getLBRYStreamURL(CompletableFuture<String> futureLbryId) private static final String getLBRYStreamURL(CompletableFuture<String> futureLbryId)
throws IOException, InterruptedException, ExecutionException { throws IOException, InterruptedException, ExecutionException {
String lbryId = futureLbryId.get(); String lbryId = "";
try {
lbryId = futureLbryId.get(2, TimeUnit.SECONDS);
} catch (Exception e) {
// ignored
}
if (!lbryId.isEmpty()) if (!lbryId.isEmpty())
return new JSONObject( return new JSONObject(