fix: decode From and To headers in email forwarding

.gitignore

@@ -1 +1,2 @@
-config.json
+config.json
+*.log

README.md

@@ -38,6 +38,7 @@ pip install pysocks
 
 ```json
 {
+  "log": "output.log",
   "check_interval": 60,
   "accounts": [
     {
@@ -70,6 +71,7 @@ pip install pysocks
 
 ### 配置项说明
 
+- `log`: 日志文件路径。
 - `check_interval`: 检查邮件的时间间隔，单位为秒。
 - `accounts`: 配置多个邮箱账户。
   - `email`: 邮箱地址。

config-example.json

@@ -1,4 +1,5 @@
 {
+    "log": "output.log",
     "accounts": [
         {
             "enabled": false,

main.py

@@ -6,6 +6,7 @@ from email.mime.multipart import MIMEMultipart
 from email.mime.text import MIMEText
 from email.utils import parseaddr
 import time
+import datetime
 import logging
 import socks
 import socket
@@ -38,9 +39,19 @@ def set_proxy(proxy_config):
     socks.setdefaultproxy(socks.PROXY_TYPE_SOCKS5, proxy_config['server'], proxy_config['port'])
     socket.socket = socks.socksocket
 
-def setup_logging():
+def setup_logging(filename):
-    logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
     logger = logging.getLogger()
+    logger.setLevel('DEBUG')
+    BASIC_FORMAT = "%(asctime)s >> %(levelname)s - %(message)s"
+    DATE_FORMAT = '%Y-%m-%d %H:%M:%S'
+    formatter = logging.Formatter(BASIC_FORMAT, DATE_FORMAT)
+    chlr = logging.StreamHandler()
+    chlr.setFormatter(formatter)
+    chlr.setLevel('INFO')
+    fhlr = logging.FileHandler(filename)
+    fhlr.setFormatter(formatter)
+    logger.addHandler(chlr)
+    logger.addHandler(fhlr)
     return logger
 
 def get_unforwarded_emails(account_config, logger):
@@ -73,7 +84,8 @@ def get_unforwarded_emails(account_config, logger):
                 if 'Forwarded' not in msg['Subject']:
                     emails.append((email_id, msg))
     imap.logout()
-    logger.info(f"Retrieved {len(emails)} new emails from {account_config['email']}")
+    if len(emails) > 0:
+        logger.info(f"Retrieved {len(emails)} new emails from {account_config['email']}")
     return emails
 
 def forward_emails(account_config, emails, logger):
@@ -92,9 +104,13 @@ def forward_emails(account_config, emails, logger):
     
     for email_id, original_msg in emails:
         for recipient in account_config['forward']['to']:
+            from_name, from_address = parseaddr(original_msg['From'])
+            from_name = decode_mime_words(from_name)
+            to_name, to_address = parseaddr(original_msg['To'])
+            to_name = decode_mime_words(to_name)
             msg = MIMEMultipart('mixed')
-            msg['From'] = account_config['email']
+            msg['From'] = f"{from_name} ({from_address}) via Forwarder <{account_config['email']}>"
-            msg['To'] = recipient
+            msg['To'] = f"{to_name} ({to_address}) via Forwarder <{recipient}>"
             original_subject = decode_mime_words(original_msg['Subject'])
             msg['Subject'] = original_subject
             
@@ -129,13 +145,13 @@ def forward_emails(account_config, emails, logger):
                 msg.attach(attachment)
             
             smtp.sendmail(account_config['email'], recipient, msg.as_string())
-            logger.info(f"Forwarded email {original_subject} to {recipient}")
+            logger.info(f"Forwarded email {original_subject} from {account_config['email']} to {recipient}")
     
     smtp.quit()
 
 def main():
-    logger = setup_logging()
     config = load_config()
+    logger = setup_logging(config['log'])
     
     while True:
         for account in config['accounts']:
@@ -144,13 +160,10 @@ def main():
                     emails = get_unforwarded_emails(account, logger)
                     if emails:
                         forward_emails(account, emails, logger)
-                    else:
-                        logger.info(f"No new emails to forward for {account['email']}.")
                 except Exception as e:
                     logger.error(f"Error processing account {account['email']}: {str(e)}")
-            else:
-                logger.info(f"Account {account['email']} is disabled.")
         
+        logger.info(datetime.datetime.now().strftime("Check finished at %Y-%m-%d %H:%M:%S"))
         time.sleep(config.get('check_interval', 60))
 
 if __name__ == "__main__":