/**
 * Copyright (C) 2004-2011 Jive Software. All rights reserved.
 * <p>
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * <p>
 * http://www.apache.org/licenses/LICENSE-2.0
 * <p>
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.jivesoftware.sparkimpl.plugin.alerts;

import org.jivesoftware.resource.Res;
import org.jivesoftware.smack.filter.AndFilter;
import org.jivesoftware.smack.filter.StanzaTypeFilter;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smackx.attention.packet.AttentionExtension;
import org.jivesoftware.spark.ChatManager;
import org.jivesoftware.spark.SparkManager;
import org.jivesoftware.spark.plugin.Plugin;
import org.jivesoftware.spark.ui.ChatFrame;
import org.jivesoftware.spark.ui.ChatRoom;
import org.jivesoftware.spark.ui.ChatRoomListener;
import org.jivesoftware.spark.ui.ChatRoomNotFoundException;
import org.jivesoftware.spark.ui.ContactItem;
import org.jivesoftware.spark.ui.rooms.ChatRoomImpl;
import org.jivesoftware.spark.util.SwingTimerTask;
import org.jivesoftware.spark.util.TaskEngine;
import org.jivesoftware.sparkimpl.settings.local.SettingsManager;
import org.jxmpp.jid.EntityBareJid;

import java.util.TimerTask;

import javax.swing.SwingUtilities;

/**
 */
public class BuzzPlugin implements Plugin {

    @Override
    public void initialize() {

        SparkManager.getConnection()
            .addAsyncStanzaListener(
                            stanza -> SwingUtilities.invokeLater(() -> shakeWindow((Message)stanza)),
                            new AndFilter(StanzaTypeFilter.MESSAGE, s -> s.hasExtension(AttentionExtension.ELEMENT_NAME, AttentionExtension.NAMESPACE))
                        );

        SparkManager.getChatManager().addChatRoomListener(
            new ChatRoomListener() {
                @Override
                public void chatRoomOpened(final ChatRoom room) {
                    TimerTask task = new SwingTimerTask() {
                        @Override
                        public void doRun() {
                            addBuzzFeatureToChatRoom(room);
                        }
                    };

                    TaskEngine.getInstance().schedule(task, 100);
                }

                @Override
                public void chatRoomLeft(ChatRoom room) {
                }

                @Override
                public void chatRoomClosed(ChatRoom room) {
                }

                @Override
                public void chatRoomActivated(ChatRoom room) {
                }

                @Override
                public void userHasJoined(ChatRoom room, String userid) {
                }

                @Override
                public void userHasLeft(ChatRoom room, String userid) {
                }
            });
    }

    private void addBuzzFeatureToChatRoom(final ChatRoom room) {
        if (room instanceof ChatRoomImpl) {
            // Add Button to toolbar
            if (!SettingsManager.getLocalPreferences().isBuzzEnabled()) {
                return;
            }
            new BuzzRoomDecorator(room);
        }
    }

    private void shakeWindow(Message message) {
        EntityBareJid bareJID = message.getFrom().asEntityBareJidOrThrow();
        String nickname;
        ContactItem contact = SparkManager.getWorkspace().getContactList().getContactItemByJID(bareJID);
        if (contact != null) {
            nickname = contact.getDisplayName();
        }
        else {
            nickname = bareJID.getLocalpart().asUnescapedString();
        }

        ChatRoom room;
        try {
            room = SparkManager.getChatManager().getChatContainer()
                .getChatRoom(bareJID);
        } catch (ChatRoomNotFoundException e) {
            // Create the room if it does not exist.
            room = SparkManager.getChatManager().createChatRoom(bareJID,
                nickname, nickname);
        }

        ChatFrame chatFrame = SparkManager.getChatManager().getChatContainer()
            .getChatFrame();
        if (chatFrame != null) {
            if (SettingsManager.getLocalPreferences().isBuzzEnabled()) {
                chatFrame.buzz();
                SparkManager.getChatManager().getChatContainer()
                    .activateChatRoom(room);
            }
        }

        // Insert offline message
        room.getTranscriptWindow().insertNotificationMessage(
            Res.getString("message.buzz.message", nickname),
            ChatManager.NOTIFICATION_COLOR);
        room.scrollToBottom();
    }

    @Override
    public void shutdown() {
    }

    @Override
    public boolean canShutDown() {
        return true;
    }

    @Override
    public void uninstall() {
    }
}
