|
@@ -1,2067 +0,0 @@
|
|
|
-//
|
|
|
-// OSSClient.m
|
|
|
-// oss_ios_sdk
|
|
|
-//
|
|
|
-// Created by zhouzhuo on 8/16/15.
|
|
|
-// Copyright (c) 2015 aliyun.com. All rights reserved.
|
|
|
-//
|
|
|
-
|
|
|
-#import "OSSClient.h"
|
|
|
-#import "OSSDefine.h"
|
|
|
-#import "OSSModel.h"
|
|
|
-#import "OSSUtil.h"
|
|
|
-#import "OSSLog.h"
|
|
|
-#import "OSSBolts.h"
|
|
|
-#import "OSSNetworking.h"
|
|
|
-#import "OSSXMLDictionary.h"
|
|
|
-#import "OSSReachabilityManager.h"
|
|
|
-#import "OSSIPv6Adapter.h"
|
|
|
-
|
|
|
-#import "OSSNetworkingRequestDelegate.h"
|
|
|
-#import "OSSAllRequestNeededMessage.h"
|
|
|
-#import "OSSURLRequestRetryHandler.h"
|
|
|
-#import "OSSHttpResponseParser.h"
|
|
|
-#import "OSSGetObjectACLRequest.h"
|
|
|
-#import "OSSDeleteMultipleObjectsRequest.h"
|
|
|
-#import "OSSGetBucketInfoRequest.h"
|
|
|
-#import "OSSPutSymlinkRequest.h"
|
|
|
-#import "OSSGetSymlinkRequest.h"
|
|
|
-#import "OSSRestoreObjectRequest.h"
|
|
|
-
|
|
|
-static NSString * const kClientRecordNameWithCommonPrefix = @"oss_partInfos_storage_name";
|
|
|
-static NSString * const kClientRecordNameWithCRC64Suffix = @"-crc64";
|
|
|
-static NSString * const kClientRecordNameWithSequentialSuffix = @"-sequential";
|
|
|
-static NSUInteger const kClientMaximumOfChunks = 5000; //max part number
|
|
|
-
|
|
|
-static NSString * const kClientErrorMessageForEmptyFile = @"the length of file should not be 0!";
|
|
|
-static NSString * const kClientErrorMessageForCancelledTask = @"This task has been cancelled!";
|
|
|
-
|
|
|
-/**
|
|
|
- * extend OSSRequest to include the ref to networking request object
|
|
|
- */
|
|
|
-@interface OSSRequest ()
|
|
|
-
|
|
|
-@property (nonatomic, strong) OSSNetworkingRequestDelegate * requestDelegate;
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@interface OSSClient()
|
|
|
-
|
|
|
-- (void)enableCRC64WithFlag:(OSSRequestCRCFlag)flag requestDelegate:(OSSNetworkingRequestDelegate *)delegate;
|
|
|
-- (OSSTask *)preChecksForRequest:(OSSMultipartUploadRequest *)request;
|
|
|
-- (void)checkRequestCrc64Setting:(OSSRequest *)request;
|
|
|
-- (OSSTask *)checkNecessaryParamsOfRequest:(OSSMultipartUploadRequest *)request;
|
|
|
-- (OSSTask *)checkPartSizeForRequest:(OSSMultipartUploadRequest *)request;
|
|
|
-- (NSUInteger)judgePartSizeForMultipartRequest:(OSSMultipartUploadRequest *)request fileSize:(unsigned long long)fileSize;
|
|
|
-- (unsigned long long)getSizeWithFilePath:(nonnull NSString *)filePath error:(NSError **)error;
|
|
|
-- (NSString *)readUploadIdForRequest:(OSSResumableUploadRequest *)request recordFilePath:(NSString **)recordFilePath sequential:(BOOL)sequential;
|
|
|
-- (NSMutableDictionary *)localPartInfosDictoryWithUploadId:(NSString *)uploadId;
|
|
|
-- (OSSTask *)persistencePartInfos:(NSDictionary *)partInfos withUploadId:(NSString *)uploadId;
|
|
|
-- (OSSTask *)checkFileSizeWithRequest:(OSSMultipartUploadRequest *)request;
|
|
|
-+ (NSError *)cancelError;
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@implementation OSSClient
|
|
|
-
|
|
|
-static NSObject *lock;
|
|
|
-
|
|
|
-- (instancetype)initWithEndpoint:(NSString *)endpoint credentialProvider:(id<OSSCredentialProvider>)credentialProvider {
|
|
|
- return [self initWithEndpoint:endpoint credentialProvider:credentialProvider clientConfiguration:[OSSClientConfiguration new]];
|
|
|
-}
|
|
|
-
|
|
|
-- (instancetype)initWithEndpoint:(NSString *)endpoint
|
|
|
- credentialProvider:(id<OSSCredentialProvider>)credentialProvider
|
|
|
- clientConfiguration:(OSSClientConfiguration *)conf {
|
|
|
- if (self = [super init]) {
|
|
|
- if (!lock) {
|
|
|
- lock = [NSObject new];
|
|
|
- }
|
|
|
- // Monitor the network. If the network type is changed, recheck the IPv6 status.
|
|
|
- [OSSReachabilityManager shareInstance];
|
|
|
-
|
|
|
- NSOperationQueue * queue = [NSOperationQueue new];
|
|
|
- // using for resumable upload and compat old interface
|
|
|
- queue.maxConcurrentOperationCount = 3;
|
|
|
- _ossOperationExecutor = [OSSExecutor executorWithOperationQueue:queue];
|
|
|
-
|
|
|
- if (![endpoint oss_isNotEmpty]) {
|
|
|
- [NSException raise:NSInvalidArgumentException
|
|
|
- format:@"endpoint should not be nil or empty!"];
|
|
|
- }
|
|
|
-
|
|
|
- if ([endpoint rangeOfString:@"://"].location == NSNotFound) {
|
|
|
- endpoint = [@"https://" stringByAppendingString:endpoint];
|
|
|
- }
|
|
|
-
|
|
|
- NSURL *endpointURL = [NSURL URLWithString:endpoint];
|
|
|
- if ([endpointURL.scheme.lowercaseString isEqualToString:@"https"]) {
|
|
|
- if ([[OSSIPv6Adapter getInstance] isIPv4Address: endpointURL.host] || [[OSSIPv6Adapter getInstance] isIPv6Address: endpointURL.host]) {
|
|
|
- [NSException raise:NSInvalidArgumentException
|
|
|
- format:@"unsupported format of endpoint, please use right endpoint format!"];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- self.endpoint = [endpoint oss_trim];
|
|
|
- self.credentialProvider = credentialProvider;
|
|
|
- self.clientConfiguration = conf;
|
|
|
-
|
|
|
- OSSNetworkingConfiguration * netConf = [OSSNetworkingConfiguration new];
|
|
|
- if (conf) {
|
|
|
- netConf.maxRetryCount = conf.maxRetryCount;
|
|
|
- netConf.timeoutIntervalForRequest = conf.timeoutIntervalForRequest;
|
|
|
- netConf.timeoutIntervalForResource = conf.timeoutIntervalForResource;
|
|
|
- netConf.enableBackgroundTransmitService = conf.enableBackgroundTransmitService;
|
|
|
- netConf.backgroundSessionIdentifier = conf.backgroundSesseionIdentifier;
|
|
|
- netConf.proxyHost = conf.proxyHost;
|
|
|
- netConf.proxyPort = conf.proxyPort;
|
|
|
- netConf.maxConcurrentRequestCount = conf.maxConcurrentRequestCount;
|
|
|
- }
|
|
|
- self.networking = [[OSSNetworking alloc] initWithConfiguration:netConf];
|
|
|
- }
|
|
|
- return self;
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)invokeRequest:(OSSNetworkingRequestDelegate *)request requireAuthentication:(BOOL)requireAuthentication {
|
|
|
- /* if content-type haven't been set, we set one */
|
|
|
- if (!request.allNeededMessage.contentType.oss_isNotEmpty
|
|
|
- && ([request.allNeededMessage.httpMethod isEqualToString:@"POST"] || [request.allNeededMessage.httpMethod isEqualToString:@"PUT"])) {
|
|
|
-
|
|
|
- request.allNeededMessage.contentType = [OSSUtil detemineMimeTypeForFilePath:request.uploadingFileURL.path uploadName:request.allNeededMessage.objectKey];
|
|
|
- }
|
|
|
-
|
|
|
- // Checks if the endpoint is in the excluded CName list.
|
|
|
- [self.clientConfiguration.cnameExcludeList enumerateObjectsUsingBlock:^(NSString *exclude, NSUInteger idx, BOOL * _Nonnull stop) {
|
|
|
- if ([self.endpoint hasSuffix:exclude]) {
|
|
|
- request.allNeededMessage.isHostInCnameExcludeList = YES;
|
|
|
- *stop = YES;
|
|
|
- }
|
|
|
- }];
|
|
|
-
|
|
|
- id<OSSRequestInterceptor> uaSetting = [[OSSUASettingInterceptor alloc] initWithClientConfiguration:self.clientConfiguration];
|
|
|
- [request.interceptors addObject:uaSetting];
|
|
|
-
|
|
|
- /* check if the authentication is required */
|
|
|
- if (requireAuthentication) {
|
|
|
- id<OSSRequestInterceptor> signer = [[OSSSignerInterceptor alloc] initWithCredentialProvider:self.credentialProvider];
|
|
|
- [request.interceptors addObject:signer];
|
|
|
- }
|
|
|
-
|
|
|
- request.isHttpdnsEnable = self.clientConfiguration.isHttpdnsEnable;
|
|
|
-
|
|
|
- return [_networking sendRequest:request];
|
|
|
-}
|
|
|
-
|
|
|
-#pragma implement restful apis
|
|
|
-
|
|
|
-- (OSSTask *)getService:(OSSGetServiceRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeGetService];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.params = [request requestParams];
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeGetService;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-# pragma mark - Private Methods
|
|
|
-
|
|
|
-- (void)enableCRC64WithFlag:(OSSRequestCRCFlag)flag requestDelegate:(OSSNetworkingRequestDelegate *)delegate
|
|
|
-{
|
|
|
- switch (flag) {
|
|
|
- case OSSRequestCRCOpen:
|
|
|
- delegate.crc64Verifiable = YES;
|
|
|
- break;
|
|
|
- case OSSRequestCRCClosed:
|
|
|
- delegate.crc64Verifiable = NO;
|
|
|
- break;
|
|
|
- default:
|
|
|
- delegate.crc64Verifiable = self.clientConfiguration.crc64Verifiable;
|
|
|
- break;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)preChecksForRequest:(OSSMultipartUploadRequest *)request
|
|
|
-{
|
|
|
- OSSTask *preTask = [self checkFileSizeWithRequest:request];
|
|
|
- if (preTask) {
|
|
|
- return preTask;
|
|
|
- }
|
|
|
-
|
|
|
- preTask = [self checkNecessaryParamsOfRequest:request];
|
|
|
- if (preTask) {
|
|
|
- return preTask;
|
|
|
- }
|
|
|
-
|
|
|
- preTask = [self checkPartSizeForRequest:request];
|
|
|
- if (preTask) {
|
|
|
- return preTask;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- return preTask;
|
|
|
-}
|
|
|
-
|
|
|
-- (void)checkRequestCrc64Setting:(OSSRequest *)request
|
|
|
-{
|
|
|
- if (request.crcFlag == OSSRequestCRCUninitialized)
|
|
|
- {
|
|
|
- if (self.clientConfiguration.crc64Verifiable)
|
|
|
- {
|
|
|
- request.crcFlag = OSSRequestCRCOpen;
|
|
|
- }else
|
|
|
- {
|
|
|
- request.crcFlag = OSSRequestCRCClosed;
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)checkNecessaryParamsOfRequest:(OSSMultipartUploadRequest *)request
|
|
|
-{
|
|
|
- NSError *error = nil;
|
|
|
- if (![request.objectKey oss_isNotEmpty]) {
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"checkNecessaryParamsOfRequest requires nonnull objectKey!"}];
|
|
|
- }else if (![request.bucketName oss_isNotEmpty]) {
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"checkNecessaryParamsOfRequest requires nonnull bucketName!"}];
|
|
|
- }else if (![request.uploadingFileURL.path oss_isNotEmpty]) {
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"checkNecessaryParamsOfRequest requires nonnull uploadingFileURL!"}];
|
|
|
- }
|
|
|
-
|
|
|
- OSSTask *errorTask = nil;
|
|
|
- if (error) {
|
|
|
- errorTask = [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
-
|
|
|
- return errorTask;
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)checkPartSizeForRequest:(OSSMultipartUploadRequest *)request
|
|
|
-{
|
|
|
- OSSTask *errorTask = nil;
|
|
|
- unsigned long long fileSize = [self getSizeWithFilePath:request.uploadingFileURL.path error:nil];
|
|
|
-
|
|
|
- if (request.partSize == 0 || (fileSize > 102400 && request.partSize < 102400)) {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"Part size must be greater than equal to 100KB"}];
|
|
|
- errorTask = [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
- return errorTask;
|
|
|
-}
|
|
|
-
|
|
|
-- (NSUInteger)judgePartSizeForMultipartRequest:(OSSMultipartUploadRequest *)request fileSize:(unsigned long long)fileSize
|
|
|
-{
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- BOOL divisible = (fileSize % request.partSize == 0);
|
|
|
- NSUInteger partCount = (fileSize / request.partSize) + (divisible? 0 : 1);
|
|
|
-
|
|
|
- if(partCount > kClientMaximumOfChunks)
|
|
|
- {
|
|
|
- request.partSize = fileSize / kClientMaximumOfChunks;
|
|
|
- partCount = kClientMaximumOfChunks;
|
|
|
- }
|
|
|
- return partCount;
|
|
|
-#pragma clang diagnostic pop
|
|
|
-}
|
|
|
-
|
|
|
-- (unsigned long long)getSizeWithFilePath:(nonnull NSString *)filePath error:(NSError **)error
|
|
|
-{
|
|
|
- NSFileManager *fm = [NSFileManager defaultManager];
|
|
|
- NSDictionary *attributes = [fm attributesOfItemAtPath:filePath error:error];
|
|
|
- return attributes.fileSize;
|
|
|
-}
|
|
|
-
|
|
|
-- (NSString *)readUploadIdForRequest:(OSSResumableUploadRequest *)request recordFilePath:(NSString **)recordFilePath sequential:(BOOL)sequential
|
|
|
-{
|
|
|
- NSString *uploadId = nil;
|
|
|
- NSString *record = [NSString stringWithFormat:@"%@%@%@%lu", request.md5String, request.bucketName, request.objectKey, (unsigned long)request.partSize];
|
|
|
- if (sequential) {
|
|
|
- record = [record stringByAppendingString:kClientRecordNameWithSequentialSuffix];
|
|
|
- }
|
|
|
- if (request.crcFlag == OSSRequestCRCOpen) {
|
|
|
- record = [record stringByAppendingString:kClientRecordNameWithCRC64Suffix];
|
|
|
- }
|
|
|
-
|
|
|
- NSData *data = [record dataUsingEncoding:NSUTF8StringEncoding];
|
|
|
- NSString *recordFileName = [OSSUtil dataMD5String:data];
|
|
|
- *recordFilePath = [request.recordDirectoryPath stringByAppendingPathComponent: recordFileName];
|
|
|
- NSFileManager *fileManager = [NSFileManager defaultManager];
|
|
|
- if ([fileManager fileExistsAtPath: *recordFilePath]) {
|
|
|
- NSFileHandle * read = [NSFileHandle fileHandleForReadingAtPath:*recordFilePath];
|
|
|
- uploadId = [[NSString alloc] initWithData:[read readDataToEndOfFile] encoding:NSUTF8StringEncoding];
|
|
|
- [read closeFile];
|
|
|
- } else {
|
|
|
- [fileManager createFileAtPath:*recordFilePath contents:nil attributes:nil];
|
|
|
- }
|
|
|
- return uploadId;
|
|
|
-}
|
|
|
-
|
|
|
-#pragma mark - sequential multipart upload
|
|
|
-
|
|
|
-- (NSMutableDictionary *)localPartInfosDictoryWithUploadId:(NSString *)uploadId
|
|
|
-{
|
|
|
- NSMutableDictionary *localPartInfoDict = nil;
|
|
|
- NSString *partInfosDirectory = [[NSString oss_documentDirectory] stringByAppendingPathComponent:kClientRecordNameWithCommonPrefix];
|
|
|
- NSString *partInfosPath = [partInfosDirectory stringByAppendingPathComponent:uploadId];
|
|
|
- BOOL isDirectory;
|
|
|
- NSFileManager *defaultFM = [NSFileManager defaultManager];
|
|
|
- if (!([defaultFM fileExistsAtPath:partInfosDirectory isDirectory:&isDirectory] && isDirectory))
|
|
|
- {
|
|
|
- if (![defaultFM createDirectoryAtPath:partInfosDirectory
|
|
|
- withIntermediateDirectories:NO
|
|
|
- attributes:nil error:nil]) {
|
|
|
- OSSLogError(@"create Directory(%@) failed!",partInfosDirectory);
|
|
|
- };
|
|
|
- }
|
|
|
-
|
|
|
- if (![defaultFM fileExistsAtPath:partInfosPath])
|
|
|
- {
|
|
|
- if (![defaultFM createFileAtPath:partInfosPath
|
|
|
- contents:nil
|
|
|
- attributes:nil])
|
|
|
- {
|
|
|
- OSSLogError(@"create local partInfo file failed!");
|
|
|
- }
|
|
|
- }
|
|
|
- localPartInfoDict = [[NSMutableDictionary alloc] initWithContentsOfURL:[NSURL fileURLWithPath:partInfosPath]];
|
|
|
- return localPartInfoDict;
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)persistencePartInfos:(NSDictionary *)partInfos withUploadId:(NSString *)uploadId
|
|
|
-{
|
|
|
- NSString *filePath = [[[NSString oss_documentDirectory] stringByAppendingPathComponent:kClientRecordNameWithCommonPrefix] stringByAppendingPathComponent:uploadId];
|
|
|
- if (![partInfos writeToFile:filePath atomically:YES])
|
|
|
- {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeFileCantWrite
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"uploadId for this task can't be stored persistentially!"}];
|
|
|
- OSSLogDebug(@"[Error]: %@", error);
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
- return nil;
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)checkPutObjectFileURL:(OSSPutObjectRequest *)request {
|
|
|
- NSError *error = nil;
|
|
|
- if (!request.uploadingFileURL || ![request.uploadingFileURL.path oss_isNotEmpty]) {
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"Please check your request's uploadingFileURL!"}];
|
|
|
- } else {
|
|
|
- NSFileManager *dfm = [NSFileManager defaultManager];
|
|
|
- NSDictionary *attributes = [dfm attributesOfItemAtPath:request.uploadingFileURL.path error:&error];
|
|
|
- unsigned long long fileSize = [attributes[NSFileSize] unsignedLongLongValue];
|
|
|
- if (!error && fileSize == 0) {
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: kClientErrorMessageForEmptyFile}];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (error) {
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- } else {
|
|
|
- return [OSSTask taskWithResult:nil];
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)checkFileSizeWithRequest:(OSSMultipartUploadRequest *)request {
|
|
|
- NSError *error = nil;
|
|
|
- if (!request.uploadingFileURL || ![request.uploadingFileURL.path oss_isNotEmpty]) {
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"Please check your request's uploadingFileURL!"}];
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- NSFileManager *dfm = [NSFileManager defaultManager];
|
|
|
- NSDictionary *attributes = [dfm attributesOfItemAtPath:request.uploadingFileURL.path error:&error];
|
|
|
- unsigned long long fileSize = [attributes[NSFileSize] unsignedLongLongValue];
|
|
|
- if (!error && fileSize == 0) {
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: kClientErrorMessageForEmptyFile}];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (error) {
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- } else {
|
|
|
- return nil;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-+ (NSError *)cancelError{
|
|
|
- static NSError *error = nil;
|
|
|
- static dispatch_once_t onceToken;
|
|
|
- dispatch_once(&onceToken, ^{
|
|
|
- error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeTaskCancelled
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: kClientErrorMessageForCancelledTask}];
|
|
|
- });
|
|
|
- return error;
|
|
|
-}
|
|
|
-
|
|
|
-- (void)dealloc{
|
|
|
- [self.networking.session invalidateAndCancel];
|
|
|
-}
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-
|
|
|
-@implementation OSSClient (Bucket)
|
|
|
-
|
|
|
-- (OSSTask *)createBucket:(OSSCreateBucketRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate *requestDelegate = request.requestDelegate;
|
|
|
- NSMutableDictionary *headerParams = [NSMutableDictionary dictionary];
|
|
|
- [headerParams oss_setObject:request.xOssACL forKey:OSSHttpHeaderBucketACL];
|
|
|
-
|
|
|
- if (request.location) {
|
|
|
- requestDelegate.uploadingData = [OSSUtil constructHttpBodyForCreateBucketWithLocation:request.location];
|
|
|
- }
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeCreateBucket];
|
|
|
-
|
|
|
- NSString *bodyString = [NSString stringWithFormat:@"<?xml version='1.0' encoding='UTF-8'?><CreateBucketConfiguration><StorageClass>%@</StorageClass></CreateBucketConfiguration>", request.storageClassAsString];
|
|
|
- requestDelegate.uploadingData = [bodyString dataUsingEncoding:NSUTF8StringEncoding];
|
|
|
- NSString *md5String = [OSSUtil base64Md5ForData:requestDelegate.uploadingData];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPUT;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.headerParams = headerParams;
|
|
|
- neededMsg.contentMd5 = md5String;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeCreateBucket;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)deleteBucket:(OSSDeleteObjectRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeDeleteBucket];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodDELETE;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeDeleteBucket;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)getBucket:(OSSGetBucketRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeGetBucket];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.params = request.requestParams;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeGetBucket;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)getBucketInfo:(OSSGetBucketInfoRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeGetBucketInfo];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.params = request.requestParams;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeGetBucketInfo;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)getBucketACL:(OSSGetBucketACLRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeGetBucketACL];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.params = request.requestParams;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeGetBucketACL;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@implementation OSSClient (Object)
|
|
|
-
|
|
|
-- (OSSTask *)headObject:(OSSHeadObjectRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeHeadObject];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodHEAD;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeHeadObject;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)getObject:(OSSGetObjectRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- NSString * rangeString = nil;
|
|
|
- if (request.range) {
|
|
|
- rangeString = [request.range toHeaderString];
|
|
|
- }
|
|
|
- if (request.downloadProgress) {
|
|
|
- requestDelegate.downloadProgress = request.downloadProgress;
|
|
|
- }
|
|
|
- if (request.onRecieveData) {
|
|
|
- requestDelegate.onRecieveData = request.onRecieveData;
|
|
|
- }
|
|
|
- NSMutableDictionary * params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:request.xOssProcess forKey:OSSHttpQueryProcess];
|
|
|
-
|
|
|
- [self enableCRC64WithFlag:request.crcFlag requestDelegate:requestDelegate];
|
|
|
- OSSHttpResponseParser *responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeGetObject];
|
|
|
- responseParser.crc64Verifiable = requestDelegate.crc64Verifiable;
|
|
|
-
|
|
|
- requestDelegate.responseParser = responseParser;
|
|
|
- requestDelegate.responseParser.downloadingFileURL = request.downloadToFileURL;
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.range = rangeString;
|
|
|
- neededMsg.params = params;
|
|
|
- neededMsg.headerParams = request.headerFields;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeGetObject;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)getObjectACL:(OSSGetObjectACLRequest *)request
|
|
|
-{
|
|
|
- OSSNetworkingRequestDelegate *requestDelegate = request.requestDelegate;
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeGetObjectACL];
|
|
|
-
|
|
|
- NSMutableDictionary *params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:@"" forKey:@"acl"];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectName;
|
|
|
- neededMsg.params = params;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeGetObjectACL;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)putObject:(OSSPutObjectRequest *)request
|
|
|
-{
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- NSMutableDictionary * headerParams = [NSMutableDictionary dictionaryWithDictionary:request.objectMeta];
|
|
|
- [self enableCRC64WithFlag:request.crcFlag requestDelegate:requestDelegate];
|
|
|
-
|
|
|
- if (request.uploadingData) {
|
|
|
- requestDelegate.uploadingData = request.uploadingData;
|
|
|
- if (requestDelegate.crc64Verifiable)
|
|
|
- {
|
|
|
- NSMutableData *mutableData = [NSMutableData dataWithData:request.uploadingData];
|
|
|
- requestDelegate.contentCRC = [NSString stringWithFormat:@"%llu",[mutableData oss_crc64]];
|
|
|
- }
|
|
|
- }
|
|
|
- if (request.uploadingFileURL) {
|
|
|
- OSSTask *checkIfEmptyTask = [self checkPutObjectFileURL:request];
|
|
|
- if (checkIfEmptyTask.error) {
|
|
|
- return checkIfEmptyTask;
|
|
|
- }
|
|
|
- requestDelegate.uploadingFileURL = request.uploadingFileURL;
|
|
|
- }
|
|
|
-
|
|
|
- if (request.uploadProgress) {
|
|
|
- requestDelegate.uploadProgress = request.uploadProgress;
|
|
|
- }
|
|
|
- if (request.uploadRetryCallback) {
|
|
|
- requestDelegate.retryCallback = request.uploadRetryCallback;
|
|
|
- }
|
|
|
-
|
|
|
- [headerParams oss_setObject:[request.callbackParam base64JsonString] forKey:OSSHttpHeaderXOSSCallback];
|
|
|
- [headerParams oss_setObject:[request.callbackVar base64JsonString] forKey:OSSHttpHeaderXOSSCallbackVar];
|
|
|
- [headerParams oss_setObject:request.contentDisposition forKey:OSSHttpHeaderContentDisposition];
|
|
|
- [headerParams oss_setObject:request.contentEncoding forKey:OSSHttpHeaderContentEncoding];
|
|
|
- [headerParams oss_setObject:request.expires forKey:OSSHttpHeaderExpires];
|
|
|
- [headerParams oss_setObject:request.cacheControl forKey:OSSHttpHeaderCacheControl];
|
|
|
-
|
|
|
- OSSHttpResponseParser *responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypePutObject];
|
|
|
- responseParser.crc64Verifiable = requestDelegate.crc64Verifiable;
|
|
|
- requestDelegate.responseParser = responseParser;
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPUT;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.contentMd5 = request.contentMd5;
|
|
|
- neededMsg.contentType = request.contentType;
|
|
|
- neededMsg.headerParams = headerParams;
|
|
|
- neededMsg.contentSHA1 = request.contentSHA1;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypePutObject;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)putObjectACL:(OSSPutObjectACLRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- if (request.uploadRetryCallback) {
|
|
|
- requestDelegate.retryCallback = request.uploadRetryCallback;
|
|
|
- }
|
|
|
- NSMutableDictionary * headerParams = [NSMutableDictionary dictionary];
|
|
|
- [headerParams oss_setObject:request.acl forKey:OSSHttpHeaderObjectACL];
|
|
|
-
|
|
|
- NSMutableDictionary * params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:@"" forKey:@"acl"];
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypePutObjectACL];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPUT;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.params = params;
|
|
|
- neededMsg.headerParams = headerParams;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypePutObjectACL;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)appendObject:(OSSAppendObjectRequest *)request
|
|
|
-{
|
|
|
- return [self appendObject:request withCrc64ecma:nil];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)appendObject:(OSSAppendObjectRequest *)request withCrc64ecma:(nullable NSString *)crc64ecma
|
|
|
-{
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- requestDelegate.lastCRC = crc64ecma;
|
|
|
- [self enableCRC64WithFlag:request.crcFlag requestDelegate:requestDelegate];
|
|
|
-
|
|
|
- if (request.uploadingData)
|
|
|
- {
|
|
|
- requestDelegate.uploadingData = request.uploadingData;
|
|
|
- if (requestDelegate.crc64Verifiable)
|
|
|
- {
|
|
|
- NSMutableData *mutableData = [NSMutableData dataWithData:request.uploadingData];
|
|
|
- requestDelegate.contentCRC = [NSString stringWithFormat:@"%llu",[mutableData oss_crc64]];
|
|
|
- }
|
|
|
- }
|
|
|
- if (request.uploadingFileURL) {
|
|
|
- requestDelegate.uploadingFileURL = request.uploadingFileURL;
|
|
|
- }
|
|
|
- if (request.uploadProgress) {
|
|
|
- requestDelegate.uploadProgress = request.uploadProgress;
|
|
|
- }
|
|
|
-
|
|
|
- NSMutableDictionary * headerParams = [NSMutableDictionary dictionaryWithDictionary:request.objectMeta];
|
|
|
- [headerParams oss_setObject:request.contentDisposition forKey:OSSHttpHeaderContentDisposition];
|
|
|
- [headerParams oss_setObject:request.contentEncoding forKey:OSSHttpHeaderContentEncoding];
|
|
|
- [headerParams oss_setObject:request.expires forKey:OSSHttpHeaderExpires];
|
|
|
- [headerParams oss_setObject:request.cacheControl forKey:OSSHttpHeaderCacheControl];
|
|
|
-
|
|
|
- NSMutableDictionary* params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:@"" forKey:@"append"];
|
|
|
- [params oss_setObject:[@(request.appendPosition) stringValue] forKey:@"position"];
|
|
|
-
|
|
|
- OSSHttpResponseParser *responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeAppendObject];
|
|
|
- responseParser.crc64Verifiable = requestDelegate.crc64Verifiable;
|
|
|
- requestDelegate.responseParser = responseParser;
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPOST;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.contentType = request.contentType;
|
|
|
- neededMsg.contentMd5 = request.contentMd5;
|
|
|
- neededMsg.headerParams = headerParams;
|
|
|
- neededMsg.params = params;
|
|
|
- neededMsg.contentSHA1 = request.contentSHA1;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeAppendObject;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)deleteObject:(OSSDeleteObjectRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypePutObject];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodDELETE;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeDeleteObject;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)deleteMultipleObjects:(OSSDeleteMultipleObjectsRequest *)request
|
|
|
-{
|
|
|
- if ([request.keys count] == 0) {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"keys should not be empty"}];
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
-
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- requestDelegate.uploadingData = [OSSUtil constructHttpBodyForDeleteMultipleObjects:request.keys quiet:request.quiet];
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeDeleteMultipleObjects];
|
|
|
- NSString *md5String = [OSSUtil base64Md5ForData:requestDelegate.uploadingData];
|
|
|
-
|
|
|
- NSMutableDictionary *params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:@"" forKey:@"delete"];
|
|
|
- [params oss_setObject:request.encodingType forKey:@"encoding-type"];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPOST;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.contentMd5 = md5String;
|
|
|
- neededMsg.params = params;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeDeleteMultipleObjects;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)copyObject:(OSSCopyObjectRequest *)request {
|
|
|
- NSString *copySourceHeader = nil;
|
|
|
- if (request.sourceCopyFrom) {
|
|
|
- copySourceHeader = request.sourceCopyFrom;
|
|
|
- } else {
|
|
|
- if (![request.sourceBucketName oss_isNotEmpty]) {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain code:OSSClientErrorCodeInvalidArgument userInfo:@{NSLocalizedDescriptionKey: @"sourceBucketName should not be empty!"}];
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
-
|
|
|
- if (![request.sourceObjectKey oss_isNotEmpty]) {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain code:OSSClientErrorCodeInvalidArgument userInfo:@{NSLocalizedDescriptionKey: @"sourceObjectKey should not be empty!"}];
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
-
|
|
|
- copySourceHeader = [NSString stringWithFormat:@"/%@/%@",request.bucketName, request.sourceObjectKey.oss_urlEncodedString];
|
|
|
- }
|
|
|
-
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- NSMutableDictionary * headerParams = [NSMutableDictionary dictionaryWithDictionary:request.objectMeta];
|
|
|
- [headerParams oss_setObject:copySourceHeader forKey:OSSHttpHeaderCopySource];
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeCopyObject];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPUT;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.contentType = request.contentType;
|
|
|
- neededMsg.contentMd5 = request.contentMd5;
|
|
|
- neededMsg.headerParams = headerParams;
|
|
|
- neededMsg.contentSHA1 = request.contentSHA1;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeCopyObject;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)putSymlink:(OSSPutSymlinkRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypePutSymlink];
|
|
|
-
|
|
|
- NSMutableDictionary *headerFields = [NSMutableDictionary dictionary];
|
|
|
- [headerFields oss_setObject:[request.targetObjectName oss_urlEncodedString] forKey:OSSHttpHeaderSymlinkTarget];
|
|
|
- if (request.objectMeta) {
|
|
|
- [headerFields addEntriesFromDictionary:request.objectMeta];
|
|
|
- }
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPUT;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.params = request.requestParams;
|
|
|
- neededMsg.headerParams = headerFields;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypePutSymlink;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)getSymlink:(OSSGetSymlinkRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeGetSymlink];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.params = request.requestParams;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeGetSymlink;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)restoreObject:(OSSRestoreObjectRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeRestoreObject];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPOST;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.params = request.requestParams;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeRestoreObject;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@implementation OSSClient (MultipartUpload)
|
|
|
-
|
|
|
-- (OSSTask *)listMultipartUploads:(OSSListMultipartUploadsRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- NSMutableDictionary *params = [[NSMutableDictionary alloc] initWithDictionary:[request requestParams]];
|
|
|
- [params oss_setObject:@"" forKey:@"uploads"];
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeListMultipartUploads];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.params = params;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeListMultipartUploads;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)multipartUploadInit:(OSSInitMultipartUploadRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- NSMutableDictionary * headerParams = [NSMutableDictionary dictionaryWithDictionary:request.objectMeta];
|
|
|
-
|
|
|
- [headerParams oss_setObject:request.contentDisposition forKey:OSSHttpHeaderContentDisposition];
|
|
|
- [headerParams oss_setObject:request.contentEncoding forKey:OSSHttpHeaderContentEncoding];
|
|
|
- [headerParams oss_setObject:request.expires forKey:OSSHttpHeaderExpires];
|
|
|
- [headerParams oss_setObject:request.cacheControl forKey:OSSHttpHeaderCacheControl];
|
|
|
-
|
|
|
- NSMutableDictionary *params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:@"" forKey:@"uploads"];
|
|
|
- if (request.sequential) {
|
|
|
- [params oss_setObject:@"" forKey:@"sequential"];
|
|
|
- }
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeInitMultipartUpload];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPOST;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.contentType = request.contentType;
|
|
|
- neededMsg.params = params;
|
|
|
- neededMsg.headerParams = headerParams;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeInitMultipartUpload;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)uploadPart:(OSSUploadPartRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- NSMutableDictionary * params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:[@(request.partNumber) stringValue] forKey:@"partNumber"];
|
|
|
- [params oss_setObject:request.uploadId forKey:@"uploadId"];
|
|
|
-
|
|
|
- [self enableCRC64WithFlag:request.crcFlag requestDelegate:requestDelegate];
|
|
|
- if (request.uploadPartData) {
|
|
|
- requestDelegate.uploadingData = request.uploadPartData;
|
|
|
- if (requestDelegate.crc64Verifiable)
|
|
|
- {
|
|
|
- NSMutableData *mutableData = [NSMutableData dataWithData:request.uploadPartData];
|
|
|
- requestDelegate.contentCRC = [NSString stringWithFormat:@"%llu",[mutableData oss_crc64]];
|
|
|
- }
|
|
|
- }
|
|
|
- if (request.uploadPartFileURL) {
|
|
|
- requestDelegate.uploadingFileURL = request.uploadPartFileURL;
|
|
|
- }
|
|
|
- if (request.uploadPartProgress) {
|
|
|
- requestDelegate.uploadProgress = request.uploadPartProgress;
|
|
|
- }
|
|
|
-
|
|
|
- OSSHttpResponseParser *responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeUploadPart];
|
|
|
- responseParser.crc64Verifiable = requestDelegate.crc64Verifiable;
|
|
|
- requestDelegate.responseParser = responseParser;
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPUT;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectkey;
|
|
|
- neededMsg.contentMd5 = request.contentMd5;
|
|
|
- neededMsg.params = params;
|
|
|
- neededMsg.contentSHA1 = request.contentSHA1;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeUploadPart;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)completeMultipartUpload:(OSSCompleteMultipartUploadRequest *)request
|
|
|
-{
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
- NSMutableDictionary * headerParams = [NSMutableDictionary dictionary];
|
|
|
- if (request.partInfos) {
|
|
|
- requestDelegate.uploadingData = [OSSUtil constructHttpBodyFromPartInfos:request.partInfos];
|
|
|
- }
|
|
|
-
|
|
|
- [headerParams oss_setObject:[request.callbackParam base64JsonString] forKey:OSSHttpHeaderXOSSCallback];
|
|
|
- [headerParams oss_setObject:[request.callbackVar base64JsonString] forKey:OSSHttpHeaderXOSSCallbackVar];
|
|
|
-
|
|
|
- if (request.completeMetaHeader) {
|
|
|
- [headerParams addEntriesFromDictionary:request.completeMetaHeader];
|
|
|
- }
|
|
|
- NSMutableDictionary * params = [NSMutableDictionary dictionaryWithObjectsAndKeys:request.uploadId, @"uploadId", nil];
|
|
|
-
|
|
|
- OSSHttpResponseParser *responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeCompleteMultipartUpload];
|
|
|
- responseParser.crc64Verifiable = requestDelegate.crc64Verifiable;
|
|
|
- requestDelegate.responseParser = responseParser;
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPOST;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.contentMd5 = request.contentMd5;
|
|
|
- neededMsg.headerParams = headerParams;
|
|
|
- neededMsg.params = params;
|
|
|
- neededMsg.contentSHA1 = request.contentSHA1;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeCompleteMultipartUpload;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)listParts:(OSSListPartsRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- NSMutableDictionary *params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject: request.uploadId forKey: @"uploadId"];
|
|
|
- [params oss_setObject: [NSString stringWithFormat:@"%d",request.partNumberMarker] forKey: @"part-number-marker"];
|
|
|
-
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeListMultipart];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodGET;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.params = params;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeListMultipart;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)abortMultipartUpload:(OSSAbortMultipartUploadRequest *)request {
|
|
|
- OSSNetworkingRequestDelegate * requestDelegate = request.requestDelegate;
|
|
|
-
|
|
|
- NSMutableDictionary * params = [NSMutableDictionary dictionaryWithObjectsAndKeys:request.uploadId, @"uploadId", nil];
|
|
|
- requestDelegate.responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeAbortMultipartUpload];
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodDELETE;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectKey;
|
|
|
- neededMsg.params = params;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeAbortMultipartUpload;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)abortResumableMultipartUpload:(OSSResumableUploadRequest *)request
|
|
|
-{
|
|
|
- return [self abortMultipartUpload:request sequential:NO resumable:YES];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)abortMultipartUpload:(OSSMultipartUploadRequest *)request sequential:(BOOL)sequential resumable:(BOOL)resumable {
|
|
|
-
|
|
|
- OSSTask *errorTask = nil;
|
|
|
- if(resumable) {
|
|
|
- OSSResumableUploadRequest *resumableRequest = (OSSResumableUploadRequest *)request;
|
|
|
- NSString *nameInfoString = [NSString stringWithFormat:@"%@%@%@%lu",request.md5String, resumableRequest.bucketName, resumableRequest.objectKey, (unsigned long)resumableRequest.partSize];
|
|
|
- if (sequential) {
|
|
|
- nameInfoString = [nameInfoString stringByAppendingString:kClientRecordNameWithSequentialSuffix];
|
|
|
- }
|
|
|
- if (request.crcFlag == OSSRequestCRCOpen) {
|
|
|
- nameInfoString = [nameInfoString stringByAppendingString:kClientRecordNameWithCRC64Suffix];
|
|
|
- }
|
|
|
-
|
|
|
- NSData *data = [nameInfoString dataUsingEncoding:NSUTF8StringEncoding];
|
|
|
- NSString *recordFileName = [OSSUtil dataMD5String:data];
|
|
|
- NSString *recordFilePath = [NSString stringWithFormat:@"%@/%@",resumableRequest.recordDirectoryPath,recordFileName];
|
|
|
- NSFileManager *fileManager = [NSFileManager defaultManager];
|
|
|
- NSString *partInfosFilePath = [[[NSString oss_documentDirectory] stringByAppendingPathComponent:kClientRecordNameWithCommonPrefix] stringByAppendingPathComponent:resumableRequest.uploadId];
|
|
|
-
|
|
|
- if([fileManager fileExistsAtPath:recordFilePath])
|
|
|
- {
|
|
|
- NSError *error;
|
|
|
- if (![fileManager removeItemAtPath:recordFilePath error:&error])
|
|
|
- {
|
|
|
- OSSLogDebug(@"[OSSSDKError]: %@", error);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if ([fileManager fileExistsAtPath:partInfosFilePath]) {
|
|
|
- NSError *error;
|
|
|
- if (![fileManager removeItemAtPath:partInfosFilePath error:&error])
|
|
|
- {
|
|
|
- OSSLogDebug(@"[OSSSDKError]: %@", error);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- OSSAbortMultipartUploadRequest * abort = [OSSAbortMultipartUploadRequest new];
|
|
|
- abort.bucketName = request.bucketName;
|
|
|
- abort.objectKey = request.objectKey;
|
|
|
- if (request.uploadId) {
|
|
|
- abort.uploadId = request.uploadId;
|
|
|
- } else {
|
|
|
- abort.uploadId = [[NSString alloc] initWithData:[[NSFileHandle fileHandleForReadingAtPath:recordFilePath] readDataToEndOfFile] encoding:NSUTF8StringEncoding];
|
|
|
- }
|
|
|
-
|
|
|
- errorTask = [self abortMultipartUpload:abort];
|
|
|
- }else
|
|
|
- {
|
|
|
- OSSAbortMultipartUploadRequest * abort = [OSSAbortMultipartUploadRequest new];
|
|
|
- abort.bucketName = request.bucketName;
|
|
|
- abort.objectKey = request.objectKey;
|
|
|
- abort.uploadId = request.uploadId;
|
|
|
- errorTask = [self abortMultipartUpload:abort];
|
|
|
- }
|
|
|
-
|
|
|
- return errorTask;
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)multipartUpload:(OSSMultipartUploadRequest *)request {
|
|
|
- return [self multipartUpload: request resumable: NO sequential: NO];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)processCompleteMultipartUpload:(OSSMultipartUploadRequest *)request partInfos:(NSArray<OSSPartInfo *> *)partInfos clientCrc64:(uint64_t)clientCrc64 recordFilePath:(NSString *)recordFilePath localPartInfosPath:(NSString *)localPartInfosPath
|
|
|
-{
|
|
|
- OSSCompleteMultipartUploadRequest * complete = [OSSCompleteMultipartUploadRequest new];
|
|
|
- complete.bucketName = request.bucketName;
|
|
|
- complete.objectKey = request.objectKey;
|
|
|
- complete.uploadId = request.uploadId;
|
|
|
- complete.partInfos = partInfos;
|
|
|
- complete.crcFlag = request.crcFlag;
|
|
|
- complete.contentSHA1 = request.contentSHA1;
|
|
|
-
|
|
|
- if (request.completeMetaHeader != nil) {
|
|
|
- complete.completeMetaHeader = request.completeMetaHeader;
|
|
|
- }
|
|
|
- if (request.callbackParam != nil) {
|
|
|
- complete.callbackParam = request.callbackParam;
|
|
|
- }
|
|
|
- if (request.callbackVar != nil) {
|
|
|
- complete.callbackVar = request.callbackVar;
|
|
|
- }
|
|
|
-
|
|
|
- OSSTask * completeTask = [self completeMultipartUpload:complete];
|
|
|
- [completeTask waitUntilFinished];
|
|
|
-
|
|
|
- if (completeTask.error) {
|
|
|
- OSSLogVerbose(@"completeTask.error %@: ",completeTask.error);
|
|
|
- return completeTask;
|
|
|
- } else
|
|
|
- {
|
|
|
- if(recordFilePath && [[NSFileManager defaultManager] fileExistsAtPath:recordFilePath])
|
|
|
- {
|
|
|
- NSError *deleteError;
|
|
|
- if (![[NSFileManager defaultManager] removeItemAtPath:recordFilePath error:&deleteError])
|
|
|
- {
|
|
|
- OSSLogError(@"delete localUploadIdPath failed!Error: %@",deleteError);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (localPartInfosPath && [[NSFileManager defaultManager] fileExistsAtPath:localPartInfosPath])
|
|
|
- {
|
|
|
- NSError *deleteError;
|
|
|
- if (![[NSFileManager defaultManager] removeItemAtPath:localPartInfosPath error:&deleteError])
|
|
|
- {
|
|
|
- OSSLogError(@"delete localPartInfosPath failed!Error: %@",deleteError);
|
|
|
- }
|
|
|
- }
|
|
|
- OSSCompleteMultipartUploadResult * completeResult = completeTask.result;
|
|
|
- if (complete.crcFlag == OSSRequestCRCOpen && completeResult.remoteCRC64ecma)
|
|
|
- {
|
|
|
- uint64_t remote_crc64 = 0;
|
|
|
- NSScanner *scanner = [NSScanner scannerWithString:completeResult.remoteCRC64ecma];
|
|
|
- if ([scanner scanUnsignedLongLong:&remote_crc64])
|
|
|
- {
|
|
|
- OSSLogVerbose(@"resumableUpload local_crc64 %llu",clientCrc64);
|
|
|
- OSSLogVerbose(@"resumableUpload remote_crc64 %llu", remote_crc64);
|
|
|
- if (remote_crc64 != clientCrc64)
|
|
|
- {
|
|
|
- NSString *errorMessage = [NSString stringWithFormat:@"local_crc64(%llu) is not equal to remote_crc64(%llu)!",clientCrc64,remote_crc64];
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidCRC
|
|
|
- userInfo:@{OSSErrorMessageTOKEN:errorMessage}];
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- OSSResumableUploadResult * result = [OSSResumableUploadResult new];
|
|
|
- result.requestId = completeResult.requestId;
|
|
|
- result.httpResponseCode = completeResult.httpResponseCode;
|
|
|
- result.httpResponseHeaderFields = completeResult.httpResponseHeaderFields;
|
|
|
- result.serverReturnJsonString = completeResult.serverReturnJsonString;
|
|
|
- result.remoteCRC64ecma = completeResult.remoteCRC64ecma;
|
|
|
-
|
|
|
- return [OSSTask taskWithResult:result];
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-- (OSSTask *)resumableUpload:(OSSResumableUploadRequest *)request
|
|
|
-{
|
|
|
- return [self multipartUpload: request resumable: YES sequential: NO];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)processListPartsWithObjectKey:(nonnull NSString *)objectKey bucket:(nonnull NSString *)bucket uploadId:(NSString * _Nonnull *)uploadId uploadedParts:(nonnull NSMutableArray *)uploadedParts uploadedLength:(NSUInteger *)uploadedLength totalSize:(unsigned long long)totalSize partSize:(NSUInteger)partSize
|
|
|
-{
|
|
|
- BOOL isTruncated = NO;
|
|
|
- int nextPartNumberMarker = 0;
|
|
|
-
|
|
|
- do {
|
|
|
- OSSListPartsRequest * listParts = [OSSListPartsRequest new];
|
|
|
- listParts.bucketName = bucket;
|
|
|
- listParts.objectKey = objectKey;
|
|
|
- listParts.uploadId = *uploadId;
|
|
|
- listParts.partNumberMarker = nextPartNumberMarker;
|
|
|
- OSSTask * listPartsTask = [self listParts:listParts];
|
|
|
- [listPartsTask waitUntilFinished];
|
|
|
-
|
|
|
- if (listPartsTask.error)
|
|
|
- {
|
|
|
- isTruncated = NO;
|
|
|
- [uploadedParts removeAllObjects];
|
|
|
- if ([listPartsTask.error.domain isEqualToString: OSSServerErrorDomain] && labs(listPartsTask.error.code) == 404)
|
|
|
- {
|
|
|
- OSSLogVerbose(@"local record existes but the remote record is deleted");
|
|
|
- *uploadId = nil;
|
|
|
- } else
|
|
|
- {
|
|
|
- return listPartsTask;
|
|
|
- }
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- OSSListPartsResult *res = listPartsTask.result;
|
|
|
- isTruncated = res.isTruncated;
|
|
|
- nextPartNumberMarker = res.nextPartNumberMarker;
|
|
|
- OSSLogVerbose(@"resumableUpload listpart ok");
|
|
|
- if (res.parts.count > 0) {
|
|
|
- [uploadedParts addObjectsFromArray:res.parts];
|
|
|
- }
|
|
|
- }
|
|
|
- } while (isTruncated);
|
|
|
-
|
|
|
- __block NSUInteger firstPartSize = 0;
|
|
|
- __block NSUInteger bUploadedLength = 0;
|
|
|
- [uploadedParts enumerateObjectsUsingBlock:^(NSDictionary *part, NSUInteger idx, BOOL * _Nonnull stop) {
|
|
|
- unsigned long long iPartSize = 0;
|
|
|
- NSString *partSizeString = [part objectForKey:OSSSizeXMLTOKEN];
|
|
|
- NSScanner *scanner = [NSScanner scannerWithString:partSizeString];
|
|
|
- [scanner scanUnsignedLongLong:&iPartSize];
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- bUploadedLength += iPartSize;
|
|
|
- if (idx == 0)
|
|
|
- {
|
|
|
- firstPartSize = iPartSize;
|
|
|
- }
|
|
|
-#pragma clang diagnostic pop
|
|
|
- }];
|
|
|
- *uploadedLength = bUploadedLength;
|
|
|
-
|
|
|
- if (totalSize < bUploadedLength)
|
|
|
- {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeCannotResumeUpload
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"The uploading file is inconsistent with before"}];
|
|
|
- return [OSSTask taskWithError: error];
|
|
|
- }
|
|
|
- else if (firstPartSize != 0 && firstPartSize != partSize && totalSize != firstPartSize)
|
|
|
- {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeCannotResumeUpload
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"The part size setting is inconsistent with before"}];
|
|
|
- return [OSSTask taskWithError: error];
|
|
|
- }
|
|
|
- return nil;
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)processResumableInitMultipartUpload:(OSSInitMultipartUploadRequest *)request recordFilePath:(NSString *)recordFilePath
|
|
|
-{
|
|
|
- OSSTask *task = [self multipartUploadInit:request];
|
|
|
- [task waitUntilFinished];
|
|
|
-
|
|
|
- if(task.result && [recordFilePath oss_isNotEmpty])
|
|
|
- {
|
|
|
- OSSInitMultipartUploadResult *result = task.result;
|
|
|
- if (![result.uploadId oss_isNotEmpty])
|
|
|
- {
|
|
|
- NSString *errorMessage = [NSString stringWithFormat:@"Can not get uploadId!"];
|
|
|
- NSError *error = [NSError errorWithDomain:OSSServerErrorDomain
|
|
|
- code:OSSClientErrorCodeNilUploadid userInfo:@{OSSErrorMessageTOKEN: errorMessage}];
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
-
|
|
|
- NSFileManager *defaultFM = [NSFileManager defaultManager];
|
|
|
- if (![defaultFM fileExistsAtPath:recordFilePath])
|
|
|
- {
|
|
|
- if (![defaultFM createFileAtPath:recordFilePath contents:nil attributes:nil]) {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeFileCantWrite
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"uploadId for this task can't be stored persistentially!"}];
|
|
|
- OSSLogDebug(@"[Error]: %@", error);
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
- }
|
|
|
- NSFileHandle * write = [NSFileHandle fileHandleForWritingAtPath:recordFilePath];
|
|
|
- [write writeData:[result.uploadId dataUsingEncoding:NSUTF8StringEncoding]];
|
|
|
- [write closeFile];
|
|
|
- }
|
|
|
- return task;
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)upload:(OSSMultipartUploadRequest *)request
|
|
|
- uploadIndex:(NSMutableArray *)alreadyUploadIndex
|
|
|
- uploadPart:(NSMutableArray *)alreadyUploadPart
|
|
|
- count:(NSUInteger)partCout
|
|
|
- uploadedLength:(NSUInteger *)uploadedLength
|
|
|
- fileSize:(unsigned long long)uploadFileSize
|
|
|
-{
|
|
|
- NSOperationQueue *queue = [[NSOperationQueue alloc] init];
|
|
|
- [queue setMaxConcurrentOperationCount: 5];
|
|
|
-
|
|
|
- NSObject *localLock = [[NSObject alloc] init];
|
|
|
-
|
|
|
- OSSRequestCRCFlag crcFlag = request.crcFlag;
|
|
|
- __block OSSTask *errorTask;
|
|
|
- __block NSMutableDictionary *localPartInfos = nil;
|
|
|
-
|
|
|
- if (crcFlag == OSSRequestCRCOpen) {
|
|
|
- localPartInfos = [self localPartInfosDictoryWithUploadId:request.uploadId];
|
|
|
- }
|
|
|
-
|
|
|
- if (!localPartInfos) {
|
|
|
- localPartInfos = [NSMutableDictionary dictionary];
|
|
|
- }
|
|
|
-
|
|
|
- NSError *readError;
|
|
|
- NSFileHandle *fileHande = [NSFileHandle fileHandleForReadingFromURL:request.uploadingFileURL error:&readError];
|
|
|
- if (readError) {
|
|
|
- return [OSSTask taskWithError: readError];
|
|
|
- }
|
|
|
-
|
|
|
- NSData * uploadPartData;
|
|
|
- NSInteger realPartLength = request.partSize;
|
|
|
- __block BOOL hasError = NO;
|
|
|
-
|
|
|
- for (NSUInteger idx = 1; idx <= partCout; idx++)
|
|
|
- {
|
|
|
- if (request.isCancelled)
|
|
|
- {
|
|
|
- [queue cancelAllOperations];
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- if ([alreadyUploadIndex containsObject:@(idx)])
|
|
|
- {
|
|
|
- continue;
|
|
|
- }
|
|
|
-
|
|
|
- // while operationCount >= 5,the loop will stay here
|
|
|
- while (queue.operationCount >= 5) {
|
|
|
- [NSThread sleepForTimeInterval: 0.15f];
|
|
|
- }
|
|
|
-
|
|
|
- if (idx == partCout) {
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- realPartLength = uploadFileSize - request.partSize * (idx - 1);
|
|
|
-#pragma clang diagnostic pop
|
|
|
- }
|
|
|
- @autoreleasepool
|
|
|
- {
|
|
|
- [fileHande seekToFileOffset: request.partSize * (idx - 1)];
|
|
|
- uploadPartData = [fileHande readDataOfLength:realPartLength];
|
|
|
-
|
|
|
- NSBlockOperation *operation = [NSBlockOperation blockOperationWithBlock:^{
|
|
|
- OSSTask *uploadPartErrorTask = nil;
|
|
|
-
|
|
|
- [self executePartUpload:request
|
|
|
- totalBytesExpectedToSend:uploadFileSize
|
|
|
- totalBytesSent:uploadedLength
|
|
|
- index:idx
|
|
|
- partData:uploadPartData
|
|
|
- alreadyUploadPart:alreadyUploadPart
|
|
|
- localParts:localPartInfos
|
|
|
- errorTask:&uploadPartErrorTask];
|
|
|
-
|
|
|
- if (uploadPartErrorTask != nil) {
|
|
|
- @synchronized(localLock) {
|
|
|
- if (!hasError) {
|
|
|
- hasError = YES;
|
|
|
- errorTask = uploadPartErrorTask;
|
|
|
- }
|
|
|
- }
|
|
|
- uploadPartErrorTask = nil;
|
|
|
- }
|
|
|
- }];
|
|
|
- [queue addOperation:operation];
|
|
|
- }
|
|
|
- }
|
|
|
- [fileHande closeFile];
|
|
|
- [queue waitUntilAllOperationsAreFinished];
|
|
|
-
|
|
|
- localLock = nil;
|
|
|
-
|
|
|
- if (!errorTask && request.isCancelled) {
|
|
|
- errorTask = [OSSTask taskWithError:[OSSClient cancelError]];
|
|
|
- }
|
|
|
-
|
|
|
- return errorTask;
|
|
|
-}
|
|
|
-
|
|
|
-- (void)executePartUpload:(OSSMultipartUploadRequest *)request totalBytesExpectedToSend:(unsigned long long)totalBytesExpectedToSend totalBytesSent:(NSUInteger *)totalBytesSent index:(NSUInteger)idx partData:(NSData *)partData alreadyUploadPart:(NSMutableArray *)uploadedParts localParts:(NSMutableDictionary *)localParts errorTask:(OSSTask **)errorTask
|
|
|
-{
|
|
|
- NSUInteger bytesSent = partData.length;
|
|
|
-
|
|
|
- OSSUploadPartRequest * uploadPart = [OSSUploadPartRequest new];
|
|
|
- uploadPart.bucketName = request.bucketName;
|
|
|
- uploadPart.objectkey = request.objectKey;
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- uploadPart.partNumber = idx;
|
|
|
-#pragma clang diagnostic pop
|
|
|
- uploadPart.uploadId = request.uploadId;
|
|
|
- uploadPart.uploadPartData = partData;
|
|
|
- uploadPart.contentMd5 = [OSSUtil base64Md5ForData:partData];
|
|
|
- uploadPart.crcFlag = request.crcFlag;
|
|
|
-
|
|
|
- OSSTask * uploadPartTask = [self uploadPart:uploadPart];
|
|
|
- [uploadPartTask waitUntilFinished];
|
|
|
- if (uploadPartTask.error) {
|
|
|
- if (labs(uploadPartTask.error.code) != 409) {
|
|
|
- *errorTask = uploadPartTask;
|
|
|
- }
|
|
|
- } else {
|
|
|
- OSSUploadPartResult * result = uploadPartTask.result;
|
|
|
- OSSPartInfo * partInfo = [OSSPartInfo new];
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- partInfo.partNum = idx;
|
|
|
-#pragma clang diagnostic pop
|
|
|
- partInfo.eTag = result.eTag;
|
|
|
- partInfo.size = bytesSent;
|
|
|
- uint64_t crc64OfPart;
|
|
|
- @try {
|
|
|
- NSScanner *scanner = [NSScanner scannerWithString:result.remoteCRC64ecma];
|
|
|
- [scanner scanUnsignedLongLong:&crc64OfPart];
|
|
|
- partInfo.crc64 = crc64OfPart;
|
|
|
- } @catch (NSException *exception) {
|
|
|
- OSSLogError(@"multipart upload error with nil remote crc64!");
|
|
|
- }
|
|
|
-
|
|
|
- @synchronized(lock){
|
|
|
- [uploadedParts addObject:partInfo];
|
|
|
-
|
|
|
- if (request.crcFlag == OSSRequestCRCOpen)
|
|
|
- {
|
|
|
- [self processForLocalPartInfos:localParts
|
|
|
- partInfo:partInfo
|
|
|
- uploadId:request.uploadId];
|
|
|
- [self persistencePartInfos:localParts
|
|
|
- withUploadId:request.uploadId];
|
|
|
- }
|
|
|
-
|
|
|
- *totalBytesSent += bytesSent;
|
|
|
- if (request.uploadProgress)
|
|
|
- {
|
|
|
- request.uploadProgress(bytesSent, *totalBytesSent, totalBytesExpectedToSend);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-- (void)processForLocalPartInfos:(NSMutableDictionary *)localPartInfoDict partInfo:(OSSPartInfo *)partInfo uploadId:(NSString *)uploadId
|
|
|
-{
|
|
|
- NSDictionary *partInfoDict = [partInfo entityToDictionary];
|
|
|
- NSString *keyString = [NSString stringWithFormat:@"%i",partInfo.partNum];
|
|
|
- [localPartInfoDict oss_setObject:partInfoDict forKey:keyString];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)sequentialMultipartUpload:(OSSResumableUploadRequest *)request
|
|
|
-{
|
|
|
- return [self multipartUpload:request resumable:YES sequential:YES];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)multipartUpload:(OSSMultipartUploadRequest *)request resumable:(BOOL)resumable sequential:(BOOL)sequential
|
|
|
-{
|
|
|
- if (resumable) {
|
|
|
- if (![request isKindOfClass:[OSSResumableUploadRequest class]]) {
|
|
|
- NSError *typoError = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"resumable multipart request should use instance of class OSSMultipartUploadRequest!"}];
|
|
|
- return [OSSTask taskWithError: typoError];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- [self checkRequestCrc64Setting:request];
|
|
|
- OSSTask *preTask = [self preChecksForRequest:request];
|
|
|
- if (preTask) {
|
|
|
- return preTask;
|
|
|
- }
|
|
|
-
|
|
|
- return [[OSSTask taskWithResult:nil] continueWithExecutor:self.ossOperationExecutor withBlock:^id(OSSTask *task) {
|
|
|
-
|
|
|
- __block NSUInteger uploadedLength = 0;
|
|
|
- uploadedLength = 0;
|
|
|
- __block OSSTask * errorTask;
|
|
|
- __block NSString *uploadId;
|
|
|
-
|
|
|
- NSError *error;
|
|
|
- unsigned long long uploadFileSize = [self getSizeWithFilePath:request.uploadingFileURL.path error:&error];
|
|
|
- if (error) {
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
-
|
|
|
- NSUInteger partCount = [self judgePartSizeForMultipartRequest:request fileSize:uploadFileSize];
|
|
|
-
|
|
|
- if (partCount > 1 && request.partSize < 102400) {
|
|
|
- NSError *checkPartSizeError = [NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"Part size must be greater than equal to 100KB"}];
|
|
|
- return [OSSTask taskWithError:checkPartSizeError];
|
|
|
- }
|
|
|
-
|
|
|
- if (request.isCancelled) {
|
|
|
- return [OSSTask taskWithError:[OSSClient cancelError]];
|
|
|
- }
|
|
|
-
|
|
|
- NSString *recordFilePath = nil;
|
|
|
- NSMutableArray * uploadedPart = [NSMutableArray array];
|
|
|
- NSString *localPartInfosPath = nil;
|
|
|
- NSDictionary *localPartInfos = nil;
|
|
|
-
|
|
|
- NSMutableArray<OSSPartInfo *> *uploadedPartInfos = [NSMutableArray array];
|
|
|
- NSMutableArray * alreadyUploadIndex = [NSMutableArray array];
|
|
|
-
|
|
|
- if (resumable) {
|
|
|
- OSSResumableUploadRequest *resumableRequest = (OSSResumableUploadRequest *)request;
|
|
|
- NSString *recordDirectoryPath = resumableRequest.recordDirectoryPath;
|
|
|
- request.md5String = [OSSUtil fileMD5String:request.uploadingFileURL.path];
|
|
|
- if ([recordDirectoryPath oss_isNotEmpty])
|
|
|
- {
|
|
|
- uploadId = [self readUploadIdForRequest:resumableRequest recordFilePath:&recordFilePath sequential:sequential];
|
|
|
- OSSLogVerbose(@"local uploadId: %@,recordFilePath: %@",uploadId, recordFilePath);
|
|
|
- }
|
|
|
-
|
|
|
- if([uploadId oss_isNotEmpty])
|
|
|
- {
|
|
|
- localPartInfosPath = [[[NSString oss_documentDirectory] stringByAppendingPathComponent:kClientRecordNameWithCommonPrefix] stringByAppendingPathComponent:uploadId];
|
|
|
-
|
|
|
- localPartInfos = [[NSDictionary alloc] initWithContentsOfFile:localPartInfosPath];
|
|
|
-
|
|
|
- OSSTask *listPartTask = [self processListPartsWithObjectKey:request.objectKey
|
|
|
- bucket:request.bucketName
|
|
|
- uploadId:&uploadId
|
|
|
- uploadedParts:uploadedPart
|
|
|
- uploadedLength:&uploadedLength
|
|
|
- totalSize:uploadFileSize
|
|
|
- partSize:request.partSize];
|
|
|
- if (listPartTask.error)
|
|
|
- {
|
|
|
- return listPartTask;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- [uploadedPart enumerateObjectsUsingBlock:^(NSDictionary *partInfo, NSUInteger idx, BOOL * _Nonnull stop) {
|
|
|
- unsigned long long remotePartNumber = 0;
|
|
|
- NSString *partNumberString = [partInfo objectForKey: OSSPartNumberXMLTOKEN];
|
|
|
- NSScanner *scanner = [NSScanner scannerWithString: partNumberString];
|
|
|
- [scanner scanUnsignedLongLong: &remotePartNumber];
|
|
|
-
|
|
|
- NSString *remotePartEtag = [partInfo objectForKey:OSSETagXMLTOKEN];
|
|
|
-
|
|
|
- unsigned long long remotePartSize = 0;
|
|
|
- NSString *partSizeString = [partInfo objectForKey:OSSSizeXMLTOKEN];
|
|
|
- scanner = [NSScanner scannerWithString:partSizeString];
|
|
|
- [scanner scanUnsignedLongLong:&remotePartSize];
|
|
|
-
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
-
|
|
|
- OSSPartInfo * info = [[OSSPartInfo alloc] init];
|
|
|
- info.partNum = remotePartNumber;
|
|
|
- info.size = remotePartSize;
|
|
|
- info.eTag = remotePartEtag;
|
|
|
-
|
|
|
-#pragma clang diagnostic pop
|
|
|
-
|
|
|
- NSDictionary *tPartInfo = [localPartInfos objectForKey: [@(remotePartNumber) stringValue]];
|
|
|
- info.crc64 = [tPartInfo[@"crc64"] unsignedLongLongValue];
|
|
|
-
|
|
|
- [uploadedPartInfos addObject:info];
|
|
|
- [alreadyUploadIndex addObject:@(remotePartNumber)];
|
|
|
- }];
|
|
|
-
|
|
|
- if ([alreadyUploadIndex count] > 0 && request.uploadProgress && uploadFileSize) {
|
|
|
- request.uploadProgress(0, uploadedLength, uploadFileSize);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (![uploadId oss_isNotEmpty]) {
|
|
|
- OSSInitMultipartUploadRequest *initRequest = [OSSInitMultipartUploadRequest new];
|
|
|
- initRequest.bucketName = request.bucketName;
|
|
|
- initRequest.objectKey = request.objectKey;
|
|
|
- initRequest.contentType = request.contentType;
|
|
|
- initRequest.objectMeta = request.completeMetaHeader;
|
|
|
- initRequest.sequential = sequential;
|
|
|
- initRequest.crcFlag = request.crcFlag;
|
|
|
-
|
|
|
- OSSTask *task = [self processResumableInitMultipartUpload:initRequest
|
|
|
- recordFilePath:recordFilePath];
|
|
|
- if (task.error)
|
|
|
- {
|
|
|
- return task;
|
|
|
- }
|
|
|
- OSSInitMultipartUploadResult *initResult = (OSSInitMultipartUploadResult *)task.result;
|
|
|
- uploadId = initResult.uploadId;
|
|
|
- }
|
|
|
-
|
|
|
- request.uploadId = uploadId;
|
|
|
- localPartInfosPath = [[[NSString oss_documentDirectory] stringByAppendingPathComponent:kClientRecordNameWithCommonPrefix] stringByAppendingPathComponent:uploadId];
|
|
|
-
|
|
|
- if (request.isCancelled)
|
|
|
- {
|
|
|
- if(resumable)
|
|
|
- {
|
|
|
- OSSResumableUploadRequest *resumableRequest = (OSSResumableUploadRequest *)request;
|
|
|
- if (resumableRequest.deleteUploadIdOnCancelling) {
|
|
|
- OSSTask *abortTask = [self abortMultipartUpload:request sequential:sequential resumable:resumable];
|
|
|
- [abortTask waitUntilFinished];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return [OSSTask taskWithError:[OSSClient cancelError]];
|
|
|
- }
|
|
|
-
|
|
|
- if (sequential) {
|
|
|
- errorTask = [self sequentialUpload:request
|
|
|
- uploadIndex:alreadyUploadIndex
|
|
|
- uploadPart:uploadedPartInfos
|
|
|
- count:partCount
|
|
|
- uploadedLength:&uploadedLength
|
|
|
- fileSize:uploadFileSize];
|
|
|
- } else {
|
|
|
- errorTask = [self upload:request
|
|
|
- uploadIndex:alreadyUploadIndex
|
|
|
- uploadPart:uploadedPartInfos
|
|
|
- count:partCount
|
|
|
- uploadedLength:&uploadedLength
|
|
|
- fileSize:uploadFileSize];
|
|
|
- }
|
|
|
-
|
|
|
- if(errorTask.error)
|
|
|
- {
|
|
|
- OSSTask *abortTask;
|
|
|
- if(resumable)
|
|
|
- {
|
|
|
- OSSResumableUploadRequest *resumableRequest = (OSSResumableUploadRequest *)request;
|
|
|
- if (resumableRequest.deleteUploadIdOnCancelling || errorTask.error.code == OSSClientErrorCodeFileCantWrite) {
|
|
|
- abortTask = [self abortMultipartUpload:request sequential:sequential resumable:resumable];
|
|
|
- }
|
|
|
- }else
|
|
|
- {
|
|
|
- abortTask =[self abortMultipartUpload:request sequential:sequential resumable:resumable];
|
|
|
- }
|
|
|
- [abortTask waitUntilFinished];
|
|
|
-
|
|
|
- return errorTask;
|
|
|
- }
|
|
|
-
|
|
|
- [uploadedPartInfos sortUsingComparator:^NSComparisonResult(OSSPartInfo *part1,OSSPartInfo* part2) {
|
|
|
- if(part1.partNum < part2.partNum){
|
|
|
- return NSOrderedAscending;
|
|
|
- }else if(part1.partNum > part2.partNum){
|
|
|
- return NSOrderedDescending;
|
|
|
- }else{
|
|
|
- return NSOrderedSame;
|
|
|
- }
|
|
|
- }];
|
|
|
-
|
|
|
- // 如果开启了crc64的校验
|
|
|
- uint64_t local_crc64 = 0;
|
|
|
- if (request.crcFlag == OSSRequestCRCOpen)
|
|
|
- {
|
|
|
- for (NSUInteger index = 0; index< uploadedPartInfos.count; index++)
|
|
|
- {
|
|
|
- uint64_t partCrc64 = uploadedPartInfos[index].crc64;
|
|
|
- int64_t partSize = uploadedPartInfos[index].size;
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- local_crc64 = [OSSUtil crc64ForCombineCRC1:local_crc64 CRC2:partCrc64 length:partSize];
|
|
|
-#pragma clang diagnostic pop
|
|
|
- }
|
|
|
- }
|
|
|
- return [self processCompleteMultipartUpload:request
|
|
|
- partInfos:uploadedPartInfos
|
|
|
- clientCrc64:local_crc64
|
|
|
- recordFilePath:recordFilePath
|
|
|
- localPartInfosPath:localPartInfosPath];
|
|
|
- }];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)sequentialUpload:(OSSMultipartUploadRequest *)request
|
|
|
- uploadIndex:(NSMutableArray *)alreadyUploadIndex
|
|
|
- uploadPart:(NSMutableArray *)alreadyUploadPart
|
|
|
- count:(NSUInteger)partCout
|
|
|
- uploadedLength:(NSUInteger *)uploadedLength
|
|
|
- fileSize:(unsigned long long)uploadFileSize
|
|
|
-{
|
|
|
- OSSRequestCRCFlag crcFlag = request.crcFlag;
|
|
|
- __block OSSTask *errorTask;
|
|
|
- __block NSMutableDictionary *localPartInfos = nil;
|
|
|
-
|
|
|
- if (crcFlag == OSSRequestCRCOpen) {
|
|
|
- localPartInfos = [self localPartInfosDictoryWithUploadId:request.uploadId];
|
|
|
- }
|
|
|
-
|
|
|
- if (!localPartInfos) {
|
|
|
- localPartInfos = [NSMutableDictionary dictionary];
|
|
|
- }
|
|
|
-
|
|
|
- NSError *readError;
|
|
|
- NSFileHandle *fileHande = [NSFileHandle fileHandleForReadingFromURL:request.uploadingFileURL error:&readError];
|
|
|
- if (readError) {
|
|
|
- return [OSSTask taskWithError: readError];
|
|
|
- }
|
|
|
-
|
|
|
- NSUInteger realPartLength = request.partSize;
|
|
|
-
|
|
|
- for (int i = 1; i <= partCout; i++) {
|
|
|
- if (errorTask) {
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- if (request.isCancelled) {
|
|
|
- errorTask = [OSSTask taskWithError:[OSSClient cancelError]];
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- if ([alreadyUploadIndex containsObject:@(i)]) {
|
|
|
- continue;
|
|
|
- }
|
|
|
-
|
|
|
- realPartLength = request.partSize;
|
|
|
- [fileHande seekToFileOffset:request.partSize * (i - 1)];
|
|
|
- if (i == partCout) {
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- realPartLength = uploadFileSize - request.partSize * (i - 1);
|
|
|
-#pragma clang diagnostic pop
|
|
|
- }
|
|
|
- NSData *uploadPartData = [fileHande readDataOfLength:realPartLength];
|
|
|
-
|
|
|
- @autoreleasepool {
|
|
|
- OSSUploadPartRequest * uploadPart = [OSSUploadPartRequest new];
|
|
|
- uploadPart.bucketName = request.bucketName;
|
|
|
- uploadPart.objectkey = request.objectKey;
|
|
|
- uploadPart.partNumber = i;
|
|
|
- uploadPart.uploadId = request.uploadId;
|
|
|
- uploadPart.uploadPartData = uploadPartData;
|
|
|
- uploadPart.contentMd5 = [OSSUtil base64Md5ForData:uploadPartData];
|
|
|
- uploadPart.crcFlag = request.crcFlag;
|
|
|
-
|
|
|
- OSSTask * uploadPartTask = [self uploadPart:uploadPart];
|
|
|
- [uploadPartTask waitUntilFinished];
|
|
|
-
|
|
|
- if (uploadPartTask.error) {
|
|
|
- if (labs(uploadPartTask.error.code) != 409) {
|
|
|
- errorTask = uploadPartTask;
|
|
|
- break;
|
|
|
- } else {
|
|
|
- NSDictionary *partDict = uploadPartTask.error.userInfo;
|
|
|
- OSSPartInfo *partInfo = [[OSSPartInfo alloc] init];
|
|
|
- partInfo.eTag = partDict[@"PartEtag"];
|
|
|
-#pragma clang diagnostic push
|
|
|
-#pragma clang diagnostic ignored "-Wshorten-64-to-32"
|
|
|
- partInfo.partNum = [(NSString *)partDict[@"PartNumber"] integerValue];
|
|
|
- partInfo.size = realPartLength;
|
|
|
-#pragma clang diagnostic push
|
|
|
- partInfo.crc64 = [[uploadPartData mutableCopy] oss_crc64];
|
|
|
-
|
|
|
- [alreadyUploadPart addObject:partInfo];
|
|
|
- }
|
|
|
- } else {
|
|
|
- OSSUploadPartResult * result = uploadPartTask.result;
|
|
|
- OSSPartInfo * partInfo = [OSSPartInfo new];
|
|
|
- partInfo.partNum = i;
|
|
|
- partInfo.eTag = result.eTag;
|
|
|
- partInfo.size = realPartLength;
|
|
|
- uint64_t crc64OfPart;
|
|
|
- @try {
|
|
|
- NSScanner *scanner = [NSScanner scannerWithString:result.remoteCRC64ecma];
|
|
|
- [scanner scanUnsignedLongLong:&crc64OfPart];
|
|
|
- partInfo.crc64 = crc64OfPart;
|
|
|
- } @catch (NSException *exception) {
|
|
|
- OSSLogError(@"multipart upload error with nil remote crc64!");
|
|
|
- }
|
|
|
-
|
|
|
- [alreadyUploadPart addObject:partInfo];
|
|
|
- if (crcFlag == OSSRequestCRCOpen)
|
|
|
- {
|
|
|
- [self processForLocalPartInfos:localPartInfos
|
|
|
- partInfo:partInfo
|
|
|
- uploadId:request.uploadId];
|
|
|
- [self persistencePartInfos:localPartInfos
|
|
|
- withUploadId:request.uploadId];
|
|
|
- }
|
|
|
-
|
|
|
- @synchronized(lock) {
|
|
|
- *uploadedLength += realPartLength;
|
|
|
- if (request.uploadProgress)
|
|
|
- {
|
|
|
- request.uploadProgress(realPartLength, *uploadedLength, uploadFileSize);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- [fileHande closeFile];
|
|
|
-
|
|
|
- return errorTask;
|
|
|
-}
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@implementation OSSClient (PresignURL)
|
|
|
-
|
|
|
-- (OSSTask *)presignConstrainURLWithBucketName:(NSString *)bucketName
|
|
|
- withObjectKey:(NSString *)objectKey
|
|
|
- withExpirationInterval:(NSTimeInterval)interval {
|
|
|
-
|
|
|
- return [self presignConstrainURLWithBucketName:bucketName
|
|
|
- withObjectKey:objectKey
|
|
|
- withExpirationInterval:interval
|
|
|
- withParameters:@{}];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)presignConstrainURLWithBucketName:(NSString *)bucketName
|
|
|
- withObjectKey:(NSString *)objectKey
|
|
|
- withExpirationInterval:(NSTimeInterval)interval
|
|
|
- withParameters:(NSDictionary *)parameters {
|
|
|
-
|
|
|
- return [self presignConstrainURLWithBucketName: bucketName
|
|
|
- withObjectKey: objectKey
|
|
|
- httpMethod: @"GET"
|
|
|
- withExpirationInterval: interval
|
|
|
- withParameters: parameters];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)presignConstrainURLWithBucketName:(NSString *)bucketName
|
|
|
- withObjectKey:(NSString *)objectKey
|
|
|
- httpMethod:(NSString *)method
|
|
|
- withExpirationInterval:(NSTimeInterval)interval
|
|
|
- withParameters:(NSDictionary *)parameters
|
|
|
-{
|
|
|
- return [[OSSTask taskWithResult:nil] continueWithBlock:^id(OSSTask *task) {
|
|
|
- NSString * resource = [NSString stringWithFormat:@"/%@/%@", bucketName, objectKey];
|
|
|
- NSString * expires = [@((int64_t)[[NSDate oss_clockSkewFixedDate] timeIntervalSince1970] + interval) stringValue];
|
|
|
-
|
|
|
- NSMutableDictionary * params = [NSMutableDictionary dictionary];
|
|
|
- if (parameters.count > 0) {
|
|
|
- [params addEntriesFromDictionary:parameters];
|
|
|
- }
|
|
|
-
|
|
|
- NSString * wholeSign = nil;
|
|
|
- OSSFederationToken *token = nil;
|
|
|
- NSError *error = nil;
|
|
|
-
|
|
|
- if ([self.credentialProvider isKindOfClass:[OSSFederationCredentialProvider class]]) {
|
|
|
- token = [(OSSFederationCredentialProvider *)self.credentialProvider getToken:&error];
|
|
|
- if (error) {
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
- } else if ([self.credentialProvider isKindOfClass:[OSSStsTokenCredentialProvider class]]) {
|
|
|
- token = [(OSSStsTokenCredentialProvider *)self.credentialProvider getToken];
|
|
|
- }
|
|
|
-
|
|
|
- if ([self.credentialProvider isKindOfClass:[OSSFederationCredentialProvider class]]
|
|
|
- || [self.credentialProvider isKindOfClass:[OSSStsTokenCredentialProvider class]])
|
|
|
- {
|
|
|
- [params oss_setObject:token.tToken forKey:@"security-token"];
|
|
|
- resource = [NSString stringWithFormat:@"%@?%@", resource, [OSSUtil populateSubresourceStringFromParameter:params]];
|
|
|
- NSString * string2sign = [NSString stringWithFormat:@"%@\n\n\n%@\n%@", method, expires, resource];
|
|
|
- wholeSign = [OSSUtil sign:string2sign withToken:token];
|
|
|
- } else {
|
|
|
- NSString * subresource = [OSSUtil populateSubresourceStringFromParameter:params];
|
|
|
- if ([subresource length] > 0) {
|
|
|
- resource = [NSString stringWithFormat:@"%@?%@", resource, [OSSUtil populateSubresourceStringFromParameter:params]];
|
|
|
- }
|
|
|
- NSString * string2sign = [NSString stringWithFormat:@"%@\n\n\n%@\n%@", method, expires, resource];
|
|
|
- wholeSign = [self.credentialProvider sign:string2sign error:&error];
|
|
|
- if (error) {
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- NSArray * splitResult = [wholeSign componentsSeparatedByString:@":"];
|
|
|
- if ([splitResult count] != 2
|
|
|
- || ![((NSString *)[splitResult objectAtIndex:0]) hasPrefix:@"OSS "]) {
|
|
|
- return [OSSTask taskWithError:[NSError errorWithDomain:OSSClientErrorDomain
|
|
|
- code:OSSClientErrorCodeSignFailed
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"the returned signature is invalid"}]];
|
|
|
- }
|
|
|
- NSString * accessKey = [(NSString *)[splitResult objectAtIndex:0] substringFromIndex:4];
|
|
|
- NSString * signature = [splitResult objectAtIndex:1];
|
|
|
-
|
|
|
- NSURL * endpointURL = [NSURL URLWithString:self.endpoint];
|
|
|
- NSString * host = endpointURL.host;
|
|
|
- if ([OSSUtil isOssOriginBucketHost:host]) {
|
|
|
- host = [NSString stringWithFormat:@"%@.%@", bucketName, host];
|
|
|
- }
|
|
|
-
|
|
|
- [params oss_setObject:signature forKey:@"Signature"];
|
|
|
- [params oss_setObject:accessKey forKey:@"OSSAccessKeyId"];
|
|
|
- [params oss_setObject:expires forKey:@"Expires"];
|
|
|
- NSString * stringURL = [NSString stringWithFormat:@"%@://%@/%@?%@",
|
|
|
- endpointURL.scheme,
|
|
|
- host,
|
|
|
- [OSSUtil encodeURL:objectKey],
|
|
|
- [OSSUtil populateQueryStringFromParameter:params]];
|
|
|
- return [OSSTask taskWithResult:stringURL];
|
|
|
- }];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)presignPublicURLWithBucketName:(NSString *)bucketName
|
|
|
- withObjectKey:(NSString *)objectKey {
|
|
|
-
|
|
|
- return [self presignPublicURLWithBucketName:bucketName
|
|
|
- withObjectKey:objectKey
|
|
|
- withParameters:@{}];
|
|
|
-}
|
|
|
-
|
|
|
-- (OSSTask *)presignPublicURLWithBucketName:(NSString *)bucketName
|
|
|
- withObjectKey:(NSString *)objectKey
|
|
|
- withParameters:(NSDictionary *)parameters {
|
|
|
-
|
|
|
- return [[OSSTask taskWithResult:nil] continueWithBlock:^id(OSSTask *task) {
|
|
|
- NSURL * endpointURL = [NSURL URLWithString:self.endpoint];
|
|
|
- NSString * host = endpointURL.host;
|
|
|
- if ([OSSUtil isOssOriginBucketHost:host]) {
|
|
|
- host = [NSString stringWithFormat:@"%@.%@", bucketName, host];
|
|
|
- }
|
|
|
- if ([parameters count] > 0) {
|
|
|
- NSString * stringURL = [NSString stringWithFormat:@"%@://%@/%@?%@",
|
|
|
- endpointURL.scheme,
|
|
|
- host,
|
|
|
- [OSSUtil encodeURL:objectKey],
|
|
|
- [OSSUtil populateQueryStringFromParameter:parameters]];
|
|
|
- return [OSSTask taskWithResult:stringURL];
|
|
|
- } else {
|
|
|
- NSString * stringURL = [NSString stringWithFormat:@"%@://%@/%@",
|
|
|
- endpointURL.scheme,
|
|
|
- host,
|
|
|
- [OSSUtil encodeURL:objectKey]];
|
|
|
- return [OSSTask taskWithResult:stringURL];
|
|
|
- }
|
|
|
- }];
|
|
|
-}
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@implementation OSSClient (Utilities)
|
|
|
-
|
|
|
-- (BOOL)doesObjectExistInBucket:(NSString *)bucketName
|
|
|
- objectKey:(NSString *)objectKey
|
|
|
- error:(const NSError **)error {
|
|
|
-
|
|
|
- OSSHeadObjectRequest * headRequest = [OSSHeadObjectRequest new];
|
|
|
- headRequest.bucketName = bucketName;
|
|
|
- headRequest.objectKey = objectKey;
|
|
|
- OSSTask * headTask = [self headObject:headRequest];
|
|
|
- [headTask waitUntilFinished];
|
|
|
- NSError *headError = headTask.error;
|
|
|
- if (!headError) {
|
|
|
- return YES;
|
|
|
- } else {
|
|
|
- if ([headError.domain isEqualToString: OSSServerErrorDomain] && labs(headError.code) == 404) {
|
|
|
- return NO;
|
|
|
- } else {
|
|
|
- if (error != nil) {
|
|
|
- *error = headError;
|
|
|
- }
|
|
|
- return NO;
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@implementation OSSClient (ImageService)
|
|
|
-
|
|
|
-- (OSSTask *)imageActionPersist:(OSSImagePersistRequest *)request
|
|
|
-{
|
|
|
- if (![request.fromBucket oss_isNotEmpty]
|
|
|
- || ![request.fromObject oss_isNotEmpty]
|
|
|
- || ![request.toBucket oss_isNotEmpty]
|
|
|
- || ![request.toObject oss_isNotEmpty]
|
|
|
- || ![request.action oss_isNotEmpty]) {
|
|
|
- NSError *error = [NSError errorWithDomain:OSSTaskErrorDomain
|
|
|
- code:OSSClientErrorCodeInvalidArgument
|
|
|
- userInfo:@{OSSErrorMessageTOKEN: @"imagePersist parameters not be empty!"}];
|
|
|
- return [OSSTask taskWithError:error];
|
|
|
- }
|
|
|
-
|
|
|
- OSSNetworkingRequestDelegate *requestDelegate = request.requestDelegate;
|
|
|
- NSMutableDictionary *params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:@"" forKey:OSSHttpQueryProcess];
|
|
|
-
|
|
|
- requestDelegate.uploadingData = [OSSUtil constructHttpBodyForImagePersist:request.action toBucket:request.toBucket toObjectKey:request.toObject];
|
|
|
-
|
|
|
- OSSHttpResponseParser *responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeImagePersist];
|
|
|
- requestDelegate.responseParser = responseParser;
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPOST;
|
|
|
- neededMsg.bucketName = request.fromBucket;
|
|
|
- neededMsg.objectKey = request.fromObject;
|
|
|
- neededMsg.params = params;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeImagePersist;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-@end
|
|
|
-
|
|
|
-@implementation OSSClient (Callback)
|
|
|
-
|
|
|
-- (OSSTask *)triggerCallBack:(OSSCallBackRequest *)request
|
|
|
-{
|
|
|
- OSSNetworkingRequestDelegate *requestDelegate = request.requestDelegate;
|
|
|
- NSMutableDictionary *params = [NSMutableDictionary dictionary];
|
|
|
- [params oss_setObject:@"" forKey:OSSHttpQueryProcess];
|
|
|
- NSString *paramString = [request.callbackParam base64JsonString];
|
|
|
- NSString *variblesString = [request.callbackVar base64JsonString];
|
|
|
- requestDelegate.uploadingData = [OSSUtil constructHttpBodyForTriggerCallback:paramString callbackVaribles:variblesString];
|
|
|
- NSString *md5String = [OSSUtil base64Md5ForData:requestDelegate.uploadingData];
|
|
|
-
|
|
|
- OSSHttpResponseParser *responseParser = [[OSSHttpResponseParser alloc] initForOperationType:OSSOperationTypeTriggerCallBack];
|
|
|
- requestDelegate.responseParser = responseParser;
|
|
|
-
|
|
|
- OSSAllRequestNeededMessage *neededMsg = [[OSSAllRequestNeededMessage alloc] init];
|
|
|
- neededMsg.endpoint = self.endpoint;
|
|
|
- neededMsg.httpMethod = OSSHTTPMethodPOST;
|
|
|
- neededMsg.bucketName = request.bucketName;
|
|
|
- neededMsg.objectKey = request.objectName;
|
|
|
- neededMsg.contentMd5 = md5String;
|
|
|
- neededMsg.params = params;
|
|
|
- requestDelegate.allNeededMessage = neededMsg;
|
|
|
-
|
|
|
- requestDelegate.operType = OSSOperationTypeTriggerCallBack;
|
|
|
-
|
|
|
- return [self invokeRequest:requestDelegate requireAuthentication:request.isAuthenticationRequired];
|
|
|
-}
|
|
|
-
|
|
|
-@end
|