kamma/xtream-player
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix4

Browse Source
This commit is contained in:
Radek Davidek 2026-03-04 14:32:42 +01:00
parent 4ea3d96496
commit de7d38c596
1 changed files with 36 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/cz/kamma/xtreamplayer/XtreamPlayerApplication.java
View File

@ -248,7 +248,9 @@ public final class XtreamPlayerApplication {
List<URI> attempts = candidateUris(target); List<URI> attempts = candidateUris(target);
HttpResponse<byte[]> response = null; HttpResponse<byte[]> response = null;
URI usedTarget = target; URI usedTarget = target;
List<String> attemptErrors = new ArrayList<>();
for (URI candidate : attempts) { for (URI candidate : attempts) {
try {
HttpRequest.Builder requestBuilder = HttpRequest.newBuilder(candidate) HttpRequest.Builder requestBuilder = HttpRequest.newBuilder(candidate)
.GET() .GET()
.timeout(Duration.ofSeconds(60)) .timeout(Duration.ofSeconds(60))
@ -271,14 +273,22 @@ public final class XtreamPlayerApplication {
} }
HttpRequest request = requestBuilder.build(); HttpRequest request = requestBuilder.build();
HttpResponse<byte[]> candidateResponse = HTTP_CLIENT.send(request, HttpResponse.BodyHandlers.ofByteArray()); HttpResponse<byte[]> candidateResponse = HTTP_CLIENT.send(request, HttpResponse.BodyHandlers.ofByteArray());
if (response == null || response.statusCode() >= 400) {
response = candidateResponse; response = candidateResponse;
usedTarget = candidate; usedTarget = candidate;
}
if (candidateResponse.statusCode() < 400) { if (candidateResponse.statusCode() < 400) {
response = candidateResponse;
usedTarget = candidate;
break; break;
} }
} catch (Exception candidateException) {
attemptErrors.add(maskUri(candidate) + " -> " + compactError(candidateException));
LOGGER.warn("Stream proxy candidate failed uri={}", maskUri(candidate), candidateException);
}
} }
if (response == null) { if (response == null) {
writeJson(exchange, 502, errorJson("Unable to proxy stream: empty upstream response.")); writeJson(exchange, 502, errorJson("Unable to proxy stream. Attempts: " + String.join(" | ", attemptErrors)));
return; return;
} }
String contentType = response.headers().firstValue("Content-Type").orElse("application/octet-stream"); String contentType = response.headers().firstValue("Content-Type").orElse("application/octet-stream");