wn test

b6/src/jetblue.py

@@ -58,6 +58,7 @@ headers = {
 
 success = 0
 total = 0
+token = ''
 while True:
     r = requests.get('http://ymx-lcc.unififi.com/header/task/pull/headerB6?brush_name=test')
     if platform.uname().system != 'Darwin':
@@ -98,7 +99,6 @@ while True:
 
             selectId = random.choice(list(envs))
             # selectId = 'a74b38e7115cf4d1b1f6976c'
-
             if  usedTime > 5:
                 c = session.get('https://www.jetblue.com/js/src/jb-74873.js', insecure_skip_verify=True).text
                 m5 = md5(c)
@@ -133,14 +133,14 @@ while True:
                 with open('js_dom_run1.js', 'w', encoding='utf-8') as f:
                     f.write(code1 + '\n\n' + c)
             t1 = time.time()
-            token = list(db.token_shape.aggregate( [ {'$match': {'update_time':{'$gte': int(time.time() * 1000) - 60*60*12}}}, { '$sample': { 'size': 1 } } ] ))[0]['_id']
+            # token = list(db.token_shape.aggregate( [ {'$match': {'update_time':{'$gte': int(time.time() * 1000) - 60*60*12}}}, { '$sample': { 'size': 1 } } ] ))[0]['_id']
             # token = '11'
             # r = requests.get('http://127.0.0.1:5000/getinfo').json()['message']
             # r = requests.get('http://127.0.0.1:3001').json()
-            p = subprocess.Popen(['node', 'js_dom_run1.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
+            # p = subprocess.Popen(['node', 'js_dom_run1.js', selectId, '11'], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
             # p = subprocess.Popen(['node', 'src_run_chrome_105.js', selectId, '11', token], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
             # p = subprocess.Popen(['node', 'src_run_company_chrome.js', selectId, '11', token], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
-            # p = subprocess.Popen(['node', 'src_run1.js', selectId, '11', token], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
+            p = subprocess.Popen(['node', 'src_run1.js', selectId, '11', token], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
                                  stderr=subprocess.PIPE)
             output, err = p.communicate(timeout=10)
             tmp = ''