support pissmail

This commit is contained in:
2023-10-11 00:09:58 +02:00
parent c45886cbc3
commit 4ca367129d
2 changed files with 29 additions and 31 deletions
+19 -4
View File
@@ -19,6 +19,7 @@ DOMAIN_GMX_US = "gmx.us"
DOMAIN_ONET = "onet.pl" DOMAIN_ONET = "onet.pl"
DOMAIN_NAVER = "naver.com" DOMAIN_NAVER = "naver.com"
DOMAIN_INBOX_LV = "inbox.lv" DOMAIN_INBOX_LV = "inbox.lv"
DOMAIN_PISS_MAIL = "pissmail.com"
AOL_IMAP_SERVER = "imap.aol.com" AOL_IMAP_SERVER = "imap.aol.com"
IMAP_SERVER_163 = "imap.163.com" IMAP_SERVER_163 = "imap.163.com"
@@ -34,15 +35,27 @@ BTVM_NE_JP = "imap.btvm.ne.jp"
SEREVER_GMAIL = "imap.gmail.com" SEREVER_GMAIL = "imap.gmail.com"
SERVER_IMAGE_ONET = "imap.poczta.onet.pl" SERVER_IMAGE_ONET = "imap.poczta.onet.pl"
SERVER_GMX = "imap.gmx.com" SERVER_GMX = "imap.gmx.com"
SERVER_PISS_MAIL = "mail.pissmail.com"
INBOX_LV = "mail.inbox.lv" INBOX_LV = "mail.inbox.lv"
def show_folders(imap) -> list: def show_folders(imap) -> list:
folders = [] folders = []
for i in imap.list()[1]: isImapClient = isinstance(imap, IMAPClient)
l = i.decode().split(' "/" ') if not isImapClient:
folders.append(l[1]) for i in imap.list()[1]:
return folders l = i.decode().split(' "/" ')
if len(l)>1:
folders.append(l[1])
if len(folders)==0:
folders.append('INBOX')
return folders
else:
list = imap.list_folders()
for i in list:
name = i[-1]
folders.append(name)
return folders
def create_imap(login: str): def create_imap(login: str):
@@ -78,6 +91,8 @@ def create_imap(login: str):
imap = imaplib.IMAP4_SSL(NAVER_SERVER, port=993) imap = imaplib.IMAP4_SSL(NAVER_SERVER, port=993)
elif DOMAIN_INBOX_LV in login: elif DOMAIN_INBOX_LV in login:
imap = imaplib.IMAP4_SSL(INBOX_LV, port=993) imap = imaplib.IMAP4_SSL(INBOX_LV, port=993)
elif DOMAIN_PISS_MAIL in login:
imap = imaplib.IMAP4_SSL(SERVER_PISS_MAIL, port=993)
else: else:
imap = imaplib.IMAP4_SSL(AOL_IMAP_SERVER) imap = imaplib.IMAP4_SSL(AOL_IMAP_SERVER)
return imap return imap
Regular → Executable
+10 -27
View File
@@ -11,7 +11,7 @@ from imapclient import IMAPClient
from src.db.mongo_manager import MONGO_STORE_MANAGER from src.db.mongo_manager import MONGO_STORE_MANAGER
from src.logs.AppLogging import init_logger from src.logs.AppLogging import init_logger
from src.mail.mail_constants import DOMAIN_HOTMAIL, create_imap from src.mail.mail_constants import DOMAIN_HOTMAIL, create_imap, show_folders
from src.pojo.mail.mail_pojo import MailPojo, MailAddress from src.pojo.mail.mail_pojo import MailPojo, MailAddress
from src.utils.excel_reader import ExcelHelper from src.utils.excel_reader import ExcelHelper
from src.utils.timeutiles import is_time_between from src.utils.timeutiles import is_time_between
@@ -24,7 +24,8 @@ HERMES_EMAIL = "no-reply@hermes.com"
EMAIL_ADDRESS_REGEX = r'\b[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Z|a-z]{2,7}\b' EMAIL_ADDRESS_REGEX = r'\b[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Z|a-z]{2,7}\b'
date_format = "%d-%b-%Y" # DD-Mon-YYYY e.g., 3-Mar-2014 date_format = "%d-%b-%Y" # DD-Mon-YYYY e.g., 3-Mar-2014
REDIRECTION_MAILS = "appointment2022@aol.com, chenpeijun@aol.com,hongjiang176@aol.com,ciyuexie@aol.com,rutger.62@aol.com,ciccidaniel@aol.com,armasgoodman@aol.com,wknd.gemerine@aol.com,rafmail1981@aol.com,tonovichivanenaki@aol.com,hetland.ari@aol.com,mateusiversen@aol.com,lacerdaraffaello@aol.com,anasida76@aol.com,liamolinari@aol.com,sen70zib@aol.com,mezeiderrick@aol.com,stanisl49avchic@aol.com,damcvrobaneuron@aol.com,suyzanna_fleona@aol.com,dxealing.dissa@aol.com,hogg.karen@aol.com,obocharovamarina@aol.com,buchholzjohann@aol.com,orn.cecchini@aol.com,percivaltorgersen@aol.com,candalgudrun@aol.com,filimonis.76@aol.com,bengann_100@aol.com,axelhanne@aol.com,tiffanylarochelle@aol.com,nicoleta.r@aol.com,eichenbaum.1963@aol.com,kotensasharev@aol.com,samognat32@aol.com,edem_headshot@aol.com,kozmakuzmich1960@aol.com,damonsvensson@aol.com,anders.riva@aol.com,caiminwei123@gmail.com,yulingguo086@gmail.com,yingxiaolu086@gmail.com,lijiazhen0035@gmail.com,fangp370@gmail.com,huangyayu10086@gmail.com,fuziyuan110@gmail.com,xinyingdu886@gmail.com,yasiaforever.1971@aol.com,lukaszfidalgo@aol.com,zaichi29@aol.com,prostotakitak.1974@aol.com,mo90nroe@aol.com,blonde.87@aol.com,dimidrol.1969@aol.com" REDIRECTION_MAILS = "appointment2022@aol.com, chenpeijun@aol.com,hongjiang176@aol.com,ciyuexie@aol.com,rutger.62@aol.com,ciccidaniel@aol.com,armasgoodman@aol.com,wknd.gemerine@aol.com,rafmail1981@aol.com,tonovichivanenaki@aol.com,hetland.ari@aol.com,mateusiversen@aol.com,lacerdaraffaello@aol.com,anasida76@aol.com,liamolinari@aol.com,sen70zib@aol.com,mezeiderrick@aol.com,stanisl49avchic@aol.com,damcvrobaneuron@aol.com,suyzanna_fleona@aol.com,dxealing.dissa@aol.com,hogg.karen@aol.com,obocharovamarina@aol.com,buchholzjohann@aol.com,orn.cecchini@aol.com,percivaltorgersen@aol.com,candalgudrun@aol.com,filimonis.76@aol.com,bengann_100@aol.com,axelhanne@aol.com,tiffanylarochelle@aol.com,nicoleta.r@aol.com,eichenbaum.1963@aol.com,kotensasharev@aol.com,samognat32@aol.com,edem_headshot@aol.com,kozmakuzmich1960@aol.com,damonsvensson@aol.com,anders.riva@aol.com,caiminwei123@gmail.com,yulingguo086@gmail.com,yingxiaolu086@gmail.com,lijiazhen0035@gmail.com,fangp370@gmail.com,huangyayu10086@gmail.com,fuziyuan110@gmail.com,xinyingdu886@gmail.com,yasiaforever.1971@aol.com,lukaszfidalgo@aol.com,zaichi29@aol.com,prostotakitak.1974@aol.com,mo90nroe@aol.com,blonde.87@aol.com,dimidrol.1969@aol.com,duwei1998@gmx.com"
def check_email_address(email): def check_email_address(email):
# pass the regular expression # pass the regular expression
@@ -56,22 +57,6 @@ class MailReader():
self.login = login self.login = login
self.password = password self.password = password
@staticmethod
def show_folders(imap) -> list:
folders = []
isImapClient = isinstance(imap, IMAPClient)
if not isImapClient:
for i in imap.list()[1]:
l = i.decode().split(' "/" ')
folders.append(l[1])
return folders
else:
list = imap.list_folders()
for i in list:
name = i[-1]
folders.append(name)
return folders
def read_emails(self, mails_messages: list) -> list: def read_emails(self, mails_messages: list) -> list:
imap = create_imap(self.login) imap = create_imap(self.login)
isImapClient = isinstance(imap, IMAPClient) isImapClient = isinstance(imap, IMAPClient)
@@ -87,7 +72,7 @@ class MailReader():
mail_list = [] mail_list = []
print("read mails from {}".format(self.login)) print("read mails from {}".format(self.login))
if not isImapClient: if not isImapClient:
folder_list = self.show_folders(imap) folder_list = show_folders(imap)
for folder in folder_list: for folder in folder_list:
print("folder is {}".format(folder)) print("folder is {}".format(folder))
mail_list.extend(self._get_messages_from_folder(imap, subject=VALIDATION_URL_SUBJECT_fr, mail_list.extend(self._get_messages_from_folder(imap, subject=VALIDATION_URL_SUBJECT_fr,
@@ -95,7 +80,7 @@ class MailReader():
mail_list.extend(self._get_messages_from_folder(imap, subject=VALIDATION_URL_SUBJECT_EN, mail_list.extend(self._get_messages_from_folder(imap, subject=VALIDATION_URL_SUBJECT_EN,
folder=folder)) folder=folder))
else: else:
folder_list = self.show_folders(imap) folder_list = show_folders(imap)
for folder in folder_list: for folder in folder_list:
print("folder is " + folder) print("folder is " + folder)
mail_list.extend(self._get_messages_from_folder_for_imapclient(imap, folder=folder)) mail_list.extend(self._get_messages_from_folder_for_imapclient(imap, folder=folder))
@@ -206,8 +191,6 @@ def need_to_valid_url(url: str, successful_items) -> bool:
parts = url.split('/') parts = url.split('/')
id = parts[5] id = parts[5]
if len(id) == 6: if len(id) == 6:
if id == "CS93VB":
print("found")
for item in successful_items: for item in successful_items:
if item.id == id: if item.id == id:
if item.url_validated is not None: if item.url_validated is not None:
@@ -231,8 +214,6 @@ def need_to_check_email(mail: str, successful_items) -> bool:
# get all the item with the current mail # get all the item with the current mail
filtered_items = list(filter(lambda item: item.email == mail, successful_items)) filtered_items = list(filter(lambda item: item.email == mail, successful_items))
# has validated value # has validated value
if mail == "lakrishstarko@aol.com":
print("found")
if len(filtered_items) > 0: if len(filtered_items) > 0:
validated_items = list(filter( validated_items = list(filter(
lambda filtered_item: filtered_item.url_validated is not None and filtered_item.url_validated is True, lambda filtered_item: filtered_item.url_validated is not None and filtered_item.url_validated is True,
@@ -259,15 +240,17 @@ def need_to_check_email(mail: str, successful_items) -> bool:
def read_mails(): def read_mails():
# check time before start checking emails # check time before start checking emails
if is_time_between(time(7, 30), time(19, 30)): if is_time_between(time(7, 30), time(23, 30)):
# get email address # get email address
mail_list = MONGO_STORE_MANAGER.get_destination_emails() mail_list = MONGO_STORE_MANAGER.get_destination_emails()
# excel_reader = ExcelHelper() # excel_reader = ExcelHelper()
# mail_list =excel_reader.read_email_pojo(file_name="/Users/lpan/Desktop/hotmail_list.xlsx") # mail_list =excel_reader.read_email_pojo(file_name="/Users/lpan/Desktop/hotmail_list.xlsx")
# mail_address1 = MailAddress(mail="appointment2022@aol.com", password="gyilpmvyyvlcaviq") # mail_address1 = MailAddress(mail="appointment2022@aol.com", password="gyilpmvyyvlcaviq")
# mail_address1 = MailAddress(mail="chenpeijun@aol.com", password="ytifuwguknzifqyb") # mail_address1 = MailAddress(mail="chenpeijun@aol.com", password="ytifuwguknzifqyb")
# # mail_address3 = MailAddress(mail="ciyuexie@aol.com", password="czezlmmyypokdfce") # mail_address3 = MailAddress(mail="ciyuexie@aol.com", password="czezlmmyypokdfce")
# mail_list = [mail_address1] # mail_address3 = MailAddress(mail="shenpeiyun@naver.com", password="Rdv@20222021")
# mail_address3 = MailAddress(mail="panleicim@pissmail.com", password="PANLei+1984")
# mail_list = [mail_address3]
successful_items = MONGO_STORE_MANAGER.get_all_successful_items_for_day() successful_items = MONGO_STORE_MANAGER.get_all_successful_items_for_day()
mails_messages = [] mails_messages = []
with ThreadPoolExecutor(max_workers=200) as executor: with ThreadPoolExecutor(max_workers=200) as executor: