v5.7.0-beta1

Example/testHotUpdate/src/index.js

@@ -8,6 +8,7 @@ import {
   TouchableOpacity,
   Linking,
   Image,
+  NativeModules,
 } from 'react-native';
 
 import {
@@ -70,6 +71,12 @@ export default class App extends Component {
   };
 
   checkUpdate = async () => {
+    return await this.doUpdate({
+      update: true,
+      pdiffUrl: 'http://localhost:8888/1.pdiff',
+      hash: 'test',
+    });
+
     let info;
     try {
       info = await checkUpdate(appKey);
@@ -108,17 +115,17 @@ export default class App extends Component {
   render() {
     return (
       <View style={styles.container}>
-        <Text style={styles.welcome}>欢迎使用热更新服务</Text>
+        <Text style={styles.welcome}>443欢迎使用热更新服务</Text>
         <Image
           resizeMode={'contain'}
-          source={require('./assets/shoucang.png')}
+          source={require('./assets/shezhi.png')}
           style={styles.image}
         />
         <Text style={styles.instructions}>
           这是版本一 {'\n'}
-          当前包版本号: {packageVersion}
+          当前原生包版本号: {packageVersion}
           {'\n'}
-          当前版本Hash: {currentVersion || '(空)'}
+          当前热更新版本Hash: {currentVersion || '(空)'}
           {'\n'}
         </Text>
         <TouchableOpacity onPress={this.checkUpdate}>

endpoints.json

@@ -0,0 +1 @@
+["https://update.react-native.cn/api", "https://update.reactnative.cn/api"]

ios/RCTPushy/RCTPushy.m

@@ -93,10 +93,10 @@ RCT_EXPORT_MODULE(RCTPushy);
             BOOL isFirstTime = [pushyInfo[paramIsFirstTime] boolValue];
             BOOL isFirstLoadOK = [pushyInfo[paramIsFirstLoadOk] boolValue];
             
-            NSString *loadVersioin = curVersion;
-            BOOL needRollback = (!ignoreRollback && isFirstTime == NO && isFirstLoadOK == NO) || loadVersioin.length<=0;
+            NSString *loadVersion = curVersion;
+            BOOL needRollback = (!ignoreRollback && isFirstTime == NO && isFirstLoadOK == NO) || loadVersion.length<=0;
             if (needRollback) {
-                loadVersioin = lastVersion;
+                loadVersion = lastVersion;
                 
                 if (lastVersion.length) {
                     // roll back to last version
@@ -125,10 +125,10 @@ RCT_EXPORT_MODULE(RCTPushy);
                 [defaults synchronize];
             }
             
-            if (loadVersioin.length) {
+            if (loadVersion.length) {
                 NSString *downloadDir = [RCTPushy downloadDir];
                 
-                NSString *bundlePath = [[downloadDir stringByAppendingPathComponent:loadVersioin] stringByAppendingPathComponent:BUNDLE_FILE_NAME];
+                NSString *bundlePath = [[downloadDir stringByAppendingPathComponent:loadVersion] stringByAppendingPathComponent:BUNDLE_FILE_NAME];
                 if ([[NSFileManager defaultManager] fileExistsAtPath:bundlePath isDirectory:NULL]) {
                     NSURL *bundleURL = [NSURL fileURLWithPath:bundlePath];
                     return bundleURL;
@@ -302,7 +302,7 @@ RCT_EXPORT_METHOD(markSuccess)
         callback([self errorWithMessage:ERROR_FILE_OPERATION]);
         return;
     }
-    
+
     NSString *zipFilePath = [dir stringByAppendingPathComponent:[NSString stringWithFormat:@"%@%@",hashName, [self zipExtension:type]]];
     NSString *unzipDir = [dir stringByAppendingPathComponent:hashName];
 

ios/RCTPushy/RCTPushyManager.m

@@ -24,6 +24,21 @@
     return self;
 }
 
+
+- (BOOL)addSkipBackupAttributeToItemAtPath:(NSString *) filePathString
+{
+    NSURL* URL= [NSURL fileURLWithPath: filePathString];
+    assert([[NSFileManager defaultManager] fileExistsAtPath: [URL path]]);
+ 
+    NSError *error = nil;
+    BOOL success = [URL setResourceValue: [NSNumber numberWithBool: YES]
+                                  forKey: NSURLIsExcludedFromBackupKey error: &error];
+    if(!success){
+        NSLog(@"Error excluding %@ from backup %@", [URL lastPathComponent], error);
+    }
+    return success;
+}
+
 - (BOOL)createDir:(NSString *)dir
 {
     __block BOOL success = false;
@@ -48,7 +63,7 @@
             return;
         }
     });
-    
+    [self addSkipBackupAttributeToItemAtPath:dir];
     return success;
 }
 

lib/endpoint.js

@@ -0,0 +1,89 @@
+let currentEndpoint = 'https://update.reactnative.cn/api';
+
+function ping(url, rejectImmediate) {
+  return new Promise((resolve, reject) => {
+    const xhr = new XMLHttpRequest();
+    xhr.onreadystatechange = (e) => {
+      if (xhr.readyState !== 4) {
+        return;
+      }
+      if (xhr.status === 200) {
+        resolve(url);
+      } else {
+        rejectImmediate ? reject() : setTimeout(reject, 5000);
+      }
+    };
+    xhr.open('HEAD', url);
+    xhr.send();
+    xhr.timeout = 5000;
+    xhr.ontimeout = reject;
+  });
+}
+
+function logger(...args) {
+  // console.warn('pushy', ...args);
+}
+
+let backupEndpoints = [];
+let backupEndpointsQueryUrl =
+  'https://cdn.jsdelivr.net/gh/reactnativecn/react-native-pushy@master/endpoints.json';
+
+export async function tryBackupEndpoints() {
+  if (!backupEndpoints.length && !backupEndpointsQueryUrl) {
+    return;
+  }
+  try {
+    await ping(getStatusUrl(), true);
+    logger('current endpoint ok');
+    return;
+  } catch (e) {
+    logger('current endpoint failed');
+  }
+  if (!backupEndpoints.length && backupEndpointsQueryUrl) {
+    try {
+      const resp = await fetch(backupEndpointsQueryUrl);
+      backupEndpoints = await resp.json();
+      logger('get remote endpoints:', backupEndpoints);
+    } catch (e) {
+      logger('get remote endpoints failed');
+      return;
+    }
+  }
+  await pickFatestAvailableEndpoint();
+}
+
+async function pickFatestAvailableEndpoint(endpoints = backupEndpoints) {
+  const fastestEndpoint = await Promise.race(
+    endpoints.map(pingAndReturnEndpoint),
+  );
+  if (typeof fastestEndpoint === 'string') {
+    logger(`pick endpoint: ${fastestEndpoint}`);
+    currentEndpoint = fastestEndpoint;
+  } else {
+    logger('all remote endpoints failed');
+  }
+}
+
+async function pingAndReturnEndpoint(endpoint = currentEndpoint) {
+  return ping(getStatusUrl(endpoint)).then(() => endpoint);
+}
+
+function getStatusUrl(endpoint = currentEndpoint) {
+  return `${endpoint}/status`;
+}
+
+export function getCheckUrl(APPKEY, endpoint = currentEndpoint) {
+  return `${endpoint}/checkUpdate/${APPKEY}`;
+}
+
+export function setCustomEndpoints({ main, backups, backupQueryUrl }) {
+  currentEndpoint = main;
+  backupEndpointsQueryUrl = null;
+  if (Array.isArray(backups) && backups.length > 0) {
+    backupEndpoints = backups;
+    pickFatestAvailableEndpoint();
+  }
+  if (typeof backupQueryUrl === 'string') {
+    backupEndpointsQueryUrl = backupQueryUrl;
+  }
+}

lib/getHost.js

@@ -1,57 +0,0 @@
-let availableDomain = 'update.react-native.cn';
-
-function ping(domain, rejectImmediate) {
-  return new Promise((resolve, reject) => {
-    const xhr = new XMLHttpRequest();
-    xhr.onreadystatechange = e => {
-      if (xhr.readyState !== 4) {
-        return;
-      }
-      if (xhr.status === 200) {
-        resolve(domain);
-      } else {
-        rejectImmediate ? reject() : setTimeout(reject, 5000);
-      }
-    };
-    xhr.open('HEAD', `https://${domain}`);
-    xhr.send();
-    xhr.timeout = 5000;
-    xhr.ontimeout = reject;
-  });
-}
-
-function logger(...args) {
-  // console.warn('pushy', ...args);
-}
-
-export async function tryBackupDomains() {
-  try {
-    await ping(availableDomain, true);
-    logger('main domain ok');
-    return;
-  } catch (e) {
-    logger('main domain failed');
-  }
-  let backupDomains = [];
-  try {
-    const resp = await fetch(
-      'https://cdn.jsdelivr.net/gh/reactnativecn/react-native-pushy@master/domains.json',
-    );
-    backupDomains = await resp.json();
-    logger('get remote domains:', backupDomains);
-  } catch (e) {
-    logger('get remote domains failed');
-    return;
-  }
-  const fastestDomain = await Promise.race(backupDomains.map(ping));
-  if (typeof fastestDomain === 'string') {
-    logger(`pick domain: ${fastestDomain}`);
-    availableDomain = fastestDomain;
-  } else {
-    logger('all remote domains failed');
-  }
-}
-
-export default function getHost() {
-  return `https://${availableDomain}/api`;
-}

lib/index.d.ts

@@ -20,17 +20,38 @@ export interface UpdateAvailableResult {
   description: string;
   metaInfo: string;
   pdiffUrl: string;
-  diffUrl: string;
+  diffUrl?: string;
 }
 
-export type CheckResult = Partial<ExpiredResult & UpTodateResult & UpdateAvailableResult>;
+export type CheckResult =
+  | ExpiredResult
+  | UpTodateResult
+  | UpdateAvailableResult;
 
 export function checkUpdate(appkey: string): Promise<CheckResult>;
 
-export function downloadUpdate(options: UpdateAvailableResult): Promise<undefined | string>;
+export function downloadUpdate(
+  options: UpdateAvailableResult,
+): Promise<undefined | string>;
 
 export function switchVersion(hash: string): void;
 
 export function switchVersionLater(hash: string): void;
 
 export function markSuccess(): void;
+
+/**
+ * @param {string} main - The main api endpoint
+ * @param {string[]} [backups] - The back up endpoints.
+ * @param {string} [backupQueryUrl] - An url that return a json file containing an array of endpoint.
+ *                                    like: ["https://backup.api/1", "https://backup.api/2"]
+ */
+export function setCustomEndpoints({
+  main,
+  backups,
+  backupQueryUrl,
+}: {
+  main: string;
+  backUps?: string[];
+  backupQueryUrl?: string;
+}): void;

lib/index.js

@@ -1,5 +1,6 @@
-import getHost, { tryBackupDomains } from './getHost';
+import { tryBackupEndpoints, getCheckUrl, setCustomEndpoints } from './endpoint';
 import { NativeAppEventEmitter, NativeModules } from 'react-native';
+export { setCustomEndpoints };
 
 let Pushy = NativeModules.Pushy;
 
@@ -47,7 +48,7 @@ export async function checkUpdate(APPKEY, isRetry) {
   assertRelease();
   let resp;
   try {
-    resp = await fetch(`${getHost()}/checkUpdate/${APPKEY}`, {
+    resp = await fetch(getCheckUrl(APPKEY), {
       method: 'POST',
       headers: {
         Accept: 'application/json',
@@ -63,7 +64,7 @@ export async function checkUpdate(APPKEY, isRetry) {
     if (isRetry) {
       throw new Error('Could not connect to pushy server');
     }
-    await tryBackupDomains();
+    await tryBackupEndpoints(APPKEY);
     return checkUpdate(APPKEY, true);
   }
 
@@ -91,11 +92,6 @@ export async function downloadUpdate(options) {
       updateUrl: options.pdiffUrl,
       hashName: options.hash,
     });
-  } else {
-    await Pushy.downloadUpdate({
-      updateUrl: options.updateUrl,
-      hashName: options.hash,
-    });
   }
   return options.hash;
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "react-native-update",
-  "version": "5.6.0",
+  "version": "5.7.0-beta1",
   "description": "react-native hot update",
   "main": "lib/index.js",
   "scripts": {