From b9f8fc99f56543426a7b4d5092df4939708dc7b6 Mon Sep 17 00:00:00 2001
From: Kavin <20838718+FireMasterK@users.noreply.github.com>
Date: Mon, 5 Jun 2023 23:44:05 +0100
Subject: [PATCH] Add sentry videoId information to pubsub webhook.

---
 src/main/java/me/kavin/piped/server/ServerLauncher.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/main/java/me/kavin/piped/server/ServerLauncher.java b/src/main/java/me/kavin/piped/server/ServerLauncher.java
index f7f48e9..25ef627 100644
--- a/src/main/java/me/kavin/piped/server/ServerLauncher.java
+++ b/src/main/java/me/kavin/piped/server/ServerLauncher.java
@@ -10,6 +10,7 @@ import io.activej.inject.annotation.Provides;
 import io.activej.inject.module.AbstractModule;
 import io.activej.inject.module.Module;
 import io.activej.launchers.http.MultithreadedHttpServerLauncher;
+import io.sentry.Sentry;
 import it.unimi.dsi.fastutil.objects.ObjectArrayList;
 import me.kavin.piped.consts.Constants;
 import me.kavin.piped.server.handlers.*;
@@ -87,12 +88,14 @@ public class ServerLauncher extends MultithreadedHttpServerLauncher {
                         Multithreading.runAsync(() -> {
                             for (var entry : feed.getEntries()) {
                                 String url = entry.getLinks().get(0).getHref();
+                                String videoId = StringUtils.substring(url, -11);
                                 try (StatelessSession s = DatabaseSessionFactory.createStatelessSession()) {
-                                    if (DatabaseHelper.doesVideoExist(s, StringUtils.substring(url, -11)))
+                                    if (DatabaseHelper.doesVideoExist(s, videoId))
                                         continue;
                                 }
                                 Multithreading.runAsync(() -> {
                                     try {
+                                        Sentry.setExtra("videoId", videoId);
                                         StreamInfo info = StreamInfo.getInfo(url);
 
                                         Multithreading.runAsync(() -> {