Synnefo » Pithos MacOS Client

#import "PithosActivityFacility.h"

                accountRequest.userInfo = [NSMutableDictionary dictionaryWithObjectsAndKeys:

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

                                           nil];

- (void)accountRequestFailed:(ASIPithosAccountRequest *)request {

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

    if (retries > 0) {

        ASIPithosAccountRequest *newAccountRequest = (ASIPithosAccountRequest *)[PithosUtilities copyRequest:accountRequest];

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

        [accountRequest release];

        accountRequest = newAccountRequest;

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

        NSString *message;

        NSError *error = [accountRequest error];

        if (error)

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

        else

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

                       accountRequest.responseStatusCode, accountRequest.responseStatusMessage];

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

        [newChildren release];

        newChildren = nil;

        [accountRequest release];

        accountRequest = nil;

        [containers release];

        containers = nil;

        forcedRefresh = NO;

        @synchronized(self) {

            freshness = PithosNodeStateRefreshNeeded;

        }

}

- (void)accountRequestFinished:(ASIPithosAccountRequest *)request {

    NSLog(@"List account finished: %@", [accountRequest url]);

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

    if (accountRequest.responseStatusCode == 200) {

        self.pithosAccount = [accountRequest account];

        NSArray *someContainers = [accountRequest containers];

        if (containers == nil) {

            containers = [[NSMutableArray alloc] initWithArray:someContainers];

        } else {

            [containers addObjectsFromArray:someContainers];

        }

        if ([someContainers count] < 10000) {

            if (!accountRequest.didUseCachedResponse || ([containers count] != [someContainers count]) || !children) {

                // Save new children

                NSLog(@"using newChildren");

                newChildren = [[NSMutableArray alloc] init];

                NSMutableIndexSet *keptNodes = [NSMutableIndexSet indexSet];

                for (ASIPithosContainer *container in containers) {

                    PithosContainerNode *node = [[[PithosContainerNode alloc] initWithPithosContainer:container] 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 = container;

                            [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

            [accountRequest release];

            accountRequest = nil;

            [containers release];

            containers = nil;

            forcedRefresh = NO;

            @synchronized(self) {

                freshness = PithosNodeStateRefreshFinished;

            // Notify observers that children are updated

            [[NSNotificationCenter defaultCenter] postNotificationName:@"PithosAccountNodeChildrenUpdated" object:self];

        } else {

            [accountRequest release];

            // Do an additional request to fetch more objects

            accountRequest = [[ASIPithosAccountRequest listContainersRequestWithLimit:0 

                                                                               marker:[[someContainers lastObject] name] 

                                                                               shared:shared 

                                                                                until:nil] retain];

            if (sharingAccount)

                [accountRequest setRequestUserFromDefaultTo:sharingAccount];

            accountRequest.delegate = self;

            accountRequest.didFinishSelector = @selector(accountRequestFinished:);

            accountRequest.didFailSelector = @selector(accountRequestFailed:);

            accountRequest.userInfo = [NSMutableDictionary dictionaryWithObjectsAndKeys:

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

                                       nil];

            if (!forcedRefresh)

                accountRequest.downloadCache = [ASIDownloadCache sharedCache];

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

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

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

        [self accountRequestFailed:accountRequest];

#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];

#import "PithosActivityFacility.h"

                sharingAccountsRequest.userInfo = [NSMutableDictionary dictionaryWithObjectsAndKeys:

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

                                                   nil];

- (void)sharingAccountsRequestFailed:(ASIPithosRequest *)request {

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

    if (retries > 0) {

        ASIPithosRequest *newSharingAccountsRequest = (ASIPithosRequest *)[PithosUtilities copyRequest:sharingAccountsRequest];

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

        [sharingAccountsRequest release];

        sharingAccountsRequest = newSharingAccountsRequest;

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

        NSString *message;

        NSError *error = [sharingAccountsRequest error];

        if (error)

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

        else

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

                       sharingAccountsRequest.responseStatusCode, sharingAccountsRequest.responseStatusMessage];

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

        [newChildren release];

        newChildren = nil;

            freshness = PithosNodeStateRefreshNeeded;

- (void)sharingAccountsRequestFinished:(ASIPithosRequest *)request {

    NSLog(@"List sharing accounts finished: %@", [sharingAccountsRequest url]);

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

    if (sharingAccountsRequest.responseStatusCode == 200) {

        NSArray *someSharingAccounts = [sharingAccountsRequest sharingAccounts];

        if (sharingAccounts == nil) {

            sharingAccounts = [[NSMutableArray alloc] initWithArray:someSharingAccounts];

        } else {

            [sharingAccounts addObjectsFromArray:someSharingAccounts];

        }

        if ([someSharingAccounts count] < 10000) {

            if (!sharingAccountsRequest.didUseCachedResponse || ([sharingAccounts count] != [someSharingAccounts count]) || !children) {

                // Save new children

                NSLog(@"using newChildren");

                newChildren = [[NSMutableArray alloc] init];

                NSMutableIndexSet *keptNodes = [NSMutableIndexSet indexSet];

                for (ASIPithosAccount *account in sharingAccounts) {

                    if (![account.name isEqualToString:[ASIPithosRequest authUser]]) {

                        PithosAccountNode *node = [[[PithosAccountNode alloc] init] autorelease];

                        node.parent = self;

                        node.shared = shared;

                        node.sharingAccount = account.name;

                        if (children) {

                            NSUInteger oldIndex = [children indexOfObject:node];

                            if (oldIndex != NSNotFound) {

                                // Use the same pointer value, if possible

                                node = [children objectAtIndex:oldIndex];

                                [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

            [sharingAccountsRequest release];

            sharingAccountsRequest = nil;

            [sharingAccounts release];

            sharingAccounts = nil;

            forcedRefresh = NO;

            @synchronized(self) {

                freshness = PithosNodeStateRefreshFinished;

            }

            // Notify observers that children are updated

            [[NSNotificationCenter defaultCenter] postNotificationName:@"PithosSharingAccountsNodeChildrenUpdated" object:self];

        } else {

            [sharingAccountsRequest release];

            // Do an additional request to fetch more objects

            sharingAccountsRequest = [[ASIPithosRequest listSharingAccountsRequestWithLimit:0 

                                                                                     marker:[[someSharingAccounts lastObject] name]] retain];

            sharingAccountsRequest.delegate = self;

            sharingAccountsRequest.didFinishSelector = @selector(sharingAccountsRequestFinished:);

            sharingAccountsRequest.didFailSelector = @selector(sharingAccountsRequestFailed:);

            sharingAccountsRequest.userInfo = [NSMutableDictionary dictionaryWithObjectsAndKeys:

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

                                               nil];

            if (!forcedRefresh)

                sharingAccountsRequest.downloadCache = [ASIDownloadCache sharedCache];

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

        }

    } else {

        [self sharingAccountsRequestFailed:sharingAccountsRequest];