//
//  OpenStackRequest.m
//  OpenStack
//
//  Created by Mike Mayo on 10/8/10.
//  The OpenStack project is provided under the Apache 2.0 license.
//

#import "OpenStackRequest.h"
#import "Provider.h"
#import "OpenStackAccount.h"
#import "Server.h"
#import "Image.h"
#import "Flavor.h"
#import "APILogger.h"
#import "JSON.h"
#import "RateLimit.h"
#import "Container.h"
#import "StorageObject.h"
#import "Folder.h"
#import "BackupSchedule.h"
#import "AccountManager.h"
#import "GetFlavorsRequest.h"
#import "APICallback.h"
#import "APILogEntry.h"


static NSRecursiveLock *accessDetailsLock = nil;

@implementation OpenStackRequest

@synthesize account, callback, retriedCount;

- (BOOL)isSuccess {
	return (200 <= [self responseStatusCode]) && ([self responseStatusCode] <= 299);
}

- (void)notify:(NSString *)name {
    NSDictionary *callbackUserInfo = [NSDictionary dictionaryWithObject:self forKey:@"response"];
    NSNotification *notification = [NSNotification notificationWithName:name object:nil userInfo:callbackUserInfo];
    [[NSNotificationCenter defaultCenter] postNotification:notification];
}

- (void)notify {
    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];
    
    NSDictionary *callbackUserInfo = [NSDictionary dictionaryWithObject:self forKey:@"response"];

    NSNotification *observeNotification = [NSNotification notificationWithName:observeName object:nil userInfo:callbackUserInfo];
    [[NSNotificationCenter defaultCenter] postNotification:observeNotification];

    NSNotification *callbackNotification = [NSNotification notificationWithName:callbackName object:nil userInfo:callbackUserInfo];
    [[NSNotificationCenter defaultCenter] postNotification:callbackNotification];
    
}

- (NSString *)responseString {
    if (retried) {
        return [retriedRequest responseString];
    } else {
        return [super responseString];
    }
}

- (NSData *)responseData {
    if (retried) {
        return [retriedRequest responseData];
    } else {
        return [super responseData];
    }
}

- (NSDictionary *)responseHeaders {
    if (retried) {
        return [retriedRequest responseHeaders];
    } else {
        return [super responseHeaders];
    }
}

- (int)responseStatusCode {
    if (retried) {
        return [retriedRequest responseStatusCode];
    } else {
        return [super responseStatusCode];
    }
}

- (NSString *)responseStatusMessage {
    if (retried) {
        return [retriedRequest responseStatusMessage];
    } else {
        return [super responseStatusMessage];
    }
}

- (void)setCompletionBlock:(ASIBasicBlock)aCompletionBlock {
    [super setCompletionBlock:aCompletionBlock];
    [backupCompletionBlock release];
    backupCompletionBlock = [aCompletionBlock copy];
}

- (void)setFailedBlock:(ASIBasicBlock)aFailedBlock {
    [super setFailedBlock:aFailedBlock];
    [backupFailureBlock release];
    backupFailureBlock = [aFailedBlock copy];
}

+ (RateLimit *)limitForPath:(NSString *)path verb:(NSString *)verb account:(OpenStackAccount *)anAccount {
    
    // find the lowest requests remaining of all the limits

    RateLimit *lowestLimit = nil;
    
    for (RateLimit *limit in anAccount.rateLimits) {
        if ([limit.verb isEqualToString:verb]) {
            NSRegularExpression *regex = [NSRegularExpression regularExpressionWithPattern:limit.regex options:NSRegularExpressionCaseInsensitive error:nil];
            NSInteger matches = [regex numberOfMatchesInString:path options:0 range:NSMakeRange(0, [path length])];
            
            if (matches > 0) {
                if (lowestLimit) {
                    if (limit.remaining < lowestLimit.remaining) {
                        lowestLimit = limit;
                    }
                } else {
                    lowestLimit = limit;
                }
            }
        }
    }
    
    return lowestLimit;
}

#pragma mark -
#pragma mark Generic Constructors

+ (void)initialize {
	if (self == [OpenStackRequest class]) {
		accessDetailsLock = [[NSRecursiveLock alloc] init];
	}
}

