python-dotenv
This commit is contained in:
parent
71869cf458
commit
b2e4b85205
|
|
@ -1,55 +0,0 @@
|
||||||
import sys
|
|
||||||
from flask import Flask, request, jsonify
|
|
||||||
import smtplib
|
|
||||||
import base64
|
|
||||||
import gzip
|
|
||||||
import logging
|
|
||||||
import os
|
|
||||||
|
|
||||||
# Python-Version prüfen
|
|
||||||
if sys.version_info < (3, 12):
|
|
||||||
raise RuntimeError("Python 3.12 oder höher erforderlich")
|
|
||||||
|
|
||||||
app = Flask(__name__)
|
|
||||||
logging.basicConfig(level=logging.INFO)
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
# Konfiguration
|
|
||||||
SMTP_HOST = "postfix" # MailCow Postfix-Container
|
|
||||||
SMTP_PORT = 25 # Fest auf Port 25 ohne TLS
|
|
||||||
API_TOKEN = os.environ.get('API_TOKEN', 'your-api-token') # Muss mit Lambda übereinstimmen
|
|
||||||
|
|
||||||
@app.route('/process/<domain>', methods=['POST'])
|
|
||||||
def process_email(domain):
|
|
||||||
# Authentifizierung via Bearer-Token
|
|
||||||
auth_header = request.headers.get('Authorization')
|
|
||||||
if not auth_header or auth_header != f'Bearer {API_TOKEN}':
|
|
||||||
return jsonify({'error': 'Unauthorized'}), 401
|
|
||||||
|
|
||||||
data = request.get_json()
|
|
||||||
request_id = data.get('request_id')
|
|
||||||
email_content = data.get('email_content')
|
|
||||||
compressed = data.get('compressed', False)
|
|
||||||
|
|
||||||
logger.info(f"[{request_id}] Processing email for domain: {domain}")
|
|
||||||
|
|
||||||
try:
|
|
||||||
# Entkomprimieren, falls komprimiert
|
|
||||||
if compressed:
|
|
||||||
email_bytes = base64.b64decode(email_content)
|
|
||||||
email_content = gzip.decompress(email_bytes).decode('utf-8')
|
|
||||||
else:
|
|
||||||
email_content = base64.b64decode(email_content).decode('utf-8')
|
|
||||||
|
|
||||||
# An Postfix lokal weiterleiten (Port 25, kein TLS)
|
|
||||||
with smtplib.SMTP(SMTP_HOST, SMTP_PORT) as smtp:
|
|
||||||
smtp.sendmail('lambda@andreasknuth.de', f'inbox@{domain}', email_content)
|
|
||||||
logger.info(f"[{request_id}] Email forwarded to Postfix for {domain}")
|
|
||||||
|
|
||||||
return jsonify({'message': 'Email processed', 'request_id': request_id}), 200
|
|
||||||
except Exception as e:
|
|
||||||
logger.error(f"[{request_id}] Error processing email: {str(e)}")
|
|
||||||
return jsonify({'error': str(e), 'request_id': request_id}), 500
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
|
||||||
app.run(host='0.0.0.0', port=5000)
|
|
||||||
|
|
@ -1,7 +1,7 @@
|
||||||
services:
|
services:
|
||||||
email-api:
|
email-api:
|
||||||
container_name: email-api
|
container_name: email-api
|
||||||
image: python:3.12-slim # Wechsel zu Python 3.12
|
image: python:3.12-slim
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
ports:
|
ports:
|
||||||
- "5000:5000"
|
- "5000:5000"
|
||||||
|
|
@ -10,10 +10,12 @@ services:
|
||||||
volumes:
|
volumes:
|
||||||
- ./email_api:/app
|
- ./email_api:/app
|
||||||
working_dir: /app
|
working_dir: /app
|
||||||
|
env_file:
|
||||||
|
- .env # Explizit .env-Datei laden
|
||||||
environment:
|
environment:
|
||||||
- API_TOKEN=your-api-token # Muss mit Lambda übereinstimmen
|
- API_TOKEN=${API_TOKEN} # Lädt API_TOKEN aus .env
|
||||||
command: >
|
command: >
|
||||||
bash -c "pip install flask && python app.py"
|
bash -c "pip install --upgrade pip && pip install flask python-dotenv && python app.py"
|
||||||
networks:
|
networks:
|
||||||
mail_network:
|
mail_network:
|
||||||
external: true
|
external: true
|
||||||
Loading…
Reference in New Issue