[react-packager][streamline oss] Move open sourced JS source to react-native-github

ReactKit/Modules/RCTDataManager.m

@@ -0,0 +1,73 @@
+// Copyright 2004-present Facebook. All Rights Reserved.
+
+#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;
+        }
+        NSString *returnData = [[NSString alloc] initWithData:data encoding:encoding];
+        responseJSON = @{@"status": @200, @"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 {
+    
+    RCTLogMustFix(@"unsupported query type %@", queryType);
+    return;
+  }
+}
+
+@end