Messenger.java

import java.io.IOException;
import java.time.LocalDateTime;
import java.util.*;
import java.sql.Timestamp;
import java.time.LocalDateTime;

public class Messenger {
    Scanner in=new Scanner(System.in);
    private static int MessengerID=0;

    public int getMessengerid() {
        return Messengerid;
    }

    public List<Integer> getNoUnreadConversations() {
        return noUnreadConversations;
    }

    private int Messengerid;
    private List<Conversation> conversations;
    private List<Integer> noUnreadConversations;
    User user;
    public Messenger(User user) {
        MessengerID++;
        Messengerid=MessengerID;
        this.user=user;
        this.conversations =user.getConversations();
    }
    public void addconversations(Conversation con){
        conversations.add(con);
    }

    public void MessengerFeed() {

        /////// Conversations ops.
        user.getMessenger().sortConversations();
        user.getMessenger().displayConversations();
        System.out.println("Welcome to Messenger");
        System.out.println("1-Create new conversation");
        System.out.println("2- Find conversation");
        System.out.println("3- Search in conversations by keyword");
        System.out.println("4- Delete Conversation");
        System.out.println("5- Exit Messenger");
        System.out.println("Choice:");
        int choice =0;
        Boolean validate=new Boolean(false);
        while(!validate) {
            try {
                choice=in.nextInt();
                validate=true;
            } catch (InputMismatchException e) {
                System.out.println("invaild choice try again");
                System.out.print("Enter a choice :");
                in.nextLine();
            }
        }
        switch (choice){
            case 1:
                System.out.println("Enter number of participants:");
                Long no=new Long(0);
                while (true) {
                    System.out.println("Please enter number of participants (digits only): ");
                    String input = in.next();

                    if (!input.matches("[0-9]+")) {
                        System.out.println("Number of participants should contain digits only. Please try again.");

                    } else {
                        no = Long.parseLong(input);
                        break; // Exit the loop if the input contains only digits
                    }}
                String username;
                ArrayList<User>participants=new ArrayList<>();
                participants.add(user);
                Boolean check=false;
                for(int i=1;i<no;i++)
                {
                    System.out.println("Enter Participant "+i);
                    username=in.next();
                    for (User friend:user.getFriends()) {
                        if(friend.getUserName().equals(username)) {
                            participants.add(friend);
                            check=true;
                            break;
                        }
                    }
                }
                if(check==false)
                {
                    System.out.println("Invalid User");
                    MessengerFeed();
                }
                Conversation conversation=new Conversation(participants);
                //user.getMessenger().NewConversation(conversation);
//
                conversation.displayMessages(conversation);
                for (User participant: conversation.getParticipants()) {
                participant.setConversations(conversation);
               }
                Options(conversation);
                for (User participant: conversation.getParticipants()) {
                    participant.getMessenger().conversations.add(conversation);
                }
                break;
            case 2:
                displayConversations();
                System.out.println("Enter ID:");
                int id;
                Long No=new Long(0);
                while (true) {
                    System.out.println("Please enter conv ID (digits only): ");
                    String input = in.next();

                    if (!input.matches("[0-9]+")) {
                        System.out.println("conv ID should contain digits only. Please try again.");

                    } else {
                        No = Long.parseLong(input);
                        id=No.intValue();
                        break; // Exit the loop if the input contains only digits
                    }}
                Conversation conv=findConversation(id);
                if(conv !=null) {
                    conv.displayMessages(conv);
                    //conv.markAsRead();
                }
                else {
                    System.out.println("You don't have any conversations yet");
                    MessengerFeed();
                }
                Options(conv); break;
            case 3:
                System.out.println("Enter keyword:");
                String keyword = in.next();
                List<Conversation> matchingConversations =searchConversations(keyword);
                System.out.println("Matching conversations:");
                for (Conversation con : matchingConversations ) {
                    System.out.println("Conversation ID: " + con.getConversation_id());
                    System.out.println("Conversation participants: " + con.getParticipants());
                }
                break;
            case 4:
                displayConversations();
                System.out.println("Enter conversation ID:");
                int convID=in.nextInt();
                user.getMessenger().deleteConversation(convID);
                break;
            case 5:
                break;
            default:
                System.out.println("Invalid Choice");
        }
        if(choice==5)
            backToFeed();
        MessengerFeed();
    }

    //// message options
    public void Options(Conversation conversation){
        System.out.println("1- Add a message");
        System.out.println("2- Delete a message");
        System.out.println("3- Edit a message");
        System.out.println("4- Search in conversation");
        System.out.println("5- Exit Conversation");
        int Choice;
        System.out.println("Enter Value:");
        int choice =0;
        Boolean validate=new Boolean(false);
        while(!validate) {
            try {
                choice=in.nextInt();
                validate=true;
            } catch (InputMismatchException e) {
                System.out.println("invaild choice try again");
                System.out.print("Enter a choice :");
                in.nextLine();
            }
        }
        switch (choice){
            case 1:
                System.out.println("Enter Content:");
                String content=in.next();
                conversation.Add_Message(user.getUserID(),content);
                break;
            case 2:
                conversation.DeleteMessage(conversation);break;
            case 3:
                conversation.displayMessages(conversation);
                System.out.println("Enter MessageID:");
                int id=in.nextInt();
                System.out.println("Enter new content:");
                String NewContent=in.next();
                for (Messages mes:conversation.getMessages()) {
                    if(mes.getMesID()==(id))
                    {
                        mes.EditMessage(NewContent);
                    }
                }
                break;
            case 4:
                System.out.println("Enter Keyword:");
                String keyword=in.next();
                ArrayList<Messages>matching=searchMessagesInConversation(conversation,keyword);
                for (Messages mes: matching) {
                    System.out.println(mes.getMesID());
                    System.out.println(mes.content);
                }
                break;
            case 5:
                MessengerFeed();break;
            default:
                System.out.println("Invalid Choice");
        }
        Options(conversation);
    }
    public void backToFeed() {
        Feed feed = new Feed(user);
    }
    ////////messenger methods///////

