v10.0.0-beta.0

.eslintrc

@@ -1,29 +1,4 @@
 {
-  "extends": "eslint-config-airbnb/base",
+  "root": true,
-  "parser": "babel-eslint",
+  "extends": "@react-native"
-  "env": {
-    "browser": true,
-    "node": true,
-    "mocha": true
-  },
-  "rules": {
-    // Disable for console/alert
-    "no-console": 0,
-    "no-alert": 0,
-
-    "indent": [2, 2, {"SwitchCase": 1}]
-  },
-  "plugins": [
-    "import"
-  ],
-  "settings": {
-    "import/parser": "babel-eslint",
-    "import/resolve": {
-      "moduleDirectory": ["node_modules", "src"]
-    }
-  },
-  "globals": {
-    "__DEV__": true,
-    "__OPTION__": true
-  }
 }

Example/testHotUpdate/babel.config.js

@@ -1,3 +1,8 @@
 module.exports = {
   presets: ['module:metro-react-native-babel-preset'],
+  env: {
+    production: {
+      plugins: ['react-native-paper/babel'],
+    },
+  },
 };

Example/testHotUpdate/package.json

@@ -16,7 +16,10 @@
     "postinstall-postinstall": "^2.1.0",
     "react": "18.0.0",
     "react-native": "0.69.8",
