mirror of
https://github.com/hjdhnx/dr_py.git
synced 2024-10-18 02:48:26 -05:00
190 lines
7.3 KiB
Python
190 lines
7.3 KiB
Python
#!/usr/bin/env python3
|
||
# -*- coding: utf-8 -*-
|
||
# File : parser.py
|
||
# Author: DaShenHan&道长-----先苦后甜，任凭晚风拂柳颜------
|
||
# Date : 2022/8/25
|
||
|
||
import os
|
||
import shutil
|
||
|
||
import requests
|
||
from flask import make_response, jsonify,render_template_string
|
||
from functools import partial # 这玩意儿能锁定一个函数的参数
|
||
import subprocess
|
||
subprocess.Popen = partial(subprocess.Popen, encoding="utf-8") # 固定写法
|
||
# 解决execjs执行js时产生的乱码报错，需要在导入该模块之前，让Popen的encoding参数锁定为utf-8
|
||
# import execjs
|
||
import js2py
|
||
from js2py.base import JsObjectWrapper,PyJsString,PyJsObject
|
||
|
||
# os.environ["EXECJS_RUNTIME"] = "JScript"
|
||
# print(execjs.get().name)
|
||
|
||
def runJScode(jscode,loader=None,ctx=None):
|
||
if loader is None:
|
||
if ctx is None:
|
||
ctx = {}
|
||
loader = js2py.EvalJs(ctx,enable_require=False) # enable_require启用require关键字,会自动获取系统nodejs环境
|
||
loader.execute(jscode)
|
||
return loader, jscode
|
||
|
||
def runJs(jsPath, before='', after='', ctx=None):
|
||
# base_path = os.path.dirname(os.path.abspath(__file__)) # 当前文件所在目录
|
||
# base_path = os.path.dirname(os.getcwd()) # 当前主程序所在工作目录
|
||
# base_path = os.path.dirname(os.path.abspath('.')) # 上级目录
|
||
# js_code = 'var rule={}'
|
||
if ctx is None:
|
||
ctx = {}
|
||
base_path = os.path.dirname(os.path.abspath(os.path.dirname(__file__))) # 上级目录
|
||
if str(jsPath).startswith('http'):
|
||
js_name = jsPath.split('/')[-1]
|
||
cache_path = os.path.join(base_path, f'cache/{js_name}')
|
||
if not os.path.exists(cache_path):
|
||
try:
|
||
print(f'开始缓存远程规则:{js_name},来源{jsPath}')
|
||
js_code = requests.get(url=jsPath,timeout=3).text
|
||
# js_code = requests.get(jsPath).text
|
||
with open(cache_path,mode='w+',encoding='utf-8') as f:
|
||
f.write(js_code)
|
||
except Exception as e:
|
||
print('发生了错误:',e)
|
||
return None, ''
|
||
else:
|
||
with open(cache_path, 'r', encoding='UTF-8') as fp:
|
||
js_code = fp.read()
|
||
else:
|
||
js_path = os.path.join(base_path, jsPath)
|
||
if not os.path.exists(js_path):
|
||
return None,''
|
||
js_name = jsPath.split('/')[-1]
|
||
cache_path = os.path.join(base_path, f'cache/{js_name}')
|
||
if not str(jsPath).startswith('js/') and not os.path.exists(cache_path) and os.path.exists(js_path):
|
||
shutil.copy(js_path,cache_path) # 本地txt目录的复制过去凑数,实际不使用
|
||
# print(js_path)
|
||
with open(js_path, 'r', encoding='UTF-8') as fp:
|
||
js_code = fp.read()
|
||
# print(js_code)
|
||
jscode_to_run = js_code
|
||
# print(jscode_to_run)
|
||
if before:
|
||
jscode_to_run = before + jscode_to_run
|
||
if after:
|
||
jscode_to_run += after
|
||
loader = js2py.EvalJs(ctx)
|
||
return runJScode(jscode_to_run,loader)
|
||
# loader = execjs.compile(jscode_to_run)
|
||
# print(jscode_to_run)
|
||
# loader.execute(jscode_to_run)
|
||
# return loader,js_code
|
||
|
||
def toJs(jsPath,jsRoot='cache',env=None):
|
||
base_path = os.path.dirname(os.path.abspath(os.path.dirname(__file__))) # 上级目录
|
||
js_path = os.path.join(base_path, f'{jsRoot}/{jsPath}')
|
||
# print(js_path)
|
||
if not os.path.exists(js_path):
|
||
return jsonify({'code': -2, 'msg': f'非法猥亵,文件不存在'})
|
||
with open(js_path, 'r', encoding='UTF-8') as fp:
|
||
js = fp.read()
|
||
if env:
|
||
# js = render_template_string(js,env=env)
|
||
for k in env:
|
||
# print(f'${k}', f'{env[k]}')
|
||
if f'${k}' in js:
|
||
js = js.replace(f'${k}', f'{env[k]}')
|
||
# js = render_template_string(js,**env)
|
||
response = make_response(js)
|
||
response.headers['Content-Type'] = 'text/javascript; charset=utf-8'
|
||
return response
|
||
|
||
def getJs(jsPath,jsRoot='cache'):
|
||
base_path = os.path.dirname(os.path.abspath(os.path.dirname(__file__))) # 上级目录
|
||
js_path = os.path.join(base_path, f'{jsRoot}/{jsPath}')
|
||
# print(js_path)
|
||
if not os.path.exists(js_path):
|
||
return ''
|
||
with open(js_path, 'r', encoding='UTF-8') as fp:
|
||
js = fp.read()
|
||
return js
|
||
|
||
def toHtml(jsPath):
|
||
base_path = os.path.dirname(os.path.abspath(os.path.dirname(__file__))) # 上级目录
|
||
js_path = os.path.join(base_path, f'cache/{jsPath}')
|
||
with open(js_path, 'r', encoding='UTF-8') as fp:
|
||
js = fp.read()
|
||
response = make_response(js)
|
||
response.headers['Content-Type'] = 'text/html; charset=utf-8'
|
||
return response
|
||
|
||
def runPy(pyPath):
|
||
# base_path = os.path.dirname(os.path.abspath(__file__)) # 当前文件所在目录
|
||
# base_path = os.path.dirname(os.getcwd()) # 当前主程序所在工作目录
|
||
# base_path = os.path.dirname(os.path.abspath('.')) # 上级目录
|
||
# js_code = 'var rule={}'
|
||
if pyPath and not str(pyPath).endswith('.py'):
|
||
pyPath += '.py'
|
||
base_path = os.path.dirname(os.path.abspath(os.path.dirname(__file__))) # 上级目录
|
||
if str(pyPath).startswith('http'):
|
||
py_name = pyPath.split('/')[-1]
|
||
cache_path = os.path.join(base_path, f'cache/{py_name}')
|
||
print('远程免嗅:',py_name)
|
||
if not os.path.exists(cache_path):
|
||
try:
|
||
py_code = requests.get(pyPath,timeout=2).text
|
||
with open(cache_path,mode='w+',encoding='utf-8') as f:
|
||
f.write(py_code)
|
||
except Exception as e:
|
||
print('发生了错误:',e)
|
||
return None
|
||
else:
|
||
with open(cache_path, 'r', encoding='UTF-8') as fp:
|
||
py_code = fp.read()
|
||
else:
|
||
py_root = os.path.join(base_path, 'py/')
|
||
os.makedirs(py_root,exist_ok=True)
|
||
py_path = os.path.join(py_root, pyPath)
|
||
if not os.path.exists(py_path):
|
||
return ''
|
||
with open(py_path, 'r', encoding='UTF-8') as fp:
|
||
py_code = fp.read()
|
||
# print(js_code)
|
||
return py_code
|
||
|
||
def covert_demo():
|
||
ctx = {'py_sum':sum,'requests':requests}
|
||
loader = js2py.EvalJs(ctx)
|
||
# loader.execute('var a=py_sum(2,3);function f(x) {return x*x} var b=[a,"5"];var c={"a":a};')
|
||
# loader.execute('var a=py_sum(2,3);function f(x) {return x*x}')
|
||
loader.execute('function f(x) {return x*x};var a=py_sum([2,3]);var b=[a,5];var c={"a":a};')
|
||
f = loader.f
|
||
print(f(8))
|
||
print(f.toString())
|
||
print(loader.eval('py_sum(new Array(1, 2, 3))'))
|
||
print(loader.eval('py_sum([1, 2])'))
|
||
a = loader.a
|
||
print(type(a),a)
|
||
b = loader.b
|
||
b.push(6)
|
||
print(type(b),b)
|
||
b = b.to_list()
|
||
print(type(b),b)
|
||
c = loader.c
|
||
print(type(c),c)
|
||
c = c.to_dict()
|
||
print(type(c), c)
|
||
# CryptoJS = js2py.require('crypto-js')
|
||
# print(type(CryptoJS))
|
||
# print(js2py.require('underscore'))
|
||
JSON = js2py.eval_js('JSON')
|
||
r = JSON.parse('[{"a":1}]')
|
||
print(type(r),r)
|
||
print(r[0].a)
|
||
print(loader.eval('r = requests.get("https://www.baidu.com/");r.encoding = "utf-8";r.text'))
|
||
# 下面是错误用法,没有loader环境没法正确eval_js,有loader用eval不需要eval_js
|
||
# print(js2py.eval_js('r = requests.get("https://www.baidu.com/");r.encoding = "utf-8";r.text'))
|
||
with open('../js/蓝莓影视.js',encoding='utf-8') as f:
|
||
yk = f.read()
|
||
print(yk)
|
||
|
||
|
||
if __name__ == '__main__':
|
||
covert_demo() |