    //  new conversation
    public int newConversation(ArrayList<User> participants) {
        int newConvId = conversations.size() + 1;
        Conversation conversation = new Conversation(participants);
        conversations.add(conversation);
        return newConvId;
    }
    public void NewConversation(Conversation conv) {
        int newConvId = conversations.size() + 1;
        conversations.add(conv);
    }
    // display all conversations
    public void displayConversations() {
        System.out.println("Conversations:");
        for (Conversation conversation : conversations) {
            System.out.println("Conversation ID: " + conversation.getConversation_id());
            System.out.println("Conversation Participants:");
            for (User participants:conversation.getParticipants()) {
                System.out.println(participants.getUserName());
            }
            System.out.println("------------------------");
        }

    }
    // delete conversation

    public void deleteConversation(int conversationId) {
        boolean removed = conversations.removeIf(conv -> conv.getConversation_id() == conversationId);
        if (removed) {
            System.out.println("Conversation " + conversationId + " deleted successfully.");
        } else {

            System.out.println("Conversation " + conversationId + " not found.");
        }
    }

    // sort conversations based on timestamp
    public void sortConversations() {
        conversations.sort(Comparator.comparing(Conversation::getTime).reversed());
    }


    // get unread messages count for a user
    public int getUnreadMessagesCount(int userId) {
        int count = 0;
        for (Conversation conversation : conversations) {
            if (conversation.isParticipant(userId) && !conversation.isRead()) {
                count = count + conversation.getNoUnreadMessages().size();
            }
        }
        return count;
    }

    // search in conversations by keyword
    public List<Conversation> searchConversations(String keyword) {
        List<Conversation> matchingConversations = new ArrayList<>();
        for (Conversation conversation : conversations) {
            if (conversation.containsKeyword(keyword)) {
                matchingConversations.add(conversation);
            }
        }
        return matchingConversations;
    }

    // search messages in conversation by keyword
    public ArrayList<Messages> searchMessagesInConversation(Conversation con , String keyword) {
        if (con != null) {
            return con.searchMessages(con,keyword);
        } else {
            System.out.println("Conversation " + con.getConversation_id() + " not found.");
            return new ArrayList<>();
        }
    }

    // Get conversation history
    public List<Messages> getConversationHistory(int conversationId) {
        Conversation conversation = findConversation(conversationId);
        if (conversation != null) {
            return conversation.getMessages();
        } else {
            System.out.println("Conversation " + conversationId + " not found.");
            return new ArrayList<>();
        }
    }

    // edit a message in a conversation
    public void editMessageInConversation(int conversationId, int messageId, String newContent) {
        Conversation conversation = findConversation(conversationId);
        if (conversation != null) {
            for (Messages mes : conversation.getMessages()) {
                if (mes.getId() == messageId) {
                    mes.EditMessage(newContent);
                }
            }
        } else {
            System.out.println("Conversation " + conversationId + " not found.");
        }
    }

    // react to a message in conversation
    public void reactToMessageInConversation(int conversationId, int messageId, String reaction) {
        Messages mes = new Messages();
        Conversation conversation = findConversation(conversationId);
        if (conversation != null) {
            mes.addReact();
        } else {
            System.out.println("Conversation " + conversationId + " not found.");
        }
    }

    public Conversation findConversation(int conversationId) {
        for (Conversation conversation : conversations) {
            if (conversation.getConversation_id() == conversationId) {
                return conversation;
            }
        }
        return null;
    }


    // method to find a conversation BY USERNAME
    private Conversation findConvByUserName(String userName) {
        for (Conversation conversation : conversations) {

            List<User> participants = conversation.getParticipants();
            if (participants.contains(userName)) {
                return conversation;
            }
        }
        return null;

    }

    public List<Conversation> getConversations() {
        return conversations;
    }

    public void setConversations(Conversation conversations) {
        this.conversations.add(conversations);
    }

        /*
    public int newConversation() {
      int newConvId = conversations.size() + 1;
        Conversation conversation = new Conversation(newConvId, System.currentTimeMillis());
       conversations.add(conversation);
        return newConvId;
    }
*/ // add message to conversation
  /* public void addMessageToConversation(int conversationId, int senderId, int recipientId, String content) {
        Conversation conversation = findConversation(conversationId);

        conversation.Add_Message(senderId, recipientId, content);

    }

    // delete message from conversation
    public void deleteMessageFromConversation(int conversationId, int messageId) {
        Conversation conversation = findConversation(conversationId);
        if (conversation != null) {
            conversation.DeleteMessage(messageId);
        } else {
            System.out.println("Conversation " + conversationId + " not found.");
        }
    }

    mark conversation as read
   public void markConversationAsRead(int conversationId) {
        Conversation conversation = findConversation(conversationId);
        if (conversation != null) {
            conversation.markAsRead();
        } else {
            System.out.println("Conversation " + conversationId + " not found.");
        }
    }*/

/*
                public void sortConversations () {
                        //Sorting conversations based on timestamp from newest to oldest
                    // conversations.sort(Comparator.comparingLong(Conversation::getTimestamp().reversed());

                }*/

}