|
|
import os |
|
|
import re |
|
|
import sys |
|
|
from enum import Enum |
|
|
from random import randint |
|
|
from time import time |
|
|
from urllib.parse import parse_qs, quote_plus, unquote, urlencode, urlparse |
|
|
|
|
|
import requests |
|
|
from cacheout import Cache |
|
|
from flask import Flask, abort, jsonify, make_response, redirect, request |
|
|
|
|
|
cache = Cache(maxsize=1024) |
|
|
app = Flask(__name__) |
|
|
ORIGIN = 'https://lanzoux.com' |
|
|
RAND_IP = '' |
|
|
|
|
|
|
|
|
class Client(Enum): |
|
|
PC = 0 |
|
|
MOBILE = 1 |
|
|
|
|
|
|
|
|
def change_ip(): |
|
|
global RAND_IP |
|
|
RAND_IP = '.'.join(str(randint(1, 254)) for _ in range(4)) |
|
|
|
|
|
|
|
|
def gen_headers(client: Client): |
|
|
return { |
|
|
'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8', |
|
|
'Referer': ORIGIN, |
|
|
'User-Agent': [ |
|
|
'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/89.0.4389.114 Safari/537.36', |
|
|
'Mozilla/5.0 (Linux; Android 8.0; Pixel 2 Build/OPD3.170816.012) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/89.0.4389.114 Mobile Safari/537.36' |
|
|
][client.value], |
|
|
'X-Forwarded-For': RAND_IP |
|
|
} |
|
|
|
|
|
|
|
|
def get(url, client: Client): |
|
|
return requests.get(url, headers=gen_headers(client), allow_redirects=False) |
|
|
|
|
|
|
|
|
def post_data(url, data, client: Client): |
|
|
return requests.post(url, data, headers={ |
|
|
**gen_headers(client), |
|
|
'Content-Type': 'application/x-www-form-urlencoded' |
|
|
}) |
|
|
|
|
|
|
|
|
def find_all(pattern, text): |
|
|
return re.finditer(pattern, text, re.DOTALL | re.MULTILINE) |
|
|
|
|
|
|
|
|
def find_first(pattern, text): |
|
|
match = re.findall(pattern, text, re.DOTALL | re.MULTILINE) |
|
|
if match: |
|
|
return match[0] |
|
|
|
|
|
def _oO0OO0O(OO0O0O0O): |
|
|
import re as _0x1 |
|
|
|
|
|
def _0x2(_0x3): |
|
|
def _0x4(_0x5): |
|
|
_0x10 = '' |
|
|
for _0x6 in _0x5: _0x10 += chr(_0x6) |
|
|
return _0x10 |
|
|
|
|
|
_0x11 = [40, 39, 40, 63, 58, 92, 92, 46, 124, 91, 94, 39, 92, 92, 93, 41, 42, 39, 124, 34, 40, 63, 58, 92, 92, 46, 124, 91, 94, 34, 92, 92, 93, 41, 42, 34, 41] |
|
|
_0x7 = _0x4(_0x11) |
|
|
|
|
|
_0x8 = [] |
|
|
_0x12 = 0 |
|
|
|
|
|
def _0x9(_0xa): |
|
|
nonlocal _0x12 |
|
|
_0x8.append(_0xa.group(0)) |
|
|
_0x13 = f"__{RAND_IP}_%d__" % _0x12 |
|
|
_0x12 += 1 |
|
|
return _0x13 |
|
|
|
|
|
_0xb = _0x1.sub(_0x7, _0x9, _0x3, flags=_0x1.VERBOSE | _0x1.DOTALL) |
|
|
_0x14 = [47, 47, 46, 42, 63, 36, 124, 47, 92, 42, 46, 42, 63, 92, 42, 47] |
|
|
_0xc = _0x4(_0x14) |
|
|
_0xd = _0x1.sub(_0xc, '', _0xb, flags=_0x1.MULTILINE | _0x1.DOTALL) |
|
|
|
|
|
_0x15 = 0 |
|
|
while _0x15 < len(_0x8): |
|
|
_0xf = _0x8[_0x15] |
|
|
_0xd = _0xd.replace(f"__{RAND_IP}_%d__" % _0x15, _0xf) |
|
|
_0x15 += 1 |
|
|
|
|
|
return _0xd |
|
|
return _0x2(OO0O0O0O) |
|
|
|
|
|
def get_url(fid: str, client: Client, pwd=None): |
|
|
def get_fake_url(text, params): |
|
|
m_url = find_first(r"^\s*?[^/]+?{.*?url\s*?:\s*['\"](.*?php.*?)'", text) |
|
|
result = post_data(f'{ORIGIN}/{m_url}', params, client).json() |
|
|
return f"{result['dom']}/file/{result['url']}" |
|
|
|
|
|
if client == Client.PC: |
|
|
text = _oO0OO0O(get(f'{ORIGIN}/{fid}', client).text) |
|
|
if pwd: |
|
|
old_ver = find_first(r"^\s*?[^/]+?data *?: *?'([^']+?)'", text) |
|
|
if old_ver: |
|
|
params = old_ver + pwd |
|
|
else: |
|
|
for m in find_all(r"^\s*?[^/]+? ([^\d\s][\$\w]+? *?=.+?);", text): |
|
|
try: |
|
|
exec(m.group(1)) |
|
|
except Exception: |
|
|
pass |
|
|
for m in find_all(r"^\s*?[^/]+?data *?: *?({.+?})", text): |
|
|
try: |
|
|
data = eval(m.group(1)) |
|
|
if len(data.get('sign')) > 10: |
|
|
break |
|
|
except Exception: |
|
|
pass |
|
|
params = urlencode(data, quote_via=quote_plus) |
|
|
else: |
|
|
fn = find_first(r'iframe.+?src=\"([^\"]{20,}?)\"', text) |
|
|
text = _oO0OO0O(get(f'{ORIGIN}/{fn}', client).text) |
|
|
|
|
|
for m in find_all(r"^\s*?[^/]+? ([^\d\s][\$\w]+? *?=.+?);", text): |
|
|
try: |
|
|
exec(m.group(1)) |
|
|
except Exception: |
|
|
pass |
|
|
|
|
|
data = eval(find_first(r"^\s*?[^/]+?data *?: *?({.+?})", text)) |
|
|
params = urlencode(data, quote_via=quote_plus) |
|
|
|
|
|
fake_url = get_fake_url(text, params) |
|
|
|
|
|
else: |
|
|
text = _oO0OO0O(get(f'{ORIGIN}/{fid}', client).text) |
|
|
fid_with_params = find_first(r"[^/\n;]+? *?= *?['\"]/?tp/([^'\"]+?)['\"]", text) |
|
|
text = _oO0OO0O(get(f'{ORIGIN}/tp/{fid_with_params}', client).text) |
|
|
if pwd: |
|
|
for m in find_all(r"^\s*?[^/]+? ([^\d\s][\$\w]+? *?=.+?);", text): |
|
|
try: |
|
|
exec(m.group(1)) |
|
|
except Exception: |
|
|
pass |
|
|
|
|
|
params = eval(find_first(r"^\s*?[^/]+? *?data *?: *?({.+?})", text)) |
|
|
fake_url = get_fake_url(text, params) |
|
|
else: |
|
|
url_pre = find_first(r"^\s*?[^/]+? *?= *?'(https?://[^']+?)'", text) |
|
|
url_suf = find_first(r"^\s*?[^/]+?[$\w\s]+? *?= *?'(\?[^']+?)'", text) |
|
|
fake_url = url_pre + url_suf |
|
|
|
|
|
return get(fake_url, client).headers['location'] |
|
|
|
|
|
|
|
|
def fmt_size(num, suffix='B'): |
|
|
for unit in ['', 'K', 'M', 'G', 'T', 'P', 'E', 'Z']: |
|
|
if abs(num) < 1024.0: |
|
|
return "%3.1f%s%s" % (num, unit, suffix) |
|
|
num /= 1024.0 |
|
|
return "%.1f%s%s" % (num, 'Y', suffix) |
|
|
|
|
|
|
|
|
def get_ttl(url): |
|
|
e = parse_qs(urlparse(url).query).get('e', [time() + 600])[0] |
|
|
return int(e) - int(time()) - 60 |
|
|
|
|
|
|
|
|
def get_full_info(cache_key, ttl, url): |
|
|
info = cache.get(cache_key) |
|
|
if info: |
|
|
print(f'hit cache: {info}') |
|
|
return info |
|
|
|
|
|
headers = requests.head(url, allow_redirects=False).headers |
|
|
info = { |
|
|
'name': unquote(headers.get('Content-Disposition').split('filename=')[-1].strip()), |
|
|
'size': fmt_size(int(headers.get('Content-Length'))), |
|
|
'url': url, |
|
|
} |
|
|
cache.set(cache_key, info, ttl=ttl) |
|
|
return info |
|
|
|
|
|
|
|
|
def gen_json_response(code, msg, extra={}): |
|
|
return make_response(jsonify({ |
|
|
'code': code, |
|
|
'msg': msg, |
|
|
**extra |
|
|
})) |
|
|
|
|
|
|
|
|
@app.route('/', defaults={'path': ''}) |
|
|
@app.route('/<path:path>') |
|
|
def catch_all(path): |
|
|
url = request.args.get('url', '') |
|
|
fid = url.split('/')[-1] |
|
|
if not re.match(r"[\w]{4,}.*?", fid): |
|
|
return gen_json_response( |
|
|
-1, |
|
|
'invalid link', |
|
|
{ |
|
|
'examples': [ |
|
|
f'{request.base_url}?url={ORIGIN}/ifbCQ2u5gxxa&type=down', |
|
|
f'{request.base_url}?url={ORIGIN}/i7tit9c&pwd=6svq&type=json', |
|
|
] |
|
|
} |
|
|
) |
|
|
|
|
|
pwd = request.args.get('pwd') |
|
|
accept_type = request.args.get('type') |
|
|
def respond(url, ttl=None): |
|
|
if accept_type == 'down': |
|
|
return redirect(url) |
|
|
else: |
|
|
return gen_json_response( |
|
|
200, |
|
|
'success', |
|
|
{'data': get_full_info(f'{fid}/{pwd}/info', ttl, url)} |
|
|
) |
|
|
|
|
|
cache_key = f'{fid}/{pwd}/url' |
|
|
url = cache.get(cache_key) |
|
|
if url: |
|
|
print(f'hit cache: {url}') |
|
|
return respond(url) |
|
|
|
|
|
change_ip() |
|
|
errors = [] |
|
|
for client in Client: |
|
|
try: |
|
|
url = get_url(fid, client, pwd) |
|
|
|
|
|
|
|
|
|
|
|
ttl = get_ttl(url) |
|
|
cache.set(cache_key, url, ttl=ttl) |
|
|
return respond(url, ttl) |
|
|
except Exception as e: |
|
|
errors.append(e) |
|
|
pass |
|
|
|
|
|
abort(500, errors) |
|
|
|
|
|
|
|
|
@app.errorhandler(Exception) |
|
|
def server_error(e): |
|
|
return gen_json_response( |
|
|
-2, |
|
|
f'Link does not match pwd, or LanZouCloud has changed their webpage. Errors: {e}' |
|
|
) |
|
|
|
|
|
|
|
|
@app.after_request |
|
|
def cors(response): |
|
|
response.headers['Access-Control-Allow-Origin'] = '*' |
|
|
return response |
|
|
|
|
|
|
|
|
def test(): |
|
|
def request(fid, client: Client, pwd=None): |
|
|
print(f'fid={fid}, client={client}, pwd={pwd}') |
|
|
print(get_url(fid, client, pwd)) |
|
|
print('--------------------------------------') |
|
|
|
|
|
for fid, pwd in { |
|
|
'iDuSh22faxqj': '6q1d', |
|
|
'ifbCQ2u5gxxa': None, |
|
|
'i7tit9c': '6svq', |
|
|
'i4wk2oh': None, |
|
|
'iRujgdfrkza': None, |
|
|
'dkbdv7': None, |
|
|
}.items(): |
|
|
for c in Client: |
|
|
request(fid, c, pwd) |
|
|
|
|
|
|
|
|
if __name__ == '__main__': |
|
|
port = int(os.getenv('PORT', '7860')) |
|
|
|
|
|
|
|
|
app.run(host='0.0.0.0', port=port) |
|
|
|
