github/plexpy
1
0
Fork 0
mirror of https://github.com/Tautulli/Tautulli.git synced 2025-07-31 03:50:11 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add live tv channel keys to database

Browse source
This commit is contained in:
JonnyWong16 2024-04-01 17:06:25 -07:00
parent 177962d626
commit 3dc6d226f8
No known key found for this signature in database
GPG key ID: B1F1F9807184697A
2 changed files with 40 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

36
plexpy/__init__.py
View file

@ -660,7 +660,8 @@ def dbcheck():
"transcode_hw_decoding INTEGER, transcode_hw_encoding INTEGER, "
"optimized_version INTEGER, optimized_version_profile TEXT, optimized_version_title TEXT, "
"synced_version INTEGER, synced_version_profile TEXT, "
"live INTEGER, live_uuid TEXT, channel_call_sign TEXT, channel_identifier TEXT, channel_thumb TEXT, "
"live INTEGER, live_uuid TEXT, "
"channel_call_sign TEXT, channel_id TEXT, channel_identifier TEXT, channel_title TEXT, channel_thumb TEXT, channel_vcn TEXT, "
"secure INTEGER, relayed INTEGER, "
"buffer_count INTEGER DEFAULT 0, buffer_last_triggered INTEGER, last_paused INTEGER, watched INTEGER DEFAULT 0, "
"intro INTEGER DEFAULT 0, credits INTEGER DEFAULT 0, commercial INTEGER DEFAULT 0, marker INTEGER DEFAULT 0, "
@ -721,7 +722,8 @@ def dbcheck():
"art TEXT, media_type TEXT, year INTEGER, originally_available_at TEXT, added_at INTEGER, updated_at INTEGER, "
"last_viewed_at INTEGER, content_rating TEXT, summary TEXT, tagline TEXT, rating TEXT, "
"duration INTEGER DEFAULT 0, guid TEXT, directors TEXT, writers TEXT, actors TEXT, genres TEXT, studio TEXT, "
"labels TEXT, live INTEGER DEFAULT 0, channel_call_sign TEXT, channel_identifier TEXT, channel_thumb TEXT, "
"labels TEXT, live INTEGER DEFAULT 0, "
"channel_call_sign TEXT, channel_id TEXT, channel_identifier TEXT, channel_title TEXT, channel_thumb TEXT, channel_vcn TEXT, "
"marker_credits_first INTEGER DEFAULT NULL, marker_credits_final INTEGER DEFAULT NULL)"
)
@ -1443,6 +1445,21 @@ def dbcheck():
"ALTER TABLE sessions ADD COLUMN marker INTEGER DEFAULT 0"
)
# Upgrade sessions table from earlier versions
try:
c_db.execute("SELECT channel_id FROM sessions")
except sqlite3.OperationalError:
logger.debug("Altering database. Updating database table sessions.")
c_db.execute(
"ALTER TABLE sessions ADD COLUMN channel_id TEXT"
)
c_db.execute(
"ALTER TABLE sessions ADD COLUMN channel_title TEXT"
)
c_db.execute(
"ALTER TABLE sessions ADD COLUMN channel_vcn TEXT"
)
# Upgrade session_history table from earlier versions
try:
c_db.execute("SELECT reference_id FROM session_history")
@ -1583,6 +1600,21 @@ def dbcheck():
"ALTER TABLE session_history_metadata ADD COLUMN marker_credits_final INTEGER DEFAULT NULL"
)
# Upgrade session_history_metadata table from earlier versions
try:
c_db.execute("SELECT channel_id FROM session_history_metadata")
except sqlite3.OperationalError:
logger.debug("Altering database. Updating database table session_history_metadata.")
c_db.execute(
"ALTER TABLE session_history_metadata ADD COLUMN channel_id TEXT"
)
c_db.execute(
"ALTER TABLE session_history_metadata ADD COLUMN channel_title TEXT"
)
c_db.execute(
"ALTER TABLE session_history_metadata ADD COLUMN channel_vcn TEXT"
)
# Upgrade session_history_media_info table from earlier versions
try:
c_db.execute("SELECT transcode_decision FROM session_history_media_info")

6
plexpy/activity_processor.py
View file

@ -150,8 +150,11 @@ class ActivityProcessor(object):
'rating_key_websocket': session.get('rating_key_websocket', ''),
'raw_stream_info': json.dumps(session),
'channel_call_sign': session.get('channel_call_sign', ''),
'channel_id': session.get('channel_id', ''),
'channel_identifier': session.get('channel_identifier', ''),
'channel_title': session.get('channel_title', ''),
'channel_thumb': session.get('channel_thumb', ''),
'channel_vcn': session.get('channel_vcn', ''),
'stopped': helpers.timestamp()
}
@ -470,8 +473,11 @@ class ActivityProcessor(object):
'labels': labels,
'live': session['live'],
'channel_call_sign': media_info.get('channel_call_sign', ''),
'channel_id': media_info.get('channel_id', ''),
'channel_identifier': media_info.get('channel_identifier', ''),
'channel_title': media_info.get('channel_title', ''),
'channel_thumb': media_info.get('channel_thumb', ''),
'channel_vcn': media_info.get('channel_vcn', ''),
'marker_credits_first': marker_credits_first,
'marker_credits_final': marker_credits_final
}