+ (id)request:(OpenStackAccount *)account method:(NSString *)method url:(NSURL *)url {
	OpenStackRequest *request = [[[OpenStackRequest alloc] initWithURL:url] autorelease];
    request.account = account;
	[request setRequestMethod:method];
	[request addRequestHeader:@"X-Auth-Token" value:[account authToken]];
    [request addRequestHeader:@"Content-Type" value:@"application/json"];
    [request setTimeOutSeconds:60];
    request.retriedCount = 0;
	return request;
}

+ (id)serversRequest:(OpenStackAccount *)account method:(NSString *)method path:(NSString *)path {
    NSString *now = [[[NSDate date] description] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding];
	NSURL *url = [NSURL URLWithString:[NSString stringWithFormat:@"%@%@?now=%@", account.serversURL, path, now]];
    return [OpenStackRequest request:account method:method url:url];
}

+ (id)filesRequest:(OpenStackAccount *)account method:(NSString *)method path:(NSString *)path {
    NSString *now = [[[NSDate date] description] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding];
	NSURL *url = [NSURL URLWithString:[NSString stringWithFormat:@"%@%@?format=json&now=%@", account.filesURL, path, now]];    
    return [OpenStackRequest request:account method:method url:url];
}

+ (id)cdnRequest:(OpenStackAccount *)account method:(NSString *)method path:(NSString *)path {
    NSString *now = [[[NSDate date] description] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding];
	NSURL *url = [NSURL URLWithString:[NSString stringWithFormat:@"%@%@?format=json&now=%@", account.cdnURL, path, now]];
    return [OpenStackRequest request:account method:method url:url];
}

#pragma mark -
#pragma mark Auth Retry

- (void)authRetrySucceded:(OpenStackRequest *)retryRequest {
    
    if ([self isKindOfClass:[GetFlavorsRequest class]]) {
        NSLog(@"flavor request");
    }
    
    self.account.authToken = [[retryRequest responseHeaders] objectForKey:@"X-Auth-Token"];    
    [self.account persist];
    
    // TODO: make this work for GetServersRequest, etc
    
    // try the original request again!
    retried = YES;
    retriedRequest = [self copy];
	[retriedRequest addRequestHeader:@"X-Auth-Token" value:self.account.authToken];    
    
    if (backupCompletionBlock) {
        [retriedRequest setCompletionBlock:^{
            backupCompletionBlock();
        }];
    }
    if (backupFailureBlock) {
        [retriedRequest setFailedBlock:^{
            backupFailureBlock();
        }];
    }
    [retriedRequest startSynchronous];     
}

- (void)authRetryFailed:(OpenStackRequest *)retryRequest {
    // if it fails due to bad connection, try again?
    NSLog(@"auth retry failed with status %i", retryRequest.responseStatusCode);
    NSNotification *notification = [NSNotification notificationWithName:[self.account.manager notificationName:@"authRetryFailed" identifier:0] object:nil userInfo:[NSDictionary dictionaryWithObject:retryRequest forKey:@"request"]];
    [[NSNotificationCenter defaultCenter] postNotification:notification];
}

#pragma mark -
#pragma mark ASIHTTPRequest Overrides
// overriding to log API calls

