added channel content changed listener

Author: thsc42

src/net/sharksystem/asap/ASAPChannelContentChangedListener.java

@@ -0,0 +1,5 @@
+package net.sharksystem.asap;
+
+public interface ASAPChannelContentChangedListener {
+    void asapChannelContentChanged(CharSequence format, CharSequence uri, int era);
+}

src/net/sharksystem/asap/ASAPChannelContentChangedListenerManagement.java

@@ -0,0 +1,16 @@
+package net.sharksystem.asap;
+
+public interface ASAPChannelContentChangedListenerManagement {
+    /**
+     * Add listener for changes in ASAP environment
+     * @param listener listener which is to be added
+     */
+    void addASAPChannelContentChangedListener(CharSequence format, ASAPChannelContentChangedListener listener);
+
+    /**
+     * Remove changes listener
+     * @param listener listener which is to be removed
+     */
+    void removeASAPChannelContentChangedListener(CharSequence format, ASAPChannelContentChangedListener listener);
+
+}

src/net/sharksystem/asap/ASAPListenerManagingPeer.java

@@ -1,5 +1,6 @@
 package net.sharksystem.asap;
 
+import net.sharksystem.asap.listenermanager.ASAPChannelContentChangedListenerManager;
 import net.sharksystem.asap.listenermanager.ASAPEnvironmentChangesListenerManager;
 import net.sharksystem.asap.listenermanager.ASAPMessageReceivedListenerManager;
 
@@ -19,6 +20,22 @@ public void removeASAPMessageReceivedListener(CharSequence format, ASAPMessageRe
         this.asapMessageReceivedListenerManager.removeASAPMessageReceivedListener(format, listener);
     }
 
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////
+    //                                      ASAPChannelContentChangedListener                             //
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////
+    protected ASAPChannelContentChangedListenerManager asapChannelContentChangedListenerManager =
+            new ASAPChannelContentChangedListenerManager();
+
+    @Override
+    public void addASAPChannelContentChangedListener(CharSequence format, ASAPChannelContentChangedListener listener) {
+        this.asapChannelContentChangedListenerManager.addASAPChannelContentChangedListener(format, listener);
+    }
+
+    @Override
+    public void removeASAPChannelContentChangedListener(CharSequence format, ASAPChannelContentChangedListener listener) {
+        this.asapChannelContentChangedListenerManager.removeASAPChannelContentChangedListener(format, listener);
+    }
+
     ////////////////////////////////////////////////////////////////////////////////////////////////////////
     //                                      ASAPEnvironmentChangesListener                                //
     ////////////////////////////////////////////////////////////////////////////////////////////////////////

src/net/sharksystem/asap/ASAPMessageReceivedListenerManagement.java

@@ -8,4 +8,10 @@ public interface ASAPMessageReceivedListenerManagement {
      */
     void addASAPMessageReceivedListener(CharSequence format, ASAPMessageReceivedListener listener);
     void removeASAPMessageReceivedListener(CharSequence format, ASAPMessageReceivedListener listener);
+
+    /**
+     * @ return number of listeners
+     * @return
+     */
+    int getNumberListener();
 }

src/net/sharksystem/asap/ASAPPeer.java

@@ -1,15 +1,12 @@
 package net.sharksystem.asap;
 
-import net.sharksystem.asap.protocol.ASAPConnection;
-
 import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
 
 public interface ASAPPeer extends
         ASAPMessageSender,
         ASAPEnvironmentChangesListenerManagement,
-        ASAPMessageReceivedListenerManagement
+        ASAPMessageReceivedListenerManagement,
+        ASAPChannelContentChangedListenerManagement
 {
     CharSequence UNKNOWN_USER = "anon";
     boolean ONLINE_EXCHANGE_DEFAULT = true;

src/net/sharksystem/asap/ASAPPeerFS.java

@@ -56,16 +56,30 @@ public void chunkReceived(String format, String senderE2E, String uri, int era,
             this.log("chunk received listener set - call this one");
             this.chunkReceivedListener.chunkReceived(format, senderE2E, uri, era, asapHopList);
         } else {
-            this.log("extract messages from chunk and notify listener");
-            ASAPMessages receivedMessages =
-                    Helper.getMessagesByChunkReceivedInfos(format, senderE2E, uri, this.rootFolder, era);
+            this.log("notify listener");
+            if(this.asapMessageReceivedListenerManager.getNumberListener() > 0) {
+                this.log("extract messages from chunk and notify listener");
+                ASAPMessages receivedMessages =
+                        Helper.getMessagesByChunkReceivedInfos(format, senderE2E, uri, this.rootFolder, era);
+
+                this.asapMessageReceivedListenerManager.notifyReceived(
+                        format, receivedMessages, true,
+                        senderE2E, asapHopList);
+            }
 
-            this.asapMessageReceivedListenerManager.notifyReceived(
-                    format, receivedMessages, true,
-                    senderE2E, asapHopList);
+            if(this.asapChannelContentChangedListenerManager.getNumberListener() > 0) {
+                this.log("notify channel content changed listener");
+                this.asapChannelContentChangedListenerManager.notifyChanged(format, uri, era, true);
+            }
         }
     }
 
