react-native/Libraries/Network/RCTDataManager.m

/**
 * 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