Synnefo » Pithos iOS Client

                     NSString *storageURLString = [[request responseHeaders] objectForKey:@"X-Storage-Url"];

                     if (storageURLString) {

                         account.filesURL = [NSURL URLWithString:storageURLString];

                     } else {

                         account.filesURL = [account.provider.authEndpointURL URLByAppendingPathComponent:account.username];

                     }

                     account.filesURL = [account.provider.authEndpointURL URLByAppendingPathComponent:account.username];

- (void)getObjects:(Container *)container afterMarker:(NSString *)marker objectsBuffer:(NSMutableDictionary *)objectsBuffer;

- (void)getObjects:(Container *)container;

#import "GetObjectsRequest.h"

- (APICallback *)callbackWithRequest:(id)request success:(APIResponseBlock)success failure:(APIResponseBlock)failure {

    APICallback *callback = [[[APICallback alloc] initWithAccount:self.account request:request] autorelease];

    ((OpenStackRequest *)request).delegate = self;

    ((OpenStackRequest *)request).callback = callback;

    [request startAsynchronous];

- (APICallback *)callbackWithRequest:(id)request success:(APIResponseBlock)success {

- (APICallback *)callbackWithRequest:(id)request {

        self.account.containers = [request containers];

- (void)getObjects:(Container *)container afterMarker:(NSString *)marker objectsBuffer:(NSMutableDictionary *)objectsBuffer {

    if (!self.queue) {

        self.queue = [ASINetworkQueue queue];

        self.queue.shouldCancelAllRequestsOnFailure = NO;

        [self.queue go];

    }

    GetObjectsRequest *request = [GetObjectsRequest request:self.account container:container marker:marker objectsBuffer:objectsBuffer];

    [queue addOperation:request];

- (void)getObjects:(Container *)container {

    [self getObjects:container afterMarker:nil objectsBuffer:nil];

#pragma mark - Observers

- (void)getObjectsSucceeded:(OpenStackRequest *)request {

    if ([request isSuccess]) {

        Container *container = [request.userInfo objectForKey:@"container"];

        NSMutableDictionary *objects = [request objects];

        container.rootFolder = [Folder folder];

        container.rootFolder.objects = objects;

        [self.account persist];

        NSNotification *notification = [NSNotification notificationWithName:@"getObjectsSucceeded" object:self.account userInfo:[NSDictionary dictionaryWithObject:container forKey:@"container"]];

        [[NSNotificationCenter defaultCenter] postNotification:notification];

    } else {

        NSNotification *notification = [NSNotification notificationWithName:@"getObjectsFailed" object:self.account userInfo:[NSDictionary dictionaryWithObject:request forKey:@"request"]];

        [[NSNotificationCenter defaultCenter] postNotification:notification];

    }

}

- (void)getObjectsFailed:(OpenStackRequest *)request {

    NSNotification *notification = [NSNotification notificationWithName:@"getObjectsFailed" object:self.account userInfo:[NSDictionary dictionaryWithObject:request forKey:@"request"]];

    [[NSNotificationCenter defaultCenter] postNotification:notification];

}

                     NSString *storageURLString = [[request responseHeaders] objectForKey:@"X-Storage-Url"];

                     if (storageURLString) {

                         account.filesURL = [NSURL URLWithString:storageURLString];

                     } else {

                         account.filesURL = [account.provider.authEndpointURL URLByAppendingPathComponent:account.username];

                     }

                     account.filesURL = [account.provider.authEndpointURL URLByAppendingPathComponent:account.username];

    id successObserver;

    id failureObserver;

    [self.account.manager getObjects:self.container];

    successObserver = [[NSNotificationCenter defaultCenter] addObserverForName:@"getObjectsSucceeded"

                                                                        object:self.container

                                                                         queue:[NSOperationQueue mainQueue]

                                                                    usingBlock:^(NSNotification* notification)

    {

           if (self.selectedObjectViewController) {

               [self.selectedObjectViewController reloadMetadataSection];

           } else if ([self.folder isEqual:container.rootFolder]) {

               [containersViewController.containerDetailViewController reloadMetadataSection];

           } else if ([parentFolderViewController.folderDetailVC.navigationController.topViewController 

                       isEqual:parentFolderViewController.folderDetailVC]) {

               [parentFolderViewController.folderDetailVC reloadMetadataSection];

           }

        [[NSNotificationCenter defaultCenter] removeObserver:successObserver];

        [[NSNotificationCenter defaultCenter] removeObserver:failureObserver];

    }];

    failureObserver = [[NSNotificationCenter defaultCenter] addObserverForName:@"getObjectsFailed"

                                                                        object:self.container

                                                                         queue:[NSOperationQueue mainQueue]

                                                                    usingBlock:^(NSNotification* notification)

    {

        [[NSNotificationCenter defaultCenter] removeObserver:successObserver];

        [[NSNotificationCenter defaultCenter] removeObserver:failureObserver];

//

//  GetObjectsRequest.h

//  OpenStack

//

//  Created by Mike Mayo on 12/24/10.

//  The OpenStack project is provided under the Apache 2.0 license.

//

#import "OpenStackRequest.h"

@class OpenStackAccount, Container;

@interface GetObjectsRequest : OpenStackRequest {

    Container *container;

}

@property (nonatomic, retain) Container *container;

+ (id)request:(OpenStackAccount *)account container:(Container *)container;

+ (id)request:(OpenStackAccount *)account container:(Container *)container

       marker:(NSString *)marker objectsBuffer:(NSMutableDictionary *)objectsBuffer;

@end

//

//  GetObjectsRequest.m

//  OpenStack

//

//  Created by Mike Mayo on 12/24/10.

//  The OpenStack project is provided under the Apache 2.0 license.

//

#import "GetObjectsRequest.h"

#import "OpenStackAccount.h"

#import "Container.h"

#import "StorageObject.h"

#import "AccountManager.h"

#import "Folder.h"

#import "SBJSON.h"

#import "NSString+Conveniences.h"

@implementation GetObjectsRequest

@synthesize container;

#pragma mark - Constructors

+ (id)request:(OpenStackAccount *)account method:(NSString *)method url:(NSURL *)url {

	GetObjectsRequest *request = [[[self

                                    alloc] initWithURL:url] autorelease];

    request.account = account;

	request.requestMethod = method;

	[request addRequestHeader:@"X-Auth-Token" value:account.authToken];

    [request addRequestHeader:@"Content-Type" value:@"application/json"];

    request.timeOutSeconds = 60;

    request.numberOfTimesToRetryOnTimeout = 5;

    request.validatesSecureCertificate = !account.ignoreSSLErrors;

	return request;

}

+ (id)filesRequest:(OpenStackAccount *)account method:(NSString *)method path:(NSString *)path marker:(NSString *)marker {

    NSString *urlString = [account.filesURL description];

    if (account.sharingAccount) {

        urlString = [NSString stringWithFormat:@"%@%@",

                     [urlString substringToIndex:[urlString rangeOfString:account.username].location],

                     account.sharingAccount];

    }

	NSURL *url = [NSURL URLWithString:[NSString stringWithFormat:@"%@%@?format=json%@%@",

                                       urlString,

                                       path,

                                       (account.shared ? @"&shared=" : @""),

                                       (marker ? [NSString stringWithFormat:@"&marker=%@", marker] : @"")]];

    return [self request:account method:method url:url];

}

+ (id)filesRequest:(OpenStackAccount *)account method:(NSString *)method path:(NSString *)path {

    return [self filesRequest:account method:method path:path marker:nil];

}

+ (id)request:(OpenStackAccount *)account container:(Container *)container {

    return [self request:account container:container marker:nil objectsBuffer:nil];

}

+ (id)request:(OpenStackAccount *)account container:(Container *)container

       marker:(NSString *)marker objectsBuffer:(NSMutableDictionary *)objectsBuffer {

    GetObjectsRequest *request = [self filesRequest:account

                                             method:@"GET"

                                               path:[NSString stringWithFormat:@"/%@", [NSString encodeToPercentEscape:container.name]]

                                             marker:[NSString encodeToPercentEscape:marker]];

    request.container = container;

    if (objectsBuffer == nil)

        objectsBuffer = [NSMutableDictionary dictionary];

    request.userInfo = [NSMutableDictionary dictionaryWithObject:objectsBuffer forKey:@"objectsBuffer"];

    return request;

}

#pragma mark - ASIHTTPRequest Overrides

- (void)requestFinished {

    if ([self isSuccess]) {

        Container *aContainer = self.container;

        NSMutableDictionary *objects = [self objects];

        NSMutableDictionary *objectsBuffer = [self.userInfo objectForKey:@"objectsBuffer"];

        [objectsBuffer addEntriesFromDictionary:objects];

        if (objects.count < 10000) {

            aContainer.rootFolder = [Folder folder];

            aContainer.rootFolder.objects = objectsBuffer;

            [self.account persist];

            NSNotification *notification = [NSNotification notificationWithName:@"getObjectsSucceeded" object:self.container

                                                                       userInfo:[NSDictionary dictionaryWithObjectsAndKeys:

                                                                                 aContainer, @"container",

                                                                                 self, @"request",

                                                                                 nil]];

            [[NSNotificationCenter defaultCenter] postNotification:notification];

        } else {

            SBJSON *parser = [[[SBJSON alloc] init] autorelease];

            NSArray *jsonObjects = [parser objectWithString:[self responseString]];

            NSString *marker = [[jsonObjects lastObject] objectForKey:@"name"];

            [self.account.manager getObjects:self.container afterMarker:marker objectsBuffer:objectsBuffer];

        }        

    } else {

        NSNotification *notification = [NSNotification notificationWithName:@"getObjectsFailed" object:self.container userInfo:[NSDictionary dictionaryWithObject:self forKey:@"request"]];

        [[NSNotificationCenter defaultCenter] postNotification:notification];

    }

    [super requestFinished];

}

- (void)failWithError:(NSError *)theError {

    NSNotification *notification = [NSNotification notificationWithName:@"getObjectsFailed" object:self.container userInfo:[NSDictionary dictionaryWithObject:self forKey:@"request"]];

    [[NSNotificationCenter defaultCenter] postNotification:notification];

    [super failWithError:theError];

}

#pragma mark - Memory Management

- (void)dealloc {

    [container release];

    [super dealloc];

}

@end

@property (nonatomic, retain) NSURL *filesURL;

        self.filesURL = [self decode:coder key:@"filesURL"];

    copy.filesURL = [[self.filesURL copy] autorelease];

    [coder encodeObject:filesURL forKey:@"filesURL"];

    [filesURL release];

@interface OpenStackRequest : ASIHTTPRequest {

- (NSArray *)sharingAccounts;

- (NSMutableDictionary *)containers;

- (NSMutableDictionary *)objects;

@synthesize account, callback, errorAlerter;

    NSURL *url = [NSURL URLWithString:[NSString stringWithFormat:@"%@?format=json", account.provider.authEndpointURL]];

    return [self request:account method:@"GET" url:url];

- (NSArray *)sharingAccounts {

    SBJSON *parser = [[[SBJSON alloc] init] autorelease];

    NSArray *sharingAccounts = [parser objectWithString:[self responseString]];

    return sharingAccounts;

    return [self filesRequest:account method:@"GET" path:@""];

- (NSMutableDictionary *)containers {

    SBJSON *parser = [[[SBJSON alloc] init] autorelease];

    NSArray *jsonObjects = [parser objectWithString:[self responseString]];

    NSMutableDictionary *containers = [NSMutableDictionary dictionaryWithCapacity:[jsonObjects count]];

    for (NSDictionary *dict in jsonObjects) {

        Container *container = [Container fromJSON:dict];

        [containers setObject:container forKey:container.name];

    }

    return containers;

    return [self filesRequest:account method:@"GET" path:[NSString stringWithFormat:@"/%@", [NSString encodeToPercentEscape:container.name]]];

- (NSMutableDictionary *)objects {

    SBJSON *parser = [[[SBJSON alloc] init] autorelease];

    NSArray *jsonObjects = [parser objectWithString:[self responseString]];

    NSMutableDictionary *objects = [NSMutableDictionary dictionaryWithCapacity:[jsonObjects count]];

    for (NSDictionary *dict in jsonObjects) {

        StorageObject *object = [StorageObject fromJSON:dict];

        [objects setObject:object forKey:object.name];

    }

    return objects;

    NSString *observeName = [NSString stringWithFormat:@"%@ %@ %@", [self isSuccess] ? @"SUCCESS" : @"FAILURE", self.requestMethod, [self.url description]];

    NSString *callbackName = [NSString stringWithFormat:@"%@ %@ %@ %@", [self isSuccess] ? @"SUCCESS" : @"FAILURE", self.requestMethod, [self.url description], self.callback.uuid];

         for (NSDictionary *dict in [request sharingAccounts]) {

             [sharingAccounts addObject:[dict objectForKey:@"name"]];

         }

	<string>1.7.1</string>

	<string>20130625.0</string>

		278896B312C53956006448E2 /* GetObjectsRequest.m in Sources */ = {isa = PBXBuildFile; fileRef = 278896B112C53956006448E2 /* GetObjectsRequest.m */; };

		278896B012C53956006448E2 /* GetObjectsRequest.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = GetObjectsRequest.h; sourceTree = "<group>"; };

		278896B112C53956006448E2 /* GetObjectsRequest.m */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.objc; path = GetObjectsRequest.m; sourceTree = "<group>"; };

				2788958612C476A3006448E2 /* Object Storage */,

		2788958612C476A3006448E2 /* Object Storage */ = {

			isa = PBXGroup;

			children = (

				278896B012C53956006448E2 /* GetObjectsRequest.h */,

				278896B112C53956006448E2 /* GetObjectsRequest.m */,

			);

			name = "Object Storage";

			sourceTree = "<group>";

		};

				278896B312C53956006448E2 /* GetObjectsRequest.m in Sources */,