111

wn/src/main.py

@@ -302,17 +302,18 @@ setTimeout(r=> {
                         # f.write(code + '\n\n' + get_random_location() + ';;' + c)
 
                 code1 = open('js_dom_run.js','r').read()
-                # with open('js_dom_run1.js', 'w', encoding='utf-8') as f:
-                #     f.write(code1 + '\n\n' + c)
+                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 = '11'
             # r = requests.get('http://127.0.0.1:5000/getinfo').json()['message']
             # r = requests.get('http://127.0.0.1:3001').json()
+            logger.info("start execute js")
+
             # 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,
-            logger.info("start execute js")
             p = subprocess.Popen(['node', 'src_run1.js', selectId, '11', token, proxy], stdin=subprocess.PIPE, stdout=subprocess.PIPE,
                                  stderr=subprocess.PIPE)
             output, err = p.communicate(timeout=10)
@@ -328,8 +329,8 @@ setTimeout(r=> {
             # )
             usedTime += 1
             # print(r)
-            xhr_url = r.pop('xhr_url')
-            xhr_res = r.pop('xhr_res')
+            # xhr_url = r.pop('xhr_url')
+            # xhr_res = r.pop('xhr_res')
             # print('xhr_url', xhr_url)
             # print('xhr_res', xhr_res)
             headers.update(r)