User Streams API Support

.gitmodules

@@ -2,4 +2,6 @@
 	path = External/AFNetworking
 	url = https://github.com/AFNetworking/AFNetworking
 	ignore = dirty
-
+[submodule "SocketShuttle"]
+	path = External/SocketShuttle
+	url=https://github.com/joeldev/SocketShuttle.git

ADNKit/ADNKit-Prefix.pch

@@ -13,8 +13,6 @@
 #ifdef __OBJC__
 	#import <Foundation/Foundation.h>
 
-	#define _AFNETWORKING_PIN_SSL_CERTIFICATES_
-
 	#if __IPHONE_OS_VERSION_MIN_REQUIRED
 		#import <MobileCoreServices/MobileCoreServices.h>
 	#endif

ADNKit/ADNKit-iOS.h

@@ -10,5 +10,5 @@
  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
 
-#import <ADNKit/ANKOAuthViewController.h>
-#import <ADNKit/ANKUsernamePasswordAuthViewController.h>
+#import "ANKOAuthViewController.h"
+#import "ANKUsernamePasswordAuthViewController.h"

ADNKit/ANKAPIResponseMeta.h

@@ -59,6 +59,13 @@ static NSString *const kANKErrorIDKey = @"ANKErrorID";
 @property (strong) NSString *errorSlug;
 @property (strong) NSString *errorID;
 
+// user streaming properties
+@property (assign) BOOL isDeleted;
+@property (strong) NSString *deletedID;
+@property (strong) NSArray *subscriptionIDs;
+@property (strong) NSString *connectionID;
+@property (strong) NSString *type;
+
 - (NSError *)error;
 - (BOOL)isError;
 - (ANKErrorType)errorType;

ADNKit/ANKAPIResponseMeta.m

@@ -23,7 +23,12 @@ + (NSDictionary *)JSONToLocalKeyMapping {
 			@"more": @"moreDataAvailable",
 			@"error_message": @"errorMessage",
 			@"error_slug": @"errorSlug",
-			@"error_id": @"errorID"}];
+			@"error_id": @"errorID",
+			@"is_deleted": @"isDeleted",
+			@"deleted_id": @"deletedID",
+			@"subscription_ids": @"subscriptionIDs",
+			@"connection_id": @"connectionID",
+			@"type": @"type"}];
 }
 
 

ADNKit/ANKAnnotation.m

@@ -15,6 +15,7 @@
 #import "ANKPlace.h"
 #import "ANKChannel.h"
 #import "ANKGeolocation.h"
+#import "ANKOEmbed.h"
 
 
 @interface ANKAnnotation ()

ADNKit/ANKChannel.h

@@ -28,6 +28,7 @@
 @property (strong) ANKACL *writers;
 @property (assign) BOOL isCurrentUserSubscribed;
 @property (assign) BOOL isEditableByCurrentUser;
+@property (assign) BOOL isInactive;
 @property (assign) BOOL hasUnreadMessages;
 
 - (BOOL)isPrivateMessageChannel;

ADNKit/ANKChannel.m

@@ -23,7 +23,8 @@ + (NSDictionary *)JSONToLocalKeyMapping {
 			@"you_can_edit": @"isEditableByCurrentUser",
 			@"has_unread": @"hasUnreadMessages",
 			@"recent_message_id": @"latestMessageID",
-			@"recent_message": @"latestMessage"}];
+			@"recent_message": @"latestMessage",
+            @"is_inactive" : @"isInactive"}];
 }
 
 

ADNKit/ANKClient+ANKRequestsAPI.m

@@ -1,4 +1,4 @@
-/*
+    /*
  Copyright (c) 2013, Joel Levin
  All rights reserved.
 

ADNKit/ANKClient.h

@@ -34,8 +34,32 @@ typedef NS_ENUM(NSUInteger, ANKResponseDecodingType) {
 	ANKResponseDecodingTypeNone // don't decode server response
 };
 
+typedef NS_ENUM(NSUInteger, ANKStreamingAvailability) {
+    ANKStreamingAvailabilityAllConnections,
+    ANKStreamingAvailabilityWiFi
+};
+
+
+@class ANKClient, ANKAPIResponseMeta;
+
+#pragma mark -
+#pragma mark - Protocols
+
+@protocol ANKStreamingDelegate <NSObject>
+
+@optional
+
+- (void)clientSocketDidConnect:(ANKClient *)client;
+- (void)clientSocketDidDisconnect:(ANKClient *)client;
+
+- (void)client:(ANKClient *)client didDisconnectOnSocketError:(NSError *)error;
+
+@required
+
+- (void)client:(ANKClient *)client didReceiveObject:(id)responseObject withMeta:(ANKAPIResponseMeta *)meta;
+
+@end
 
-@class ANKAPIResponseMeta;
 typedef void (^ANKClientCompletionBlock)(id responseObject, ANKAPIResponseMeta *meta, NSError *error);
 
 
@@ -58,6 +82,8 @@ typedef void (^ANKClientCompletionBlock)(id responseObject, ANKAPIResponseMeta *
 @property (assign) dispatch_queue_t successCallbackQueue;
 @property (assign) dispatch_queue_t failureCallbackQueue;
 
+@property (assign) ANKStreamingAvailability streamingAvailbility;
+
 @property (copy) void (^webAuthCompletionHandler)(BOOL success, NSError *error); // set as completion block for oauth authentication
 
 #pragma mark -
@@ -109,6 +135,10 @@ typedef void (^ANKClientCompletionBlock)(id responseObject, ANKAPIResponseMeta *
 - (void)setObject:(id)object forKeyInAuthenticatedUserDefaults:(NSString *)key;
 - (id)objectForKeyInAuthenticatedUserDefaults:(NSString *)key;
 
+#pragma mark -
+#pragma mark - Streams
+
+- (void)requestStreamingUpdatesForOperation:(ANKJSONRequestOperation *)operation withDelegate:(id<ANKStreamingDelegate>)delegate;
 
 #pragma mark -
 #pragma mark Operation Queues