- (void)requestFinished {
    //NSLog(@"request finished: %i %@", self.responseStatusCode, self.url);
    NSUserDefaults *defaults = [NSUserDefaults standardUserDefaults];
    NSString *loggingLevel = [defaults valueForKey:@"api_logging_level"];    
    if ([loggingLevel isEqualToString:@"all"] || ([loggingLevel isEqualToString:@"errors"] && ![self isSuccess])) {
        [APILogger log:self];
    }
    
    [super requestFinished];
}

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

    if (responseStatusCode == 401 && ![url isEqual:account.provider.authEndpointURL]) {
        // auth is expired, so get a fresh token
        if (account) {
            OpenStackRequest *retryRequest = [OpenStackRequest authenticationRequest:account];
            retryRequest.delegate = self;
            retryRequest.didFinishSelector = @selector(authRetrySucceded:);
            retryRequest.didFailSelector = @selector(authRetryFailed:);
            [retryRequest startSynchronous];
        }
    } else if (responseStatusCode == 503) {        
        NSNotification *notification = [NSNotification notificationWithName:@"serviceUnavailable" object:nil userInfo:nil];
        [[NSNotificationCenter defaultCenter] postNotification:notification];        
        [super failWithError:theError];
    } else if (responseStatusCode == 0) {
        NSUserDefaults *defaults = [NSUserDefaults standardUserDefaults];
        if (![defaults boolForKey:@"already_failed_on_connection"]) {
            UIAlertView *alert = [[UIAlertView alloc] initWithTitle:@"Connection Error" message:@"Please check your connection or API URL and try again." delegate:nil cancelButtonTitle:@"OK" otherButtonTitles:nil];
            [alert show];
            [alert release];
        }
        [defaults setBool:YES forKey:@"already_failed_on_connection"];
        [defaults synchronize];              
    }

    [super failWithError:theError];
}

#pragma mark - Authentication

+ (NSString *)apiVersionForURL:(NSURL *)url {
    NSArray *components = [[url description] componentsSeparatedByString:@"/"];
    if ([[components lastObject] isEqualToString:@"2.0"]) {
        return @"2.0";
    } else if ([[components lastObject] isEqualToString:@"v1.1"]) {
        return @"1.1";
    } else {
        return @"1.0";
    }
}

+ (void)setupV1AuthForRequest:(OpenStackRequest *)request account:(OpenStackAccount *)account apiVersion:(NSString *)apiVersion {
    [request addRequestHeader:@"X-Auth-User" value:account.username];
    if (account.apiKey) {
        [request addRequestHeader:@"X-Auth-Key" value:account.apiKey];
    } else {
        [request addRequestHeader:@"X-Auth-Key" value:@""];
    }        
}

+ (void)setupAuthForRequest:(OpenStackRequest *)request account:(OpenStackAccount *)account apiVersion:(NSString *)apiVersion {

    if ([apiVersion isEqualToString:@"1.0"]) {
        
        [OpenStackRequest setupV1AuthForRequest:request account:account apiVersion:apiVersion];
        account.apiVersion = @"1.0";
        
    } else if ([apiVersion isEqualToString:@"1.1"]) {
        
        [OpenStackRequest setupV1AuthForRequest:request account:account apiVersion:apiVersion];
        if (account.projectId) {
            [request addRequestHeader:@"X-Auth-Project-Id" value:account.projectId];
        }
        account.apiVersion = @"1.1";
        
    } else if ([apiVersion isEqualToString:@"2.0"]) {
        
        // TODO: support 2.0 auth
        account.apiVersion = @"1.1";
    }
}

+ (OpenStackRequest *)authenticationRequest:(OpenStackAccount *)account {

	OpenStackRequest *request = [[[OpenStackRequest alloc] initWithURL:account.provider.authEndpointURL] autorelease];
    request.account = account;

    NSString *apiVersion = [OpenStackRequest apiVersionForURL:account.provider.authEndpointURL];
    [OpenStackRequest setupAuthForRequest:request account:account apiVersion:apiVersion];

	return request;
}

#pragma mark - Rate Limits

+ (OpenStackRequest *)getLimitsRequest:(OpenStackAccount *)account {
    return [OpenStackRequest serversRequest:account method:@"GET" path:@"/limits"];
}

- (NSDictionary *)limits {
    SBJSON *parser = [[SBJSON alloc] init];
    NSDictionary *jsonObjects = [[parser objectWithString:[self responseString]] objectForKey:@"limits"];    
    [parser release];
    return jsonObjects;
}

- (NSArray *)rateLimits {
    NSArray *jsonObjects = [[self limits] objectForKey:@"rate"];
    NSMutableArray *rateLimits = [[NSMutableArray alloc] initWithCapacity:[jsonObjects count]];

    for (NSDictionary *dict in jsonObjects) {
        [rateLimits addObject:[RateLimit fromJSON:dict]];
    }

    NSArray *result = [NSArray arrayWithArray:rateLimits];
    
    [rateLimits release];
    return result;
}

