Changeset 39352 for titan/mediathek/localhoster

Timestamp:

11/19/16 14:22:57 (7 years ago)

Author:

obi

Message:

fix flashx.py

Location:

titan/mediathek/localhoster

Files:

• flashx.py (modified) (2 diffs)
• lib/aa_decoder.py (added)
• lib/common.py (added)
• lib/fx_gmu.py (added)
• lib/helpers.py (added)
• lib/ol_gmu.py (added)
• movshare.py (modified) (2 diffs)

titan/mediathek/localhoster/flashx.py

@@ -5 +5 @@
 from lib.net import Net
 import lib.common as common
+import lib.fx_gmu as fx_gmu
+import lib.fx_gmu as fx_gmu
+
+FX_SOURCE = 'https://offshoregit.com/tvaresolvers/fx_gmu.py'
+FX_PATH = ''
 
 class FlashxResolver(object):
@@ -26 +31 @@
             return False
 
+    def get_fx_code(self):
+        try:
+            headers = self.net.http_HEAD(FX_SOURCE).get_headers(as_dict=True)
+            old_etag = self.get_setting('etag')
+            new_etag = headers.get('Etag', '')
+            old_len = self.__old_length()
+            new_len = int(headers.get('Content-Length', 0))
+            if old_etag != new_etag or old_len != new_len:
+                self.set_setting('etag', new_etag)
+                new_py = self.net.http_GET(FX_SOURCE).content
+                if new_py:
+                    with open(FX_PATH, 'w') as f:
+                        f.write(new_py)
+            else:
+                print 'Reusing existing fx_gmu.py: |%s|%s|%s|%s|' % (old_etag, new_etag, old_len, new_len)
+        except Exception as e:
+            print 'Exception during flashx code retrieve: %s' % e
+            
+    def __old_length(self):
+        try:
+            with open(FX_PATH, 'r') as f:
+                old_py = f.read()
+            old_len = len(old_py)
+        except:
+            old_len = 0
+        return old_len
+
     def get_media_url(self, host, media_id):
-        web_url = self.get_url(host, media_id)
-        resp = self.net.http_GET(web_url)
-        html = resp.content
-        cfdcookie = resp._response.info()['set-cookie']
-        cfduid = re.search('cfduid=(.*?);', cfdcookie).group(1)
-        file_id = re.search("'file_id', '(.*?)'", html).group(1)
-        aff = re.search("'aff', '(.*?)'", html).group(1)
-        headers = {'User-Agent': common.IE_USER_AGENT,
-                   'Referer': web_url,
-                   'Cookie': '__cfduid=' + cfduid + '; lang=1'}
-        surl = re.search('src="(.*?' + file_id + ')', html, re.IGNORECASE).group(1)
-        dummy = self.net.http_GET(url=surl, headers=headers).content
-        headers = {'User-Agent': common.IE_USER_AGENT,
-                   'Referer': web_url,
-                   'Cookie': '__cfduid=' + cfduid + '; lang=1; file_id=' + file_id + '; aff=' + aff}
-        html = self.net.http_GET(url=web_url, headers=headers).content
-        fname = re.search('name="fname" value="(.*?)"', html).group(1)
-        hash = re.search('name="hash" value="(.*?)"', html).group(1)
-        fdata = {'op': 'download1',
-                 'usr_login': '',
-                 'id': media_id,
-                 'fname': fname,
-                 'referer': '',
-                 'hash': hash,
-                 'imhuman': 'Proceed to video'}
-        furl = 'http://www.flashx.tv/dl'# + media_id
-        time.sleep(5)
-        html = self.net.http_POST(url=furl, form_data=fdata, headers=headers).content
+#        try:
+#            if self.get_setting('auto_update') == 'true':
+#                self.get_fx_code()
+#            with open(FX_PATH, 'r') as f:
+#                py_data = f.read()
+#            import fx_gmu
+            web_url = self.get_url(host, media_id)
+            print fx_gmu.get_media_url(web_url)
+#        except Exception as e:
+#            print 'error'
+        
+    def get_url(self, host, media_id):
+        return 'http://%s/embed.php?c=%s' % (host, media_id)
 
