From 8c5ea39edf2e4b14a8b909df80c61d8a0a7787f0 Mon Sep 17 00:00:00 2001
From: Alhaziel01 <alhaziel01@gmail.com>
Date: Wed, 6 Oct 2021 12:38:43 +0200
Subject: [PATCH] Fix Streaming Community

---
 channels/streamingcommunity.py | 39 ++++++++++++++++++----------------
 1 file changed, 21 insertions(+), 18 deletions(-)

diff --git a/channels/streamingcommunity.py b/channels/streamingcommunity.py
index f2914337..79c5d62a 100644
--- a/channels/streamingcommunity.py
+++ b/channels/streamingcommunity.py
@@ -5,7 +5,7 @@
 
 import json, requests, sys
 from core import support, channeltools
-from platformcode import logger
+from platformcode import logger, platformtools
 if sys.version_info[0] >= 3:
     from concurrent import futures
 else:
@@ -205,14 +205,19 @@ def episodios(item):
 
 
 def findvideos(item):
+    itemlist = [item.clone(title = channeltools.get_channel_parameters(item.channel)['title'], server='directo')]
+    return support.server(item, itemlist=itemlist)
+
+def play(item):
     video_urls = []
+    from time import time
+    from base64 import b64encode as b64
+    import hashlib
+
     data = support.match(item.url + item.episodeid, headers=headers).data.replace('&quot;','"').replace('\\','')
-    url = support.match(data, patron=r'video_url"\s*:\s*"([^"]+)"').match
+    url = support.match(data, patron=r'video_url"\s*:\s*"([^"]+)"').match + 'm3u8'
 
     def calculateToken():
-        from time import time
-        from base64 import b64encode as b64
-        import hashlib
         o = 48
         n = support.match(host + '/client-address').data
         i = 'Yc8U6r8KjAKAepEA'
@@ -221,18 +226,16 @@ def findvideos(item):
         md5 = hashlib.md5(l.encode())
         s = '?token={}&expires={}'.format(b64(md5.digest()).decode().replace('=', '').replace('+', "-").replace('\\', "_"), t)
         return s
+
+
     token = calculateToken()
+    code = support.httptools.downloadpage(url + token).code
+    count = 0
+    while not code == 200:
+        token = calculateToken()
+        code = support.httptools.downloadpage(url + token).code
+        count +=1
+        if count == 30:
+            break
 
-    def videourls(res):
-        newurl = '{}/{}{}'.format(url, res, token)
-        if requests.head(newurl, headers=headers).status_code == 200:
-            video_urls.append(["m3u8 {} [StreamingCommunity]".format(res), newurl])
-
-    with futures.ThreadPoolExecutor() as executor:
-        for res in ['480p', '720p', '1080p']:
-            executor.submit(videourls, res) 
-
-    if not video_urls: video_urls = [["m3u8 [StreamingCommunity]", url + token]]
-    else: video_urls.sort(key=lambda url: int(support.match(url[0], patron=r'(\d+)p').match))
-    itemlist = [item.clone(title = channeltools.get_channel_parameters(item.channel)['title'], server='directo', video_urls=video_urls, thumbnail=channeltools.get_channel_parameters(item.channel)["thumbnail"], forcethumb=True)]
-    return support.server(item, itemlist=itemlist)
\ No newline at end of file
+    return [item.clone(title = channeltools.get_channel_parameters(item.channel)['title'], server='directo', url=url + token)]