81 lines
2.6 KiB
Objective-C
81 lines
2.6 KiB
Objective-C
/**
|
|
* Copyright (c) 2015-present, Facebook, Inc.
|
|
* All rights reserved.
|
|
*
|
|
* This source code is licensed under the BSD-style license found in the
|
|
* LICENSE file in the root directory of this source tree. An additional grant
|
|
* of patent rights can be found in the PATENTS file in the same directory.
|
|
*/
|
|
|
|
#import "RCTDataManager.h"
|
|
|
|
#import "RCTAssert.h"
|
|
#import "RCTLog.h"
|
|
#import "RCTUtils.h"
|
|
|
|
@implementation RCTDataManager
|
|
|
|
/**
|
|
* Executes a network request.
|
|
* The responseSender block won't be called on same thread as called.
|
|
*/
|
|
- (void)executeQuery:(NSString *)queryType
|
|
query:(id)query
|
|
queryHash:(__unused NSString *)queryHash
|
|
responseSender:(RCTResponseSenderBlock)responseSender
|
|
{
|
|
RCT_EXPORT(queryData);
|
|
|
|
if ([queryType isEqualToString:@"http"]) {
|
|
|
|
// Parse query
|
|
NSDictionary *queryDict = query;
|
|
if ([query isKindOfClass:[NSString class]]) {
|
|
// TODO: it would be more efficient just to send a dictionary
|
|
queryDict = RCTJSONParse(query, NULL);
|
|
}
|
|
|
|
// Build request
|
|
NSURL *url = [NSURL URLWithString:queryDict[@"url"]];
|
|
NSMutableURLRequest *request = [NSMutableURLRequest requestWithURL:url];
|
|
request.HTTPMethod = queryDict[@"method"] ?: @"GET";
|
|
request.allHTTPHeaderFields = queryDict[@"headers"];
|
|
if ([queryDict[@"data"] isKindOfClass:[NSString class]]) {
|
|
request.HTTPBody = [queryDict[@"data"] dataUsingEncoding:NSUTF8StringEncoding];
|
|
}
|
|
|
|
// Build data task
|
|
NSURLSessionDataTask *task = [[NSURLSession sharedSession] dataTaskWithRequest:request completionHandler:^(NSData *data, NSURLResponse *response, NSError *connectionError) {
|
|
|
|
// Build response
|
|
NSDictionary *responseJSON;
|
|
if (connectionError == nil) {
|
|
NSStringEncoding encoding;
|
|
if (response.textEncodingName) {
|
|
CFStringEncoding cfEncoding = CFStringConvertIANACharSetNameToEncoding((CFStringRef)response.textEncodingName);
|
|
encoding = CFStringConvertEncodingToNSStringEncoding(cfEncoding);
|
|
} else {
|
|
encoding = NSUTF8StringEncoding;
|
|
}
|
|
int responseCode = (int)[((NSHTTPURLResponse *)response) statusCode];
|
|
NSString *returnData = [[NSString alloc] initWithData:data encoding:encoding];
|
|
responseJSON = @{@"status": @(responseCode), @"responseText": returnData};
|
|
} else {
|
|
responseJSON = @{@"status": @0, @"responseText": [connectionError localizedDescription]};
|
|
}
|
|
|
|
// Send response (won't be sent on same thread as caller)
|
|
responseSender(@[RCTJSONStringify(responseJSON, NULL)]);
|
|
|
|
}];
|
|
|
|
[task resume];
|
|
|
|
} else {
|
|
|
|
RCTLogError(@"unsupported query type %@", queryType);
|
|
}
|
|
}
|
|
|
|
@end
|