panleicim/appointment_tool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

multi instance works

Browse Source
This commit is contained in:
Lei PAN
2022-04-12 17:53:06 +02:00
parent b3a8e0f5dc
commit 2fdd7f9b38
2 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
commandor_page.py
+10 -8
View File
@@ -84,8 +84,8 @@ class CommandorPage:
self.logger.info("will set thread event") self.logger.info("will set thread event")
self.thread_event.set() self.thread_event.set()
# wait for the sms for 20 seconds # wait for the sms for 20 seconds
while not self.is_finished: # while not self.is_finished:
time.sleep(2) # time.sleep(2)
self.is_finished = True self.is_finished = True
if self.current_gsm_modem: if self.current_gsm_modem:
self.logger.info("will close used modem") self.logger.info("will close used modem")
@@ -125,6 +125,7 @@ class CommandorPage:
self.reset_air_plan_mode() self.reset_air_plan_mode()
def _run(self, e: threading.Event, proxy): def _run(self, e: threading.Event, proxy):
print("will start browser")
self.on_success_listener = on_success self.on_success_listener = on_success
# reset otp_value to None # reset otp_value to None
self.otp_value = None self.otp_value = None
@@ -150,6 +151,7 @@ class CommandorPage:
# wait for sms_code field # wait for sms_code field
# self.clickOnValidBtn() # self.clickOnValidBtn()
self.thread_event = e self.thread_event = e
self.set_up_sms_listener()
otp_input = self.page.locator(OTP_FIELD_ID) otp_input = self.page.locator(OTP_FIELD_ID)
otp_input.wait_for(state='visible', timeout=TIME_OUT) otp_input.wait_for(state='visible', timeout=TIME_OUT)
event_is_set = e.wait() event_is_set = e.wait()
@@ -196,12 +198,12 @@ class CommandorPage:
self.browser.close() self.browser.close()
return None return None
def start_page(self, proxy) -> threading.Event: def start_page(self, proxy):
self.set_up_sms_listener()
e = threading.Event() e = threading.Event()
t = threading.Thread(target=self._run, args=(e, proxy)) # t = threading.Thread(target=self._run, args=(e, proxy))
t.start() # t.start()
return e self._run(e, proxy)
# return e
def _on_page_loaded(self): def _on_page_loaded(self):
self.logger.info("page loaded") self.logger.info("page loaded")
@@ -322,7 +324,7 @@ def launch_page(ready_for_otp) -> threading.Event:
first_name="xingzhen", first_name="xingzhen",
mail="ColbyPatel653@gmail.com", ccid="", position=0) mail="ColbyPatel653@gmail.com", ccid="", position=0)
page = CommandorPage() page = CommandorPage()
return page.start_page(proxy, contact, ready_for_otp, on_sucess=on_success) return page.start_page(proxy)
def wait_for_otp(event: threading.Event, commandor: CommandorPage): def wait_for_otp(event: threading.Event, commandor: CommandorPage):
main.py
+2 -2
View File
@@ -66,8 +66,8 @@ def init_modems() -> list:
def start_book(): def start_book():
start_slot_number = 1 start_slot_number = 13
end_slot_number = 21 end_slot_number = 13
slot_list = list(range(start_slot_number, end_slot_number + 1)) slot_list = list(range(start_slot_number, end_slot_number + 1))
random.shuffle(slot_list) random.shuffle(slot_list)
for i in slot_list: for i in slot_list: