Synnefo » Pithos MacOS Client

#import "PithosActivityFacility.h"

                containerRequest.userInfo = [NSMutableDictionary dictionaryWithObjectsAndKeys:

                                             [NSNumber numberWithUnsignedInteger:10], @"retries", 

                                             nil];

- (void)containerRequestFailed:(ASIPithosContainerRequest *)request {

    NSUInteger retries = [[containerRequest.userInfo objectForKey:@"retries"] unsignedIntegerValue];

    if (retries > 0) {

        ASIPithosContainerRequest *newContainerRequest = (ASIPithosContainerRequest *)[PithosUtilities copyRequest:containerRequest];

        [(NSMutableDictionary *)(newContainerRequest.userInfo)setObject:[NSNumber numberWithUnsignedInteger:(--retries)] forKey:@"retries"];

        [containerRequest release];

        containerRequest = newContainerRequest;

        [[PithosUtilities prepareRequest:containerRequest priority:NSOperationQueuePriorityVeryHigh] startAsynchronous];

        NSString *message;

        NSError *error = [containerRequest error];

        if (error)

            message = [NSString stringWithFormat:@"Container listing failed: %@", error];

        else

            message = [NSString stringWithFormat:@"Container listing failed: (%d) %@", 

                       containerRequest.responseStatusCode, containerRequest.responseStatusMessage];

        [[PithosActivityFacility defaultPithosActivityFacility] startAndEndActivityWithType:PithosActivityOther message:message];

        [newChildren release];

        newChildren = nil;

        [containerRequest release];

        containerRequest = nil;

        [objects release];

        objects = nil;

        forcedRefresh = NO;

        @synchronized(self) {

            freshness = PithosNodeStateRefreshNeeded;

        }

}

- (void)containerRequestFinished:(ASIPithosContainerRequest *)request {

    NSLog(@"List container finished: %@", [containerRequest url]);

    NSLog(@"Cached: %d", [containerRequest didUseCachedResponse]);

    if (containerRequest.responseStatusCode == 200) {

        if ((pithosContainer.blockHash == nil) || (pithosContainer.blockSize == 0)) {

            pithosContainer.blockHash = [containerRequest blockHash];

            pithosContainer.blockSize = [containerRequest blockSize];

        }

        NSArray *someObjects = [containerRequest objects];

        if (objects == nil) {

            objects = [[NSMutableArray alloc] initWithArray:someObjects];

        } else {

            [objects addObjectsFromArray:someObjects];

        }

        if ([someObjects count] < 10000) {

            if (!containerRequest.didUseCachedResponse || ([objects count] != [someObjects count]) || !children) {

                // Save new children

                NSLog(@"using newChildren");

                newChildren = [[NSMutableArray alloc] init];

                NSArray *objectNames = [objects valueForKey:@"name"];

                NSMutableIndexSet *keptNodes = [NSMutableIndexSet indexSet];

                BOOL isSubdirNode = ([self class] == [PithosSubdirNode class]);

                for (ASIPithosObject *object in objects) {

                    if (!isSubdirNode || 

                        [object.name hasPrefix:[((PithosSubdirNode *)self).prefix stringByAppendingString:@"/"]]) {

                        // The check above removes false objects due to trailing slash or same prefix

                        if (object.subdir) {

                            NSUInteger sameNameObjectIndex = [objectNames indexOfObject:[object.name substringToIndex:([object.name length] - 1)]];

                            if ((sameNameObjectIndex == NSNotFound) || 

                                ![PithosUtilities isContentTypeDirectory:[[objects objectAtIndex:sameNameObjectIndex] contentType]]) {

                                PithosSubdirNode *node = [[[PithosSubdirNode alloc] initWithPithosContainer:pithosContainer pithosObject:object] autorelease];

                                node.parent = self;

                                node.shared = shared;

                                node.sharingAccount = sharingAccount;

                                if (children) {

                                    NSUInteger oldIndex = [children indexOfObject:node];

                                    if (oldIndex != NSNotFound) {

                                        // Use the same pointer value, if possible

                                        node = [children objectAtIndex:oldIndex];

                                        node.pithosContainer = pithosContainer;

                                        node.pithosObject = object;

                                        [keptNodes addIndex:oldIndex];

                                    }

                                }

                                if (sharingAccount)

                                    node.pithosObject.allowedTo = [NSString stringWithString:@"read"];

                                [newChildren addObject:node];

                            }

                        } else if ([PithosUtilities isContentTypeDirectory:object.contentType]) {

                        } else {

                            PithosObjectNode *node = [[[PithosObjectNode alloc] initWithPithosContainer:pithosContainer pithosObject:object] autorelease];

                            node.parent = self;

                            node.shared = shared;

                            node.sharingAccount = sharingAccount;

                            if (children) {

                                NSUInteger oldIndex = [children indexOfObject:node];

                                if (oldIndex != NSNotFound) {

                                    // Use the same pointer value, if possible

                                    node = [children objectAtIndex:oldIndex];

                                    node.pithosContainer = pithosContainer;

                                    node.pithosObject = object;

                                    [keptNodes addIndex:oldIndex];

                                }

                            [newChildren addObject:node];                                

                [[children objectsAtIndexes:

                  [[NSIndexSet indexSetWithIndexesInRange:NSMakeRange(0, [children count])] indexesPassingTest:^(NSUInteger idx, BOOL *stop){

                    if ([keptNodes containsIndex:idx])

                        return NO;

                    return YES;

                }]] makeObjectsPerformSelector:@selector(pithosNodeWillBeRemoved)];

            }

            // Else cache was used and all results were fetched during this request, so existing children can be reused

            [containerRequest release];

            containerRequest = nil;

            [objects release];

            objects = nil;

            forcedRefresh = NO;

            @synchronized(self) {

                freshness = PithosNodeStateRefreshFinished;

            // Notify observers that children are updated

            [[NSNotificationCenter defaultCenter] postNotificationName:childrenUpdatedNotificationName object:self];

        } else {

            [containerRequest release];

            // Do an additional request to fetch more objects

            containerRequest = [[ASIPithosContainerRequest listObjectsRequestWithContainerName:pithosContainer.name 

                                                                                         limit:0 

                                                                                        marker:[[someObjects lastObject] name] 

                                                                                        prefix:prefix 

                                                                                     delimiter:@"/" 

                                                                                          path:nil 

                                                                                          meta:nil 

                                                                                        shared:shared 

                                                                                         until:nil] retain];

            if (sharingAccount)

                [containerRequest setRequestUserFromDefaultTo:sharingAccount];

            containerRequest.delegate = self;

            containerRequest.didFinishSelector = @selector(containerRequestFinished:);

            containerRequest.didFailSelector = @selector(containerRequestFailed:);

            containerRequest.userInfo = [NSMutableDictionary dictionaryWithObjectsAndKeys:

                                         [NSNumber numberWithUnsignedInteger:10], @"retries", 

                                         nil];

            if (!forcedRefresh)

            containerRequest.downloadCache = [ASIDownloadCache sharedCache];

            [[PithosUtilities prepareRequest:containerRequest priority:NSOperationQueuePriorityVeryHigh] startAsynchronous];

    } else if (containerRequest.responseStatusCode == 304) {

        // Container is not modified, so existing children can be reused

        [self containerRequestFailed:containerRequest];