Update app.py

app.py

@@ -77,7 +77,8 @@ def format_datetime(value):
         return value.strftime("%I:%M %p").replace("AM", "صباحاً").replace("PM", "مساءً") + " " + value.strftime("%Y-%m-%d")
 
 app.config['SECRET_KEY'] = 'your-secret-key'
-app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///users.db?check_same_thread=False'
+# 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'] = {
@@ -714,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:
@@ -725,37 +726,36 @@ 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  # تحديث آخر رسالة تم إرسالها
 
-                    # تحويل التاريخ إلى تنسيق قابل للتسلسل
-                    message_data = {
+                    # إرسال بيانات الرسالة
+                    yield f"data: {json.dumps({
                         '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
-                    }
+                        '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"
 
-                    # إرسال بيانات الرسالة
-                    yield f"data: {json.dumps(message_data)}\n\n"
-
-                time.sleep(1)
+                time.sleep(1)  # انتظر ثانية قبل التحقق مرة أخرى
 
             except Exception as e:
                 print(f"Error in SSE stream: {e}")
-                time.sleep(5)
+                time.sleep(5)  # انتظر 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):
@@ -867,10 +867,11 @@ 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):
@@ -927,20 +928,18 @@ def stream_message_updates(user_id):
                 last_update_time = messages[-1].last_updated  # تحديث وقت التحقق الأخير
 
                 for message in messages:
-                    # تحويل التاريخ إلى تنسيق قابل للتسلسل
-                    message_data = {
+                    yield f"data: {json.dumps({
                         '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,
-                        'last_updated': message.last_updated.strftime('%Y-%m-%d %H:%M:%S')  # تحويل التاريخ
-                    }
-                    yield f"data: {json.dumps(message_data)}\n\n"
+                        'watched_by_sender': message.watched_by_sender
+                    })}\n\n"
 
-            time.sleep(0.5)
+            time.sleep(0.5)  # تحقق كل 0.5 ثانية لتحسين الأداء
 
     return Response(stream_with_context(event_stream()), content_type='text/event-stream')
+
 @app.route('/leave_chat', methods=['POST'])
 @login_required
 def leave_chat():
@@ -1584,8 +1583,6 @@ def delete_video_from_playlist():
 if __name__ == '__main__':
     with app.app_context():
         db.create_all()
-        # Session = scoped_session(sessionmaker(bind=db.engine))
-        app.run(debug=True, host="0.0.0.0")
-
-
+        Session = scoped_session(sessionmaker(bind=db.engine))
+        app.run(debug=True, host="0.0.0.0", port=int(os.environ.get("PORT", 8080)))