Update app.py

app.py

@@ -1,23 +1,35 @@
-import asyncio
-from aiosmtpd.controller import Controller
-
-class SMTPServerHandler:
-    async def handle_DATA(self, server, session, envelope):
-        print('Message from:', envelope.mail_from)
-        print('Message to  :', envelope.rcpt_tos)
-        print('Message data:')
-        print(envelope.content.decode('utf8', errors='replace'))
-        return '250 OK'
-
-def start_smtp_server():
-    handler = SMTPServerHandler()
-    controller = Controller(handler, hostname='localhost', port=7860)
-    controller.start()
-    print('SMTP server running on port 7860...')
-    try:
-        asyncio.get_event_loop().run_forever()
-    except KeyboardInterrupt:
-        controller.stop()
-
-if __name__ == "__main__":
-    start_smtp_server()
+import smtplib
+import socket
+import threading
+import time
+
+HOST = 'localhost'  # Replace with your desired hostname
+PORT = 25        # Standard SMTP port
+
+server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+server_socket.bind((HOST, PORT))
+server_socket.listen()
+
+def handle_client(client_socket, addr):
+    while True:
+        data = client_socket.recv(1024).decode()
+        if not data:
+            break
+
+        # Process received data (e.g., parse commands, send responses)
+        # ... (Implement your desired logic here)
+
+        # Example: Respond to HELO/EHLO command
+        if data.startswith('HELO') or data.startswith('EHLO'):
+            response = f'250 {HOST} Ready'
+            client_socket.send(response.encode())
+
+    client_socket.close()
+
+while True:
+    client_socket, addr = server_socket.accept()
+    print('Connected by', addr)
+
+    # Create a separate thread to handle the client
+    client_thread = threading.Thread(target=handle_client, args=(client_socket, addr))
+    client_thread.start()