Adding new delegate method for XMPPStream - xmppStreamDidFilterStanza

Author: robbiehanson

Core/XMPPStream.h

@@ -940,6 +940,14 @@ extern const NSTimeInterval XMPPStreamTimeoutNone;
 - (XMPPMessage *)xmppStream:(XMPPStream *)sender willReceiveMessage:(XMPPMessage *)message;
 - (XMPPPresence *)xmppStream:(XMPPStream *)sender willReceivePresence:(XMPPPresence *)presence;
 
+/**
+ * This method is called if any of the xmppStream:willReceiveX: methods filter the incoming stanza.
+ * 
+ * It may be useful for some extensions to know that something was received,
+ * even if it was filtered for some reason.
+**/
+- (void)xmppStreamDidFilterStanza:(XMPPStream *)sender;
+
 /**
  * These methods are called after their respective XML elements are received on the stream.
  * 
@@ -1093,7 +1101,7 @@ extern const NSTimeInterval XMPPStreamTimeoutNone;
  * The standard example is XEP-0198, which uses <r> & <a> elements.
  * 
  * If you're using custom elements, you must register the custom element name(s).
- * Otherwise the xmppStream will treat an non-XMPP elements as errors (xmppStream:didReceiveError:).
+ * Otherwise the xmppStream will treat non-XMPP elements as errors (xmppStream:didReceiveError:).
  * 
  * @see registerCustomElementNames (in XMPPInternal.h)
 **/

Core/XMPPStream.m

@@ -2830,15 +2830,16 @@ - (void)receiveIQ:(XMPPIQ *)iq
 				}});
 			}
 
-			if (modifiedIQ)
-			{
-				dispatch_async(xmppQueue, ^{ @autoreleasepool {
-					
-					if (state == STATE_XMPP_CONNECTED) {
+			dispatch_async(xmppQueue, ^{ @autoreleasepool {
+				
+				if (state == STATE_XMPP_CONNECTED)
+				{
+					if (modifiedIQ)
 						[self continueReceiveIQ:modifiedIQ];
-					}
-				}});
-			}
+					else
+						[multicastDelegate xmppStreamDidFilterStanza:self];
+				}
+			}});
 		}});
 	}
 }
@@ -2904,15 +2905,16 @@ - (void)receiveMessage:(XMPPMessage *)message
 				}});
 			}
 
-			if (modifiedMessage)
-			{
-				dispatch_async(xmppQueue, ^{ @autoreleasepool {
-					
-					if (state == STATE_XMPP_CONNECTED) {
+			dispatch_async(xmppQueue, ^{ @autoreleasepool {
+				
+				if (state == STATE_XMPP_CONNECTED)
+				{
+					if (modifiedMessage)
 						[self continueReceiveMessage:modifiedMessage];
-					}
-				}});
-			}
+					else
+						[multicastDelegate xmppStreamDidFilterStanza:self];
+				}
+			}});
 		}});
 	}
 }
@@ -2978,15 +2980,16 @@ - (void)receivePresence:(XMPPPresence *)presence
 				}});
 			}
 
-			if (modifiedPresence)
-			{
-				dispatch_async(xmppQueue, ^{ @autoreleasepool {
-					
-					if (state == STATE_XMPP_CONNECTED) {
+			dispatch_async(xmppQueue, ^{ @autoreleasepool {
+				
+				if (state == STATE_XMPP_CONNECTED)
+				{
+					if (modifiedPresence)
 						[self continueReceivePresence:presence];
-					}
-				}});
-			}
+					else
+						[multicastDelegate xmppStreamDidFilterStanza:self];
+				}
+			}});
 		}});
 	}
 }