update

Author: Tom Softreck

examples/email_test.yaml examples/emaill.yamlexamples/email_test.yaml renamed to examples/emaill.yaml

@@ -8,6 +8,8 @@
 import argparse
 import sys
 from typing import Dict, Any, Optional
+from dialogchain.utils.logger import setup_logger
+logger = setup_logger(__name__)
 
 def list_printers() -> Dict[str, Dict[str, Any]]:
     """List all available printers."""
@@ -32,7 +34,7 @@ def print_text(text: str, printer_name: Optional[str] = None) -> int:
             return 1
 
         if printer_name and printer_name not in printers:
-            print(f"❌ Printer '{printer_name}' not found")
+            logger.error(f"❌ Printer '{printer_name}' not found")
             print("\nAvailable printers:")
             for name, attrs in printers.items():
                 print(f"- {name} ({attrs.get('device-uri', 'no URI')})")
@@ -51,7 +53,7 @@ def print_text(text: str, printer_name: Optional[str] = None) -> int:
         return 0
 
     except cups.IPPError as e:
-        print(f"❌ Print error: {e}")
+        logger.error(f"❌ Print error: {e}")
         return 1
 
 def main() -> int:
@@ -139,7 +141,7 @@ def main() -> int:
                         content = f.read()
                     print(f"📄 Printing file: {args.file}")
                 except Exception as e:
-                    print(f"❌ Error reading file: {e}")
+                    logger.error(f"❌ Error reading file: {e}")
                     return 1
             else:
                 content = args.text

scripts/printer_scanner.py

@@ -10,6 +10,8 @@
 from email.mime.text import MIMEText
 from email.mime.multipart import MIMEMultipart
 from datetime import datetime
+from dialogchain.utils.logger import setup_logger
+logger = setup_logger(__name__)
 
 def test_smtp_connection(server, port, username, password, recipient):
     """Test SMTP connection and send a test email."""
@@ -34,7 +36,7 @@ def test_smtp_connection(server, port, username, password, recipient):
                 print("✅ Email sent successfully using STARTTLS")
                 return True
         except Exception as e:
-            print(f"❌ STARTTLS failed: {e}")
+            logger.error(f"❌ STARTTLS failed: {e}")
 
         # Try SSL (port 465)
         try:
@@ -46,12 +48,12 @@ def test_smtp_connection(server, port, username, password, recipient):
                 print("✅ Email sent successfully using SSL")
                 return True
         except Exception as e:
-            print(f"❌ SSL failed: {e}")
+            logger.error(f"❌ SSL failed: {e}")
 
         return False
 
     except Exception as e:
-        print(f"❌ Error: {e}")
+        logger.error(f"❌ Error: {e}")
         return False
 
 if __name__ == "__main__":

scripts/test_smtp.py

@@ -0,0 +1,49 @@
+import smtplib
+import ssl
+from datetime import datetime
+import os
+from dotenv import load_dotenv
+from dialogchain.utils.logger import setup_logger
+logger = setup_logger(__name__)
+
+# Load environment variables from .env file
+load_dotenv()
+
+# SMTP Configuration
+SMTP_SERVER = os.getenv('SMTP_SERVER')
+SMTP_PORT = int(os.getenv('SMTP_PORT', '465'))
+SMTP_USER = os.getenv('SMTP_USER')
+SMTP_PASS = os.getenv('SMTP_PASS')
+TO_EMAIL = os.getenv('ALERT_EMAIL')
+
+def test_smtp_connection():
+    print(f"Testing SMTP connection to {SMTP_SERVER}:{SMTP_PORT}")
+    print(f"Username: {SMTP_USER}")
+    
+    try:
+        # Create SSL context
+        context = ssl.create_default_context()
+        
+        print("\nAttempting to connect with SSL...")
+        with smtplib.SMTP_SSL(SMTP_SERVER, SMTP_PORT, context=context) as server:
+            print("✅ Connected to SMTP server with SSL")
+            
+            print(f"Authenticating as {SMTP_USER}...")
+            server.login(SMTP_USER, SMTP_PASS)
+            print("✅ Authentication successful")
+            
+            # Test sending an email
+            message = f"Subject: SMTP Test\n\nThis is a test email sent at {datetime.now()}"
+            server.sendmail(SMTP_USER, TO_EMAIL, message)
+            print(f"✅ Test email sent to {TO_EMAIL}")
+            
+    except Exception as e:
+        logger.error(f"❌ Error: {e}")
+        print(f"Error type: {type(e).__name__}")
+        if hasattr(e, 'smtp_code'):
+            print(f"SMTP Code: {e.smtp_code}")
+        if hasattr(e, 'smtp_error'):
+            print(f"SMTP Error: {e.smtp_error}")
+
+if __name__ == "__main__":
+    test_smtp_connection()

scripts/test_smtp_connection.py

@@ -1,6 +1,7 @@
 import asyncio
 import json
 import smtplib
+import ssl
 import aiohttp
 import cv2
 import os
@@ -216,22 +217,30 @@ async def send(self, message: Any) -> None:
             # Format message body
             if isinstance(message, dict):
                 body = json.dumps(message, indent=2)
-                print(f"ℹ️  Message is a dictionary, converting to JSON")
+                logger.info(f"ℹ️  Message is a dictionary, converting to JSON")
             else:
                 body = str(message)
-                print(f"ℹ️  Message is a string, length: {len(body)} characters")
+                logger.info(f"ℹ️  Message is a string, length: {len(body)} characters")
 
             msg.attach(MIMEText(body, "plain"))
-            print(f"✉️  Message prepared, connecting to SMTP server...")
+            logger.info(f"✉️  Message prepared, connecting to SMTP server...")
 
             # SMTP connection and sending
