basic notifications

1 files changed, 198 insertions, 167 deletions

diff --git a/src/de/gultsch/chat/services/XmppConnectionService.java b/src/de/gultsch/chat/services/XmppConnectionService.java
index fa2e6d7e..fee2aafe 100644
--- a/src/de/gultsch/chat/services/XmppConnectionService.java
+++ b/src/de/gultsch/chat/services/XmppConnectionService.java
@@ -5,222 +5,252 @@ import java.util.ArrayList;
 import java.util.Hashtable;
 import java.util.List;
 
-
 import de.gultsch.chat.entities.Account;
 import de.gultsch.chat.entities.Contact;
 import de.gultsch.chat.entities.Conversation;
 import de.gultsch.chat.entities.Message;
 import de.gultsch.chat.persistance.DatabaseBackend;
+import de.gultsch.chat.ui.ConversationActivity;
 import de.gultsch.chat.ui.OnConversationListChangedListener;
 import de.gultsch.chat.ui.OnRosterFetchedListener;
+import de.gultsch.chat.utils.UIHelper;
 import de.gultsch.chat.xml.Element;
 import de.gultsch.chat.xmpp.IqPacket;
 import de.gultsch.chat.xmpp.MessagePacket;
 import de.gultsch.chat.xmpp.OnIqPacketReceived;
 import de.gultsch.chat.xmpp.OnMessagePacketReceived;
 import de.gultsch.chat.xmpp.XmppConnection;
+import android.R;
+import android.R.dimen;
+import android.app.NotificationManager;
+import android.app.PendingIntent;
 import android.app.Service;
 import android.content.Context;
 import android.content.Intent;
+import android.content.res.Resources;
 import android.os.Binder;
 import android.os.IBinder;
 import android.os.PowerManager;
