Update app.py

app.py

@@ -40,8 +40,8 @@ def r(e, t):
     m = 3 % y["row"]
     v = 7 % y["column"]
     w = y["matrix"][m][v]
-    b = i(f) + o(w)
-    x = i(w) - o(f)
+    b =  i(f) + o(w)
+    x =  i(w) - o(f)
     return [s(a(i(f), o(f))), s(a(i(g), o(g))), s(a(i(w), o(w))), s(a(b, x))]
 
 
@@ -88,7 +88,7 @@ def get_hash(str):
     return hashlib.md5(str.encode()).hexdigest()
 
 
-def get_change_ip():
+async def get_change_ip():
     m = random.randint(0, 255)
     n = random.randint(0, 255)
     x = random.randint(0, 255)
@@ -98,7 +98,7 @@ def get_change_ip():
 
 
 # 创建随机UA
-def get_user_agent():
+async def get_user_agent():
     tmp1 = random.randrange(90, 120)
     tmp2 = random.randrange(5200, 5500)
     tmp3 = random.randrange(90, 180)
@@ -118,7 +118,7 @@ basicRequestHeaders_1 = {
     "content-type": "application/json"
 }
 
-def get_image_d(pid, device_id, f, change_ip):
+async def get_image_d(pid, device_id, f, change_ip):
     url = "https://pik-d.bilivo.top/"
     payload = {
         "pid": pid,
@@ -136,7 +136,7 @@ def get_image_d(pid, device_id, f, change_ip):
 
 
 # 安全验证-登录
-def init(client_id, device_id, User_Agent, mail, change_ip):
+async def init(client_id, device_id, User_Agent, mail, change_ip):
     url = f"https://user.mypikpak.net/v1/shield/captcha/init"
     payload = {
         "action": "POST:/v1/auth/signin",
@@ -158,7 +158,7 @@ def init(client_id, device_id, User_Agent, mail, change_ip):
     return json.loads(response.text)
 
 
-def get_image(xid, change_ip):
+async def get_image(xid, change_ip):
     url = "http://user.mypikpak.com/pzzl/gen"
     header = {'X-Forwarded-For': str(change_ip)}
     params = {
@@ -176,7 +176,7 @@ def get_image(xid, change_ip):
     json_data = img_jj(frames, int(SELECT_ID), pid)
     f = json_data['f']
     npac = json_data['ca']
-    d = get_image_d(pid, xid, f, change_ip)
+    d = await get_image_d(pid, xid, f, change_ip)
     params = {
         'pid': pid,
         'deviceid': xid,
@@ -194,7 +194,7 @@ def get_image(xid, change_ip):
     return result
 
 
-def sign_in(device_id, username, password, client_id, captcha_token, change_ip):
+async def sign_in(device_id, username, password, client_id, captcha_token, change_ip):
     url = "https://user.pikpak.me/v1/auth/signin"
 
     headers = {
@@ -454,7 +454,7 @@ def corp_image(img):
     new_img = img[row_top:raw_down + 1, col_top:col_down + 1, 0:3]
     return new_img
 
-def get_new_token(result, xid, captcha, change_ip):
+async def get_new_token(result, xid, captcha, change_ip):
     traceid = result['traceid']
     pid = result['pid']
     header = {'X-Forwarded-For': str(change_ip)}
@@ -468,7 +468,6 @@ def get_new_token(result, xid, captcha, change_ip):
 # ---------------滑块验证---------------
 app = Quart(__name__)
 
-
 @app.route('/', methods=['GET'])
 @route_cors(allow_origin='*')
 async def home():
@@ -480,25 +479,25 @@ async def home():
 @app.route('/login', methods=['POST'])
 @route_cors(allow_origin='*')
 async def login():
-    data = request.get_json()
+    data = await request.get_json()
     if not data:
         return jsonify({"error": "没有指定参数"}), 400
     email = data.get('userName')
     password = data.get('passWord')
     try:
-        change_ip = get_change_ip()
+        change_ip = await get_change_ip()
         client_id1 = "YNxT9w7GMdWvEOKa"
         device_id = str(uuid.uuid4()).replace("-", "")
-        user_agent = get_user_agent()
-        action_init = init(client_id1, device_id, user_agent, email, change_ip)
+        user_agent = await get_user_agent()
+        action_init = await init(client_id1, device_id, user_agent, email, change_ip)
         captcha_token = action_init["captcha_token"]
         while True:
-            img_info = get_image(device_id, change_ip)
+            img_info = await get_image(device_id, change_ip)
             if img_info['response_data']['result'] == 'accept':
                 print('验证通过!!!')
                 break
-        token_data = get_new_token(img_info, device_id, captcha_token, change_ip)
-        login_data = sign_in(device_id, email, password, client_id1, token_data['captcha_token'], change_ip)
+        token_data = await get_new_token(img_info, device_id, captcha_token, change_ip)
+        login_data = await sign_in(device_id, email, password, client_id1, token_data['captcha_token'], change_ip)
         return jsonify({"code": 200, "data": login_data, "msg": 'success'}), 200
     except Exception as e:
         print(e)
@@ -512,5 +511,3 @@ config.bind = ["0.0.0.0:8090"]
 if __name__ == '__main__':
     import asyncio
     asyncio.run(serve(app, config))
-
-