foul-magics/Mage.Server/src/main/java/mage/server/ChatManager.java

/*
* Copyright 2010 BetaSteward_at_googlemail.com. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without modification, are
* permitted provided that the following conditions are met:
*
*    1. Redistributions of source code must retain the above copyright notice, this list of
*       conditions and the following disclaimer.
*
*    2. Redistributions in binary form must reproduce the above copyright notice, this list
*       of conditions and the following disclaimer in the documentation and/or other materials
*       provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY BetaSteward_at_googlemail.com ``AS IS'' AND ANY EXPRESS OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
* FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL BetaSteward_at_googlemail.com OR
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
* ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
* ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
* The views and conclusions contained in the software and documentation are those of the
* authors and should not be interpreted as representing official policies, either expressed
* or implied, of BetaSteward_at_googlemail.com.
*/

package mage.server;

import java.util.ArrayList;
import java.util.Locale;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import mage.view.ChatMessage.MessageColor;
import mage.view.ChatMessage.MessageType;
import mage.view.ChatMessage.SoundToPlay;
import org.apache.log4j.Logger;

/**
 *
 * @author BetaSteward_at_googlemail.com
 */
public class ChatManager {

    private static final Logger logger = Logger.getLogger(ChatManager.class);
    
    private static final ChatManager INSTANCE = new ChatManager();

    public static ChatManager getInstance() {
        return INSTANCE;
    }

    private ChatManager() {}

    private final ConcurrentHashMap<UUID, ChatSession> chatSessions = new ConcurrentHashMap<>();

    public UUID createChatSession() {
        ChatSession chatSession = new ChatSession();
        chatSessions.put(chatSession.getChatId(), chatSession);
        return chatSession.getChatId();
    }

    public void joinChat(UUID chatId, UUID userId) {
        if (chatSessions.containsKey(chatId)) {
            chatSessions.get(chatId).join(userId);
        } else {
            logger.debug("ChatManager:joinChat - chatId does not exist - chatId: " + chatId +"  userId: " + userId);
        }        
        
    }

    public void leaveChat(UUID chatId, UUID userId) {
        if (chatSessions.containsKey(chatId)) {
            chatSessions.get(chatId).kill(userId, DisconnectReason.CleaningUp);
        } 
    }

    public void destroyChatSession(UUID chatId) {
        if (chatId != null && chatSessions.containsKey(chatId)) {
            chatSessions.remove(chatId);
        } else {
            logger.debug("ChatManager:destroy chat - chatId does not exist - chatId: " + chatId);
        } 
    }

    public void broadcast(UUID chatId, String userName, String message, MessageColor color) {
        this.broadcast(chatId, userName, message, color, true);
    }

    public void broadcast(UUID chatId, String userName, String message, MessageColor color, boolean withTime) {
        this.broadcast(chatId, userName, message, color, withTime, MessageType.TALK);
    }

    public void broadcast(UUID chatId, String userName, String message, MessageColor color, boolean withTime, MessageType messageType) {
        this.broadcast(chatId, userName, message, color, withTime, messageType, null);
    }

    public void broadcast(UUID chatId, String userName, String message, MessageColor color, boolean withTime, MessageType messageType, SoundToPlay soundToPlay) {
        if (message.startsWith("\\")) {
            User user = UserManager.getInstance().findUser(userName);
            if (user != null && performUserCommand(user, message, chatId)) {
                return;
            }
        }
        chatSessions.get(chatId).broadcast(userName, message, color, withTime, messageType, soundToPlay);
    }


    private boolean performUserCommand(User user, String message, UUID chatId) {
        String command = message.trim().toUpperCase(Locale.ENGLISH);
        if (command.equals("\\I") || command.equals("\\INFO")) {            
            user.setInfo("");
            chatSessions.get(chatId).broadcastInfoToUser(user,message);
            return true;
        }
        if (command.startsWith("\\I ") || command.startsWith("\\INFO ")) {
            user.setInfo(message.substring(command.startsWith("\\I ") ? 3 : 6));
            chatSessions.get(chatId).broadcastInfoToUser(user,message);
            return true;
        }
        if (command.startsWith("\\W ") || command.startsWith("\\WHISPER ")) {
            String rest = message.substring(command.startsWith("\\W ") ? 3 : 9);
            int first = rest.indexOf(" ");
            if (first > 1) {
                String userToName = rest.substring(0,first);
                rest = rest.substring(first + 1).trim();
                User userTo = UserManager.getInstance().findUser(userToName);
                if (userTo != null) {
                    if (!chatSessions.get(chatId).broadcastWhisperToUser(user, userTo, rest)) {
                        message += new StringBuilder("\nUser ").append(userToName).append(" not found").toString();
                        chatSessions.get(chatId).broadcastInfoToUser(user,message);
                    }
                } else {
                    message += new StringBuilder("\nUser ").append(userToName).append(" not found").toString();
                    chatSessions.get(chatId).broadcastInfoToUser(user,message);
                }
                return true;
            }
        }
        if (command.equals("\\L") || command.equals("\\LIST")) {
            message += new StringBuilder("\nList of commands:")
                    .append("\n\\info <text> - set a info text to your player")
                    .append("\n\\list - Show a list of commands")
                    .append("\n\\whisper <player name> <text> - Whiper to a player").toString();
            chatSessions.get(chatId).broadcastInfoToUser(user,message);
            return true;
        }
        return false;
    }



    /**
     * 
     * use mainly for announcing that a user connection was lost or that a user has reconnected
     * 
     * @param userId
     * @param message
     * @param color 
     */
    public void broadcast(UUID userId, String message, MessageColor color) {
        User user = UserManager.getInstance().getUser(userId);
        if (user != null) {
            for (ChatSession chat: chatSessions.values()) {
                if (chat.hasUser(userId)) {
                    chat.broadcast(user.getName(), message, color);
                }
            }
        }
    }

    public void removeUser(UUID userId, DisconnectReason reason) {
        Logger.getLogger(ChatManager.class).debug("ChatManager: Remove user start - chatSessions: " + chatSessions.size());
        for (ChatSession chat: chatSessions.values()) {
            chat.kill(userId, reason);
        }
        Logger.getLogger(ChatManager.class).debug("ChatManager: Remove user end");
    }

    public ArrayList<ChatSession> getChatSessions() {
        ArrayList<ChatSession> chatSessionList = new ArrayList<>();
        chatSessionList.addAll(chatSessions.values());
        return chatSessionList;
    }
}