+import android.support.v4.app.NotificationCompat;
+import android.support.v4.app.TaskStackBuilder;
 import android.util.Log;
 
 public class XmppConnectionService extends Service {
-	
+
 	protected static final String LOGTAG = "xmppService";
 	protected DatabaseBackend databaseBackend;
-	
+
 	public long startDate;
-	
+
 	private List<Account> accounts;
 	private List<Conversation> conversations = null;
-	
-	private Hashtable<Account,XmppConnection> connections = new Hashtable<Account, XmppConnection>();
+
+	private Hashtable<Account, XmppConnection> connections = new Hashtable<Account, XmppConnection>();
 
 	private OnConversationListChangedListener convChangedListener = null;
-	
-    private final IBinder mBinder = new XmppConnectionBinder();
+
+	private final IBinder mBinder = new XmppConnectionBinder();
 	private OnMessagePacketReceived messageListener = new OnMessagePacketReceived() {
-		
+
 		@Override
-		public void onMessagePacketReceived(Account account, MessagePacket packet) {
-			if (packet.getType()==MessagePacket.TYPE_CHAT) {
+		public void onMessagePacketReceived(Account account,
+				MessagePacket packet) {
+			if (packet.getType() == MessagePacket.TYPE_CHAT) {
 				String fullJid = packet.getFrom();
 				String jid = fullJid.split("/")[0];
 				String name = jid.split("@")[0];
-				Contact contact = new Contact(account,name,jid,null); //dummy contact
-				Conversation conversation = findOrCreateConversation(account, contact);
-				Message message = new Message(conversation, fullJid, packet.getBody(), Message.ENCRYPTION_NONE, Message.STATUS_RECIEVED);
+				Contact contact = new Contact(account, name, jid, null); // dummy
+																			// contact
+				Conversation conversation = findOrCreateConversation(account,
+						contact);
+				Message message = new Message(conversation, fullJid,
+						packet.getBody(), Message.ENCRYPTION_NONE,
+						Message.STATUS_RECIEVED);
 				conversation.getMessages().add(message);
 				databaseBackend.createMessage(message);
 				if (convChangedListener != null) {
 					convChangedListener.onConversationListChanged();
+				} else {
+					NotificationManager mNotificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
+					mNotificationManager.notify(2342, UIHelper
+							.getUnreadMessageNotification(
+									getApplicationContext(), conversation));
 				}
 			}
 		}
 	};
 
-    public class XmppConnectionBinder extends Binder {
-        public XmppConnectionService getService() {
-        	return XmppConnectionService.this;
-        }
-    }
-    
-    @Override 
-    public int onStartCommand(Intent intent, int flags, int startId) {
-        PowerManager pm = (PowerManager) getSystemService(Context.POWER_SERVICE);
-        for(Account account : accounts) {
-        	if (!connections.containsKey(account)) {
-        		XmppConnection connection = new XmppConnection(account, pm);
-        		connection.setOnMessagePacketReceivedListener(this.messageListener );
-        		Thread thread = new Thread(connection);
-        		thread.start();
-        		this.connections.put(account, connection);
-        	}
-        }
-        return START_STICKY;
-    }
-    
-    @Override
-    public void onCreate() {
-    	databaseBackend = DatabaseBackend.getInstance(getApplicationContext());
-    	this.accounts = databaseBackend.getAccounts();
-    }
-    
-    @Override
-    public IBinder onBind(Intent intent) {
-        return mBinder;
-    }
-    
-    public void sendMessage(final Account account, final Message message) {
-    	new Thread() {
-    		@Override
-    		public void run() {
-    			Log.d(LOGTAG,"sending message for "+account.getJid()+" to: "+message.getCounterpart());
-    			databaseBackend.createMessage(message);
-    			MessagePacket packet = new MessagePacket();
-    			packet.setType(MessagePacket.TYPE_CHAT);
-    			packet.setTo(message.getCounterpart());
-    			packet.setFrom(account.getJid());
-    			packet.setBody(message.getBody());
-    			try {
+	public class XmppConnectionBinder extends Binder {
+		public XmppConnectionService getService() {
+			return XmppConnectionService.this;
+		}
+	}
+
+	@Override
+	public int onStartCommand(Intent intent, int flags, int startId) {
+		PowerManager pm = (PowerManager) getSystemService(Context.POWER_SERVICE);
+		for (Account account : accounts) {
+			if (!connections.containsKey(account)) {
+				XmppConnection connection = new XmppConnection(account, pm);
+				connection
+						.setOnMessagePacketReceivedListener(this.messageListener);
+				Thread thread = new Thread(connection);
+				thread.start();
+				this.connections.put(account, connection);
+			}
+		}
+		return START_STICKY;
+	}
+
+	@Override
+	public void onCreate() {
+		databaseBackend = DatabaseBackend.getInstance(getApplicationContext());
+		this.accounts = databaseBackend.getAccounts();
+	}
+
+	@Override
+	public IBinder onBind(Intent intent) {
+		return mBinder;
+	}
+
+	public void sendMessage(final Account account, final Message message) {
+		new Thread() {
+			@Override
+			public void run() {
+				Log.d(LOGTAG, "sending message for " + account.getJid()
+						+ " to: " + message.getCounterpart());
+				databaseBackend.createMessage(message);
+				MessagePacket packet = new MessagePacket();
+				packet.setType(MessagePacket.TYPE_CHAT);
+				packet.setTo(message.getCounterpart());
+				packet.setFrom(account.getJid());
+				packet.setBody(message.getBody());
+				try {
 					connections.get(account).sendMessagePacket(packet);
 					message.setStatus(Message.STATUS_SEND);
 					databaseBackend.updateMessage(message);
 				} catch (IOException e) {
-					Log.d(LOGTAG,"io exception during send. message is in database. will try again later");
+					Log.d(LOGTAG,
+							"io exception during send. message is in database. will try again later");
 				}
-    		}
-    	}.start();
-    }
-    
-    public void getRoster(final Account account, final OnRosterFetchedListener listener) {
-    	new Thread() {
-    		@Override
-    		public void run() {
-    			IqPacket iqPacket = new IqPacket(IqPacket.TYPE_GET);
-    	    	Element query = new Element("query");
-    	    	query.setAttribute("xmlns", "jabber:iq:roster");
-    	    	query.setAttribute("ver", "");
-    	    	iqPacket.addChild(query);
-    	    	try {
-    	    		connections.get(account).sendIqPacket(iqPacket, new OnIqPacketReceived() {
-    					
-    					@Override
-    					public void onIqPacketReceived(Account account, IqPacket packet) {
-    						Element roster = packet.findChild("query");
-    						List<Contact> contacts = new ArrayList<Contact>();
-    						for(Element item : roster.getChildren()) {
-    							String name = item.getAttribute("name");
-    							String jid = item.getAttribute("jid");
-    							if (name==null) {
-    								name = jid.split("@")[0];
-    							}
-    							Contact contact = new Contact(account, name, jid, null);
-    							contacts.add(contact);
-    						}
-    						if (listener != null) {
-    							listener.onRosterFetched(contacts);
-    						}
-    					}
-    				});
-    			} catch (IOException e) {
-    				Log.d(LOGTAG,"io error during roster fetch");
-    			}
-    		}
-    	}.start();
-    }
-    
-    public void addConversation(Conversation conversation) {
-    	databaseBackend.createConversation(conversation);
-    }
-    
-    public List<Conversation> getConversations() {
-    	if (this.conversations == null) {
-	    	Hashtable<String, Account> accountLookupTable = new Hashtable<String, Account>();
-	    	for(Account account : this.accounts) {
-	    		accountLookupTable.put(account.getUuid(), account);
-	    	}
-	    	this.conversations = databaseBackend.getConversations(Conversation.STATUS_AVAILABLE);
-	    	for(Conversation conv : this.conversations) {
-	    		conv.setAccount(accountLookupTable.get(conv.getAccountUuid()));
-	    	}
-    	}
-    	return this.conversations;
-    }
-    
-    public List<Account> getAccounts() {
-    	return this.accounts;
-    }
-    
-    public List<Message> getMessages(Conversation conversation) {
-    	return databaseBackend.getMessages(conversation, 100);
-    }
-
-    public Conversation findOrCreateConversation(Account account, Contact contact) {
-    	//Log.d(LOGTAG,"was asked to find conversation for "+contact.getJid());
-    	for(Conversation conv : this.getConversations()) {
-    		if ((conv.getAccount().equals(account))&&(conv.getContactJid().equals(contact.getJid()))) {
-    			//Log.d(LOGTAG,"found one in memory");
-    			return conv;
-    		}
-    	}
-    	Conversation conversation = databaseBackend.findConversation(account, contact.getJid());
-    	if (conversation!=null) {
-    		Log.d("gultsch","found one. unarchive it");
-    		conversation.setStatus(Conversation.STATUS_AVAILABLE);
-    		conversation.setAccount(account);
-    		this.databaseBackend.updateConversation(conversation);
-    	} else {
-    		Log.d(LOGTAG,"didnt find one in archive. create new one");
-    		conversation = new Conversation(contact.getDisplayName(), contact.getProfilePhoto(), account, contact.getJid());
-    		this.databaseBackend.createConversation(conversation);
-    	}
-    	this.conversations.add(conversation);
-    	if (this.convChangedListener != null) {
-    		this.convChangedListener.onConversationListChanged();
-    	}
-    	return conversation;
-    }
-    
-    public void archiveConversation(Conversation conversation) {
-    	this.databaseBackend.updateConversation(conversation);
-    	this.conversations.remove(conversation);
-    	if (this.convChangedListener != null) {
-    		this.convChangedListener.onConversationListChanged();
-    	}
-    }
-    
-    public int getConversationCount() {
-    	return this.databaseBackend.getConversationCount();
-    }
+			}
+		}.start();
+	}
+
+	public void getRoster(final Account account,
+			final OnRosterFetchedListener listener) {
+		new Thread() {
+			@Override
+			public void run() {
+				IqPacket iqPacket = new IqPacket(IqPacket.TYPE_GET);
+				Element query = new Element("query");
+				query.setAttribute("xmlns", "jabber:iq:roster");
+				query.setAttribute("ver", "");
+				iqPacket.addChild(query);
+				try {
+					connections.get(account).sendIqPacket(iqPacket,
+							new OnIqPacketReceived() {
+
+								@Override
+								public void onIqPacketReceived(Account account,
+										IqPacket packet) {
+									Element roster = packet.findChild("query");
+									List<Contact> contacts = new ArrayList<Contact>();
+									for (Element item : roster.getChildren()) {
+										String name = item.getAttribute("name");
+										String jid = item.getAttribute("jid");
+										if (name == null) {
+											name = jid.split("@")[0];
+										}
+										Contact contact = new Contact(account,
+												name, jid, null);
+										contacts.add(contact);
+									}
+									if (listener != null) {
+										listener.onRosterFetched(contacts);
+									}
+								}
+							});
+				} catch (IOException e) {
+					Log.d(LOGTAG, "io error during roster fetch");
+				}
+			}
+		}.start();
+	}
+
+	public void addConversation(Conversation conversation) {
+		databaseBackend.createConversation(conversation);
+	}
+
+	public List<Conversation> getConversations() {
+		if (this.conversations == null) {
+			Hashtable<String, Account> accountLookupTable = new Hashtable<String, Account>();
+			for (Account account : this.accounts) {
+				accountLookupTable.put(account.getUuid(), account);
+			}
+			this.conversations = databaseBackend
+					.getConversations(Conversation.STATUS_AVAILABLE);
+			for (Conversation conv : this.conversations) {
+				conv.setAccount(accountLookupTable.get(conv.getAccountUuid()));
+			}
+		}
+		return this.conversations;
+	}
+
+	public List<Account> getAccounts() {
+		return this.accounts;
+	}
+
+	public List<Message> getMessages(Conversation conversation) {
+		return databaseBackend.getMessages(conversation, 100);
+	}
+
+	public Conversation findOrCreateConversation(Account account,
+			Contact contact) {
+		// Log.d(LOGTAG,"was asked to find conversation for "+contact.getJid());
+		for (Conversation conv : this.getConversations()) {
+			if ((conv.getAccount().equals(account))
+					&& (conv.getContactJid().equals(contact.getJid()))) {
+				// Log.d(LOGTAG,"found one in memory");
+				return conv;
+			}
+		}
+		Conversation conversation = databaseBackend.findConversation(account,
+				contact.getJid());
+		if (conversation != null) {
+			Log.d("gultsch", "found one. unarchive it");
+			conversation.setStatus(Conversation.STATUS_AVAILABLE);
+			conversation.setAccount(account);
+			this.databaseBackend.updateConversation(conversation);
+		} else {
+			Log.d(LOGTAG, "didnt find one in archive. create new one");
+			conversation = new Conversation(contact.getDisplayName(),
+					contact.getProfilePhoto(), account, contact.getJid());
+			this.databaseBackend.createConversation(conversation);
+		}
+		this.conversations.add(conversation);
+		if (this.convChangedListener != null) {
+			this.convChangedListener.onConversationListChanged();
+		}
+		return conversation;
+	}
+
+	public void archiveConversation(Conversation conversation) {
+		this.databaseBackend.updateConversation(conversation);
+		this.conversations.remove(conversation);
+		if (this.convChangedListener != null) {
+			this.convChangedListener.onConversationListChanged();
+		}
+	}
+
+	public int getConversationCount() {
+		return this.databaseBackend.getConversationCount();
+	}
 
 	public void createAccount(Account account) {
 		databaseBackend.createAccount(account);
 	}
-	
+
 	public void updateAccount(Account account) {
 		databaseBackend.updateAccount(account);
 	}
@@ -228,11 +258,12 @@ public class XmppConnectionService extends Service {
 	public void deleteAccount(Account account) {
 		databaseBackend.deleteAccount(account);
 	}
-	
-	public void setOnConversationListChangedListener(OnConversationListChangedListener listener) {
+
+	public void setOnConversationListChangedListener(
+			OnConversationListChangedListener listener) {
 		this.convChangedListener = listener;
 	}
-	
+
 	public void removeOnConversationListChangedListener() {
 		this.convChangedListener = null;
 	}