#pragma mark Collections

+ (OpenStackRequest *)getServersRequest:(OpenStackAccount *)account {
    return [OpenStackRequest serversRequest:account method:@"GET" path:@"/servers/detail"];
}

- (NSDictionary *)servers {
    SBJSON *parser = [[SBJSON alloc] init];
    NSArray *jsonObjects = [[parser objectWithString:[self responseString]] objectForKey:@"servers"];
    NSMutableDictionary *objects = [NSMutableDictionary dictionaryWithCapacity:[jsonObjects count]];
    
    for (int i = 0; i < [jsonObjects count]; i++) {
        NSDictionary *dict = [jsonObjects objectAtIndex:i];
        Server *server = [[Server alloc] initWithJSONDict:dict];
        [objects setObject:server forKey:server.identifier];
        [server release];
    }
    
    [parser release];
    return objects;
}

+ (OpenStackRequest *)getServerRequest:(OpenStackAccount *)account serverId:(NSString *)serverId {
    return [OpenStackRequest serversRequest:account method:@"GET" path:[NSString stringWithFormat:@"/servers/%@", serverId]];
}

+ (OpenStackRequest *)getImagesRequest:(OpenStackAccount *)account {
    return [OpenStackRequest serversRequest:account method:@"GET" path:@"/images/detail"];
}

- (NSDictionary *)images {
    SBJSON *parser = [[SBJSON alloc] init];
    NSArray *jsonObjects = [[parser objectWithString:[self responseString]] objectForKey:@"images"];
    NSMutableDictionary *objects = [NSMutableDictionary dictionaryWithCapacity:[jsonObjects count]];
    
    for (int i = 0; i < [jsonObjects count]; i++) {
        NSDictionary *dict = [jsonObjects objectAtIndex:i];
        Image *image = [[Image alloc] initWithJSONDict:dict];
        [objects setObject:image forKey:image.identifier];
        [image release];
    }
    
    [parser release];
    return objects;
}

+ (OpenStackRequest *)getImageRequest:(OpenStackAccount *)account imageId:(NSString *)imageId {
    return [OpenStackRequest serversRequest:account method:@"GET" path:[NSString stringWithFormat:@"/images/%@", imageId]];
}

- (Image *)image {
    SBJSON *parser = [[SBJSON alloc] init];
    NSDictionary *dict = [[parser objectWithString:[self responseString]] objectForKey:@"image"];
    Image *image = [Image fromJSON:dict];
    [parser release];
    return image;
}


+ (OpenStackRequest *)getFlavorsRequest:(OpenStackAccount *)account {
    return [OpenStackRequest serversRequest:account method:@"GET" path:@"/flavors/detail"];
}

- (NSDictionary *)flavors {
    SBJSON *parser = [[SBJSON alloc] init];
    NSArray *jsonObjects = [[parser objectWithString:[self responseString]] objectForKey:@"flavors"];
    NSMutableDictionary *objects = [NSMutableDictionary dictionaryWithCapacity:[jsonObjects count]];

    for (int i = 0; i < [jsonObjects count]; i++) {
        NSDictionary *dict = [jsonObjects objectAtIndex:i];
        Flavor *flavor = [Flavor fromJSON:dict];
        [objects setObject:flavor forKey:flavor.identifier];
    }
    
    [parser release];
    return objects;
}

#pragma mark Server Actions

#define kSoft 0
#define kHard 1

+ (OpenStackRequest *)rebootServerRequest:(OpenStackAccount *)account server:(Server *)server type:(NSInteger)type {
    NSString *body = [NSString stringWithFormat:@"{ \"reboot\": { \"type\": \"%@\" } }", (type == kSoft) ? @"SOFT" : @"HARD"];
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"POST" path:[NSString stringWithFormat:@"/servers/%@/action", server.identifier]];	
    NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
    [request setPostBody:[NSMutableData dataWithData:data]];
    return request;
}

+ (OpenStackRequest *)softRebootServerRequest:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest rebootServerRequest:account server:server type:kSoft];
}

+ (RateLimit *)softRebootServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/action", server.identifier] verb:@"POST" account:account];
}

