Update app.py

app.py

@@ -80,7 +80,6 @@ app.config['SECRET_KEY'] = 'your-secret-key'
 # app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///users.db?check_same_thread=False'
 app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://sql7760039:[email protected]/sql7760039'
 
-
 app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
 app.config['SQLALCHEMY_ENGINE_OPTIONS'] = {
     'charset': 'utf8mb4'  # تعيين الترميز UTF-8 لجميع الجداول
@@ -716,7 +715,7 @@ def send_message():
 @login_required
 def stream_messages(user_id):
     def event_stream():
-        last_message_id = None  # لتتبع آخر رسالة تم إرسالها
+        last_message_id = None
 
         while True:
             try:
@@ -727,36 +726,38 @@ def stream_messages(user_id):
                 ).order_by(Message.created_at.desc())
 
                 if last_message_id:
-                    query = query.filter(Message.id > last_message_id)  # التحقق من الرسائل الجديدة فقط
+                    query = query.filter(Message.id > last_message_id)
 
                 messages = query.limit(1).all()
 
                 if messages:
                     message = messages[0]
-                    last_message_id = message.id  # تحديث آخر رسالة تم إرسالها
+                    last_message_id = message.id
 
-                    # إرسال بيانات الرسالة
-                    yield f"data: {json.dumps({
+                    # تحويل التاريخ إلى تنسيق قابل للتسلسل
+                    message_data = {
                         'message_id': message.id,
                         'sender_id': message.sender_id,
                         'receiver_id': message.receiver_id,
                         'content': message.content,
                         'file_url': message.file_url,
                         'file_type': message.file_type,
-                        'created_at': message.created_at.strftime('%Y-%m-%d %H:%M:%S'),
-                        'watched_by_receiver': message.watched_by_receiver,  # حالة مشاهدة المستقبل
-                        'watched_by_sender': message.watched_by_sender       # حالة مشاهدة المرسل
-                    })}\n\n"
+                        'created_at': message.created_at.strftime('%Y-%m-%d %H:%M:%S'),  # تحويل التاريخ
+                        'watched_by_receiver': message.watched_by_receiver,
+                        'watched_by_sender': message.watched_by_sender
+                    }
 
-                time.sleep(1)  # انتظر ثانية قبل التحقق مرة أخرى
+                    # إرسال بيانات الرسالة
+                    yield f"data: {json.dumps(message_data)}\n\n"
+
+                time.sleep(1)
 
             except Exception as e:
                 print(f"Error in SSE stream: {e}")
-                time.sleep(5)  # انتظر 5 ثوانٍ قبل إعادة المحاولة
+                time.sleep(5)
 
     return Response(stream_with_context(event_stream()), content_type='text/event-stream')
 
-
 @app.route('/is_user_active/<int:user_id>')
 @login_required
 def is_user_active(user_id):
@@ -868,11 +869,10 @@ def stream_unread_count():
                 last_count = unread_count
                 yield f"data: {json.dumps({'unread_count': unread_count})}\n\n"
 
-            time.sleep(1)  # انتظر ثانية قبل التحقق مرة أخرى
+            time.sleep(1)
 
     return Response(stream_with_context(event_stream()), content_type='text/event-stream')
 
-
 @app.route('/mark_message_as_seen/<int:message_id>', methods=['POST'])
 @login_required
 def mark_message_as_seen(message_id):
@@ -929,15 +929,18 @@ def stream_message_updates(user_id):
                 last_update_time = messages[-1].last_updated  # تحديث وقت التحقق الأخير
 
                 for message in messages:
-                    yield f"data: {json.dumps({
+                    # تحويل التاريخ إلى تنسيق قابل للتسلسل
+                    message_data = {
                         'message_id': message.id,
                         'sender_id': message.sender_id,
                         'receiver_id': message.receiver_id,
                         'watched_by_receiver': message.watched_by_receiver,
-                        'watched_by_sender': message.watched_by_sender
-                    })}\n\n"
+                        'watched_by_sender': message.watched_by_sender,
+                        'last_updated': message.last_updated.strftime('%Y-%m-%d %H:%M:%S')  # تحويل التاريخ
+                    }
+                    yield f"data: {json.dumps(message_data)}\n\n"
 
-            time.sleep(0.5)  # تحقق كل 0.5 ثانية لتحسين الأداء
+            time.sleep(0.5)
 
     return Response(stream_with_context(event_stream()), content_type='text/event-stream')