stevazi/addon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

fix vidtome e migliorie vcrypt

Browse Source
This commit is contained in:
mac12m99
2021-03-22 20:29:33 +01:00
parent bf70737555
commit bc9540064a
6 changed files with 71 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/httptools.py
+1 -1
View File
@@ -44,7 +44,7 @@ directIP = {
'akvideo.stream': '31.220.1.77', 'akvideo.stream': '31.220.1.77',
'vcrypt.net': '31.220.1.77', 'vcrypt.net': '31.220.1.77',
'vcrypt.pw': '31.220.1.77', 'vcrypt.pw': '31.220.1.77',
'vidtome.host': '94.75.219.1"', # 'vidtome.host': '94.75.219.1',
'nored.icu': '31.220.1.77', 'nored.icu': '31.220.1.77',
'wstream.icu': '31.220.1.77', 'wstream.icu': '31.220.1.77',
'wstream.video': '31.220.1.77', 'wstream.video': '31.220.1.77',
lib/unshortenit.py
+54 -51
View File
@@ -506,29 +506,14 @@ class UnshortenIt(object):
return uri, 0 return uri, 0
r = None r = None
def decrypt(str):
try:
from Cryptodome.Cipher import AES
except:
from Crypto.Cipher import AES
str = str.replace("_ppl_", "+").replace("_eqq_", "=").replace("_sll_", "/")
iv = b"\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0"
key = b"naphajU2usWUswec"
decoded = b64decode(str)
decoded = decoded + b'\0' * (len(decoded) % 16)
crypt_object = AES.new(key, AES.MODE_CBC, iv)
decrypted = b''
for p in range(0, len(decoded), 16):
decrypted += crypt_object.decrypt(decoded[p:p + 16]).replace(b'\0', b'')
return decrypted.decode('ascii')
if 'shield' in uri.split('/')[-2]: if 'shield' in uri.split('/')[-2]:
uri = decrypt(uri.split('/')[-1]) uri = decrypt_aes(uri.split('/')[-1], b"naphajU2usWUswec")
else: else:
if 'sb/' in uri or 'akv/' in uri or 'wss/' in uri or 'wsd/' in uri: if 'sb/' in uri or 'akv/' in uri or 'wss/' in uri or 'wsd/' in uri:
import datetime, hashlib import datetime, hashlib
from base64 import b64encode from base64 import b64encode
ip = urlopen('https://api.ipify.org/').read() # ip = urlopen('https://api.ipify.org/').read()
ip = b'31.220.1.77'
day = datetime.date.today().strftime('%Y%m%d') day = datetime.date.today().strftime('%Y%m%d')
if PY3: day = day.encode() if PY3: day = day.encode()
headers = { headers = {
@@ -536,9 +521,9 @@ class UnshortenIt(object):
} }
spl = uri.split('/') spl = uri.split('/')
spl[3] += '1' spl[3] += '1'
if spl[3] == 'wss1': if spl[3] in ['wss1', 'sb1']:
spl[4] = b64encode(spl[4].encode('utf-8')).decode('utf-8') spl[4] = b64encode(spl[4].encode('utf-8')).decode('utf-8')
uri = '/'.join(spl) uri = '/'.join(spl)
r = httptools.downloadpage(uri, timeout=self._timeout, headers=headers, follow_redirects=False, verify=False) r = httptools.downloadpage(uri, timeout=self._timeout, headers=headers, follow_redirects=False, verify=False)
if 'Wait 1 hour' in r.data: if 'Wait 1 hour' in r.data:
uri = '' uri = ''
@@ -656,22 +641,40 @@ class UnshortenIt(object):
if 'out_generator' in uri: if 'out_generator' in uri:
uri = re.findall('url=(.*)$', uri)[0] uri = re.findall('url=(.*)$', uri)[0]
elif '/decode/' in uri: elif '/decode/' in uri:
scheme, netloc, path, query, fragment = urlsplit(uri) uri = decrypt_aes(uri.split('/')[-1], b"whdbegdhsnchdbeh")
splitted = path.split('/')
splitted[1] = 'outlink' # scheme, netloc, path, query, fragment = urlsplit(uri)
r = httptools.downloadpage(uri, follow_redirects=False, post={'url': splitted[2]}) # splitted = path.split('/')
if 'location' in r.headers and r.headers['location']: # splitted[1] = 'outlink'
new_uri = r.headers['location'] # r = httptools.downloadpage(uri, follow_redirects=False, post={'url': splitted[2]})
else: # if 'location' in r.headers and r.headers['location']:
r = httptools.downloadpage(scheme + '://' + netloc + "/".join(splitted) + query + fragment, # new_uri = r.headers['location']
follow_redirects=False, post={'url': splitted[2]}) # else:
if 'location' in r.headers and r.headers['location']: # r = httptools.downloadpage(scheme + '://' + netloc + "/".join(splitted) + query + fragment,
new_uri = r.headers['location'] # follow_redirects=False, post={'url': splitted[2]})
if new_uri and new_uri != uri: # if 'location' in r.headers and r.headers['location']:
uri = new_uri # new_uri = r.headers['location']
# if new_uri and new_uri != uri:
# uri = new_uri
return uri, 200 return uri, 200
def decrypt_aes(text, key):
try:
from Cryptodome.Cipher import AES
except:
from Crypto.Cipher import AES
text = text.replace("_ppl_", "+").replace("_eqq_", "=").replace("_sll_", "/")
iv = b"\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0"
decoded = b64decode(text)
decoded = decoded + b'\0' * (len(decoded) % 16)
crypt_object = AES.new(key, AES.MODE_CBC, iv)
decrypted = b''
for p in range(0, len(decoded), 16):
decrypted += crypt_object.decrypt(decoded[p:p + 16]).replace(b'\0', b'')
return decrypted.decode('ascii')
def unwrap_30x_only(uri, timeout=10): def unwrap_30x_only(uri, timeout=10):
unshortener = UnshortenIt() unshortener = UnshortenIt()
uri, status = unshortener.unwrap_30x(uri, timeout=timeout) uri, status = unshortener.unwrap_30x(uri, timeout=timeout)
@@ -709,22 +712,22 @@ def findlinks(text):
text += '\n' + unshorten(matches[0])[0] text += '\n' + unshorten(matches[0])[0]
elif matches: elif matches:
# non threaded for webpdb # non threaded for webpdb
# for match in matches: for match in matches:
# sh = unshorten(match)[0] sh = unshorten(match)[0]
# text += '\n' + sh text += '\n' + sh
import sys # import sys
if sys.version_info[0] >= 3: # if sys.version_info[0] >= 3:
from concurrent import futures # from concurrent import futures
else: # else:
from concurrent_py2 import futures # from concurrent_py2 import futures
with futures.ThreadPoolExecutor() as executor: # with futures.ThreadPoolExecutor() as executor:
unshList = [executor.submit(unshorten, match) for match in matches] # unshList = [executor.submit(unshorten, match) for match in matches]
for link in futures.as_completed(unshList): # for link in futures.as_completed(unshList):
if link.result()[0] not in matches: # if link.result()[0] not in matches:
links = link.result()[0] # links = link.result()[0]
if type(links) == list: # if type(links) == list:
for l in links: # for l in links:
text += '\n' + l # text += '\n' + l
else: # else:
text += '\n' + str(link.result()[0]) # text += '\n' + str(link.result()[0])
return text return text
servers/backin.json
+7 -3
View File
@@ -4,12 +4,16 @@
"ignore_urls": [], "ignore_urls": [],
"patterns": [ "patterns": [
{ {
"pattern": "(backin.net/fastids/[0-9]+)", "pattern": "https?://(backin.net/fastid[a-z]+/[0-9]+)",
"url": "http://\\1" "url": "http://\\1"
}, },
{ {
"pattern": "backin.net/([a-zA-Z0-9]{10,})", "pattern": "https?://backin.net/([a-zA-Z0-9]{10,})",
"url": "\\1" "url": "http://backin.net/stream-\\1-500x400.html"
},
{
"pattern": "https?://backin.net/s/streams.php?s=([a-zA-Z0-9]{10,})",
"url": "http://backin.net/stream-\\1-500x400.html"
} }
] ]
}, },
servers/backin.py
+3 -3
View File
@@ -11,11 +11,11 @@ except ImportError:
def test_video_exists(page_url): def test_video_exists(page_url):
logger.debug("(page_url='%s')" % page_url) logger.debug("(page_url='%s')" % page_url)
if 'http://' in page_url: # fastids if 'fastid' in page_url: # fastid
page_url = httptools.downloadpage(page_url, follow_redirects=False, only_headers=True).headers['location'] page_url = httptools.downloadpage(page_url, follow_redirects=False, only_headers=True).headers['location']
page_url = scrapertools.find_single_match(page_url, 'backin.net/([a-zA-Z0-9]+)') page_url = "http://backin.net/stream-%s-500x400.html" % scrapertools.find_single_match(page_url, 'backin.net/([a-zA-Z0-9]+)')
global data global data
data = httptools.downloadpage("http://backin.net/stream-%s-500x400.html" % page_url).data data = httptools.downloadpage(page_url).data
if 'File Not Found' in data: if 'File Not Found' in data:
return False, config.get_localized_string(70449) % "backin" return False, config.get_localized_string(70449) % "backin"
servers/vidtome.json
+4 -4
View File
@@ -4,12 +4,12 @@
"ignore_urls": [], "ignore_urls": [],
"patterns": [ "patterns": [
{ {
"pattern": "(?:vidtome.stream|vidto.me)/(?!api)(?:embed-)?([A-z0-9]+)", "pattern": "https?://vidtome.host/(?!api)(?:embed-)?([A-z0-9]+)",
"url": "http://vidtome.stream/\\1.html" "url": "http://vidtome.host/\\1.html"
}, },
{ {
"pattern": "vidtome.stream/api/fastredirect/streaming\\.php\\?file_real=([A-z0-9]+)", "pattern": "https?://vidtome.host/api/fastredirect/streaming\\.php\\?file_real=([A-z0-9]+)",
"url": "http://vidtome.stream/api/fastredirect/streaming.php?file_real=\\1" "url": "http://vidtome.host/api/fastredirect/streaming.php?file_real=\\1"
} }
] ]
}, },
servers/vidtome.py
+2 -2
View File
@@ -1,6 +1,6 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
from core import httptools, scrapertools from core import httptools, scrapertools, servertools
from platformcode import logger, config from platformcode import logger, config
from lib import jsunpack from lib import jsunpack
@@ -21,7 +21,7 @@ def get_video_url(page_url, premium=False, user="", password="", video_password=
code = scrapertools.find_single_match(data, 'name="code" value="([^"]+)') code = scrapertools.find_single_match(data, 'name="code" value="([^"]+)')
hash = scrapertools.find_single_match(data, 'name="hash" value="([^"]+)') hash = scrapertools.find_single_match(data, 'name="hash" value="([^"]+)')
post = "op=download1&code=%s&hash=%s&imhuman=Proceed+to+video" %(code, hash) post = "op=download1&code=%s&hash=%s&imhuman=Proceed+to+video" %(code, hash)
data = httptools.downloadpage("http://vidtome.co/playvideos/%s" %code, post=post).data data = httptools.downloadpage("http://%s/playvideos/%s" % (servertools.get_server_host("vidtome")[0], code), post=post).data
packed = scrapertools.find_multiple_matches(data, r'(eval\s?\(function\(p,a,c,k,e,d\).*?\n)') packed = scrapertools.find_multiple_matches(data, r'(eval\s?\(function\(p,a,c,k,e,d\).*?\n)')
for p in packed: for p in packed:
data = jsunpack.unpack(p) data = jsunpack.unpack(p)