+ (OpenStackRequest *)hardRebootServerRequest:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest rebootServerRequest:account server:server type:kHard];
}

+ (RateLimit *)hardRebootServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/action", server.identifier] verb:@"POST" account:account];
}

+ (OpenStackRequest *)changeServerAdminPasswordRequest:(OpenStackAccount *)account server:(Server *)server password:(NSString *)password {
	NSString *body = [NSString stringWithFormat:@"{ \"server\": { \"adminPass\": \"%@\" } }", password];
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"PUT" path:[NSString stringWithFormat:@"/servers/%@", server.identifier]];	
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)changeServerAdminPasswordLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@", server.identifier] verb:@"PUT" account:account];
}

+ (OpenStackRequest *)renameServerRequest:(OpenStackAccount *)account server:(Server *)server name:(NSString *)name {
	NSString *body = [NSString stringWithFormat:@"{ \"server\": { \"name\": \"%@\" } }", name];
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"PUT" path:[NSString stringWithFormat:@"/servers/%@", server.identifier]];	
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)renameServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@", server.identifier] verb:@"PUT" account:account];
}

+ (OpenStackRequest *)deleteServerRequest:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest serversRequest:account method:@"DELETE" path:[NSString stringWithFormat:@"/servers/%@", server.identifier]];
}

+ (RateLimit *)deleteServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@", server.identifier] verb:@"DELETE" account:account];
}

+ (OpenStackRequest *)createServerRequest:(OpenStackAccount *)account server:(Server *)server {
	NSString *body = [server toJSON:account.apiVersion];
	NSURL *url = [NSURL URLWithString:[NSString stringWithFormat:@"%@/servers", account.serversURL]];
    NSLog(@"create server: %@", body);
    OpenStackRequest *request = [OpenStackRequest request:account method:@"POST" url:url];    
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)createServerLimit:(OpenStackAccount *)account {
    return [OpenStackRequest limitForPath:@"/servers" verb:@"POST" account:account];
}

- (Server *)server {
    SBJSON *parser = [[SBJSON alloc] init];
    NSDictionary *dict = [[parser objectWithString:[self responseString]] objectForKey:@"server"];
    Server *server = [Server fromJSON:dict];
    [parser release];
    return server;
}

+ (OpenStackRequest *)resizeServerRequest:(OpenStackAccount *)account server:(Server *)server flavor:(Flavor *)flavor {
	NSString *body;
    if ([account.apiVersion isEqualToString:@"1.0"]) {
        body = [NSString stringWithFormat:@"{ \"resize\": { \"flavorId\": %@ } }", flavor.identifier];
    } else {
        body = [NSString stringWithFormat:@"{ \"resize\": { \"flavorRef\": %@ } }", flavor.identifier];
    }
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"POST" path:[NSString stringWithFormat:@"/servers/%@/action", server.identifier]];	
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)resizeServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/action", server.identifier] verb:@"POST" account:account];
}

+ (OpenStackRequest *)confirmResizeServerRequest:(OpenStackAccount *)account server:(Server *)server {
	NSString *body = @"{ \"confirmResize\": null }";
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"POST" path:[NSString stringWithFormat:@"/servers/%@/action", server.identifier]];	
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)confirmResizeServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/action", server.identifier] verb:@"POST" account:account];
}

+ (OpenStackRequest *)revertResizeServerRequest:(OpenStackAccount *)account server:(Server *)server {
	NSString *body = @"{ \"revertResize\": null }";
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"POST" path:[NSString stringWithFormat:@"/servers/%@/action", server.identifier]];	
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)revertResizeServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/action", server.identifier] verb:@"POST" account:account];
}

+ (OpenStackRequest *)rebuildServerRequest:(OpenStackAccount *)account server:(Server *)server image:(Image *)image {
	NSString *body = [NSString stringWithFormat:@"{ \"rebuild\": { \"imageId\": %@ } }", image.identifier];
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"POST" path:[NSString stringWithFormat:@"/servers/%@/action", server.identifier]];	
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)rebuildServerLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/action", server.identifier] verb:@"POST" account:account];
}


