feat(async-storage): legacy ios codegen

Author: krizzu

packages/async-storage/apple/AsyncStorage.mm

@@ -1,5 +1,6 @@
 #import "AsyncStorage.h"
 #import "AsyncStorage-Swift.h"
+#import "RNCAsyncStorage.h" // legacy storage
 
 @implementation AsyncStorage
 RCT_EXPORT_MODULE(RNAsyncStorage)
@@ -41,24 +42,106 @@ - (void)getKeys:(nonnull NSString *)dbName resolve:(nonnull RCTPromiseResolveBlo
 
 
 - (void)legacy_multiGet:(nonnull NSArray *)keys resolve:(nonnull RCTPromiseResolveBlock)resolve reject:(nonnull RCTPromiseRejectBlock)reject {
-    resolve(nil);
-
+    RNCAsyncStorage *legacy = [RNCAsyncStorage sharedInstance];
+
+
+    dispatch_async([legacy methodQueue], ^{
+        NSError *error = nil;
+        NSDictionary<NSString *, NSString *> *result = [legacy multiGet:keys error:&error];
+        if (error) {
+            dispatch_async(dispatch_get_main_queue(), ^{
+                reject(@"AsyncStorageError", @"Failed to get values for keys", error);
+            });
+            return;
+        }
+        
+        NSMutableArray *formatted = [NSMutableArray arrayWithCapacity:keys.count];
+        for (NSString *key in keys) {
+            id value = result[key];
+            if (value == [NSNull null] || value == nil) {
+                value = (id)kCFNull;
+            }
+            [formatted addObject:@[key, value]];
+        }
+        
+        dispatch_async(dispatch_get_main_queue(), ^{
+            resolve(formatted);
+        });
+        
+    });
 }
 
 - (void)legacy_multiSet:(nonnull NSArray *)kvPairs resolve:(nonnull RCTPromiseResolveBlock)resolve reject:(nonnull RCTPromiseRejectBlock)reject {
-    resolve(nil);
+    RNCAsyncStorage *legacy = [RNCAsyncStorage sharedInstance];
+
+    dispatch_async([legacy methodQueue], ^{
+        NSError *error = nil;
+        BOOL success = [legacy multiSet:kvPairs error:&error];
+        
+        if (!success) {
+            dispatch_async(dispatch_get_main_queue(), ^{
+                reject(@"AsyncStorageError", @"Failed to set key-value pairs", error);
+            });
+            return;
+        }
+        
+        dispatch_async(dispatch_get_main_queue(), ^{
+            resolve(nil);
+        }); 
+    });
 }
 
 - (void)legacy_multiRemove:(nonnull NSArray *)keys resolve:(nonnull RCTPromiseResolveBlock)resolve reject:(nonnull RCTPromiseRejectBlock)reject {
-    resolve(nil);
+    RNCAsyncStorage *legacy = [RNCAsyncStorage sharedInstance];
+
+    dispatch_async([legacy methodQueue], ^{
+        NSError *error = nil;
+        BOOL success = [legacy multiRemove:keys error:&error];
+
+        
+        dispatch_async(dispatch_get_main_queue(), ^{
+            if (!success) {
+                reject(@"AsyncStorageError", @"Failed to remove keys", error);
+            } else {
+                resolve(nil);
+            }
+        });
+    });
 }
 
-- (void)legacy_getAllKeys:(nonnull RCTPromiseResolveBlock)resolve reject:(nonnull RCTPromiseRejectBlock)reject { 
-    resolve(nil);
+- (void)legacy_getAllKeys:(nonnull RCTPromiseResolveBlock)resolve reject:(nonnull RCTPromiseRejectBlock)reject {
+    RNCAsyncStorage *legacy = [RNCAsyncStorage sharedInstance];
+    
+    dispatch_async([legacy methodQueue], ^{
+        NSError *error = nil;
+        NSArray<NSString *> *keys = [legacy getAllKeys:&error];
+        
+        dispatch_async(dispatch_get_main_queue(), ^{
+            if (!keys) {
+                reject(@"AsyncStorageError", @"Failed to get all keys", error);
+            } else {
+                resolve(keys);
+            }
+        });
+    });
 }
 
 - (void)legacy_clear:(nonnull RCTPromiseResolveBlock)resolve reject:(nonnull RCTPromiseRejectBlock)reject {
-    resolve(nil);
+    
+    RNCAsyncStorage *legacy = [RNCAsyncStorage sharedInstance];
+    
+    dispatch_async([legacy methodQueue], ^{
+        NSError *error = nil;
+        BOOL success = [legacy clear:&error];
+        
+        dispatch_async(dispatch_get_main_queue(), ^{
+            if (!success) {
+                reject(@"AsyncStorageError", @"Failed to clear storage", error);
+            } else {
+                resolve(nil);
+            }
+        });
+    });
 }
 
 - (void)legacy_multiMerge:(nonnull NSArray *)kvPairs resolve:(nonnull RCTPromiseResolveBlock)resolve reject:(nonnull RCTPromiseRejectBlock)reject { 

packages/async-storage/apple/legacy_storage/RNCAsyncStorage.h

@@ -0,0 +1,58 @@
+/**
+ * Copyright (c) Facebook, Inc. and its affiliates.
+ *
+ * This source code is licensed under the MIT license found in the
+ * LICENSE file in the root directory of this source tree.
+ */
+
+#import <Foundation/Foundation.h>
+
+#import <React/RCTBridgeModule.h>
+#import <React/RCTInvalidating.h>
+
+/**
+ * A simple, asynchronous, persistent, key-value storage system designed as a
+ * backend to the AsyncStorage JS module, which is modeled after LocalStorage.
+ *
+ * Current implementation stores small values in serialized dictionary and
+ * larger values in separate files. Since we use a serial file queue
+ * `RKFileQueue`, reading/writing from multiple threads should be perceived as
+ * being atomic, unless someone bypasses the `RNCAsyncStorage` API.
+ *
+ * Keys and values must always be strings or an error is returned.
+ */
+
+NS_ASSUME_NONNULL_BEGIN
+
+@interface RNCAsyncStorage : NSObject<RCTInvalidating>
+
+@property (nonatomic, assign) BOOL clearOnInvalidate;
+
+@property (nonatomic, readonly, getter=isValid) BOOL valid;
+
++ (instancetype)sharedInstance;
+
+- (dispatch_queue_t)methodQueue;
+
+// Clear the RNCAsyncStorage data from native code
+- (void)clearAllData;
+
+// For clearing data when the bridge may not exist, e.g. when logging out.
++ (void)clearAllData;
+
+- (nullable NSDictionary<NSString *, NSString *> *)multiGet:(NSArray<NSString *> *)keys
+                                                      error:(NSError **)error;
+
+- (BOOL)multiSet:(NSArray<NSArray<NSString *> *> *)kvPairs
+           error:(NSError **)error;
+
+- (BOOL)multiRemove:(NSArray<NSString *> *)keys
+              error:(NSError **)error;
+
+- (nullable NSArray<NSString *> *)getAllKeys:(NSError **)error;
+
+- (BOOL)clear:(NSError **)error;
+
+@end
+
+NS_ASSUME_NONNULL_END