Refactor social network episode release to use parallel streams

Shikkanime · Mar 8, 2024 · 1bea6f3 · 1bea6f3
1 parent a0f0bf7
commit 1bea6f3
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 18 deletions.
diff --git a/src/main/kotlin/fr/shikkanime/jobs/FetchEpisodesJob.kt b/src/main/kotlin/fr/shikkanime/jobs/FetchEpisodesJob.kt
@@ -98,23 +98,21 @@ class FetchEpisodesJob : AbstractJob {
             return
         }
 
-        Constant.abstractSocialNetworks.forEach { socialNetwork ->
-            Thread {
-                try {
-                    socialNetwork.sendEpisodeRelease(dto, mediaImage)
-                } catch (e: Exception) {
-                    logger.log(
-                        Level.SEVERE,
-                        "Error while sending episode release for ${
-                            socialNetwork.javaClass.simpleName.replace(
-                                "SocialNetwork",
-                                ""
-                            )
-                        }",
-                        e
-                    )
-                }
-            }.start()
+        Constant.abstractSocialNetworks.parallelStream().forEach { socialNetwork ->
+            try {
+                socialNetwork.sendEpisodeRelease(dto, mediaImage)
+            } catch (e: Exception) {
+                logger.log(
+                    Level.SEVERE,
+                    "Error while sending episode release for ${
+                        socialNetwork.javaClass.simpleName.replace(
+                            "SocialNetwork",
+                            ""
+                        )
+                    }",
+                    e
+                )
+            }
         }
     }
 }
diff --git a/src/main/kotlin/fr/shikkanime/services/ImageService.kt b/src/main/kotlin/fr/shikkanime/services/ImageService.kt
@@ -495,7 +495,9 @@ object ImageService {
             ImageIO.read(URI(episode.anime.image!!).toURL()).resize((480 / scale).toInt(), (720 / scale).toInt())
 
         val platformImage = try {
-            ImageIO.read(URI("http://localhost:37100/assets/img/platforms/${episode.platform.image}").toURL())
+            ImageIO.read(
+                ClassLoader.getSystemClassLoader().getResourceAsStream("assets/img/platforms/${episode.platform.image}")
+            )
                 .resize(32, 32)
         } catch (e: Exception) {
             e.printStackTrace()