From 2449459a0857a642e6177480a28038c09ca69f8f Mon Sep 17 00:00:00 2001 From: Lei PAN Date: Tue, 30 Jan 2024 14:19:03 +0100 Subject: [PATCH] fix wrong proxy list --- queue_message/appointmentrequestsendor.py | 7 ++++--- workers/link_validator.py | 2 +- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/queue_message/appointmentrequestsendor.py b/queue_message/appointmentrequestsendor.py index 3cddad5..c73da19 100644 --- a/queue_message/appointmentrequestsendor.py +++ b/queue_message/appointmentrequestsendor.py @@ -98,13 +98,14 @@ class AppointmentRequestSendor(threading.Thread): def on_message(self, ch, method, properties, body): print(f" [x] Received {body}") - print("message count in queue is {}".format(self.cookiesPublisher.message_count())) + _message_count = self.cookiesPublisher.message_count() + print("message count in queue is {}".format(_message_count)) sender = Sender(body.decode("UTF-8"), cookiesPublisher=self.cookiesPublisher, - proxy_to_use=random.choice(PROXY_LIST_DE)) + proxy_to_use=random.choice(self.proxy_to_use_list)) self.contact_list = filter_contacts(self.contact_list) # remove already booked contacts random.shuffle(self.contact_list) - if len(self.contact_list) > 0 and is_open(): + if len(self.contact_list) > 0 and is_open() and _message_count > 40: captchaResultGetter = CaptchaResultGetter() print("contact number is {}".format(len(self.contact_list))) self.contact_list = filter_contacts(self.contact_list) diff --git a/workers/link_validator.py b/workers/link_validator.py index 6fdc315..dbfe8b3 100644 --- a/workers/link_validator.py +++ b/workers/link_validator.py @@ -135,7 +135,7 @@ def validate_with_FR_ip(): _fr_proxy_to_use = random.choice(PROXY_LIST_FR) receiver = LinkValidator(link_to_validate_list=_link_list_to_click, cookiesPublisher=cookiesPublisher, proxy_to_use=_fr_proxy_to_use, - queue_to_listen=_queue_name, ip_country="FR", limit=10) + queue_to_listen=_queue_name, ip_country="FR", limit=40) receiver.set_up_connection() receiver.listen_to_queue(receiver.on_message) pass