From b6230155a720519caf1a6b4564a55d0a74476bcf Mon Sep 17 00:00:00 2001
From: Asal Lotfi <asal.army.233@gmail.com>
Date: Tue, 5 Aug 2025 21:08:29 +0330
Subject: [PATCH] Message and Message Database updated based on new init.sql.

---
 .../Database/MessageDatabase.java             | 22 +++++++++++++++++--
 .../telegramfinalproject/Models/Message.java  | 11 +++++++++-
 2 files changed, 30 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/to/telegramfinalproject/Database/MessageDatabase.java b/src/main/java/org/to/telegramfinalproject/Database/MessageDatabase.java
index fcdaf7c..f4f0739 100644
--- a/src/main/java/org/to/telegramfinalproject/Database/MessageDatabase.java
+++ b/src/main/java/org/to/telegramfinalproject/Database/MessageDatabase.java
@@ -172,7 +172,8 @@ public class MessageDatabase {
                         rs.getBoolean("is_edited"),
                         rs.getObject("original_message_id") != null ? UUID.fromString(rs.getString("original_message_id")) : null,
                         rs.getObject("forwarded_by") != null ? UUID.fromString(rs.getString("forwarded_by")) : null,
-                        rs.getObject("forwarded_from") != null ? UUID.fromString(rs.getString("forwarded_from")) : null
+                        rs.getObject("forwarded_from") != null ? UUID.fromString(rs.getString("forwarded_from")) : null,
+                        rs.getBoolean("is_deleted_globally")
                 ));
             }
 
@@ -273,7 +274,8 @@ public class MessageDatabase {
                 rs.getBoolean("is_edited"),
                 (UUID) rs.getObject("original_message_id"),
                 (UUID) rs.getObject("forwarded_by"),
-                (UUID) rs.getObject("forwarded_from")
+                (UUID) rs.getObject("forwarded_from"),
+                rs.getBoolean("is_deleted_globally")
         );
     }
 
@@ -480,5 +482,21 @@ public class MessageDatabase {
         return messages;
     }
 
+    public static boolean insertSavedMessage(Message message) {
+        String sql = "INSERT INTO messages (message_id, sender_id, receiver_type, receiver_id, content, message_type, status) " +
+                "VALUES (?, ?, ?, ?, ?, ?, ?)";
+
+        try (Connection conn = ConnectionDb.connect();
+             PreparedStatement ps = conn.prepareStatement(sql)) {
+
+
+            return ps.executeUpdate() > 0;
+
+        } catch (SQLException e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
 
 }
diff --git a/src/main/java/org/to/telegramfinalproject/Models/Message.java b/src/main/java/org/to/telegramfinalproject/Models/Message.java
index 5160d82..8dd8cb2 100644
--- a/src/main/java/org/to/telegramfinalproject/Models/Message.java
+++ b/src/main/java/org/to/telegramfinalproject/Models/Message.java
@@ -19,11 +19,12 @@ public class Message {
     private UUID forwarded_by;
     private UUID forwarded_from;
     private List<FileAttachment> attachments;
+    private boolean is_deleted_globally;
 
     public Message(UUID message_id, UUID sender_id, String receiver_type, UUID receiver_id, String content,
                    String message_type, LocalDateTime send_at, String status,
                    UUID reply_to_id, boolean is_edited, UUID original_message_id,
-                   UUID forwarded_by, UUID forwarded_from) {
+                   UUID forwarded_by, UUID forwarded_from,boolean is_deleted_globally) {
         this.message_id = message_id;
         this.sender_id = sender_id;
         this.receiver_type = receiver_type;
@@ -37,6 +38,7 @@ public class Message {
         this.original_message_id = original_message_id;
         this.forwarded_by = forwarded_by;
         this.forwarded_from = forwarded_from;
+        this.is_deleted_globally = is_deleted_globally;
     }
 
     public Message(UUID messageId, UUID senderId, UUID receiverId, String receiverType, String content, String messageType, LocalDateTime now) {
@@ -157,4 +159,11 @@ public class Message {
     public List<FileAttachment> getAttachments() {
         return attachments;
     }
+
+    public void setIs_deleted_globally(boolean is_deleted_globally) {
+        this.is_deleted_globally = is_deleted_globally;
+    }
+    public boolean getIs_deleted_globally() {
+        return is_deleted_globally;
+    }
 }