+    /// TODO this method makes absolutely no sense in that class.
+    @Override
+    public int getNumberListener() {
+        return this.asapMessageReceivedListenerManager.getNumberListener();
+    }
+
     // TODO move behaviour control into this package
 
     @Override

src/net/sharksystem/asap/listenermanager/ASAPChannelContentChangedListenerManager.java

@@ -0,0 +1,71 @@
+package net.sharksystem.asap.listenermanager;
+
+import net.sharksystem.asap.*;
+
+import java.util.HashMap;
+
+public class ASAPChannelContentChangedListenerManager implements ASAPChannelContentChangedListenerManagement {
+    private HashMap<CharSequence, GenericListenerImplementation<ASAPChannelContentChangedListener>> listenerMap =
+            new HashMap();
+
+    @Override
+    public void addASAPChannelContentChangedListener(CharSequence format, ASAPChannelContentChangedListener listener) {
+        GenericListenerImplementation<ASAPChannelContentChangedListener> listenerList = this.listenerMap.get(format);
+        if(listenerList == null) {
+            listenerList = new GenericListenerImplementation<ASAPChannelContentChangedListener>();
+            this.listenerMap.put(format, listenerList);
+        }
+
+        listenerList.addListener(listener);
+    }
+
+    @Override
+    public void removeASAPChannelContentChangedListener(CharSequence format, ASAPChannelContentChangedListener listener) {
+        GenericListenerImplementation<ASAPChannelContentChangedListener> listenerList = this.listenerMap.get(format);
+        if(listenerList != null) {
+            listenerList.removeListener(listener);
+        }
+    }
+
+    public int getNumberListener() {
+        if(this.listenerMap == null) return 0;
+        return this.listenerMap.size();
+    }
+
+    public void removeAllListeners() {
+        // reset
+        this.listenerMap = new HashMap();
+    }
+
+    public void notifyChanged(CharSequence format, CharSequence uri, int era) {
+
+        this.notifyChanged(format, uri, era, false);
+    }
+
+    public void notifyChanged(CharSequence format, CharSequence uri, int era, boolean useThreads) {
+
+        GenericListenerImplementation<ASAPChannelContentChangedListener> listenerList = this.listenerMap.get(format);
+        if(listenerList != null) {
+            ASAPChannelContentChangedListenerManager.ASAPChannelContentChangedNotifier notifier
+                    = new ASAPChannelContentChangedListenerManager.ASAPChannelContentChangedNotifier(format, uri, era);
+
+            listenerList.notifyAll(notifier, useThreads);
+        }
+    }
+
+    public class ASAPChannelContentChangedNotifier implements GenericNotifier<ASAPChannelContentChangedListener> {
+        private CharSequence format;
+        private CharSequence uri;
+        private int era;
+
+        ASAPChannelContentChangedNotifier(CharSequence format, CharSequence uri, int era) {
+            this.format = format;
+            this.uri = uri;
+            this.era = era;
+        }
+
+        public void doNotify(ASAPChannelContentChangedListener listener) {
+            listener.asapChannelContentChanged(this.format, this.uri, this.era);
+        }
+    }
+}

src/net/sharksystem/asap/listenermanager/ASAPMessageReceivedListenerManager.java

@@ -29,6 +29,12 @@ public void removeASAPMessageReceivedListener(CharSequence format, ASAPMessageRe
         }
     }
 
+    @Override
+    public int getNumberListener() {
+        if(this.listenerMap == null) return 0;
+        return this.listenerMap.size();
+    }
+
     public void removeAllListeners() {
         // reset
         this.listenerMap = new HashMap();