From ff1727e405a24c6532dc681c88d3c0e42e3b0482 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Elan=20Ruusam=C3=A4e?= <glen@pld-linux.org>
Date: Tue, 30 Apr 2024 20:30:55 +0300
Subject: [PATCH] Make plugin submethods async

---
 plextraktsync/sync/AddCollectionPlugin.py | 6 +++---
 plextraktsync/sync/SyncRatingsPlugin.py   | 8 ++++----
 plextraktsync/sync/SyncWatchedPlugin.py   | 6 +++---
 plextraktsync/sync/WatchProgressPlugin.py | 6 +++---
 4 files changed, 13 insertions(+), 13 deletions(-)

diff --git a/plextraktsync/sync/AddCollectionPlugin.py b/plextraktsync/sync/AddCollectionPlugin.py
index 1f48cf93a21..e49866f93c0 100644
--- a/plextraktsync/sync/AddCollectionPlugin.py
+++ b/plextraktsync/sync/AddCollectionPlugin.py
@@ -22,13 +22,13 @@ def factory(cls, sync):
 
     @hookimpl
     async def walk_movie(self, movie: Media, dry_run: bool):
-        self.sync_collection(movie, dry_run=dry_run)
+        await self.sync_collection(movie, dry_run=dry_run)
 
     @hookimpl
     async def walk_episode(self, episode: Media, dry_run: bool):
-        self.sync_collection(episode, dry_run=dry_run)
+        await self.sync_collection(episode, dry_run=dry_run)
 
-    def sync_collection(self, m: Media, dry_run: bool):
+    async def sync_collection(self, m: Media, dry_run: bool):
         if m.is_collected:
             return
 
diff --git a/plextraktsync/sync/SyncRatingsPlugin.py b/plextraktsync/sync/SyncRatingsPlugin.py
index af7ac364e54..c7a93cd55fa 100644
--- a/plextraktsync/sync/SyncRatingsPlugin.py
+++ b/plextraktsync/sync/SyncRatingsPlugin.py
@@ -33,20 +33,20 @@ def init(self):
     @hookimpl
     async def fini(self, walker: Walker, dry_run: bool):
         async for show in walker.walk_shows(self.shows, title="Syncing show ratings"):
-            self.sync_ratings(show, dry_run=dry_run)
+            await self.sync_ratings(show, dry_run=dry_run)
 
     @hookimpl
     async def walk_movie(self, movie: Media, dry_run: bool):
-        self.sync_ratings(movie, dry_run=dry_run)
+        await self.sync_ratings(movie, dry_run=dry_run)
 
     @hookimpl
     async def walk_episode(self, episode: Media, dry_run: bool):
-        self.sync_ratings(episode, dry_run=dry_run)
+        await self.sync_ratings(episode, dry_run=dry_run)
 
         if episode.show:
             self.shows.add(episode.show)
 
-    def sync_ratings(self, m: Media, dry_run: bool):
+    async def sync_ratings(self, m: Media, dry_run: bool):
         if m.plex_rating == m.trakt_rating:
             return
 
diff --git a/plextraktsync/sync/SyncWatchedPlugin.py b/plextraktsync/sync/SyncWatchedPlugin.py
index 0e6325b2ef6..ce4eaf4c50e 100644
--- a/plextraktsync/sync/SyncWatchedPlugin.py
+++ b/plextraktsync/sync/SyncWatchedPlugin.py
@@ -26,13 +26,13 @@ def factory(cls, sync: Sync):
 
     @hookimpl
     async def walk_movie(self, movie: Media, dry_run: bool):
-        self.sync_watched(movie, dry_run=dry_run)
+        await self.sync_watched(movie, dry_run=dry_run)
 
     @hookimpl
     async def walk_episode(self, episode: Media, dry_run: bool):
-        self.sync_watched(episode, dry_run=dry_run)
+        await self.sync_watched(episode, dry_run=dry_run)
 
-    def sync_watched(self, m: Media, dry_run: bool):
+    async def sync_watched(self, m: Media, dry_run: bool):
         if m.watched_on_plex is m.watched_on_trakt:
             return
 
diff --git a/plextraktsync/sync/WatchProgressPlugin.py b/plextraktsync/sync/WatchProgressPlugin.py
index 4805f9ed232..84969c85b04 100644
--- a/plextraktsync/sync/WatchProgressPlugin.py
+++ b/plextraktsync/sync/WatchProgressPlugin.py
@@ -29,13 +29,13 @@ def factory(cls, sync: Sync):
 
     @hookimpl
     async def walk_movie(self, movie: Media, dry_run: bool):
-        self.sync_progress(movie, dry_run=dry_run)
+        await self.sync_progress(movie, dry_run=dry_run)
 
     @hookimpl
     async def walk_episode(self, episode: Media, dry_run: bool):
-        self.sync_progress(episode, dry_run=dry_run)
+        await self.sync_progress(episode, dry_run=dry_run)
 
-    def sync_progress(self, m: Media, dry_run=False):
+    async def sync_progress(self, m: Media, dry_run=False):
         p = self.trakt.watch_progress.match(m)
         if not p:
             return