Send text message Real time updated

This commit is contained in:
2025-07-30 21:10:33 +03:30
parent c6eea66966
commit f604ca4f22
5 changed files with 109 additions and 6 deletions
@@ -2508,14 +2508,22 @@ public class ActionHandler {
return;
}
System.out.println("\n💬 Your Chats:");
System.out.println("0. 📦 Archived chats");
int index = 1;
System.out.println("0. Archived chats");
for (ChatEntry chat : Session.activeChats) {
System.out.printf("%d. [%s] %s (%s)\n", index++, chat.getType(), chat.getName(), chat.getDisplayId());
String time = (chat.getLastMessageTime() == null)
? "No messages yet"
: chat.getLastMessageTime().toString();
System.out.printf("%d. [%s] %s (%s) - Last: %s\n",
index++, chat.getType(), chat.getName(), chat.getDisplayId(), time);
}
}
public static class ChatStateMonitor implements Runnable {
private final PrintWriter out;
@@ -158,6 +158,44 @@ public class IncomingMessageListener implements Runnable {
System.out.println("✅ Updated last message time for chat: " + chat.getDisplayId());
});
Session.activeChats.stream()
.filter(chat -> chat.getId().equals(chatUUID))
.findFirst()
.ifPresent(chat -> {
chat.setLastMessageTime(newTime);
System.out.println("✅ Updated last message time for chat: " + chat.getDisplayId());
});
Session.archivedChats.stream()
.filter(chat -> chat.getId().equals(chatUUID))
.findFirst()
.ifPresent(chat -> {
chat.setLastMessageTime(newTime);
System.out.println("✅ Updated last message time for chat: " + chat.getDisplayId());
});
Session.chatList.sort((c1, c2) -> {
if (c1.getLastMessageTime() == null && c2.getLastMessageTime() == null) return 0;
if (c1.getLastMessageTime() == null) return 1;
if (c2.getLastMessageTime() == null) return -1;
return c2.getLastMessageTime().compareTo(c1.getLastMessageTime()); // descending
});
Session.activeChats.sort((c1, c2) -> {
if (c1.getLastMessageTime() == null && c2.getLastMessageTime() == null) return 0;
if (c1.getLastMessageTime() == null) return 1;
if (c2.getLastMessageTime() == null) return -1;
return c2.getLastMessageTime().compareTo(c1.getLastMessageTime()); // descending
});
Session.archivedChats.sort((c1, c2) -> {
if (c1.getLastMessageTime() == null && c2.getLastMessageTime() == null) return 0;
if (c1.getLastMessageTime() == null) return 1;
if (c2.getLastMessageTime() == null) return -1;
return c2.getLastMessageTime().compareTo(c1.getLastMessageTime()); // descending
});
if (Session.inChatListMenu) {
ActionHandler.displayChatList();
System.out.print("Select a chat by number: ");
@@ -4,6 +4,7 @@ import org.json.JSONArray;
import org.json.JSONObject;
import org.to.telegramfinalproject.Models.ChatEntry;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
@@ -36,24 +37,65 @@ public class Session {
throw new RuntimeException("❌ No UUID found in currentUser!");
}
// public static void updateChatList(JSONArray chatArray) {
// chatList.clear();
// for (int i = 0; i < chatArray.length(); i++) {
// JSONObject obj = chatArray.getJSONObject(i);
// ChatEntry entry = new ChatEntry(
// UUID.fromString(obj.getString("internal_id")),
// obj.optString("id", ""), // displayId
// obj.optString("name", ""), // name
// obj.optString("image_url", ""),
// obj.getString("type"),
// null, // last message time (if needed, parse it)
// obj.optBoolean("is_owner", false),
// obj.optBoolean("is_admin", false)
// );
// entry.setPermissions(obj.optJSONObject("permissions"));
// chatList.add(entry);
// }
// }
public static void updateChatList(JSONArray chatArray) {
chatList.clear();
for (int i = 0; i < chatArray.length(); i++) {
JSONObject obj = chatArray.getJSONObject(i);
LocalDateTime lastMessageTime = null;
if (obj.has("last_message_time") && !obj.isNull("last_message_time")) {
String timeStr = obj.getString("last_message_time");
if (!timeStr.isBlank()) {
lastMessageTime = LocalDateTime.parse(timeStr);
}
}
ChatEntry entry = new ChatEntry(
UUID.fromString(obj.getString("internal_id")),
obj.optString("id", ""), // displayId
obj.optString("name", ""), // name
obj.optString("image_url", ""),
obj.getString("type"),
null, // last message time (if needed, parse it)
lastMessageTime,
obj.optBoolean("is_owner", false),
obj.optBoolean("is_admin", false)
);
entry.setPermissions(obj.optJSONObject("permissions")); // اگر permissions وجود داره
entry.setPermissions(obj.optJSONObject("permissions"));
chatList.add(entry);
}
chatList.sort((c1, c2) -> {
if (c1.getLastMessageTime() == null && c2.getLastMessageTime() == null) return 0;
if (c1.getLastMessageTime() == null) return 1;
if (c2.getLastMessageTime() == null) return -1;
return c2.getLastMessageTime().compareTo(c1.getLastMessageTime());
});
activeChats = chatList.stream().filter(c -> !c.isArchived()).toList();
archivedChats = chatList.stream().filter(ChatEntry::isArchived).toList();
}
public static List<ChatEntry> getChatList() {
return chatList;
}
@@ -115,6 +115,22 @@ public class ChatEntry {
this.archived = archived;
}
public void setLastMessageTime(String newTime) {this.lastMessageTime = LocalDateTime.parse(newTime);
// public void setLastMessageTime(String newTime) {this.lastMessageTime = LocalDateTime.parse(newTime);
// }
public void setLastMessageTime(String newTime) {
if (newTime == null || newTime.isBlank()) {
this.lastMessageTime = null;
return;
}
try {
this.lastMessageTime = LocalDateTime.parse(newTime);
} catch (Exception e) {
System.out.println("❌ Failed to parse lastMessageTime: " + newTime);
this.lastMessageTime = null;
}
}
}
@@ -1930,7 +1930,6 @@ public class ClientHandler implements Runnable {
return new ResponseModel("error", "Message inserted but failed to attach files.");
}
// ری‌ل‌تایم (اختیاری: dispatchMessageToReceiver(messageId, receiverId, receiverType))
Message msg = new Message(messageId, senderId, receiverId, receiverType, content, messageType, LocalDateTime.now());