AttentionManager.java

/**
 * Copyright (c) 2013, Redsolution LTD. All rights reserved.
 * 
 * This file is part of Xabber project; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License, Version 3.
 * 
 * Xabber is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 * See the GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License,
 * along with this program. If not, see http://www.gnu.org/licenses/.
 */
package com.xabber.android.data.extension.attention;

import java.util.Iterator;

import org.jivesoftware.smack.Connection;
import org.jivesoftware.smack.ConnectionCreationListener;
import org.jivesoftware.smack.Connection;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.packet.Packet;
import org.jivesoftware.smack.packet.PacketExtension;
import org.jivesoftware.smackx.ServiceDiscoveryManager;

import android.media.AudioManager;
import android.net.Uri;

import com.xabber.android.data.Application;
import com.xabber.android.data.NetworkException;
import com.xabber.android.data.OnLoadListener;
import com.xabber.android.data.SettingsManager;
import com.xabber.android.data.account.AccountItem;
import com.xabber.android.data.account.AccountManager;
import com.xabber.android.data.connection.ConnectionItem;
import com.xabber.android.data.connection.ConnectionManager;
import com.xabber.android.data.connection.ConnectionThread;
import com.xabber.android.data.connection.OnPacketListener;
import com.xabber.android.data.extension.capability.CapabilitiesManager;
import com.xabber.android.data.extension.capability.ClientInfo;
import com.xabber.android.data.message.AbstractChat;
import com.xabber.android.data.message.ChatAction;
import com.xabber.android.data.message.MessageManager;
import com.xabber.android.data.message.RegularChat;
import com.xabber.android.data.notification.EntityNotificationProvider;
import com.xabber.android.data.notification.NotificationManager;
import com.xabber.android.data.roster.PresenceManager;
import com.xabber.android.data.roster.ResourceItem;
import com.xabber.androiddev.R;
import com.xabber.xmpp.address.Jid;
import com.xabber.xmpp.attention.Attention;

/**
 * XEP-0224: Attention.
 * 
 * @author alexander.ivanov
 * 
 */
public class AttentionManager implements OnPacketListener, OnLoadListener {

	private final static Object enabledLock;

	private final static AttentionManager instance;

	static {
		instance = new AttentionManager();
		Application.getInstance().addManager(instance);

		enabledLock = new Object();
		Connection
				.addConnectionCreationListener(new ConnectionCreationListener() {
					@Override
					public void connectionCreated(final Connection connection) {
						synchronized (enabledLock) {
							if (SettingsManager.chatsAttention())
								ServiceDiscoveryManager.getInstanceFor(
										connection).addFeature(
										Attention.NAMESPACE);
						}
					}
				});
	}

	public static AttentionManager getInstance() {
		return instance;
	}

	private final EntityNotificationProvider<AttentionRequest> attentionRequestProvider = new EntityNotificationProvider<AttentionRequest>(
			R.drawable.ic_stat_attention) {

		@Override
		public Uri getSound() {
			return SettingsManager.chatsAttentionSound();
		}

		@Override
		public int getStreamType() {
			return AudioManager.STREAM_RING;
		}

	};

	public AttentionManager() {
	}

	public void onSettingsChanged() {
		synchronized (enabledLock) {
			for (String account : AccountManager.getInstance().getAccounts()) {
				ConnectionThread connectionThread = AccountManager
						.getInstance().getAccount(account)
						.getConnectionThread();
				if (connectionThread == null)
					continue;
				Connection xmppConnection = connectionThread
						.getXMPPConnection();
				if (xmppConnection == null)
					continue;
				ServiceDiscoveryManager manager = ServiceDiscoveryManager
						.getInstanceFor(xmppConnection);
				if (manager == null)
					continue;
				boolean contains = false;
				for (Iterator<String> iterator = manager.getFeatures(); iterator
						.hasNext();)
					if (Attention.NAMESPACE.equals(iterator.next()))
						contains = true;
				if (SettingsManager.chatsAttention() == contains)
					continue;
				if (SettingsManager.chatsAttention())
					manager.addFeature(Attention.NAMESPACE);
				else
					manager.removeFeature(Attention.NAMESPACE);
			}
			AccountManager.getInstance().resendPresence();
		}
	}

	@Override
	public void onLoad() {
		Application.getInstance().runOnUiThread(new Runnable() {
			@Override
			public void run() {
				onLoaded();
			}
		});
	}

	private void onLoaded() {
		NotificationManager.getInstance().registerNotificationProvider(
				attentionRequestProvider);
	}

	@Override
	public void onPacket(ConnectionItem connection, String bareAddress,
			Packet packet) {
		if (!(connection instanceof AccountItem))
			return;
		if (!(packet instanceof Message))
			return;
		if (!SettingsManager.chatsAttention())
			return;
		final String account = ((AccountItem) connection).getAccount();
		if (bareAddress == null)
			return;
		for (PacketExtension packetExtension : packet.getExtensions())
			if (packetExtension instanceof Attention) {
				MessageManager.getInstance().openChat(account, bareAddress);
				MessageManager.getInstance()
						.getOrCreateChat(account, bareAddress)
						.newAction(null, null, ChatAction.attention_requested);
				attentionRequestProvider.add(new AttentionRequest(account,
						bareAddress), true);
			}
	}

	public void sendAttention(String account, String user)
			throws NetworkException {
		AbstractChat chat = MessageManager.getInstance().getOrCreateChat(
				account, user);
		if (!(chat instanceof RegularChat))
			throw new NetworkException(R.string.ENTRY_IS_NOT_FOUND);
		String to = chat.getTo();
		if (Jid.getResource(to) == null || "".equals(Jid.getResource(to))) {
			ResourceItem resourceItem = PresenceManager.getInstance()
					.getResourceItem(account, user);
			if (resourceItem == null)
				throw new NetworkException(R.string.NOT_CONNECTED);
			to = resourceItem.getUser(user);
		}
		ClientInfo clientInfo = CapabilitiesManager.getInstance()
				.getClientInfo(account, to);
		if (clientInfo == null)
			throw new NetworkException(R.string.ENTRY_IS_NOT_AVAILABLE);
		if (!clientInfo.getFeatures().contains(Attention.NAMESPACE))
			throw new NetworkException(R.string.ATTENTION_IS_NOT_SUPPORTED);
		Message message = new Message();
		message.setTo(to);
		message.setType(Message.Type.headline);
		message.addExtension(new Attention());
		ConnectionManager.getInstance().sendPacket(account, message);
		chat.newAction(null, null, ChatAction.attention_called);
	}

	public void removeAccountNotifications(String account, String user) {
		attentionRequestProvider.remove(account, user);
	}

}