|
11 | 11 |
|
12 | 12 | def process_payload(payload, user):
|
13 | 13 | """Process a Jellyfin webhook payload."""
|
| 14 | + logger.debug("Processing Jellyfin webhook payload: %s", payload) |
| 15 | + |
14 | 16 | event_type = payload["Event"]
|
15 | 17 |
|
16 |
| - if event_type not in ("Stop", "MarkPlayed", "MarkUnplayed"): |
| 18 | + if event_type not in ("Play", "Stop", "MarkPlayed", "MarkUnplayed"): |
17 | 19 | logger.info("Ignoring Jellyfin webhook event: %s", event_type)
|
18 | 20 | return
|
19 | 21 |
|
@@ -52,24 +54,24 @@ def process_payload(payload, user):
|
52 | 54 | )
|
53 | 55 | if mal_id:
|
54 | 56 | logger.info("Detected anime: %s", title)
|
55 |
| - add_anime(mal_id, episode_offset, payload, user) |
| 57 | + handle_anime(mal_id, episode_offset, payload, user) |
56 | 58 | return
|
57 | 59 |
|
58 | 60 | logger.info("Detected TV show: %s", title)
|
59 |
| - add_tv(tmdb_id, payload, user) |
| 61 | + handle_tv_episode(tmdb_id, payload, user) |
60 | 62 |
|
61 | 63 | elif media_type == MediaTypes.MOVIE.value:
|
62 | 64 | title = payload["Item"]["Name"]
|
63 | 65 | mal_id = get_mal_id_from_tmdb_movie(mapping_data, tmdb_id)
|
64 | 66 | if mal_id and user.anime_enabled:
|
65 | 67 | logger.info("Detected anime movie: %s", title)
|
66 |
| - add_anime(mal_id, 1, payload, user) |
| 68 | + handle_anime(mal_id, 1, payload, user) |
67 | 69 | else:
|
68 | 70 | logger.info("Detected movie: %s", title)
|
69 |
| - add_movie(tmdb_id, payload, user) |
| 71 | + handle_movie(tmdb_id, payload, user) |
70 | 72 |
|
71 | 73 |
|
72 |
| -def add_anime(media_id, episode_number, payload, user): |
| 74 | +def handle_anime(media_id, episode_number, payload, user): |
73 | 75 | """Add an anime episode as watched."""
|
74 | 76 | anime_metadata = app.providers.mal.anime(media_id)
|
75 | 77 | episode_played = payload["Item"]["UserData"]["Played"]
|
@@ -110,7 +112,7 @@ def add_anime(media_id, episode_number, payload, user):
|
110 | 112 | )
|
111 | 113 |
|
112 | 114 |
|
113 |
| -def add_movie(media_id, payload, user): |
| 115 | +def handle_movie(media_id, payload, user): |
114 | 116 | """Add a movie as watched."""
|
115 | 117 | movie_metadata = app.providers.tmdb.movie(media_id)
|
116 | 118 | movie_played = payload["Item"]["UserData"]["Played"]
|
@@ -154,7 +156,7 @@ def add_movie(media_id, payload, user):
|
154 | 156 | )
|
155 | 157 |
|
156 | 158 |
|
157 |
| -def add_tv(media_id, payload, user): |
| 159 | +def handle_tv_episode(media_id, payload, user): |
158 | 160 | """Add a TV show episode as watched."""
|
159 | 161 | season_number = payload["Item"]["ParentIndexNumber"]
|
160 | 162 | episode_number = payload["Item"]["IndexNumber"]
|
|
0 commit comments