[plugin.video.cbc] v4.0.23

micahg · micahg · commit 4892bbd48bd4 · 2026-02-15T13:07:55.000-05:00
diff --git a/plugin.video.cbc/addon.xml b/plugin.video.cbc/addon.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
 <addon id="plugin.video.cbc"
        name="Canadian Broadcasting Corp (CBC)"
-       version="4.0.22+matrix.1"
+       version="4.0.23+matrix.1"
        provider-name="micahg,t1m,smf007,oshanrube,jgaudet">
   <requires>
     <import addon="xbmc.python" version="3.0.0"/>
@@ -29,8 +29,10 @@
     <website>https://watch.cbc.ca/</website>
     <source>https://github.com/micahg/plugin.video.cbc</source>
     <news>
-      - Updates for new Auth API
-      - Fixes for live events
+      - Add back missing live channels
+      - Better live event handling
+      - Better EPG error handling
+      - Remove dead code and fix match bug
     </news>
   </extension>
 </addon>
diff --git a/plugin.video.cbc/default.py b/plugin.video.cbc/default.py
@@ -12,7 +12,7 @@
 import routing
 
 from resources.lib.cbc import CBC
-from resources.lib.utils import log, getAuthorizationFile, get_cookie_file, get_iptv_channels_file
+from resources.lib.utils import log, getAuthorizationFile, get_iptv_channels_file, is_pending, iso8601_to_local
 from resources.lib.livechannels import LiveChannels
 from resources.lib.gemv2 import GemV2
 from resources.lib.iptvmanager import IPTVManager
@@ -119,7 +119,6 @@ def logout():
     """Remove authorization stuff."""
     log('Logging out...', True)
     os.remove(getAuthorizationFile())
-    os.remove(get_cookie_file())
 
 
 @plugin.route('/iptv/channels')
@@ -174,6 +173,7 @@ def play_live_channel():
 def live_channels_menu():
     """Populate the menu with live channels."""
     xbmcplugin.setContent(plugin.handle, 'videos')
+    xbmcplugin.addSortMethod(plugin.handle, xbmcplugin.SORT_METHOD_LABEL)
     chans = LiveChannels()
     chan_list = chans.get_live_channels()
     cbc = CBC()
@@ -184,7 +184,10 @@ def live_channels_menu():
         item = xbmcgui.ListItem(labels['title'])
         item.setArt({'thumb': image, 'poster': image})
         item.setInfo(type="Video", infoLabels=labels)
