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

Merge pull request #413 from TeamPiped/sentry-tracing

Browse source 
Ignore ErrorResponse and implement tracing.
This commit is contained in:
Kavin 2022-10-30 22:27:50 +00:00 committed by GitHub
commit fa1b3163d4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 17 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/main/java/me/kavin/piped/Main.java
View file

@ -29,7 +29,12 @@ public class Main {
YoutubeStreamExtractor.forceFetchAndroidClient(true);
YoutubeStreamExtractor.forceFetchIosClient(true);
Sentry.init(Constants.SENTRY_DSN);
Sentry.init(options -> {
options.setDsn(Constants.SENTRY_DSN);
options.setRelease(Constants.VERSION);
options.addIgnoredExceptionForType(ErrorResponse.class);
options.setTracesSampleRate(0.1);
});
Injector.useSpecializer();

11
src/main/java/me/kavin/piped/server/handlers/StreamHandlers.java
View file

@ -3,6 +3,8 @@ package me.kavin.piped.server.handlers;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.grack.nanojson.JsonObject;
import com.grack.nanojson.JsonWriter;
import io.sentry.ITransaction;
import io.sentry.Sentry;
import it.unimi.dsi.fastutil.objects.ObjectArrayList;
import me.kavin.piped.consts.Constants;
import me.kavin.piped.utils.*;
@ -36,6 +38,7 @@ public class StreamHandlers {
public static byte[] streamsResponse(String videoId) throws Exception {
final var futureStream = Multithreading.supplyAsync(() -> {
ITransaction transaction = Sentry.startTransaction("StreamInfo fetch", "fetch");
try {
return StreamInfo.getInfo("https://www.youtube.com/watch?v=" + videoId);
} catch (Exception e) {
@ -54,21 +57,29 @@ public class StreamHandlers {
});
final var futureLBRY = Multithreading.supplyAsync(() -> {
ITransaction transaction = Sentry.startTransaction("LBRY Stream fetch", "fetch");
try {
var childTask = transaction.startChild("fetch", "LBRY ID fetch");
String lbryId = futureLbryId.get(2, TimeUnit.SECONDS);
childTask.finish();
return LbryHelper.getLBRYStreamURL(lbryId);
} catch (Exception e) {
ExceptionHandler.handle(e);
} finally {
transaction.finish();
}
return null;
});
final var futureDislikeRating = Multithreading.supplyAsync(() -> {
ITransaction transaction = Sentry.startTransaction("Dislike Rating", "fetch");
try {
return RydHelper.getDislikeRating(videoId);
} catch (Exception e) {
ExceptionHandler.handle(e);
} finally {
transaction.finish();
}
return null;
});