From cf9d1cd8cf53cc579ed17740ee953cab961f8a52 Mon Sep 17 00:00:00 2001
From: FireMasterK <20838718+FireMasterK@users.noreply.github.com>
Date: Wed, 21 Jul 2021 18:07:43 +0530
Subject: [PATCH] Print stacktraces on any errors.

---
 src/main/java/me/kavin/piped/Main.java         |  3 +--
 .../me/kavin/piped/utils/ResponseHelper.java   | 18 ++++++++++--------
 2 files changed, 11 insertions(+), 10 deletions(-)

diff --git a/src/main/java/me/kavin/piped/Main.java b/src/main/java/me/kavin/piped/Main.java
index 267187d..d0528b8 100644
--- a/src/main/java/me/kavin/piped/Main.java
+++ b/src/main/java/me/kavin/piped/Main.java
@@ -1,6 +1,5 @@
 package me.kavin.piped;
 
-import java.io.IOException;
 import java.util.Collections;
 import java.util.List;
 import java.util.Timer;
@@ -49,7 +48,7 @@ public class Main {
                                 Session sess = DatabaseSessionFactory.createSession();
                                 try {
                                     ResponseHelper.subscribePubSub(channelId, sess);
-                                } catch (IOException | InterruptedException e) {
+                                } catch (Exception e) {
                                     e.printStackTrace();
                                 }
                                 sess.close();
diff --git a/src/main/java/me/kavin/piped/utils/ResponseHelper.java b/src/main/java/me/kavin/piped/utils/ResponseHelper.java
index b729d62..5bc2f09 100644
--- a/src/main/java/me/kavin/piped/utils/ResponseHelper.java
+++ b/src/main/java/me/kavin/piped/utils/ResponseHelper.java
@@ -609,13 +609,15 @@ public class ResponseHelper {
                         sess.save(channel);
                         sess.beginTransaction().commit();
 
-                        try {
-                            Session sessSub = DatabaseSessionFactory.createSession();
-                            subscribePubSub(channelId, sessSub);
-                            sessSub.close();
-                        } catch (IOException | InterruptedException e) {
-                            ExceptionUtils.rethrow(e);
-                        }
+                        Multithreading.runAsync(() -> {
+                            try {
+                                Session sessSub = DatabaseSessionFactory.createSession();
+                                subscribePubSub(channelId, sessSub);
+                                sessSub.close();
+                            } catch (Exception e) {
+                                e.printStackTrace();
+                            }
+                        });
 
                         for (StreamInfoItem item : info.getRelatedItems()) {
                             long time = item.getUploadDate() != null
@@ -822,7 +824,7 @@ public class ResponseHelper {
                                     Session sessSub = DatabaseSessionFactory.createSession();
                                     subscribePubSub(channelId, sessSub);
                                     sessSub.close();
-                                } catch (IOException | InterruptedException e) {
+                                } catch (Exception e) {
                                     e.printStackTrace();
                                 }
                             });