+ (OpenStackRequest *)getBackupScheduleRequest:(OpenStackAccount *)account server:(Server *)server {    
    return [OpenStackRequest serversRequest:account method:@"GET" path:[NSString stringWithFormat:@"/servers/%@/backup_schedule", server.identifier]];
}

+ (RateLimit *)getBackupScheduleLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/backup_schedule", server.identifier] verb:@"GET" account:account];
}

+ (OpenStackRequest *)updateBackupScheduleRequest:(OpenStackAccount *)account server:(Server *)server {
	NSString *body = [NSString stringWithFormat:@"{ \"backupSchedule\": { \"enabled\": true, \"weekly\": \"%@\", \"daily\": \"%@\" } }", server.backupSchedule.weekly, server.backupSchedule.daily];
    OpenStackRequest *request = [OpenStackRequest serversRequest:account method:@"POST" path:[NSString stringWithFormat:@"/servers/%@/backup_schedule", server.identifier]];	
	NSData *data = [body dataUsingEncoding:NSUTF8StringEncoding];
	[request setPostBody:[NSMutableData dataWithData:data]];
	return request;
}

+ (RateLimit *)updateBackupScheduleLimit:(OpenStackAccount *)account server:(Server *)server {
    return [OpenStackRequest limitForPath:[NSString stringWithFormat:@"/servers/%@/backup_schedule", server.identifier] verb:@"POST" account:account];
}

- (BackupSchedule *)backupSchedule {
    SBJSON *parser = [[SBJSON alloc] init];
    NSDictionary *dict = [[parser objectWithString:[self responseString]] objectForKey:@"backupSchedule"];
    BackupSchedule *backupSchedule = [BackupSchedule fromJSON:dict];
    [parser release];
    return backupSchedule;
}

#pragma mark -
#pragma mark Object Storage Requests

+ (OpenStackRequest *)getStorageAccountInfoRequest:(OpenStackAccount *)account {
    return [OpenStackRequest filesRequest:account method:@"HEAD" path:@""];
}

+ (OpenStackRequest *)getContainersRequest:(OpenStackAccount *)account {
    return [OpenStackRequest filesRequest:account method:@"GET" path:@""];
}

- (NSMutableDictionary *)containers {
    SBJSON *parser = [[SBJSON alloc] init];
    NSArray *jsonObjects = [parser objectWithString:[self responseString]];
    NSMutableDictionary *objects = [NSMutableDictionary dictionaryWithCapacity:[jsonObjects count]];
    
    for (int i = 0; i < [jsonObjects count]; i++) {
        NSDictionary *dict = [jsonObjects objectAtIndex:i];
        Container *container = [Container fromJSON:dict];
        [objects setObject:container forKey:container.name];
    }
    
    [parser release];
    return objects;
}

