Added absolute episode number to the database to help properly match video to subtitles. It must be implemented in each provider's matching method to benefit from that.

Author: morpheus65535

bazarr/app/database.py

@@ -152,6 +152,7 @@ class TableBlacklistMovie(Base):
 class TableEpisodes(Base):
     __tablename__ = 'table_episodes'
 
+    absoluteEpisode = mapped_column(Integer)
     audio_codec = mapped_column(Text)
     audio_language = mapped_column(Text)
     created_at_timestamp = mapped_column(DateTime)

bazarr/sonarr/sync/parser.py

@@ -182,4 +182,5 @@ def episodeParser(episode):
                             'audio_codec': audioCodec,
                             'episode_file_id': episode['episodeFile']['id'],
                             'audio_language': str(audio_language),
-                            'file_size': episode['episodeFile']['size']}
+                            'file_size': episode['episodeFile']['size'],
+                            'absoluteEpisode': episode.get('absoluteEpisodeNumber')}

bazarr/subtitles/refiners/database.py

@@ -32,7 +32,8 @@ def refine_from_db(path, video):
                    TableEpisodes.path,
                    TableShows.imdbId,
                    TableEpisodes.sonarrSeriesId,
-                   TableEpisodes.sonarrEpisodeId)
+                   TableEpisodes.sonarrEpisodeId,
+                   TableEpisodes.absoluteEpisode)
             .select_from(TableEpisodes)
             .join(TableShows)
             .where((TableEpisodes.path == path_mappings.path_replace_reverse(path)))) \
@@ -42,6 +43,7 @@ def refine_from_db(path, video):
             video.series = _TITLE_RE.sub('', data.seriesTitle)
             video.season = int(data.season)
             video.episode = int(data.episode)
+            video.absolute_episode = int(data.absoluteEpisode) if data.absoluteEpisode else None
             video.title = data.episodeTitle
 
             # Only refine year as a fallback

migrations/versions/df76a4410347_.py

@@ -0,0 +1,36 @@
+"""empty message
+
+Revision ID: df76a4410347
+Revises: 4274a5dfc4ad
+Create Date: 2025-11-19 07:36:46.102169
+
+"""
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision = 'df76a4410347'
+down_revision = '4274a5dfc4ad'
+branch_labels = None
+depends_on = None
+
+bind = op.get_context().bind
+insp = sa.inspect(bind)
+
+
+def column_exists(table_name, column_name):
+    columns = insp.get_columns(table_name)
+    return any(c["name"] == column_name for c in columns)
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    if not column_exists('table_episodes', 'absoluteEpisode'):
+        with op.batch_alter_table('table_episodes', schema=None) as batch_op:
+            batch_op.add_column(sa.Column('absoluteEpisode', sa.INT(), nullable=True))
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    pass