update

Author: Tom Softreck

.env.example

@@ -0,0 +1,11 @@
+# SMTP Configuration
+SMTP_SERVER=smtp.gmail.com
+SMTP_PORT=587
+SMTP_USER=your-email@gmail.com
+SMTP_PASS=your-app-specific-password
+ALERT_EMAIL=recipient@example.com
+
+# Note: For Gmail, you'll need to:
+# 1. Enable 2-factor authentication
+# 2. Create an App Password: https://myaccount.google.com/apppasswords
+# 3. Use the generated app password for SMTP_PASS

advanced_example.yaml

@@ -0,0 +1,50 @@
+# Advanced Example with Multiple Routes
+routes:
+  # Route 1: Simple timer with transform
+  - name: "greeting_route"
+    from: "timer:10s"  # Run every 10 seconds
+    
+    processors:
+      - type: "transform"
+        template: "Greeting from DialogChain at {{now().isoformat() if 'now' in globals() else 'current_time'}}!"
+    
+    to: "log:info"
+
+  # Route 2: Message transformation
+  - name: "transform_route"
+    from: "timer:15s"  # Run every 15 seconds
+    
+    processors:
+      - type: "transform"
+        template: |
+          {
+            "message": "This is a test message",
+            "status": "success",
+            "count": 1
+          }
+      
+      - type: "transform"
+        template: "Processed message: {{message}} (Status: {{status}}, Count: {{count}})"
+    
+    to: "log:info"
+
+  # Route 3: Conditional logging
+  - name: "conditional_route"
+    from: "timer:20s"  # Run every 20 seconds
+    
+    processors:
+      - type: "transform"
+        template: "test_status=failed coverage=75"
+      
+      # This filter will only pass through if condition is true
+      - type: "filter"
+        condition: "{{test_status}} == 'failed' or {{coverage}} < 80"
+      
+      - type: "transform"
+        template: "ALERT: Test {{test_status}} with {{coverage}}% coverage (below threshold)"
+    
+    to: "log:warn"
+
+# Environment variables (commented out as they're not needed for this example)
+# env_vars:
+#   - VARIABLE_NAME

check_smtp.py

@@ -0,0 +1,74 @@
+#!/usr/bin/env python3
+"""
+Simple script to test SMTP connection using environment variables.
+"""
+import os
+import smtplib
+from email.mime.text import MIMEText
+from email.mime.multipart import MIMEMultipart
+from dotenv import load_dotenv
+
+def check_smtp():
+    # Load environment variables from .env file
+    load_dotenv()
+    
+    # Required environment variables
+    required_vars = [
+        'SMTP_SERVER',
+        'SMTP_PORT',
+        'SMTP_USER',
+        'SMTP_PASS',
+        'ALERT_EMAIL'
+    ]
+    
+    # Check if all required variables are set
+    missing_vars = [var for var in required_vars if not os.getenv(var)]
+    if missing_vars:
+        print(f"❌ Missing required environment variables: {', '.join(missing_vars)}")
+        print("\nPlease add them to your .env file:")
+        for var in missing_vars:
+            print(f"{var}=your_value_here")
+        return False
+    
+    # Get SMTP settings
+    smtp_server = os.getenv('SMTP_SERVER')
+    smtp_port = int(os.getenv('SMTP_PORT', '587'))
+    smtp_user = os.getenv('SMTP_USER')
+    smtp_pass = os.getenv('SMTP_PASS')
+    to_email = os.getenv('ALERT_EMAIL')
+    
+    print(f"🔧 Testing SMTP connection to {smtp_server}:{smtp_port}")
+    print(f"🔑 Using username: {smtp_user}")
+    
+    try:
+        # Create message
+        msg = MIMEMultipart()
+        msg['From'] = smtp_user
+        msg['To'] = to_email
+        msg['Subject'] = 'SMTP Test from DialogChain'
+        
+        body = """
+        This is a test email to verify SMTP configuration.
+        
+        If you're reading this, the SMTP configuration is working correctly!
+        """
+        msg.attach(MIMEText(body, 'plain'))
+        
+        # Connect to server and send email
+        with smtplib.SMTP(smtp_server, smtp_port) as server:
+            server.starttls()
+            print(f"🔒 Attempting to authenticate with {smtp_user}:{'*' * len(smtp_pass)}")
+            server.login(smtp_user, smtp_pass)
+            print("✅ Successfully authenticated with SMTP server")
+            
+            print(f"📤 Sending test email to {to_email}...")
+            server.send_message(msg)
+            print("✅ Test email sent successfully!")
+            return True
+            
+    except Exception as e:
+        print(f"❌ Error: {e}")
+        return False
+
+if __name__ == "__main__":
+    check_smtp()

config.yaml

@@ -0,0 +1,30 @@
+# Camera Processing Routes
+routes:
+  - name: "front_door_camera"
+    from: "rtsp://{{CAMERA_USER}}:{{CAMERA_PASS}}@{{CAMERA_IP}}/stream1"
+    processors:
+      - type: "external"
+        command: "python -m ultralytics_processor"
+        input_format: "frame_stream"
+        output_format: "json"
+        config:
+          confidence_threshold: 0.6
+          target_objects: ["person", "car"]
+
+      - type: "filter"
+        condition: "{{confidence}} > 0.7"
+
+      - type: "transform"
+        template: "Person detected at {{position}} ({{confidence}}%)"
+
+    to: "smtp://{{SMTP_SERVER}}:{{SMTP_PORT}}?user={{SMTP_USER}}&password={{SMTP_PASS}}&to={{ALERT_EMAIL}}"
+
+env_vars:
+  - CAMERA_USER
+  - CAMERA_PASS  
+  - CAMERA_IP
+  - SMTP_SERVER
+  - SMTP_PORT
+  - SMTP_USER
+  - SMTP_PASS
+  - ALERT_EMAIL

docs/api.md

@@ -2,7 +2,7 @@
 
 ## Core Classes
 
-### CamelRouterEngine
+### DialogChainEngine
 
 Main routing engine that orchestrates the processing pipeline.