Talkto master

Categories/NSXMLElementAdditions.h

@@ -5,7 +5,7 @@
 #endif
 
 
-@interface NSXMLElement (XMPPStreamAdditions)
+@interface NSXMLElement (XMPPStreamAdditions) <NSCoding>
 
 + (NSXMLElement *)elementWithName:(NSString *)name xmlns:(NSString *)ns;
 
@@ -43,4 +43,6 @@
 - (NSString *)namespaceStringValueForPrefix:(NSString *)prefix;
 - (NSString *)namespaceStringValueForPrefix:(NSString *)prefix withDefaultValue:(NSString *)defaultValue;
 
++ (NSXMLElement *)parseWellFormatedXMLString:(NSString *)xml;
+
 @end

Categories/NSXMLElementAdditions.m

@@ -219,4 +219,28 @@ - (NSString *)namespaceStringValueForPrefix:(NSString *)prefix withDefaultValue:
 	return (namespace) ? [namespace stringValue] : defaultValue;
 }
 
++ (NSXMLElement *)parseWellFormatedXMLString:(NSString *)xml
+{
+	NSXMLDocument *doc = [[[NSXMLDocument alloc] initWithXMLString:xml
+														   options:0
+															 error:NULL] autorelease];
+	NSXMLElement *element = [doc rootElement];
+	[element detach];
+	return element;
+}
+
+#define kNSXMLElement @"NSXMLElementCompactXMLString"
+
+- (void)encodeWithCoder: (NSCoder *)coder
+{
+	[coder encodeObject:[self compactXMLString] forKey:kNSXMLElement];
+}
+
+- (id)initWithCoder: (NSCoder *)coder
+{
+	[self release];
+	self = [[NSXMLElement parseWellFormatedXMLString:(NSString *)[coder decodeObjectForKey:kNSXMLElement]] retain];
+	return self;
+}
+
 @end

Core/Transports/BoshTransport.h