+ (OpenStackRequest *)createContainerRequest:(OpenStackAccount *)account container:(Container *)container {    
    return [OpenStackRequest filesRequest:account method:@"PUT" path:[[NSString stringWithFormat:@"/%@", container.name] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];
}

+ (OpenStackRequest *)deleteContainerRequest:(OpenStackAccount *)account container:(Container *)container {
    return [OpenStackRequest filesRequest:account method:@"DELETE" path:[[NSString stringWithFormat:@"/%@", container.name] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];
}

+ (OpenStackRequest *)getObjectsRequest:(OpenStackAccount *)account container:(Container *)container {
    return [OpenStackRequest filesRequest:account method:@"GET" path:[[NSString stringWithFormat:@"/%@", container.name] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];    
}

- (NSMutableDictionary *)objects {
    SBJSON *parser = [[SBJSON alloc] init];
    NSArray *jsonObjects = [parser objectWithString:[self responseString]];
    NSMutableDictionary *objects = [[[NSMutableDictionary alloc] initWithCapacity:[jsonObjects count]] autorelease];
    
    for (int i = 0; i < [jsonObjects count]; i++) {
        NSDictionary *dict = [jsonObjects objectAtIndex:i];
        StorageObject *object = [StorageObject fromJSON:dict];
        [objects setObject:object forKey:object.name];
    }
    
    [parser release];
    return objects;
}

+ (OpenStackRequest *)getObjectInfoRequest:(OpenStackAccount *)account container:(Container *)container object:(StorageObject *)object {
    return [OpenStackRequest filesRequest:account method:@"HEAD" path:[[NSString stringWithFormat:@"/%@/%@", container.name, object.fullPath] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];    
}

+ (OpenStackRequest *)getObjectRequest:(OpenStackAccount *)account container:(Container *)container object:(StorageObject *)object {
    return [OpenStackRequest filesRequest:account method:@"GET" path:[[NSString stringWithFormat:@"/%@/%@", container.name, object.fullPath] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];    
}

+ (OpenStackRequest *)writeObjectRequest:(OpenStackAccount *)account container:(Container *)container object:(StorageObject *)object {
    NSString *fullPath = object.fullPath;
    if ([fullPath characterAtIndex:0] == '/') {
        fullPath = [fullPath substringFromIndex:1];
    }
    
    OpenStackRequest *request = [OpenStackRequest filesRequest:account method:@"PUT" path:[[NSString stringWithFormat:@"/%@/%@", container.name, fullPath] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];    
	[request setPostBody:[NSMutableData dataWithData:object.data]];
    [request.requestHeaders setObject:object.contentType forKey:@"Content-Type"];
	return request;
}

+ (OpenStackRequest *)writeObjectMetadataRequest:(OpenStackAccount *)account container:(Container *)container object:(StorageObject *)object {
    NSString *fullPath = [NSString stringWithString:object.fullPath];
    if ([fullPath length] && ([fullPath characterAtIndex:0] == '/'))
        fullPath = [fullPath substringFromIndex:1];

    NSString *metadataKeyHeaderPrefix;
    if (![fullPath length])
        metadataKeyHeaderPrefix = @"X-Container-Meta-";
    else
        metadataKeyHeaderPrefix = @"X-Object-Meta-";
        
    OpenStackRequest *request = [OpenStackRequest filesRequest:account method:@"POST" path:[[NSString stringWithFormat:@"/%@/%@", container.name, fullPath] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]]; 
    
    for (NSString *metadataKey in object.metadata) {
        NSString *metadataKeyHeader = [NSString stringWithFormat:@"%@%@", metadataKeyHeaderPrefix, metadataKey]; 
        [request.requestHeaders setObject:[object.metadata objectForKey:metadataKey] forKey:metadataKeyHeader];
    }
    
    NSString *objectIsPublic = ([object.publicURI length]) ? @"true" : @"false";
    [request.requestHeaders setObject:objectIsPublic forKey:@"X-Object-Public"];
    return request;
}

+ (OpenStackRequest *)deleteObjectRequest:(OpenStackAccount *)account container:(Container *)container object:(StorageObject *)object {
    if ([object.fullPath characterAtIndex:0] == '/') {
        return [OpenStackRequest filesRequest:account method:@"DELETE" path:[[NSString stringWithFormat:@"/%@%@", container.name, object.fullPath] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];
    } else {
        return [OpenStackRequest filesRequest:account method:@"DELETE" path:[[NSString stringWithFormat:@"/%@/%@", container.name, object.fullPath] stringByAddingPercentEscapesUsingEncoding:NSUTF8StringEncoding]];
    }
}

#pragma mark -
#pragma mark Memory Management

- (void)releaseBackupBlocksOnMainThread {
	NSMutableArray *blocks = [NSMutableArray array];
	if (backupCompletionBlock) {
		[blocks addObject:backupCompletionBlock];
		[backupCompletionBlock release];
		backupCompletionBlock = nil;
	}
	if (backupFailureBlock) {
		[blocks addObject:backupFailureBlock];
		[backupFailureBlock release];
		backupFailureBlock = nil;
	}
	[[self class] performSelectorOnMainThread:@selector(releaseBackupBlocks:) withObject:blocks waitUntilDone:[NSThread isMainThread]];
}

// Always called on main thread
+ (void)releaseBackupBlocks:(NSArray *)blocks {
	// Blocks will be released when this method exits
}

- (void)dealloc {
    [account release];
    [self releaseBackupBlocksOnMainThread];
    [super dealloc];
}

@end