-        item.setProperty('IsPlayable', 'true')
+        air_date = channel.get('airDate')
+        local_dt = iso8601_to_local(air_date) if air_date else None
+        if local_dt is None or not is_pending(local_dt):
+            item.setProperty('IsPlayable', 'true')
         item.addContextMenuItems([
             (getString(30014), 'RunPlugin({})'.format(plugin.url_for(live_channels_add_all))),
             (getString(30015), 'RunPlugin({})'.format(plugin.url_for(live_channels_add, callsign))),
@@ -222,16 +225,16 @@ def layout_menu(path):
     for f in items:
         n = GemV2.normalized_format_item(f)
         p = GemV2.normalized_format_path(f, path)
-        item = xbmcgui.ListItem(n['label'])
+        item = xbmcgui.ListItem(n['title'])
         if 'art' in n:
             item.setArt(n['art'])
         item.setInfo(type="Video", infoLabels=n['info_labels'])
-        if n['playable']:
-            item.setProperty('IsPlayable', 'true')
+        if 'app_code' in n and n['app_code']:
+            item.setProperty('IsPlayable', 'true' if 'playable' in n and n['playable'] else 'false')
             url = plugin.url_for(play_live_channel, id=p, app_code=n['app_code'])
         else:
             url = plugin.url_for(layout_menu, p)
-        xbmcplugin.addDirectoryItem(handle, url, item, not n['playable'])
+        xbmcplugin.addDirectoryItem(handle, url, item, not 'app_code' in n)
     xbmcplugin.endOfDirectory(handle)
 
 
diff --git a/plugin.video.cbc/resources/lib/cbc.py b/plugin.video.cbc/resources/lib/cbc.py
@@ -6,11 +6,10 @@
 import json
 # import http.client as http_client
 from urllib.parse import urlparse, parse_qs, quote
-from xml.dom.minidom import parseString
 
 import requests
 
-from .utils import save_cookies, loadCookies, saveAuthorization, log
+from .utils import saveAuthorization, log, iso8601_to_local, is_pending
 
 # http_client.HTTPConnection.debuglevel = 1
 
@@ -65,9 +64,6 @@ def __init__(self):
         """Initialize the CBC class."""
         # Create requests session object
         self.session = requests.Session()
-        session_cookies = loadCookies()
-        if session_cookies is not None:
-            self.session.cookies = session_cookies
 
     @staticmethod
     def azure_authorize_authorize(sess: requests.Session):
@@ -336,8 +332,8 @@ def get_labels(item):
             'studio': 'Canadian Broadcasting Corporation',
             'country': 'Canada'
         }
-        if 'cbc$callSign' in item:
-            labels['title'] = '{} {}'.format(item['cbc$callSign'], item['title'])
+        if 'streamTitle' in item:
+            labels['title'] = item['streamTitle'].encode('utf-8')
         else:
             labels['title'] = item['title'].encode('utf-8')
 
@@ -373,14 +369,14 @@ def get_labels(item):
             if item['cbc$audioVideo'].lower() == 'video':
                 labels['mediatype'] = 'video'
 
+        if 'airDate' in item:
+            local_dt = iso8601_to_local(item['airDate'])
+            is_pending(local_dt, item=labels)
+
         return labels
 
 
     @staticmethod
     def get_session():
         """Get a requests session object with CBC cookies."""
-        sess = requests.Session()
-        cookies = loadCookies()
-        if cookies is not None:
-            sess.cookies = cookies
-        return sess
+        return requests.Session()
diff --git a/plugin.video.cbc/resources/lib/epg.py b/plugin.video.cbc/resources/lib/epg.py
@@ -12,6 +12,8 @@
 
 # Y/M/D
 GUIDE_URL_FMT = 'https://www.cbc.ca/programguide/daily/{}/cbc_television'
+USER_AGENT = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36'
+REQUEST_TIMEOUT = (10, 20)
 
 # This is a combination of actual callsigns (NN for newsnet) and guid values
 # for over-the-top-only services. No doubt, someone will come back here some
@@ -87,9 +89,14 @@ def get_guide_url(dttm, callsign=None):
 def call_guide_url(url, location=None):
     """Call the guide URL and return the response body."""
     cookies = {}
+    headers = {'User-Agent': USER_AGENT}
     if location is not None:
         cookies['pgTvLocation'] = location
-    resp = requests.get(url, cookies=cookies)
+    try:
+        resp = requests.get(url, cookies=cookies, headers=headers, timeout=REQUEST_TIMEOUT)
+    except requests.RequestException as ex:
+        log(f'HTTP request failed for {url}: {ex}', True)
+        return None
     if resp.status_code != 200:
         log('{} returns status of {}'.format(url, resp.status_code), True)
         return None
diff --git a/plugin.video.cbc/resources/lib/gemv2.py b/plugin.video.cbc/resources/lib/gemv2.py
@@ -1,11 +1,10 @@
 """Module for the V2 Gem API."""
 import json
-from datetime import datetime
 
 import requests
 
 from resources.lib.cbc import CBC
-from resources.lib.utils import loadAuthorization, log
+from resources.lib.utils import loadAuthorization, log, iso8601_to_local, is_pending
 
 
 # api CONFIG IS AT https://services.radio-canada.ca/ott/catalog/v1/gem/settings?device=web
@@ -18,15 +17,6 @@
 class GemV2:
     """V2 Gem API class."""
 
-    @staticmethod
-    def iso8601_to_local(dttm):
-        """Convert an ISO 8601 timestamp (UTC or offset-aware) to local time string."""
-        try:
-            local_dt = datetime.fromisoformat(dttm.replace('Z', '+00:00')).astimezone()
-            return local_dt.strftime('%Y-%m-%d %H:%M:%S')
-        except (ValueError, TypeError, AttributeError):
-            return dttm
-
     @staticmethod
     def scrape_json(uri, headers=None, params=None):
         if headers is None:
@@ -198,7 +188,7 @@ def normalized_format_item(item):
         images = item['images'] if 'images' in item else None
         title = item['label'] if 'label' in item else item['title']
         retval = {
-            'label': title,
+            'title': title,
             'playable': 'idMedia' in item,
             'info_labels': {
                 'tvshowtitle': title,
@@ -225,22 +215,23 @@ def normalized_format_item(item):
             if 'credits' in meta:
                 retval['info_labels']['cast'] = meta['credits'][0]['peoples'].split(',')
             if 'live' in meta and 'startDate' in meta['live']:
-                dttm = GemV2.iso8601_to_local(meta['live']['startDate'])
-                retval['label'] += f' [Live: {dttm}]'
+                local_dt = iso8601_to_local(meta['live']['startDate'])
+                if is_pending(local_dt, item=retval):
+                    retval['playable'] = False
 
         if 'idMedia' in item:
             # logic in https://services.radio-canada.ca/ott/catalog/v1/gem/settings?device=web
             if 'type' in item:
-                match item['type'].lower():
-                    case 'media':
-                        retval['app_code'] = 'gem'
-                    case 'quickturn':
-                        retval['app_code'] = 'medianet'
-                    case 'liveevent' | 'replay':
-                        retval['app_code'] = 'medianetlive'
-                    case _:
-                        log(f'Unknown type {item["type"]} for item with idMedia {item["idMedia"]}, defaulting to app_code "gem"')
-                        retval['app_code'] = 'gem'
+                item_type = item['type'].lower()
+                if item_type == 'media':
+                    retval['app_code'] = 'gem'
+                elif item_type == 'quickturn':
+                    retval['app_code'] = 'medianet'
+                elif item_type == 'liveevent' or item_type == 'replay':
+                    retval['app_code'] = 'medianetlive'
+                else:
+                    log(f'Unknown type {item["type"]} for item with idMedia {item["idMedia"]}, defaulting to app_code "gem"')
+                    retval['app_code'] = 'gem'
 
                 
         return retval
diff --git a/plugin.video.cbc/resources/lib/livechannels.py b/plugin.video.cbc/resources/lib/livechannels.py
@@ -1,16 +1,14 @@
 """Module for live channels."""
-from concurrent import futures
 import json
 from urllib.parse import urlencode
 
 import requests
 
-from resources.lib.utils import save_cookies, loadCookies, log, get_iptv_channels_file
+from resources.lib.utils import log, get_iptv_channels_file
 from resources.lib.cbc import CBC
 from resources.lib.gemv2 import GemV2
 
-LIST_URL = 'https://services.radio-canada.ca/ott/catalog/v2/gem/home?device=web'
-LIST_ELEMENT = '2415871718'
+LIST_URL = 'https://gem.cbc.ca/_next/data/7ByKb_CElwT2xVJeTO43g/live.json'
 
 class LiveChannels:
     """Class for live channels."""
@@ -19,9 +17,6 @@ def __init__(self):
         """Initialize the live channels class."""
         # Create requests session object
         self.session = requests.Session()
-        session_cookies = loadCookies()
-        if session_cookies is not None:
-            self.session.cookies = session_cookies
 
     def get_live_channels(self):
         """Get the list of live channels."""
@@ -30,25 +25,48 @@ def get_live_channels(self):
         if not resp.status_code == 200:
             log('ERROR: {} returns status of {}'.format(LIST_URL, resp.status_code), True)
             return None
-        save_cookies(self.session.cookies)
-
-        ret = None
-        for result in json.loads(resp.content)['lineups']['results']:
-            if result['key'] == LIST_ELEMENT:
-                ret = result['items']
-
-        future_to_callsign = {}
-        with futures.ThreadPoolExecutor(max_workers=20) as executor:
-            for i, channel in enumerate(ret):
-                callsign = CBC.get_callsign(channel)
-                future = executor.submit(self.get_channel_metadata, callsign)
-                future_to_callsign[future] = i
-
-        for future in futures.as_completed(future_to_callsign):
-            i = future_to_callsign[future]
-            metadata = future.result()
-            ret[i]['image'] = metadata['Metas']['imageHR']
-        return ret
+
+        data = json.loads(resp.content)
+        page_data = data.get('pageProps', {}).get('data', {})
+        streams = page_data.get('streams', [])
+        free_tv_items = page_data.get('freeTv', {}).get('items', [])
+
+        channels = []
+        for stream in streams:
+            items = stream.get('items', [])
+            if len(items) == 0:
+                continue
+
+            for item in items:
+                channel = dict(item)
+                if 'title' not in channel or not channel['title']:
+                    channel['title'] = stream.get('title')
+                if 'genericImage' in channel and 'image' not in channel:
+                    channel['image'] = channel['genericImage']
+                channels.append(channel)
+
+        for item in free_tv_items:
+            channel = dict(item)
+            if 'genericImage' in channel and 'image' not in channel:
+                channel['image'] = channel['genericImage']
+            channels.append(channel)
+
+        unique_channels = []
+        seen_ids = set()
+        for channel in channels:
+            id_media = channel.get('idMedia')
+
+            if id_media is None:
+                unique_channels.append(channel)
+                continue
+
+            if id_media in seen_ids:
+                continue
+
+            seen_ids.add(id_media)
+            unique_channels.append(channel)
+
+        return unique_channels
 
     def get_iptv_channels(self):
         """Get the channels in a IPTV Manager compatible list."""
@@ -99,7 +117,6 @@ def get_channel_metadata(self, id):
         if not resp.status_code == 200:
             log('ERROR: {} returns status of {}'.format(LIST_URL, resp.status_code), True)
             return None
-        save_cookies(self.session.cookies)
         return json.loads(resp.content)
 
     @staticmethod
diff --git a/plugin.video.cbc/resources/lib/utils.py b/plugin.video.cbc/resources/lib/utils.py
