Make plugin submethods async

Taxel · Apr 30, 2024 · ff1727e · ff1727e
1 parent 147dec7
commit ff1727e
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 13 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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