-        js_data = re.findall('(eval\(function.*?)</script>', html.replace('\n', ''))
-
-        for i in js_data:
-            try: html += jsunpack.unpack(i)
-            except: pass
-
-        print self.get_best_source(html)
-
-    def get_url(self, host, media_id):
-        return 'http://www.flashx.tv/%s.html' % media_id
-
-
-    def get_best_source(self, html):
-        stream = re.search('file:"([^"]*/high.*)",label', html)
-        if stream:
-            return re.search('file:"([^"]*/high.*)",label', html).group(1)
-        else:
-            stream = re.search('file:"([^"]*/normal.*)",label', html)
-            if stream:
-                return re.search('file:"([^"]*/normal.*)",label', html).group(1)
-            else:
-                stream = re.search('file:"([^"]*/low.*)",label', html)
-                if stream:
-                    return re.search('file:"([^"]*/low.*)",label', html).group(1)
-                else:
-                    stream = re.search('file:"([^"]*)",label', html)
-                    if stream:
-                        return re.search('file:"([^"]*)",label', html).group(1)
-                        
 sys.stdout = FlashxResolver()

titan/mediathek/localhoster/movshare.py

@@ -1 +1 @@
 
+import random
 import re
 import urllib
 import sys
 from lib.net import Net
+from lib import helpers
 
 class MovshareResolver(object):
@@ -27 +29 @@
     def get_media_url(self, host, media_id):
         web_url = self.get_url(host, media_id)
-        html = self.net.http_GET(web_url).content
-        try:
-            stream_url = ''
-            r = re.search('flashvars.filekey=(.+?);', html)
-            if r:
-                r = r.group(1)
-                try: filekey = re.search('var\s+%s\s*=\s*"([^"]+)' % (r), html).group(1)
-                except: filekey = r
-                player_url = 'http://%s/api/player.api.php?key=%s&file=%s' % (host, urllib.quote(filekey), media_id)
-                html = self.net.http_GET(player_url).content
-                r = re.search('url=(.+?)&', html)
-                if r:
-                    stream_url = r.group(1)
-            
-        try:
-            r = re.search('id="player"[^>]+src="([^"]+)', html, re.DOTALL)
-            if r:
-                stream_url = r.group(1)
+        headers = {'User-Agent': common.FF_USER_AGENT}
+        html = self.net.http_GET(web_url, headers=headers).content
+        stream_url = ''
+        match = re.search('<video.*?</video>', html, re.DOTALL)
+        if match:
+            links = re.findall('<source[^>]+src="([^"]+)', match.group(0), re.DOTALL)
+            if links:
+                stream_url = random.choice(links)
+        
+        if not stream_url:
+            match = re.search('fkzd="([^"]+)', html)
+            if match:
+                query = {'pass': 'undefined', 'key': match.group(1), 'cid3': 'undefined', 'cid': 0, 'numOfErrors': 0, 'file': media_id, 'cid2': 'undefined', 'user': 'undefined'}
+                api_url = 'http://www.wholecloud.net//api/player.api.php?' + urllib.urlencode(query)
+                html = self.net.http_GET(api_url, headers=headers).content
+                match = re.search('url=([^&]+)', html)
+                if match:
+                    stream_url = match.group(1)
 
         if stream_url:
-            print '%s|Referer=%s' % (stream_url, web_url)
+            headers.update({'Referer': web_url, })
+            print stream_url + helpers.append_headers(headers)
 
     def get_url(self, host, media_id):
         if 'vidgg' in host:
-            return 'http://%s/embed/?id=%s' % (host, media_id)
+            template = 'http://{host}/embed/?id={media_id}'
         else:
-            return 'http://%s/embed/?v=%s' % (host, media_id)
+            template = 'http://{host}/embed/?v={media_id}'
+        print self._default_get_url(host, media_id, template)
 
 sys.stdout = MovshareResolver()