Update app.py

app.py

@@ -888,17 +888,20 @@ def send_get_request():
 
         processed_emails = set()  # Создание множества для хранения обработанных email-ов
         for user_id, user_data in users_meta.items():  # Проход по всем пользователям
-            user_data['messages'] = messages_json  # Добавление сообщений в данные пользователя
+            # Получение сообщений для текущего пользователя
+            messages_user = {key: msg for key, msg in messages_json.items() if msg.get('user_id') == user_id}
+            logging.debug(f"Messages for user {user_id}: {messages_user}")  # Логирование сообщений для текущего пользователя
+            
+            user_data['messages'] = messages_user  # Добавление сообщений текущего пользователя в данные
+
             email = user_data.get('email')  # Получение email пользователя
             if email not in processed_emails:  # Если email еще не был обработан
                 update_or_insert_user(DATABASE_NAME, user_data, mapping_template)  # Обновление или вставка данных пользователя в базу данных
                 processed_emails.add(email)  # Добавление email в множество обработанных
 
-        return jsonify({'status': 'User data saved successfully'})  # Возвращение успешного ответа
+        return jsonify({'status': 'User data saved successfully'})  # Возвращение JSON-ответа с подтверждением успешного сохранения данных
     else:
-        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code  # Возвращение ошибки в случае неудачного запроса
-
-
+        return jsonify({'error': 'Failed to fetch data from the API'}), response.status_code  # Возвращение JSON-ответа с ошибкой и кодом состояния при неудачном запросе