add ua to db
This commit is contained in:
@@ -35,6 +35,7 @@ class ReserveResultPojo:
|
|||||||
created_at = None
|
created_at = None
|
||||||
validated_at = None
|
validated_at = None
|
||||||
proxy: str = None
|
proxy: str = None
|
||||||
|
ua: str = None
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def from_firestore_dict(source):
|
def from_firestore_dict(source):
|
||||||
@@ -129,6 +130,7 @@ class ReserveResultPojo:
|
|||||||
u'accepted': self.accepted,
|
u'accepted': self.accepted,
|
||||||
u'url_validated': self.url_validated,
|
u'url_validated': self.url_validated,
|
||||||
u'proxy': self.proxy,
|
u'proxy': self.proxy,
|
||||||
|
u'ua': self.ua,
|
||||||
}
|
}
|
||||||
|
|
||||||
return dest
|
return dest
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ class ContactPojo:
|
|||||||
position: int
|
position: int
|
||||||
store: str
|
store: str
|
||||||
note: str
|
note: str
|
||||||
|
ua: str
|
||||||
|
|
||||||
def __init__(self, phone_number: str, passport_number: str, last_name: str, first_name: str, mail: str,
|
def __init__(self, phone_number: str, passport_number: str, last_name: str, first_name: str, mail: str,
|
||||||
ccid: str = "",
|
ccid: str = "",
|
||||||
@@ -24,6 +25,7 @@ class ContactPojo:
|
|||||||
self.mail = mail
|
self.mail = mail
|
||||||
self.position = position
|
self.position = position
|
||||||
self.note = ""
|
self.note = ""
|
||||||
|
self.ua = ""
|
||||||
|
|
||||||
def to_firestore_dict(self):
|
def to_firestore_dict(self):
|
||||||
dest = {
|
dest = {
|
||||||
@@ -34,7 +36,8 @@ class ContactPojo:
|
|||||||
u'mail': self.mail,
|
u'mail': self.mail,
|
||||||
u'store': self.store,
|
u'store': self.store,
|
||||||
u'ccid': self.ccid,
|
u'ccid': self.ccid,
|
||||||
u'position': self.position
|
u'position': self.position,
|
||||||
|
u'ua': self.ua
|
||||||
}
|
}
|
||||||
|
|
||||||
return dest
|
return dest
|
||||||
|
|||||||
@@ -36,6 +36,7 @@ class Sender:
|
|||||||
result = ReserveResultPojo(type=status, phone=contact.phone, message=status.value, url=url,
|
result = ReserveResultPojo(type=status, phone=contact.phone, message=status.value, url=url,
|
||||||
firstName=contact.first_name, lastName=contact.last_name, email=contact.mail,
|
firstName=contact.first_name, lastName=contact.last_name, email=contact.mail,
|
||||||
passport=contact.passport, ccid=contact.ccid)
|
passport=contact.passport, ccid=contact.ccid)
|
||||||
|
result.ua = contact.ua
|
||||||
if "oxylabs" in self.proxy_to_use["http"]:
|
if "oxylabs" in self.proxy_to_use["http"]:
|
||||||
if "mob" in self.proxy_to_use["http"]:
|
if "mob" in self.proxy_to_use["http"]:
|
||||||
result.proxy = "oxylabs_mob"
|
result.proxy = "oxylabs_mob"
|
||||||
@@ -93,6 +94,7 @@ class Sender:
|
|||||||
# add to mongodb
|
# add to mongodb
|
||||||
self.logger.info(response.text)
|
self.logger.info(response.text)
|
||||||
self.logger.info("{}:{}".format(contact.mail, response.url))
|
self.logger.info("{}:{}".format(contact.mail, response.url))
|
||||||
|
contact.ua = js_data.ua
|
||||||
self.publish_message_to_queue(contact, status=PublishType.SUCCESS, url=response.url,
|
self.publish_message_to_queue(contact, status=PublishType.SUCCESS, url=response.url,
|
||||||
store_type=_selected_store)
|
store_type=_selected_store)
|
||||||
cookies_to_set = response.headers['set-cookie']
|
cookies_to_set = response.headers['set-cookie']
|
||||||
|
|||||||
Reference in New Issue
Block a user