-    "react-native-update": "link:../.."
+    "react-native-paper": "^5.12.1",
+    "react-native-safe-area-context": "^4.8.2",
+    "react-native-update": "link:../..",
+    "react-native-vector-icons": "^10.0.3"
   },
   "devDependencies": {
     "@babel/core": "^7.21.0",

Example/testHotUpdate/src/index.js

@@ -1,188 +1,119 @@
-import React, {Component} from 'react';
+import React, {useState} from 'react';
 import {
   StyleSheet,
   Platform,
   Text,
   View,
-  Alert,
   TouchableOpacity,
-  Linking,
   Image,
+  Switch,
 } from 'react-native';
-
+import {Icon, PaperProvider, Snackbar, Banner} from 'react-native-paper';
-import {
-  isFirstTime,
-  isRolledBack,
-  packageVersion,
-  currentVersion,
-  checkUpdate,
-  downloadUpdate,
-  switchVersion,
-  switchVersionLater,
-  markSuccess,
-  downloadAndInstallApk,
-  cInfo,
-} from 'react-native-update';
 
 import TestConsole from './TestConsole';
 
 import _updateConfig from '../update.json';
+import {PushyProvider, Pushy, usePushy} from 'react-native-update';
 const {appKey} = _updateConfig[Platform.OS];
-export default class App extends Component {
+
-  state = {
+function App() {
-    received: 0,
+  const {
-    total: 0,
+    client,
-    showTestConsole: false,
+    checkUpdate,
-  };
+    downloadUpdate,
-  componentDidMount() {
+    switchVersionLater,
-    if (isRolledBack) {
+    switchVersion,
-      Alert.alert('提示', '刚刚更新失败了,版本被回滚.');
+    updateInfo,
-    } else if (isFirstTime) {
+    progress: {received, total} = {},
-      Alert.alert(
+  } = usePushy();
-        '提示',
+  const [useDefaultAlert, setUseDefaultAlert] = useState(true);
-        '这是当前版本第一次启动,是否要模拟启动失败?将回滚到上一版本',
+  const [showUpdateBanner, setShowUpdateBanner] = useState(false);
-        [
+  const [showUpdateSnackbar, setShowUpdateSnackbar] = useState(false);
-          {
+  const snackbarVisible =
-            text: '是',
+    showUpdateSnackbar &&
-            onPress: () => {
+    updateInfo &&
-              throw new Error('模拟启动失败,请重启应用');
+    updateInfo.updateAvailable &&
-            },
+    !useDefaultAlert;
-          },
+  return (
-          {
+    <View style={styles.container}>
-            text: '否',
+      <Text style={styles.welcome}>欢迎使用Pushy热更新服务</Text>
-            onPress: () => {
+      <Switch
-              markSuccess();
+        value={useCustomUi}
-            },
+        onValueChange={v => {
-          },
+          setUseDefaultAlert(v);
-        ],
+          client.setOptions({
-      );
+            showAlert: v,
-    }
-  }
-  doUpdate = async info => {
-    try {
-      const hash = await downloadUpdate(info, {
-        onDownloadProgress: ({received, total}) => {
-          this.setState({
-            received,
-            total,
           });
-        },
+        }}>
-      });
+        {useDefaultAlert ? '当前使用' : '当前不使用'}默认的alert更新提示
-      if (!hash) {
+      </Switch>
-        return;
+      <Image
-      }
+        resizeMode={'contain'}
-      Alert.alert('提示', '下载完毕,是否重启应用?', [
+        source={require('./assets/shezhi.png')}
-        {
+        style={styles.image}
-          text: '是',
+      />
-          onPress: () => {
+      <Text style={styles.instructions}>
-            switchVersion(hash);
+        这是版本一 {'\n'}
-          },
+        当前原生包版本号: {packageVersion}
-        },
+        {'\n'}
-        {text: '否'},
+        当前热更新版本Hash: {currentVersion || '(空)'}
-        {
+        {'\n'}
-          text: '下次启动时',
+      </Text>
-          onPress: () => {
+      <Text>
-            switchVersionLater(hash);
+        下载进度：{received} / {total}
-          },
+      </Text>
-        },
+      <TouchableOpacity onPress={checkUpdate}>
-      ]);
+        <Text style={styles.instructions}>点击这里检查更新</Text>
-    } catch (err) {
+      </TouchableOpacity>
-      Alert.alert('更新失败', err.message);
-    }
-  };
 
-  checkUpdate = async () => {
+      <TouchableOpacity
-    let info;
+        testID="testcase"
-    try {
+        style={{marginTop: 15}}
-      info = await checkUpdate(appKey);
+        onLongPress={() => {
-    } catch (err) {
+          this.setState({showTestConsole: true});
-      Alert.alert('更新检查失败', err.message);
+        }}>
-      return;
+        <Text style={styles.instructions}>
-    }
+          react-native-update版本：{client.version}
-    if (info.expired) {
+        </Text>
-      Alert.alert('提示', '您的应用版本已更新，点击确定下载安装新版本', [
+      </TouchableOpacity>
-        {
+      <TestConsole visible={showTestConsole} />
-          text: '确定',
+      <Snackbar
-          onPress: () => {
+        visible={snackbarVisible}
-            if (info.downloadUrl) {
+        onDismiss={() => {
-              // apk可直接下载安装
+          setShowUpdateSnackbar(false);
-              if (
+        }}
-                Platform.OS === 'android' &&
+        action={{
-                info.downloadUrl.endsWith('.apk')
+          label: '更新',
-              ) {
+          onPress: async () => {
-                downloadAndInstallApk({
+            setShowUpdateSnackbar(false);
-                  url: info.downloadUrl,
+            await downloadUpdate();
-                  onDownloadProgress: ({received, total}) => {
+            setShowUpdateBanner(true);
-                    this.setState({
-                      received,
-                      total,
-                    });
-                  },
-                });
-              } else {
-                Linking.openURL(info.downloadUrl);
-              }
-            }
           },
-        },
+        }}>
-      ]);
+        有新版本({updateInfo.version})可用，是否更新？
-    } else if (info.upToDate) {
+      </Snackbar>
-      Alert.alert('提示', '您的应用版本已是最新.');
+      <Banner
-    } else {
+        visible={showUpdateBanner}
-      Alert.alert(
+        actions={[
-        '提示',
-        '检查到新的版本' + info.name + ',是否下载?\n' + info.description,
-        [
           {
-            text: '是',
+            label: '立即重启',
+            onPress: switchVersion,
+          },
+          {
+            label: '下次再说',
             onPress: () => {
-              this.doUpdate(info);
+              switchVersionLater();
+              setShowUpdateBanner(false);
             },
           },
-          {text: '否'},
+        ]}
-        ],
+        icon={({size}) => (
-      );
+          <Icon name="checkcircleo" size={size} color="#00f" />
-    }
+        )}>
-  };
+        更新已完成，是否立即重启？
-
+      </Banner>
-  render() {
+    </View>
-    const {received, total, showTestConsole} = this.state;
+  );
-    return (
-      <View style={styles.container}>
-        <Text style={styles.welcome}>欢迎使用热更新服务</Text>
-        <Image
-          resizeMode={'contain'}
-          source={require('./assets/shezhi.png')}
-          style={styles.image}
-        />
-        <Text style={styles.instructions}>
-          这是版本一 {'\n'}
-          当前原生包版本号: {packageVersion}
-          {'\n'}
-          当前热更新版本Hash: {currentVersion || '(空)'}
-          {'\n'}
-        </Text>
-        <Text>
-          下载进度：{received} / {total}
-        </Text>
-        <TouchableOpacity onPress={this.checkUpdate}>
-          <Text style={styles.instructions}>点击这里检查更新</Text>
-        </TouchableOpacity>
-
-        <TouchableOpacity
-          testID="testcase"
-          style={{marginTop: 15}}
-          onLongPress={() => {
-            this.setState({showTestConsole: true});
-          }}>
-          <Text style={styles.instructions}>
-            react-native-update版本：{cInfo.pushy}
-          </Text>
-        </TouchableOpacity>
-        <TestConsole visible={showTestConsole} />
-      </View>
-    );
-  }
 }
 
 const styles = StyleSheet.create({
@@ -204,3 +135,18 @@ const styles = StyleSheet.create({
   },
   image: {},
 });
+
+const pushyClient = new Pushy({
+  appKey,
+  showAlert: false,
+});
+
+export default function Root() {
+  return (
+    <PushyProvider client={pushyClient}>
+      <PaperProvider>
+        <App />
+      </PaperProvider>
+    </PushyProvider>
+  );
+}

ios/RCTPushy/RCTPushy.mm

@@ -349,7 +349,8 @@ RCT_EXPORT_METHOD(reloadUpdate:(NSDictionary *)options
     }
 }
 
-RCT_EXPORT_METHOD(markSuccess:(RCTPromiseResolveBlock)resolve
+RCT_EXPORT_METHOD(markSuccess:
+                  resolver:(RCTPromiseResolveBlock)resolve
                                     rejecter:(RCTPromiseRejectBlock)reject)
 {
     

lib/endpoint.ts

@@ -1,60 +0,0 @@
-import { logger, promiseAny } from './utils';
-
-let currentEndpoint = 'https://update.react-native.cn/api';
-let backupEndpoints: string[] = [
-  'https://pushy-koa-qgbgqmcpis.cn-beijing.fcapp.run',
-  'https://update.reactnative.cn/api',
-];
-let backupEndpointsQueryUrls = [
-  'https://gitee.com/sunnylqm/react-native-pushy/raw/master/endpoints.json',
-  'https://cdn.jsdelivr.net/gh/reactnativecn/react-native-pushy@master/endpoints.json',
-];
-
-export async function updateBackupEndpoints() {
-  if (backupEndpointsQueryUrls) {
-    try {
-      const resp = await promiseAny(
-        backupEndpointsQueryUrls.map(queryUrl => fetch(queryUrl)),
-      );
-      const remoteEndpoints = await resp.json();
-      if (Array.isArray(remoteEndpoints)) {
-        backupEndpoints = Array.from(
-          new Set([...backupEndpoints, ...remoteEndpoints]),
-        );
-        logger('fetch remote endpoints:', remoteEndpoints);
-        logger('merged backup endpoints:', backupEndpoints);
-      }
-    } catch (e) {
-      logger('fetch remote endpoints failed');
-    }
-  }
-  return backupEndpoints;
-}
-
-export function getCheckUrl(APPKEY, endpoint = currentEndpoint) {
-  return `${endpoint}/checkUpdate/${APPKEY}`;
-}
-
-/**
- * @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,
-  backupQueryUrls,
-}: {
-  main: string;
-  backups?: string[];
-  backupQueryUrls?: string[];
-}) {
-  currentEndpoint = main;
-  if (Array.isArray(backups) && backups.length > 0) {
-    backupEndpoints = backups;
-  }
-  if (Array.isArray(backupQueryUrls) && backupQueryUrls.length > 0) {
-    backupEndpointsQueryUrls = backupQueryUrls;
-  }
-}

lib/index.ts

@@ -1,2 +0,0 @@
-export * from './main';
-export * from './simpleUpdate';

lib/index.web.js

@@ -1,18 +0,0 @@
-export const downloadRootDir = '';
-export const packageVersion = '';
-export const currentVersion = '';
-export const isFirstTime = false;
-export const isRolledBack = false;
-
-const noop = () => {};
-
-export const checkUpdate = noop;
-export const downloadUpdate = noop;
-export const switchVersion = noop;
-export const switchVersionLater = noop;
-export const markSuccess = noop;
-export const downloadAndInstallApk = noop;
-export const setCustomEndpoints = noop;
-export const getCurrentVersionInfo = noop;
-export const simpleUpdate = (app) => app;
-export const onPushyEvents = noop;

lib/main.ts

@@ -1,403 +0,0 @@
-import {
-  updateBackupEndpoints,
-  getCheckUrl,
-  setCustomEndpoints,
-} from './endpoint';
-import {
-  NativeEventEmitter,
-  NativeModules,
-  Platform,
-  PermissionsAndroid,
-} from 'react-native';
-import {
-  CheckResult,
-  EventType,
-  ProgressData,
-  UpdateAvailableResult,
-  UpdateEventsListener,
-} from './type';
-import { assertRelease, logger, promiseAny, testUrls } from './utils';
-export { setCustomEndpoints };
-const {
-  version: v,
-} = require('react-native/Libraries/Core/ReactNativeVersion');
-const RNVersion = `${v.major}.${v.minor}.${v.patch}`;
-const isTurboModuleEnabled = global.__turboModuleProxy != null;
-
-export const PushyModule = isTurboModuleEnabled
-  ? require('./NativeUpdate').default
-  : NativeModules.Pushy;
-
-if (!PushyModule) {
-  throw new Error('react-native-update模块无法加载，请对照安装文档检查配置。');
-}
-const PushyConstants = isTurboModuleEnabled
-  ? PushyModule.getConstants()
-  : PushyModule;
-
-export const downloadRootDir = PushyConstants.downloadRootDir;
-export const packageVersion = PushyConstants.packageVersion;
-export const currentVersion = PushyConstants.currentVersion;
-export const isFirstTime = PushyConstants.isFirstTime;
-const rolledBackVersion = PushyConstants.rolledBackVersion;
-export const isRolledBack = typeof rolledBackVersion === 'string';
-
-export const buildTime = PushyConstants.buildTime;
-let blockUpdate = PushyConstants.blockUpdate;
-let uuid = PushyConstants.uuid;
-
-if (Platform.OS === 'android' && !PushyConstants.isUsingBundleUrl) {
-  throw new Error(
-    'react-native-update模块无法加载，请对照文档检查Bundle URL的配置',
-  );
-}
-
-function setLocalHashInfo(hash: string, info: Record<string, any>) {
-  PushyModule.setLocalHashInfo(hash, JSON.stringify(info));
-}
-
-async function getLocalHashInfo(hash: string) {
-  return JSON.parse(await PushyModule.getLocalHashInfo(hash));
-}
-
-export async function getCurrentVersionInfo(): Promise<{
-  name?: string;
-  description?: string;
-  metaInfo?: string;
-}> {
-  return currentVersion ? (await getLocalHashInfo(currentVersion)) || {} : {};
-}
-
-const eventEmitter = new NativeEventEmitter(PushyModule);
-
-if (!uuid) {
-  uuid = require('nanoid/non-secure').nanoid();
-  PushyModule.setUuid(uuid);
-}
-
-const noop = () => {};
-let reporter: UpdateEventsListener = noop;
-
-export function onPushyEvents(customReporter: UpdateEventsListener) {
-  reporter = customReporter;
-  if (isRolledBack) {
-    report({
-      type: 'rollback',
-      data: {
-        rolledBackVersion,
-      },
-    });
-  }
-}
-
-function report({
-  type,
-  message = '',
-  data = {},
-}: {
-  type: EventType;
-  message?: string;
-  data?: Record<string, string | number>;
-}) {
-  logger(type + ' ' + message);
-  reporter({
-    type,
-    data: {
-      currentVersion,
-      cInfo,
-      packageVersion,
-      buildTime,
-      message,
-      ...data,
-    },
-  });
-}
-
-logger('uuid: ' + uuid);
-
-export const cInfo = {
-  pushy: require('../package.json').version,
-  rn: RNVersion,
-  os: Platform.OS + ' ' + Platform.Version,
-  uuid,
-};
-
-let lastChecking;
-const empty = {};
-let lastResult: CheckResult;
-export async function checkUpdate(APPKEY: string) {
-  assertRelease();
-  const now = Date.now();
-  if (lastResult && lastChecking && now - lastChecking < 1000 * 60) {
-    // logger('repeated checking, ignored');
-    return lastResult;
-  }
-  lastChecking = now;
-  if (blockUpdate && blockUpdate.until > Date.now() / 1000) {
-    report({
-      type: 'errorChecking',
-      message: `热更新已暂停，原因：${blockUpdate.reason}。请在"${new Date(
-        blockUpdate.until * 1000,
-      ).toLocaleString()}"之后重试。`,
-    });
-    return lastResult || empty;
-  }
-  report({ type: 'checking' });
-  const fetchPayload = {
-    method: 'POST',
-    headers: {
-      Accept: 'application/json',
-      'Content-Type': 'application/json',
-    },
-    body: JSON.stringify({
-      packageVersion,
-      hash: currentVersion,
-      buildTime,
-      cInfo,
-    }),
-  };
-  let resp;
-  try {
-    resp = await fetch(getCheckUrl(APPKEY), fetchPayload);
-  } catch (e) {
-    report({
-      type: 'errorChecking',
-      message: '无法连接主更新服务器，尝试备用节点',
-    });
-    const backupEndpoints = await updateBackupEndpoints();
-    if (backupEndpoints) {
-      try {
-        resp = await promiseAny(
-          backupEndpoints.map(endpoint =>
-            fetch(getCheckUrl(APPKEY, endpoint), fetchPayload),
-          ),
-        );
-      } catch {}
-    }
-  }
-  if (!resp) {
-    report({
-      type: 'errorChecking',
-      message: '无法连接更新服务器，请检查网络连接后重试',
-    });
-    return lastResult || empty;
-  }
-  const result: CheckResult = await resp.json();
-
-  lastResult = result;
-  // @ts-ignore
-  checkOperation(result.op);
-
-  if (resp.status !== 200) {
-    report({
-      type: 'errorChecking',
-      //@ts-ignore
-      message: result.message,
-    });
-  }
-
-  return result;
-}
-
-function checkOperation(
-  op: { type: string; reason: string; duration: number }[],
-) {
-  if (!Array.isArray(op)) {
-    return;
-  }
-  op.forEach(action => {
-    if (action.type === 'block') {
-      blockUpdate = {
-        reason: action.reason,
-        until: Math.round((Date.now() + action.duration) / 1000),
-      };
-      PushyModule.setBlockUpdate(blockUpdate);
-    }
-  });
-}
-
-let downloadingThrottling = false;
-let downloadedHash: string;
-export async function downloadUpdate(
-  options: UpdateAvailableResult,
-  eventListeners?: {
-    onDownloadProgress?: (data: ProgressData) => void;
-  },
-) {
-  assertRelease();
-  if (!options.update) {
-    return;
-  }
-  if (rolledBackVersion === options.hash) {
-    logger(`rolledback hash ${rolledBackVersion}, ignored`);
-    return;
-  }
-  if (downloadedHash === options.hash) {
-    logger(`duplicated downloaded hash ${downloadedHash}, ignored`);
-    return downloadedHash;
-  }
-  if (downloadingThrottling) {
-    logger('repeated downloading, ignored');
-    return;
-  }
-  downloadingThrottling = true;
-  setTimeout(() => {
-    downloadingThrottling = false;
-  }, 3000);
-  let progressHandler;
-  if (eventListeners) {
-    if (eventListeners.onDownloadProgress) {
-      const downloadCallback = eventListeners.onDownloadProgress;
-      progressHandler = eventEmitter.addListener(
-        'RCTPushyDownloadProgress',
-        progressData => {
-          if (progressData.hash === options.hash) {
-            downloadCallback(progressData);
-          }
-        },
-      );
-    }
-  }
-  let succeeded = false;
-  report({ type: 'downloading' });
-  const diffUrl = (await testUrls(options.diffUrls)) || options.diffUrl;
-  if (diffUrl) {
-    logger('downloading diff');
-    try {
-      await PushyModule.downloadPatchFromPpk({
-        updateUrl: diffUrl,
-        hash: options.hash,
-        originHash: currentVersion,
-      });
-      succeeded = true;
-    } catch (e) {
-      logger(`diff error: ${e.message}, try pdiff`);
-    }
-  }
-  if (!succeeded) {
-    const pdiffUrl = (await testUrls(options.pdiffUrls)) || options.pdiffUrl;
-    if (pdiffUrl) {
-      logger('downloading pdiff');
-      try {
-        await PushyModule.downloadPatchFromPackage({
-          updateUrl: pdiffUrl,
-          hash: options.hash,
-        });
-        succeeded = true;
-      } catch (e) {
-        logger(`pdiff error: ${e.message}, try full patch`);
-      }
-    }
-  }
-  if (!succeeded) {
-    const updateUrl = (await testUrls(options.updateUrls)) || options.updateUrl;
-    if (updateUrl) {
-      logger('downloading full patch');
-      try {
-        await PushyModule.downloadFullUpdate({
-          updateUrl: updateUrl,
-          hash: options.hash,
-        });
-        succeeded = true;
-      } catch (e) {
-        logger(`full patch error: ${e.message}`);
-      }
-    }
-  }
-  progressHandler && progressHandler.remove();
-  if (!succeeded) {
-    return report({ type: 'errorUpdate', data: { newVersion: options.hash } });
-  }
-  setLocalHashInfo(options.hash, {
-    name: options.name,
-    description: options.description,
-    metaInfo: options.metaInfo,
-  });
-  downloadedHash = options.hash;
-  return options.hash;
-}
-
-function assertHash(hash: string) {
-  if (!downloadedHash) {
-    logger(`no downloaded hash`);
-    return;
-  }
-  if (hash !== downloadedHash) {
-    logger(`use downloaded hash ${downloadedHash} first`);
-    return;
-  }
-  return true;
-}
-
-export function switchVersion(hash: string) {
-  assertRelease();
-  if (assertHash(hash)) {
-    logger('switchVersion: ' + hash);
-    PushyModule.reloadUpdate({ hash });
-  }
-}
-
-export function switchVersionLater(hash: string) {
-  assertRelease();
-  if (assertHash(hash)) {
-    logger('switchVersionLater: ' + hash);
-    PushyModule.setNeedUpdate({ hash });
-  }
-}
-
-let marked = false;
-export function markSuccess() {
-  assertRelease();
-  if (marked) {
-    logger('repeated markSuccess, ignored');
-    return;
-  }
-  marked = true;
-  PushyModule.markSuccess();
-  report({ type: 'markSuccess' });
-}
-
-export async function downloadAndInstallApk({
-  url,
-  onDownloadProgress,
-}: {
-  url: string;
-  onDownloadProgress?: (data: ProgressData) => void;
-}) {
-  if (Platform.OS !== 'android') {
-    return;
-  }
-  report({ type: 'downloadingApk' });
-  if (Platform.Version <= 23) {
-    try {
-      const granted = await PermissionsAndroid.request(
-        PermissionsAndroid.PERMISSIONS.WRITE_EXTERNAL_STORAGE,
-      );
-      if (granted !== PermissionsAndroid.RESULTS.GRANTED) {
-        return report({ type: 'rejectStoragePermission' });
-      }
-    } catch (err) {
-      return report({ type: 'errorStoragePermission' });
-    }
-  }
-  let hash = Date.now().toString();
-  let progressHandler;
-  if (onDownloadProgress) {
-    progressHandler = eventEmitter.addListener(
-      'RCTPushyDownloadProgress',
-      (progressData: ProgressData) => {
-        if (progressData.hash === hash) {
-          onDownloadProgress(progressData);
-        }
-      },
-    );
-  }
-  await PushyModule.downloadAndInstallApk({
-    url,
-    target: 'update.apk',
-    hash,
-  }).catch(() => {
-    report({ type: 'errowDownloadAndInstallApk' });
-  });
-  progressHandler && progressHandler.remove();
-}

lib/simpleUpdate.tsx

@@ -1,135 +0,0 @@
-import React, { PureComponent, ComponentType } from 'react';
-import {
-  Platform,
-  Alert,
-  Linking,
-  AppState,
-  NativeEventSubscription,
-} from 'react-native';
-
-import {
-  isFirstTime,
-  isRolledBack,
-  checkUpdate,
-  downloadUpdate,
-  switchVersion,
-  switchVersionLater,
-  markSuccess,
-  downloadAndInstallApk,
-  onPushyEvents,
-} from './main';
-import { UpdateEventsListener } from './type';
-
-export function simpleUpdate(
-  WrappedComponent: ComponentType,
-  options: { appKey?: string; onPushyEvents?: UpdateEventsListener } = {},
-) {
-  const { appKey, onPushyEvents: eventListeners } = options;
-  if (!appKey) {
-    throw new Error('appKey is required for simpleUpdate()');
-  }
-  if (typeof eventListeners === 'function') {
-    onPushyEvents(eventListeners);
-  }
-  return __DEV__
-    ? WrappedComponent
-    : class AppUpdate extends PureComponent {
-        stateListener: NativeEventSubscription;
-        componentDidMount() {
-          if (isRolledBack) {
-            Alert.alert('抱歉', '刚刚更新遭遇错误，已为您恢复到更新前版本');
-          } else if (isFirstTime) {
-            markSuccess();
-          }
-          this.stateListener = AppState.addEventListener(
-            'change',
-            (nextAppState) => {
-              if (nextAppState === 'active') {
-                this.checkUpdate();
-              }
-            },
-          );
-          this.checkUpdate();
-        }
-        componentWillUnmount() {
-          this.stateListener && this.stateListener.remove();
-        }
-        doUpdate = async (info) => {
-          try {
-            const hash = await downloadUpdate(info);
-            if (!hash) {
-              return;
-            }
-            this.stateListener && this.stateListener.remove();
-            Alert.alert('提示', '下载完毕，是否立即更新?', [
-              {
-                text: '以后再说',
-                style: 'cancel',
-                onPress: () => {
-                  switchVersionLater(hash);
-                },
-              },
-              {
-                text: '立即更新',
-                style: 'default',
-                onPress: () => {
-                  switchVersion(hash);
-                },
-              },
-            ]);
-          } catch (err) {
-            Alert.alert('更新失败', err.message);
-          }
-        };
-
-        checkUpdate = async () => {
-          let info;
-          try {
-            info = await checkUpdate(appKey!);
-          } catch (err) {
-            Alert.alert('更新检查失败', err.message);
-            return;
-          }
-          if (info.expired) {
-            Alert.alert('提示', '您的应用版本已更新，点击确定下载安装新版本', [
-              {
-                text: '确定',
-                onPress: () => {
-                  if (info.downloadUrl) {
-                    if (
-                      Platform.OS === 'android' &&
-                      info.downloadUrl.endsWith('.apk')
-                    ) {
-                      downloadAndInstallApk({
-                        url: info.downloadUrl,
-                      });
-                    } else {
-                      Linking.openURL(info.downloadUrl);
-                    }
-                  }
-                },
-              },
-            ]);
-          } else if (info.update) {
-            Alert.alert(
-              '提示',
-              '检查到新的版本' + info.name + ',是否下载?\n' + info.description,
-              [
-                { text: '否', style: 'cancel' },
-                {
-                  text: '是',
-                  style: 'default',
-                  onPress: () => {
-                    this.doUpdate(info);
-                  },
-                },
-              ],
-            );
-          }
-        };
-
-        render() {
-          return <WrappedComponent {...this.props} />;
-        }
-      };
-}

lib/utils.ts

@@ -1,46 +0,0 @@
-import { Platform } from 'react-native';
-
-export function logger(...args: any[]) {
-  console.log('Pushy: ', ...args);
-}
-
-export function promiseAny<T>(promises: Promise<T>[]) {
-  return new Promise<T>((resolve, reject) => {
-    let count = 0;
-
-    promises.forEach(promise => {
-      Promise.resolve(promise)
-        .then(resolve)
-        .catch(() => {
-          count++;
-          if (count === promises.length) {
-            reject(new Error('All promises were rejected'));
-          }
-        });
-    });
-  });
-}
-
-export function assertRelease() {
-  if (__DEV__) {
-    throw new Error('react-native-update 只能在 RELEASE 版本中运行.');
-  }
-}
-
-const ping =
-  Platform.OS === 'web'
-    ? Promise.resolve
-    : async (url: string) =>
-        Promise.race([
-          fetch(url, {
-            method: 'HEAD',
-          }).then(({ status }) => (status === 200 ? url : null)),
-          new Promise(r => setTimeout(() => r(null), 2000)),
-        ]);
-
-export const testUrls = async (urls?: string[]) => {
-  if (!urls?.length) {
-    return null;
-  }
-  return promiseAny(urls.map(ping)).catch(() => null);
-};

package.json

@@ -1,8 +1,8 @@
 {
   "name": "react-native-update",
-  "version": "9.2.2",
+  "version": "10.0.0-beta.0",
   "description": "react-native hot update",
-  "main": "lib/index.ts",
+  "main": "src/index.ts",
   "scripts": {
     "prepublish": "yarn submodule",
     "submodule": "git submodule update --init --recursive",
@@ -39,6 +39,7 @@
     "url": "https://github.com/reactnativecn/react-native-pushy/issues"
   },
   "peerDependencies": {
+    "react": ">=16.8.0",
     "react-native": ">=0.57.0"
   },
   "homepage": "https://github.com/reactnativecn/react-native-pushy#readme",
@@ -55,18 +56,21 @@
     ]
   },
   "devDependencies": {
+    "@react-native/eslint-config": "^0.73.2",
     "@types/fs-extra": "^9.0.13",
     "@types/jest": "^29.2.1",
     "@types/node": "^20.8.9",
-    "@types/react": "^18.2.33",
+    "@types/react": "^18.2.46",
     "detox": "^20.5.0",
+    "eslint": "^8.56.0",
     "firebase-tools": "^11.24.1",
     "fs-extra": "^9.1.0",
     "jest": "^29.2.1",
     "pod-install": "^0.1.37",
-    "react-native": "^0.72.6",
+    "prettier": "^2",
+    "react": "18.2.0",
+    "react-native": "0.73",
     "ts-jest": "^29.0.3",
-    "typescript": "^5.2.2"
+    "typescript": "^5.3.3"
-  },
+  }
-  "packageManager": "yarn@1.22.21+sha1.1959a18351b811cdeedbd484a8f86c3cc3bbaf72"
 }

react-native-update.podspec

@@ -1,5 +1,7 @@
 require 'json'
 
+new_arch_enabled = ENV['RCT_NEW_ARCH_ENABLED'] == '1'
+
 package = JSON.parse(File.read(File.join(__dir__, 'package.json')))
 
 Pod::Spec.new do |s|
@@ -40,5 +42,25 @@ Pod::Spec.new do |s|
                        'android/jni/lzma/C/Lzma2Dec.{h,c}']
     ss.private_header_files = 'ios/RCTPushy/HDiffPatch/**/*.h'
   end
-  install_modules_dependencies(s)
+  
+  if defined?(install_modules_dependencies()) != nil
+    install_modules_dependencies(s);
+  else
+    if new_arch_enabled
+      folly_compiler_flags = '-DFOLLY_NO_CONFIG -DFOLLY_MOBILE=1 -DFOLLY_USE_LIBCPP=1 -Wno-comma -Wno-shorten-64-to-32'
+
+      s.compiler_flags = folly_compiler_flags + " -DRCT_NEW_ARCH_ENABLED=1"
+
+      s.pod_target_xcconfig = {
+          "HEADER_SEARCH_PATHS" => "\"$(PODS_ROOT)/boost\"",
+          "CLANG_CXX_LANGUAGE_STANDARD" => "c++17"
+      }
+
+      s.dependency "React-Codegen"
+      s.dependency "RCT-Folly"
+      s.dependency "RCTRequired"
+      s.dependency "RCTTypeSafety"
+      s.dependency "ReactCommon/turbomodule/core"
+    end
+  end
 end

src/client.tsx

@@ -0,0 +1,316 @@
+import { CheckResult, PushyOptions, ProgressData } from './type';
+import { assertRelease, log } from './utils';
+import {
+  EmitterSubscription,
+  PermissionsAndroid,
+  Platform,
+} from 'react-native';
+import {
+  PushyModule,
+  buildTime,
+  cInfo,
+  pushyNativeEventEmitter,
+  currentVersion,
+  packageVersion,
+  report,
+  rolledBackVersion,
+  setLocalHashInfo,
+} from './core';
+
+const defaultServer = {
+  main: 'https://update.react-native.cn/api',
+  backups: ['https://update.reactnative.cn/api'],
+  queryUrl:
+    'https://raw.githubusercontent.com/reactnativecn/react-native-pushy/master/endpoints.json',
+};
+
+const empty = {};
+export class Pushy {
+  options: PushyOptions = {
+    appKey: '',
+    server: defaultServer,
+    autoMarkSuccess: true,
+    useAlert: true,
+  };
+
+  lastChecking: number;
+  lastResult: CheckResult;
+
+  progressHandlers: Record<string, EmitterSubscription> = {};
+  downloadedHash: string;
+
+  marked = false;
+  applyingUpdate = false;
+  version = cInfo.pushy;
+
+  constructor(options: PushyOptions) {
+    if (!options.appKey) {
+      throw new Error('appKey is required');
+    }
+    this.setOptions(options);
+  }
+
+  setOptions = (options: Partial<PushyOptions>) => {
+    for (const [key, value] of Object.entries(options)) {
+      if (value !== undefined) {
+        this.options[key] = value;
+      }
+    }
+  };
+
+  getCheckUrl = (endpoint: string = this.options.server!.main) => {
+    return `${endpoint}/checkUpdate/${this.options.appKey}`;
+  };
+  assertHash = (hash: string) => {
+    if (!this.downloadedHash) {
+      return;
+    }
+    if (hash !== this.downloadedHash) {
+      log(`use downloaded hash ${this.downloadedHash} first`);
+      return;
+    }
+    return true;
+  };
+  markSuccess = () => {
+    assertRelease();
+    if (this.marked) {
+      return;
+    }
+    this.marked = true;
+    PushyModule.markSuccess();
+    report({ type: 'markSuccess' });
+  };
+  switchVersion = (hash: string) => {
+    assertRelease();
+    if (this.assertHash(hash) && !this.applyingUpdate) {
+      log('switchVersion: ' + hash);
+      this.applyingUpdate = true;
+      PushyModule.reloadUpdate({ hash });
+    }
+  };
+
+  switchVersionLater = (hash: string) => {
+    assertRelease();
+    if (this.assertHash(hash)) {
+      log('switchVersionLater: ' + hash);
+      PushyModule.setNeedUpdate({ hash });
+    }
+  };
+  checkUpdate = async () => {
+    assertRelease();
+    const now = Date.now();
+    if (
+      this.lastResult &&
+      this.lastChecking &&
+      now - this.lastChecking < 1000 * 5
+    ) {
+      return this.lastResult;
+    }
+    this.lastChecking = now;
+    report({ type: 'checking' });
+    const fetchPayload = {
+      method: 'POST',
+      headers: {
+        Accept: 'application/json',
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify({
+        packageVersion,
+        hash: currentVersion,
+        buildTime,
+        cInfo,
+      }),
+    };
+    let resp;
+    try {
+      resp = await fetch(this.getCheckUrl(), fetchPayload);
+    } catch (e) {
+      report({
+        type: 'errorChecking',
+        message: 'Can not connect to update server. Trying backup endpoints.',
+      });
+      const backupEndpoints = await this.getBackupEndpoints();
+      if (backupEndpoints) {
+        try {
+          resp = await Promise.race(
+            backupEndpoints.map((endpoint) =>
+              fetch(this.getCheckUrl(endpoint), fetchPayload),
+            ),
+          );
+        } catch {}
+      }
+    }
+    if (!resp) {
+      report({
+        type: 'errorChecking',
+        message: 'Can not connect to update server. Please check your network.',
+      });
+      return this.lastResult || empty;
+    }
+    const result: CheckResult = await resp.json();
+
+    this.lastResult = result;
+
+    if (resp.status !== 200) {
+      report({
+        type: 'errorChecking',
+        //@ts-ignore
+        message: result.message,
+      });
+    }
+
+    return result;
+  };
+  getBackupEndpoints = async () => {
+    const { server } = this.options;
+    if (!server) {
+      return [];
+    }
+    if (server.queryUrl) {
+      try {
+        const resp = await fetch(server.queryUrl);
+        const remoteEndpoints = await resp.json();
+        log('fetch endpoints:', remoteEndpoints);
+        if (Array.isArray(remoteEndpoints)) {
+          server.backups = Array.from(
+            new Set([...(server.backups || []), ...remoteEndpoints]),
+          );
+        }
+      } catch (e) {
+        log('failed to fetch endpoints from: ', server.queryUrl);
+      }
+    }
+    return server.backups;
+  };
+  downloadUpdate = async (
+    info: CheckResult,
+    onDownloadProgress?: (data: ProgressData) => void,
+  ) => {
+    assertRelease();
+    if (!('update' in info)) {
+      return;
+    }
+    const { hash, diffUrl, pdiffUrl, updateUrl, name, description, metaInfo } =
+      info;
+    if (rolledBackVersion === hash) {
+      log(`rolledback hash ${rolledBackVersion}, ignored`);
+      return;
+    }
+    if (this.downloadedHash === hash) {
+      log(`duplicated downloaded hash ${this.downloadedHash}, ignored`);
+      return this.downloadedHash;
+    }
+    if (this.progressHandlers[hash]) {
+      return;
+    }
+    if (onDownloadProgress) {
+      this.progressHandlers[hash] = pushyNativeEventEmitter.addListener(
+        'RCTPushyDownloadProgress',
+        (progressData) => {
+          if (progressData.hash === hash) {
+            onDownloadProgress(progressData);
+          }
+        },
+      );
+    }
+    let succeeded = false;
+    report({ type: 'downloading' });
+    if (diffUrl) {
+      log('downloading diff');
+      try {
+        await PushyModule.downloadPatchFromPpk({
+          updateUrl: diffUrl,
+          hash,
+          originHash: currentVersion,
+        });
+        succeeded = true;
+      } catch (e) {
+        log(`diff error: ${e.message}, try pdiff`);
+      }
+    }
+    if (!succeeded && pdiffUrl) {
+      log('downloading pdiff');
+      try {
+        await PushyModule.downloadPatchFromPackage({
+          updateUrl: pdiffUrl,
+          hash,
+        });
+        succeeded = true;
+      } catch (e) {
+        log(`pdiff error: ${e.message}, try full patch`);
+      }
+    }
+    if (!succeeded && updateUrl) {
+      log('downloading full patch');
+      try {
+        await PushyModule.downloadFullUpdate({
+          updateUrl: updateUrl,
+          hash,
+        });
+        succeeded = true;
+      } catch (e) {
+        log(`full patch error: ${e.message}`);
+      }
+    }
+    if (this.progressHandlers[hash]) {
+      this.progressHandlers[hash].remove();
+      delete this.progressHandlers[hash];
+    }
+    if (!succeeded) {
+      return report({
+        type: 'errorUpdate',
+        data: { newVersion: hash },
+      });
+    }
+    setLocalHashInfo(hash, {
+      name,
+      description,
+      metaInfo,
+    });
+    this.downloadedHash = hash;
+    return hash;
+  };
+  downloadAndInstallApk = async (
+    url: string,
+    onDownloadProgress?: (data: ProgressData) => void,
+  ) => {
+    if (Platform.OS !== 'android') {
+      return;
+    }
+    report({ type: 'downloadingApk' });
+    if (Platform.Version <= 23) {
+      try {
+        const granted = await PermissionsAndroid.request(
+          PermissionsAndroid.PERMISSIONS.WRITE_EXTERNAL_STORAGE,
+        );
+        if (granted !== PermissionsAndroid.RESULTS.GRANTED) {
+          return report({ type: 'rejectStoragePermission' });
+        }
+      } catch (err) {
+        return report({ type: 'errorStoragePermission' });
+      }
+    }
+    const progressKey = 'downloadingApk';
+    if (onDownloadProgress) {
+      this.progressHandlers[progressKey] = pushyNativeEventEmitter.addListener(
+        'RCTPushyDownloadProgress',
+        (progressData: ProgressData) => {
+          if (progressData.hash === progressKey) {
+            onDownloadProgress(progressData);
+          }
+        },
+      );
+    }
+    await PushyModule.downloadAndInstallApk({
+      url,
+      target: 'update.apk',
+      hash: progressKey,
+    }).catch(() => {
+      report({ type: 'errowDownloadAndInstallApk' });
+    });
+    if (this.progressHandlers[progressKey]) {
+      this.progressHandlers[progressKey].remove();
+      delete this.progressHandlers[progressKey];
+    }
+  };
+}

src/context.ts

@@ -0,0 +1,30 @@
+import { createContext, useContext } from 'react';
+import { CheckResult, ProgressData } from './type';
+import { Pushy } from './client';
+
+const empty = {};
+const noop = () => {};
+
+export const defaultContext = {
+  checkUpdate: () => Promise.resolve(empty),
+  switchVersion: noop,
+  switchVersionLater: noop,
+  markSuccess: noop,
+  dismissError: noop,
+  downloadUpdate: noop,
+};
+
+export const PushyContext = createContext<{
+  checkUpdate: () => void;
+  switchVersion: () => void;
+  switchVersionLater: () => void;
+  progress?: ProgressData;
+  markSuccess: () => void;
+  updateInfo?: CheckResult;
+  lastError?: Error;
+  dismissError: () => void;
+  client?: Pushy;
+  downloadUpdate: () => void;
+}>(defaultContext);
+
+export const usePushy = () => useContext(PushyContext);

src/core.ts

@@ -0,0 +1,106 @@
+import { NativeEventEmitter, NativeModules, Platform } from 'react-native';
+import { EventType, UpdateEventsLogger } from './type';
+import { log } from './utils';
+const {
+  version: v,
+} = require('react-native/Libraries/Core/ReactNativeVersion');
+const RNVersion = `${v.major}.${v.minor}.${v.patch}`;
+const isTurboModuleEnabled = global.__turboModuleProxy != null;
+
+export const PushyModule = isTurboModuleEnabled
+  ? require('./turboModuleSpec').default
+  : NativeModules.Pushy;
+
+if (!PushyModule) {
+  throw new Error('react-native-update模块无法加载，请对照安装文档检查配置。');
+}
+
+const PushyConstants = isTurboModuleEnabled
+  ? PushyModule.getConstants()
+  : PushyModule;
+
+export const downloadRootDir = PushyConstants.downloadRootDir;
+export const packageVersion = PushyConstants.packageVersion;
+export const currentVersion = PushyConstants.currentVersion;
+export const isFirstTime = PushyConstants.isFirstTime;
+export const rolledBackVersion = PushyConstants.rolledBackVersion;
+export const isRolledBack = typeof rolledBackVersion === 'string';
+
+export const buildTime = PushyConstants.buildTime;
+let uuid = PushyConstants.uuid;
+
+if (Platform.OS === 'android' && !PushyConstants.isUsingBundleUrl) {
+  throw new Error(
+    'react-native-update模块无法加载，请对照文档检查Bundle URL的配置',
+  );
+}
+
+export function setLocalHashInfo(hash: string, info: Record<string, any>) {
+  PushyModule.setLocalHashInfo(hash, JSON.stringify(info));
+}
+
+async function getLocalHashInfo(hash: string) {
+  return JSON.parse(await PushyModule.getLocalHashInfo(hash));
+}
+
+export async function getCurrentVersionInfo(): Promise<{
+  name?: string;
+  description?: string;
+  metaInfo?: string;
+}> {
+  return currentVersion ? (await getLocalHashInfo(currentVersion)) || {} : {};
+}
+
+export const pushyNativeEventEmitter = new NativeEventEmitter(PushyModule);
+
+if (!uuid) {
+  uuid = require('nanoid/non-secure').nanoid();
+  PushyModule.setUuid(uuid);
+}
+
+const noop = () => {};
+let reporter: UpdateEventsLogger = noop;
+
+export function onPushyEvents(customReporter: UpdateEventsLogger) {
+  reporter = customReporter;
+  if (isRolledBack) {
+    report({
+      type: 'rollback',
+      data: {
+        rolledBackVersion,
+      },
+    });
+  }
+}
+
+export function report({
+  type,
+  message = '',
+  data = {},
+}: {
+  type: EventType;
+  message?: string;
+  data?: Record<string, string | number>;
+}) {
+  log(type + ' ' + message);
+  reporter({
+    type,
+    data: {
+      currentVersion,
+      cInfo,
+      packageVersion,
+      buildTime,
+      message,
+      ...data,
+    },
+  });
+}
+
+log('uuid: ' + uuid);
+
+export const cInfo = {
+  pushy: require('../package.json').version,
+  rn: RNVersion,
+  os: Platform.OS + ' ' + Platform.Version,
+  uuid,
+};

src/index.ts

@@ -0,0 +1,3 @@
+export { Pushy } from './client';
+export { PushyContext, usePushy } from './context';
+export { PushyProvider } from './provider';

src/index.web.js

@@ -0,0 +1,17 @@
+import { Fragment } from 'react';
+
+const noop = () => {};
+export class Pushy {
+  constructor() {
+    console.warn('react-native-update is not supported and will do nothing on web.');
+    return new Proxy(this, {
+      get() {
+        return noop;
+      },
+    });
+  }
+}
+
+export { PushyContext, usePushy } from './context';
+
+export const PushyProvider = Fragment;

src/provider.tsx

@@ -0,0 +1,184 @@
+import React, {
+  ReactNode,
+  useCallback,
+  useEffect,
+  useRef,
+  useState,
+} from 'react';
+import {
+  Alert,
+  NativeEventSubscription,
+  AppState,
+  Platform,
+  Linking,
+} from 'react-native';
+import { Pushy } from './client';
+import { isFirstTime } from './core';
+import { CheckResult } from './type';
+import { PushyContext } from './context';
+
+export const PushyProvider = ({
+  client,
+  children,
+}: {
+  client: Pushy;
+  children: ReactNode;
+}) => {
+  const { strategy, useAlert } = client.options;
+  const stateListener = useRef<NativeEventSubscription>();
+  const [updateInfo, setUpdateInfo] = useState<CheckResult>();
+  const [lastError, setLastError] = useState<Error>();
+
+  const dismissError = useCallback(() => {
+    if (lastError) {
+      setLastError(undefined);
+    }
+  }, [lastError]);
+
+  const showAlert = useCallback(
+    (...args: Parameters<typeof Alert.alert>) => {
+      if (useAlert) {
+        Alert.alert(...args);
+      }
+    },
+    [useAlert],
+  );
+
+  const switchVersion = useCallback(() => {
+    if (updateInfo && 'hash' in updateInfo) {
+      client.switchVersion(updateInfo.hash);
+    }
+  }, [client, updateInfo]);
+
+  const switchVersionLater = useCallback(() => {
+    if (updateInfo && 'hash' in updateInfo) {
+      client.switchVersionLater(updateInfo.hash);
+    }
+  }, [client, updateInfo]);
+
+  const downloadUpdate = useCallback(async () => {
+    if (!updateInfo || !('update' in updateInfo)) {
+      return;
+    }
+    try {
+      const hash = await client.downloadUpdate(updateInfo);
+      if (!hash) {
+        return;
+      }
+      stateListener.current && stateListener.current.remove();
+      showAlert('提示', '下载完毕，是否立即更新?', [
+        {
+          text: '下次再说',
+          style: 'cancel',
+          onPress: () => {
+            client.switchVersionLater(hash);
+          },
+        },
+        {
+          text: '立即更新',
+          style: 'default',
+          onPress: () => {
+            client.switchVersion(hash);
+          },
+        },
+      ]);
+    } catch (err) {
+      setLastError(err);
+      showAlert('更新失败', err.message);
+    }
+  }, [client, showAlert, updateInfo]);
+
+  const checkUpdate = useCallback(async () => {
+    let info: CheckResult;
+    try {
+      info = await client.checkUpdate();
+    } catch (err) {
+      setLastError(err);
+      showAlert('更新检查失败', err.message);
+      return;
+    }
+    setUpdateInfo(info);
+    if ('expired' in info) {
+      const { downloadUrl } = info;
+      showAlert('提示', '您的应用版本已更新，点击更新下载安装新版本', [
+        {
+          text: '更新',
+          onPress: () => {
+            if (downloadUrl) {
+              if (Platform.OS === 'android' && downloadUrl.endsWith('.apk')) {
+                client.downloadAndInstallApk(downloadUrl);
+              } else {
+                Linking.openURL(downloadUrl);
+              }
+            }
+          },
+        },
+      ]);
+    } else if ('update' in info) {
+      showAlert(
+        '提示',
+        '检查到新的版本' + info.name + ',是否下载?\n' + info.description,
+        [
+          { text: '取消', style: 'cancel' },
+          {
+            text: '确定',
+            style: 'default',
+            onPress: () => {
+              downloadUpdate();
+            },
+          },
+        ],
+      );
+    }
+  }, [client, downloadUpdate, showAlert]);
+
+  const markSuccess = client.markSuccess;
+
+  useEffect(() => {
+    if (isFirstTime) {
+      markSuccess();
+    }
+    if (strategy === 'both' || strategy === 'onAppResume') {
+      stateListener.current = AppState.addEventListener(
+        'change',
+        (nextAppState) => {
+          if (nextAppState === 'active') {
+            checkUpdate();
+          }
+        },
+      );
+    }
+    if (strategy === 'both' || strategy === 'onAppStart') {
+      checkUpdate();
+    }
+    let dismissErrorTimer: ReturnType<typeof setTimeout>;
+    const { dismissErrorAfter } = client.options;
+    if (typeof dismissErrorAfter === 'number' && dismissErrorAfter > 0) {
+      dismissErrorTimer = setTimeout(() => {
+        dismissError();
+      }, dismissErrorAfter);
+    }
+    return () => {
+      stateListener.current && stateListener.current.remove();
+      clearTimeout(dismissErrorTimer);
+    };
+  }, [checkUpdate, client.options, dismissError, markSuccess, strategy]);
+
+  return (
+    <PushyContext.Provider
+      value={{
+        checkUpdate,
+        switchVersion,
+        switchVersionLater,
+        dismissError,
+        updateInfo,
+        lastError,
+        markSuccess,
+        client,
+        downloadUpdate,
+      }}
+    >
+      {children}
+    </PushyContext.Provider>
+  );
+};

src/turboModuleSpec.ts

@@ -9,14 +9,12 @@ export interface Spec extends TurboModule {
     isFirstTime: boolean;
     rolledBackVersion: string;
     buildTime: string;
-    blockUpdate: Object;
     uuid: string;
     isUsingBundleUrl: boolean;
   };
   setLocalHashInfo(hash: string, info: string): Promise<void>;
   getLocalHashInfo(hash: string): Promise<string>;
   setUuid(uuid: string): Promise<void>;
-  setBlockUpdate(options: { reason: string; until: number }): Promise<void>;
   reloadUpdate(options: { hash: string }): Promise<void>;
   setNeedUpdate(options: { hash: string }): Promise<void>;
   markSuccess(): Promise<void>;

src/type.ts

@@ -1,29 +1,23 @@
 export interface ExpiredResult {
-  upToDate?: false;
   expired: true;
   downloadUrl: string;
 }
 
 export interface UpTodateResult {
-  expired?: false;
   upToDate: true;
   paused?: 'app' | 'package';
 }
 
 export interface UpdateAvailableResult {
-  expired?: false;
+  upToDate: false;
-  upToDate?: false;
   update: true;
   name: string; // version name
   hash: string;
   description: string;
   metaInfo: string;
   pdiffUrl: string;
-  pdiffUrls?: string[];
   diffUrl?: string;
-  diffUrls?: string[];
   updateUrl?: string;
-  updateUrls?: string[];
 }
 
 export type CheckResult =
@@ -65,10 +59,25 @@ export interface EventData {
   newVersion?: string;
   [key: string]: any;
 }
-export type UpdateEventsListener = ({
+export type UpdateEventsLogger = ({
   type,
   data,
 }: {
   type: EventType;
   data: EventData;
 }) => void;
+
+export interface PushyServerConfig {
+  main: string;
+  backups?: string[];
+  queryUrl?: string;
+}
+export interface PushyOptions {
+  appKey: string;
+  server?: PushyServerConfig;
+  logger?: UpdateEventsLogger;
+  useAlert?: boolean;
+  strategy?: 'onAppStart' | 'onAppResume' | 'both';
+  autoMarkSuccess?: boolean;
+  dismissErrorAfter?: number;
+}

src/utils.ts

@@ -0,0 +1,9 @@
+export function log(...args: any[]) {
+  console.log('pushy: ', ...args);
+}
+
+export function assertRelease() {
+  if (__DEV__) {
+    throw new Error('react-native-update 只能在 RELEASE 版本中运行.');
+  }
+}