-            server = smtplib.SMTP(self.server, self.port, timeout=10)
-            print(f"🔌 Connected to SMTP server: {self.server}:{self.port}")
+            logger.info(f"🔌 Connecting to SMTP server: {self.server}:{self.port}")
 
-            server.starttls()
-            logger.info("🔒 Started TLS encryption")
+            # Use SMTP_SSL for port 465, regular SMTP for other ports with STARTTLS
+            if self.port == 465:
+                logger.info("🔒 Using SSL/TLS (port 465)")
+                context = ssl.create_default_context()
+                server = smtplib.SMTP_SSL(self.server, self.port, timeout=10, context=context)
+                logger.info("✅ Established SSL connection")
+            else:
+                logger.info("🔓 Using STARTTLS (port 587 or other)")
+                server = smtplib.SMTP(self.server, self.port, timeout=10)
+                server.starttls()
+                logger.info("✅ STARTTLS negotiation successful")
 
-            print(f"🔑 Authenticating user: {self.user}")
+            logger.info(f"🔑 Authenticating user: {self.user}")
             server.login(self.user, self.password)
             logger.info("✅ Authentication successful")
 
@@ -244,25 +253,25 @@ async def send(self, message: Any) -> None:
 
                 try:
                     msg["To"] = clean_recipient
-                    print(f"📤 Sending to: {clean_recipient}")
+                    logger.info(f"📤 Sending to: {clean_recipient}")
                     server.send_message(msg)
                     del msg["To"]
                     success_count += 1
-                    print(f"✅ Successfully sent to: {clean_recipient}")
+                    logger.info(f"✅ Successfully sent to: {clean_recipient}")
                 except Exception as send_error:
-                    print(f"❌ Failed to send to {clean_recipient}: {send_error}")
+                    logger.error(f"❌ Failed to send to {clean_recipient}: {send_error}")
 
             server.quit()
-            print(f"📬 Email sending complete. Successfully sent to {success_count}/{len(self.recipients)} recipients")
+            logger.info(f"📬 Email sending complete. Successfully sent to {success_count}/{len(self.recipients)} recipients")
 
         except smtplib.SMTPException as smtp_error:
-            print(f"❌ SMTP Error: {smtp_error}")
-            print(f"   SMTP Code: {getattr(smtp_error, 'smtp_code', 'N/A')}")
-            print(f"   SMTP Error: {getattr(smtp_error, 'smtp_error', 'N/A')}")
+            logger.error(f"❌ SMTP Error: {smtp_error}")
+            logger.error(f"   SMTP Code: {getattr(smtp_error, 'smtp_code', 'N/A')}")
+            logger.error(f"   SMTP Error: {getattr(smtp_error, 'smtp_error', 'N/A')}")
         except Exception as e:
             import traceback
-            print(f"❌ Unexpected error: {e}")
-            logger.info("📝 Stack trace:")
+            logger.error(f"❌ Unexpected error: {e}")
+            logger.error("📝 Stack trace:")
             traceback.print_exc()
 
 
@@ -279,13 +288,13 @@ async def send(self, message: Any) -> None:
                 data = message if isinstance(message, dict) else {"data": message}
                 async with session.post(self.uri, json=data) as response:
                     if response.status == 200:
-                        print(f"🌐 HTTP sent to {self.uri}")
+                        logger.info(f"🌐 HTTP sent to {self.uri}")
                     else:
-                        print(
+                        logger.error(
                             f"❌ HTTP error {response.status}: {await response.text()}"
                         )
         except Exception as e:
-            print(f"❌ HTTP destination error: {e}")
+            logger.error(f"❌ HTTP destination error: {e}")
 
 
 class MQTTDestination(Destination):
@@ -302,10 +311,10 @@ async def send(self, message: Any) -> None:
         try:
             # Note: Would need asyncio-mqtt library
             payload = json.dumps(message) if isinstance(message, dict) else str(message)
-            print(f"📡 MQTT sent to {self.broker}:{self.port}/{self.topic}")
+            logger.info(f"📡 MQTT sent to {self.broker}:{self.port}/{self.topic}")
             # Implementation would use actual MQTT client
         except Exception as e:
-            print(f"❌ MQTT error: {e}")
+            logger.error(f"❌ MQTT error: {e}")
 
 
 class FileDestination(Destination):
@@ -321,9 +330,9 @@ async def send(self, message: Any) -> None:
             content = json.dumps(message) if isinstance(message, dict) else str(message)
             with open(self.path, "a") as f:
                 f.write(f"{datetime.now().isoformat()}: {content}\n")
-            print(f"📄 Written to {self.path}")
+            logger.info(f"📄 Written to {self.path}")
         except Exception as e:
-            print(f"❌ File destination error: {e}")
+            logger.error(f"❌ File destination error: {e}")
 
 
 class LogDestination(Destination):
@@ -351,7 +360,7 @@ async def send(self, message: Any) -> None:
                 with open(self.log_file, "a", encoding="utf-8") as f:
                     f.write(log_msg + "\n")
             except Exception as e:
-                print(f"❌ Log file error: {e}")
+                logger.error(f"❌ Log file error: {e}")
 
 
 class GRPCDestination(Destination):
@@ -364,6 +373,6 @@ async def send(self, message: Any) -> None:
         """Send gRPC message"""
         try:
             # Implementation would depend on specific gRPC service
-            print(f"🔗 gRPC sent to {self.uri}")
+            logger.info(f"🔗 gRPC sent to {self.uri}")
         except Exception as e:
-            print(f"❌ gRPC destination error: {e}")
+            logger.error(f"❌ gRPC destination error: {e}")