@@ -0,0 +1,165 @@
+//
+//  BoshTransport.h
+//  iPhoneXMPP
+//
+//  Created by Satyam Shekhar on 3/17/11.
+//  Copyright 2011 __MyCompanyName__. All rights reserved.
+//
+
+#import <Foundation/Foundation.h>
+#import "XMPPTransportProtocol.h"
+#import "XMPPJID.h"
+#import "MulticastDelegate.h"
+#import "ASIHTTPRequest.h"
+
+typedef enum {
+    ATTR_TYPE = 0,
+    NAMESPACE_TYPE = 1
+} XMLNodeType;
+
+/*
+ host-unknown
+ host-gone
+ item-not-found
+ policy-violation
+ remote-connection-failed
+ bad-request
+ internal-server-error
+ remote-stream-error
+ undefined-condition
+ */
+
+#define BoshTerminateConditionDomain @"BoshTerminateCondition"
+
+typedef enum {
+    HOST_UNKNOWN = 1,
+    HOST_GONE = 2,
+    ITEM_NOT_FOUND = 3,
+    POLICY_VIOLATION = 4,
+    REMOTE_CONNECTION_FAILED = 5,
+    BAD_REQUEST = 6,
+    INTERNAL_SERVER_ERROR = 7,
+    REMOTE_STREAM_ERROR = 8,
+    UNDEFINED_CONDITION = 9
+} BoshTerminateConditions;
+
+typedef enum {
+    CONNECTED = 0,
+    CONNECTING = 1,
+    DISCONNECTING = 2,
+    DISCONNECTED = 3,
+    TERMINATING = 4
+} BoshTransportState;
+
+@interface RequestResponsePair : NSObject <NSCoding> 
+@property (nonatomic, retain) NSXMLElement *request;
+@property (nonatomic, retain) NSXMLElement *response;
+- (id)initWithRequest:(NSXMLElement *)request response:(NSXMLElement *)response;
+- (void)dealloc;
+@end
+
+#pragma mark -
+
+/**
+ * Handles the in-order processing of responses.
+ **/
+@interface BoshWindowManager : NSObject <NSCoding>  {
+    long long maxRidReceived; // all rid value less than equal to maxRidReceived are processed.
+    long long maxRidSent;
+    NSMutableSet *receivedRids;
+}
+
+@property (nonatomic) unsigned int windowSize;
+@property (nonatomic, readonly) long long maxRidReceived;
+
+- (id)initWithRid:(long long)rid;
+- (void)sentRequestForRid:(long long)rid;
+- (void)receivedResponseForRid:(long long)rid;
+- (BOOL)isWindowFull;
+- (BOOL)isWindowEmpty;
+- (void)dealloc;
+@end
+
+
+#pragma mark -
+
+@interface BoshTransport : NSObject <XMPPTransportProtocol, NSCoding> {
+    NSString *boshVersion;
+
+    long long nextRidToSend;
+    long long maxRidProcessed;
+
+    NSMutableArray *pendingXMPPStanzas;
+    BoshWindowManager *boshWindowManager;
+    BoshTransportState state;
+
+    NSMutableDictionary *requestResponsePairs;
+
+    MulticastDelegate <XMPPTransportDelegate> *multicastDelegate;
+    NSError *disconnectError_;
+
+    int retryCounter;
+    NSTimeInterval nextRequestDelay;
+
+    BOOL secure;
+  unsigned int requests;
+}
+
+@property (nonatomic, retain) XMPPJID *myJID;
+@property (nonatomic, assign) unsigned int wait;
+@property (nonatomic, assign) unsigned int hold;
+@property (nonatomic, copy) NSString *lang;
+@property (nonatomic, copy) NSString *domain;
+@property (nonatomic, copy) NSString *routeProtocol;
+@property (nonatomic, copy) NSString *host;
+@property (nonatomic, assign) unsigned int port;
+@property (nonatomic, assign) unsigned int inactivity;
+@property (nonatomic, readonly) BOOL secure;
+@property (nonatomic, readonly) unsigned int requests;
+@property (nonatomic, copy) NSString *authid;
+@property (nonatomic, copy) NSString *sid;
+@property (nonatomic, copy) NSURL *url;
+@property (nonatomic, readonly) NSError *disconnectError;
+
+@property(nonatomic, readonly) BOOL isPaused;
+
+/* init Methods */
+- (id)initWithUrl:(NSURL *)url forDomain:(NSString *)domain;
+- (id)initWithUrl:(NSURL *)url
+        forDomain:(NSString *)domain
+    routeProtocol:(NSString *)routeProtocol
+             host:(NSString *)host
+             port:(unsigned int)port;
+- (id)initWithUrl:(NSURL *)url
+        forDomain:(NSString *)domain
+     withDelegate:(id<XMPPTransportDelegate>)delegate;
+- (id)initWithUrl:(NSURL *)url
+        forDomain:(NSString *)domain
+    routeProtocol:(NSString *)routeProtocol
+             host:(NSString *)host
+             port:(unsigned int)port
+     withDelegate:(id<XMPPTransportDelegate>)delegate;
+
+- (void)dealloc;
+
+/* ASI http methods - Delegate Methods */
+- (void)requestFinished:(ASIHTTPRequest *)request;
+- (void)requestFailed:(ASIHTTPRequest *)request;
+
+/* Protocol Methods */
+- (BOOL)isConnected;
+- (void)addDelegate:(id)delegate;
+- (void)removeDelegate:(id)delegate;
+- (XMPPJID *)myJID;
+- (void)setMyJID:(XMPPJID *)jid;
+- (BOOL)connect:(NSError **)errPtr;
+- (void)disconnect;
+- (void)restartStream;
+- (float)serverXmppStreamVersionNumber;
+- (BOOL)sendStanza:(NSXMLElement *)stanza;
+- (BOOL)sendStanzaWithString:(NSString *)string;
+
+- (void)pause;
+- (void)resume;
+
+@end