fixed timeout in mailing #30
This commit is contained in:
		
							parent
							
								
									8b15a45902
								
							
						
					
					
						commit
						d8028c4681
					
				|  | @ -31,7 +31,7 @@ class MailMessagePlugin(Plugin): | ||||||
|             self.send_mail(msg) |             self.send_mail(msg) | ||||||
| 
 | 
 | ||||||
|     def send_mail(self, msg: Message): |     def send_mail(self, msg: Message): | ||||||
|         logger.debug(f"Sending mail to {msg.receiver}") |         logger.debug(f"Sending mail to {msg.receiver} with subject {msg.subject}") | ||||||
|         if isinstance(msg.receiver, User): |         if isinstance(msg.receiver, User): | ||||||
|             if not msg.receiver.mail: |             if not msg.receiver.mail: | ||||||
|                 logger.warning("Could not send Mail, mail missing: {}".format(msg.receiver)) |                 logger.warning("Could not send Mail, mail missing: {}".format(msg.receiver)) | ||||||
|  | @ -41,18 +41,12 @@ class MailMessagePlugin(Plugin): | ||||||
|             recipients = userController.get_user_by_role(msg.receiver) |             recipients = userController.get_user_by_role(msg.receiver) | ||||||
| 
 | 
 | ||||||
|         mail = MIMEMultipart() |         mail = MIMEMultipart() | ||||||
|         try: |         mail["From"] = self.mail | ||||||
|             mail["From"] = self.mail |         mail["To"] = ", ".join(recipients) | ||||||
|             mail["To"] = ", ".join(recipients) |  | ||||||
|         except Exception as e: |  | ||||||
|             import traceback |  | ||||||
| 
 |  | ||||||
|             print(traceback.format_exc()) |  | ||||||
|         mail["Subject"] = msg.subject |         mail["Subject"] = msg.subject | ||||||
|         mail.attach(MIMEText(msg.message)) |         mail.attach(MIMEText(msg.message)) | ||||||
|         if not hasattr(self, "smtp"): |         with self.__connect() as smtp: | ||||||
|             self.__connect() |             smtp.sendmail(self.mail, recipients, mail.as_string()) | ||||||
|         self.smtp.sendmail(self.mail, recipients, mail.as_string()) |  | ||||||
| 
 | 
 | ||||||
|     def __connect(self): |     def __connect(self): | ||||||
|         if self.crypt == "SSL": |         if self.crypt == "SSL": | ||||||
|  | @ -63,3 +57,4 @@ class MailMessagePlugin(Plugin): | ||||||
|         else: |         else: | ||||||
|             raise ValueError("Invalid CRYPT given") |             raise ValueError("Invalid CRYPT given") | ||||||
|         self.smtp.login(self.user, self.password) |         self.smtp.login(self.user, self.password) | ||||||
|  |         return self.smtp | ||||||
|  |  | ||||||
		Loading…
	
		Reference in New Issue