bump version to 10.29.9

* modify harmony download logic to async

* fix harmony image assets load fail issue

Example/harmony_use_pushy/harmony/build-profile.json5

@@ -36,10 +36,6 @@
           ]
         }
       ]
-    },
-    {
-      name: 'pushy',
-      srcPath: '../node_modules/react-native-update/harmony',
     }
   ]
 }

Example/harmony_use_pushy/harmony/entry/oh-package.json5

@@ -7,7 +7,7 @@
   "license": "",
   "dependencies": {
     "@rnoh/react-native-openharmony": "0.72.38",
-    "pushy": "file:../../node_modules/react-native-update/harmony"
+    "pushy": "file:../../node_modules/react-native-update/harmony/pushy.har",
   }
 }
 

Example/harmony_use_pushy/package.json

@@ -18,7 +18,7 @@
     "@react-native-oh/react-native-harmony": "^0.72.59",
     "react": "18.2.0",
     "react-native": "0.72.5",
-    "react-native-update": "^10.26.4"
+    "react-native-update": "latest"
   },
   "devDependencies": {
     "@babel/core": "^7.20.0",

Example/testHotUpdate/.gitignore

@@ -62,3 +62,7 @@ buck-out/
 # Ruby / CocoaPods
 /ios/Pods/
 /vendor/bundle/
+
+# react-native-update
+.update
+.pushy

Example/testHotUpdate/android/gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.12-all.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME

Example/testHotUpdate/ios/AwesomeProject/AppDelegate.mm

@@ -2,12 +2,14 @@
 #import "RCTPushy.h"
 
 #import <React/RCTBundleURLProvider.h>
+#import <ReactAppDependencyProvider/RCTAppDependencyProvider.h>
 
 @implementation AppDelegate
 
 - (BOOL)application:(UIApplication *)application didFinishLaunchingWithOptions:(NSDictionary *)launchOptions
 {
   self.moduleName = @"AwesomeProject";
+  self.dependencyProvider = [RCTAppDependencyProvider new];
   // You can add your custom initial props in the dictionary below.
   // They will be passed down to the ViewController used by React Native.
   self.initialProps = @{};

Example/testHotUpdate/package.json

@@ -14,36 +14,36 @@
     "dev:harmony": "react-native bundle-harmony --dev"
   },
   "dependencies": {
-    "form-data": "^4.0.2",
+    "form-data": "^4.0.3",
     "patch-package": "^8.0.0",
     "react": "19.0.0",
-    "react-native": "0.78.0",
+    "react-native": "0.79.2",
-    "react-native-camera-kit": "^14.2.0",
+    "react-native-camera-kit": "^15.1.0",
-    "react-native-paper": "^5.13.1",
+    "react-native-paper": "^5.14.5",
-    "react-native-safe-area-context": "^5.3.0",
+    "react-native-safe-area-context": "^5.5.0",
-    "react-native-svg": "^15.11.2",
+    "react-native-svg": "^15.12.0",
-    "react-native-update": "^10.26.4",
+    "react-native-update": "^10.29.4",
     "react-native-vector-icons": "^10.2.0"
   },
   "devDependencies": {
-    "@babel/core": "^7.26.0",
+    "@babel/core": "^7.27.3",
-    "@babel/preset-env": "^7.26.0",
+    "@babel/preset-env": "^7.27.2",
-    "@babel/runtime": "^7.26.0",
+    "@babel/runtime": "^7.27.3",
-    "@react-native-community/cli": "15.0.1",
+    "@react-native-community/cli": "18.0.0",
-    "@react-native-community/cli-platform-android": "15.0.1",
+    "@react-native-community/cli-platform-android": "18.0.0",
-    "@react-native-community/cli-platform-ios": "15.0.1",
+    "@react-native-community/cli-platform-ios": "18.0.0",
-    "@react-native/babel-preset": "0.78.0",
+    "@react-native/babel-preset": "0.79.2",
-    "@react-native/eslint-config": "0.78.0",
+    "@react-native/eslint-config": "0.79.2",
-    "@react-native/metro-config": "0.78.0",
+    "@react-native/metro-config": "0.79.2",
-    "@react-native/typescript-config": "0.78.0",
+    "@react-native/typescript-config": "0.79.2",
     "@types/react": "^19.0.0",
     "@types/react-test-renderer": "^19.0.0",
-    "detox": "^20.32.0",
+    "detox": "^20.39.0",
     "eslint": "^8.19.0",
     "jest": "^29.6.3",
     "prettier": "2.8.8",
     "react-test-renderer": "19.0.0",
-    "typescript": "5.8.2"
+    "typescript": "5.8.3"
   },
   "engines": {
     "node": ">=18"

Example/testHotUpdate/src/index.tsx

@@ -52,7 +52,7 @@ function App() {
 
   return (
     <View style={styles.container}>
-      <Text style={styles.welcome}>欢迎使用Pushy热更新服务</Text>
+      <Text style={styles.welcome}>欢迎xxx使用Pushy热更新服务</Text>
       <View style={{flexDirection: 'row'}}>
         <Text>
           {useDefaultAlert ? '当前使用' : '当前不使用'}默认的alert更新提示

Example/testHotUpdate/update.json

@@ -1,7 +1,7 @@
 {
   "ios": {
-    "appId": 24794,
+    "appId": 28943,
-    "appKey": "SqShg4Klnj2hG6LAFMW2PdcgSSuniz0T"
+    "appKey": "d-OmPxIBivPrDfKhLHjxN-HS"
   },
   "android": {
     "appId": 27509,

android/proguard.pro

@@ -1,3 +1,37 @@
+# Keep our update module classes
 -keepnames class cn.reactnative.modules.update.DownloadTask { *; }
 -keepnames class cn.reactnative.modules.update.UpdateModuleImpl { *; }
+-keepnames class cn.reactnative.modules.update.** { *; }
+
+# Keep React Native classes
 -keepnames class com.facebook.react.ReactInstanceManager { *; }
+-keepnames class com.facebook.react.** { *; }
+-keepnames class com.facebook.react.bridge.** { *; }
+-keepnames class com.facebook.react.devsupport.** { *; }
+
+# Keep fields used in reflection
+-keepclassmembers class com.facebook.react.ReactInstanceManager {
+    private JSBundleLoader mBundleLoader;
+    private String mJSBundleFile;
+}
+
+-keepclassmembers class com.facebook.react.ReactDelegate {
+    private ReactHost mReactHost;
+}
+
+-keepclassmembers class com.facebook.react.ReactHost {
+    private boolean mUseDevSupport;
+    private ReactHostDelegate mReactHostDelegate;
+}
+
+# Keep Expo related classes
+-keepnames class expo.modules.ExpoReactHostFactory$ExpoReactHostDelegate { *; }
+
+# Keep methods used in reflection
+-keepclassmembers class com.facebook.react.ReactActivity {
+    public ReactDelegate getReactDelegate();
+}
+
+-keepclassmembers class com.facebook.react.ReactHost {
+    public void reload(java.lang.String);
+}

android/src/main/java/cn/reactnative/modules/update/UpdateContext.java

@@ -169,6 +169,7 @@ public class UpdateContext {
     }
 
     public void markSuccess() {
+        if (!BuildConfig.DEBUG) {
             SharedPreferences.Editor editor = sp.edit();
             editor.putBoolean("firstTimeOk", true);
             String lastVersion = sp.getString("lastVersion", null);
@@ -181,6 +182,7 @@ public class UpdateContext {
 
             this.cleanUp();
         }
+    }
 
     public void clearFirstTime() {
         SharedPreferences.Editor editor = sp.edit();

android/src/main/java/cn/reactnative/modules/update/UpdateModuleImpl.java

@@ -147,13 +147,22 @@ public class UpdateModuleImpl {
                         reactHostField.setAccessible(true);
                         Object reactHost = reactHostField.get(reactDelegate);
 
+                        Field devSupport = reactHost.getClass().getDeclaredField("mUseDevSupport");
+                        devSupport.setAccessible(true);
+                        devSupport.set(reactHost, false);
+
                         // Access the mReactHostDelegate field
                         Field reactHostDelegateField = reactHost.getClass().getDeclaredField("mReactHostDelegate");
                         reactHostDelegateField.setAccessible(true);
                         Object reactHostDelegate = reactHostDelegateField.get(reactHost);
 
+                        String bundleFieldName = "jsBundleLoader";
+                        if (reactHostDelegate.getClass().getCanonicalName().equals("expo.modules.ExpoReactHostFactory.ExpoReactHostDelegate")) {
+                            bundleFieldName = "_jsBundleLoader";
+                        }
+
                         // Modify the jsBundleLoader field
-                        Field jsBundleLoaderField = reactHostDelegate.getClass().getDeclaredField("jsBundleLoader");
+                        Field jsBundleLoaderField = reactHostDelegate.getClass().getDeclaredField(bundleFieldName);
                         jsBundleLoaderField.setAccessible(true);
                         jsBundleLoaderField.set(reactHostDelegate, loader);
                         

android/src/newarch/cn/reactnative/modules/update/UpdateModule.java

@@ -4,6 +4,8 @@ import static androidx.core.content.FileProvider.getUriForFile;
 import android.content.Intent;
 import android.net.Uri;
 import android.os.Build;
+import android.os.Handler;
+import android.os.Looper;
 import com.facebook.react.bridge.Promise;
 import com.facebook.react.bridge.ReactApplicationContext;
 import com.facebook.react.bridge.ReactContext;
@@ -17,6 +19,7 @@ import java.util.Map;
 public class UpdateModule extends NativePushySpec {
     UpdateContext updateContext;
     public static ReactApplicationContext mContext;
+    private final Handler handler = new Handler(Looper.getMainLooper());
     public UpdateModule(ReactApplicationContext reactContext, UpdateContext updateContext) {
         super(reactContext);
         this.updateContext = updateContext;
@@ -38,13 +41,23 @@ public class UpdateModule extends NativePushySpec {
         boolean isFirstTime = updateContext.isFirstTime();
         constants.put("isFirstTime", isFirstTime);
         if (isFirstTime) {
+            handler.postDelayed(new Runnable() {
+                @Override
+                public void run() {
                     updateContext.clearFirstTime();
                 }
+            }, 2000);
+        }
         String rolledBackVersion = updateContext.rolledBackVersion();
         constants.put("rolledBackVersion", rolledBackVersion);
         if (rolledBackVersion != null) {
+            handler.postDelayed(new Runnable() {
+                @Override
+                public void run() {
                     updateContext.clearRollbackMark();
                 }
+            }, 2000);
+        }
         constants.put("uuid", updateContext.getKv("uuid"));
         return constants;
     }

endpoints.json

@@ -1 +1 @@
-["https://pushy-koa-qgbgqmcpis.cn-beijing.fcapp.run", "https://p.reactnative.cn/api"]
+["https://p.reactnative.cn/api"]

harmony/oh_modules/@rnoh/react-native-openharmony

@@ -1 +0,0 @@
-../../../../../harmony/oh_modules/.ohpm/@rnoh+react-native-openharmony@0.72.38/oh_modules/@rnoh/react-native-openharmony

harmony/pushy/src/main/cpp/PushyTurboModule.cpp

@@ -73,7 +73,7 @@ static jsi::Value _hostFunction_PushyTurboModule_downloadPatchFromPpk(
     const jsi::Value* args,
     size_t count)
     {
-        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).call(rt,"downloadPatchFromPpk", args, count));
+        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).callAsync(rt,"downloadPatchFromPpk", args, count));
     }
 
 static jsi::Value _hostFunction_PushyTurboModule_downloadPatchFromPackage(
@@ -82,7 +82,7 @@ static jsi::Value _hostFunction_PushyTurboModule_downloadPatchFromPackage(
     const jsi::Value* args,
     size_t count)
     {
-        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).call(rt,"downloadPatchFromPackage", args, count));
+        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).callAsync(rt,"downloadPatchFromPackage", args, count));
     }
 
 static jsi::Value _hostFunction_PushyTurboModule_downloadFullUpdate(
@@ -91,7 +91,7 @@ static jsi::Value _hostFunction_PushyTurboModule_downloadFullUpdate(
     const jsi::Value* args,
     size_t count)
     {
-        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).call(rt,"downloadFullUpdate", args, count));
+        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).callAsync(rt,"downloadFullUpdate", args, count));
     }
 
 static jsi::Value _hostFunction_PushyTurboModule_downloadAndInstallApk(
@@ -100,7 +100,7 @@ static jsi::Value _hostFunction_PushyTurboModule_downloadAndInstallApk(
     const jsi::Value* args,
     size_t count)
     {
-        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).call(rt,"downloadAndInstallApk", args, count));
+        return jsi::Value(static_cast<ArkTSTurboModule &> (turboModule).callAsync(rt,"downloadAndInstallApk", args, count));
     }
 
 

harmony/pushy/src/main/ets/PushyFileJSBundleProvider.ets

@@ -12,7 +12,7 @@ export class PushyFileJSBundleProvider extends JSBundleProvider {
     this.updateContext = new UpdateContext(context);
   }
   getURL(): string {
-    return this.updateContext.getBundleUrl();
+    return this.updateContext.getBundleUrl().substring(1);
   }
 
   async getBundle(): Promise<ArrayBuffer> {

ios/ImportReact.h

@@ -0,0 +1,2 @@
+@import React;
+

ios/RCTPushy/RCTPushy.mm

@@ -93,8 +93,7 @@ RCT_EXPORT_MODULE(RCTPushy);
             BOOL needRollback = (!ignoreRollback && isFirstTime == NO && isFirstLoadOK == NO) || loadVersion.length<=0;
             if (needRollback) {
                 loadVersion = [self rollback];
-            }
+            } else if (isFirstTime && !ignoreRollback){
-            else if (isFirstTime && !ignoreRollback){
                 // bundleURL may be called many times, ignore rollbacks before process restarted again.
                 ignoreRollback = true;
 
@@ -302,7 +301,7 @@ RCT_EXPORT_METHOD(setNeedUpdate:(NSDictionary *)options
         
         
         resolve(@true);
-    }else{
+    } else {
         reject(@"执行报错", nil, nil);
     }
 }
@@ -314,22 +313,22 @@ RCT_EXPORT_METHOD(reloadUpdate:(NSDictionary *)options
     @try {
         NSString *hash = options[@"hash"];
         if (hash.length) {
-            [self setNeedUpdate:options resolver:resolve rejecter:reject];
+            // 只在 setNeedUpdate 成功后 resolve
-            
+            [self setNeedUpdate:options resolver:^(id result) {
-            // reload in earlier version
                 dispatch_async(dispatch_get_main_queue(), ^{
-                [self.bridge setValue:[[self class] bundleURL] forKey:@"bundleURL"];
-                [self.bridge reload];
-            });
-            
                     #if __has_include("RCTReloadCommand.h")
                         // reload 0.62+
                         RCTReloadCommandSetBundleURL([[self class] bundleURL]);
-                RCTTriggerReloadCommandListeners(@"pushy reload");
+                        RCTTriggerReloadCommandListeners(@"pushy reloadUpdate");
+                    #else
+                        [self.bridge reload];
                     #endif
-
+                });
                 resolve(@true);
-        }else{
+            } rejecter:^(NSString *code, NSString *message, NSError *error) {
+                reject(code, message, error);
+            }];
+        } else {
             reject(@"执行报错", nil, nil);
         }
     }
@@ -343,13 +342,14 @@ RCT_EXPORT_METHOD(restartApp:(RCTPromiseResolveBlock)resolve
 {
     @try {
         dispatch_async(dispatch_get_main_queue(), ^{
-            [self.bridge reload];
-        });
             #if __has_include("RCTReloadCommand.h")
                 // reload 0.62+
                 RCTReloadCommandSetBundleURL([[self class] bundleURL]);
                 RCTTriggerReloadCommandListeners(@"pushy restartApp");
+            #else
+                [self.bridge reload];
             #endif
+        });
 
         resolve(@true);
     }
@@ -361,6 +361,9 @@ RCT_EXPORT_METHOD(restartApp:(RCTPromiseResolveBlock)resolve
 RCT_EXPORT_METHOD(markSuccess:(RCTPromiseResolveBlock)resolve
                                     rejecter:(RCTPromiseRejectBlock)reject)
 {
+    #if DEBUG
+    resolve(@true);
+    #else
     
     @try {
         // up package info
@@ -384,6 +387,7 @@ RCT_EXPORT_METHOD(markSuccess:(RCTPromiseResolveBlock)resolve
     @catch (NSException *exception) {
         reject(@"执行报错", nil, nil);
     }
+    #endif
 }
 
 
@@ -542,7 +546,15 @@ RCT_EXPORT_METHOD(markSuccess:(RCTPromiseResolveBlock)resolve
             callback([self errorWithMessage:ERROR_HDIFFPATCH]);
         }
     };
+    
+    @try {
         [_fileManager hdiffFileAtPath:bundlePatch fromOrigin:bundleOrigin toDestination:destination completionHandler:completionHandler];
+    }
+    @catch (NSException *exception) {
+        NSLog(@"Pushy _dopatch error: exception occurred during hdiffFileAtPath: %@, reason: %@", 
+              exception.name, exception.reason);
+        callback([self errorWithMessage:ERROR_HDIFFPATCH]);
+    }
 }
 
 - (void)patch:(NSString *)hash fromBundle:(NSString *)bundleOrigin source:(NSString *)sourceOrigin callback:(void (^)(NSError *error))callback

package.json

@@ -1,6 +1,6 @@
 {
   "name": "react-native-update",
-  "version": "10.28.10",
+  "version": "10.29.9",
   "description": "react-native hot update",
   "main": "src/index",
   "scripts": {

react-native-update.podspec

@@ -90,13 +90,6 @@ Pod::Spec.new do |s|
 
   s.source = { :git => 'https://github.com/reactnativecn/react-native-update.git', :tag => '#{s.version}' }
 
-  # Conditionally set source files
-  if valid_expo_project
-    s.source_files = Dir.glob("ios/**/*.{h,m,mm,swift}") # Include Expo files
-  else
-    s.source_files = Dir.glob("ios/**/*.{h,m,mm,swift}").reject { |f| f.start_with?("ios/Expo/") } # Exclude Expo files
-  end
-
   s.libraries = 'bz2', 'z'
   s.vendored_libraries = 'RCTPushy/libRCTPushy.a'
   s.pod_target_xcconfig = { 
@@ -112,22 +105,18 @@ Pod::Spec.new do |s|
 
   # Conditionally add Expo dependency
   if valid_expo_project
+    s.public_header_files = ['ios/ImportReact.h']
     s.dependency 'ExpoModulesCore'
   end
 
   s.subspec 'RCTPushy' do |ss|
-    ss.source_files = 'ios/RCTPushy/*.{h,m,mm,swift}'
+    ss.source_files = ['ios/RCTPushy/**/*.{h,m,mm,c}',
-    ss.public_header_files = ['ios/RCTPushy/*.h']
-  end
-
-  s.subspec 'HDiffPatch' do |ss|
-    ss.source_files = ['ios/RCTPushy/HDiffPatch/**/*.{h,m,c}',
                        'android/jni/hpatch.{h,c}',
                        'android/jni/HDiffPatch/libHDiffPatch/HPatch/*.{h,c}',
                        'android/jni/HDiffPatch/file_for_patch.{h,c}',
                        'android/jni/lzma/C/LzmaDec.{h,c}',
                        'android/jni/lzma/C/Lzma2Dec.{h,c}']
-    ss.public_header_files = 'ios/RCTPushy/HDiffPatch/**/*.h'
+    ss.public_header_files = ['ios/RCTPushy/**/*.h']
   end
 
   # Conditionally add Expo subspec and check ExpoModulesCore version

src/client.ts

@@ -1,33 +1,33 @@
-import { CheckResult, ClientOptions, ProgressData, EventType } from './type';
 import {
-  assertDev,
+  DeviceEventEmitter,
+  EmitterSubscription,
+  Platform,
+} from 'react-native';
+import {
+  PushyModule,
+  buildTime,
+  cInfo,
+  currentVersion,
+  getCurrentVersionInfo,
+  isFirstTime,
+  isRolledBack,
+  packageVersion,
+  pushyNativeEventEmitter,
+  rolledBackVersion,
+  setLocalHashInfo,
+} from './core';
+import { PermissionsAndroid } from './permissions';
+import { CheckResult, ClientOptions, EventType, ProgressData } from './type';
+import {
   assertWeb,
   emptyObj,
+  enhancedFetch,
   joinUrls,
   log,
   noop,
   promiseAny,
   testUrls,
 } from './utils';
-import {
-  EmitterSubscription,
-  Platform,
-  DeviceEventEmitter,
-} from 'react-native';
-import { PermissionsAndroid } from './permissions';
-import {
-  PushyModule,
-  buildTime,
-  cInfo,
-  pushyNativeEventEmitter,
-  currentVersion,
-  packageVersion,
-  rolledBackVersion,
-  setLocalHashInfo,
-  isFirstTime,
-  isRolledBack,
-  getCurrentVersionInfo,
-} from './core';
 
 const SERVER_PRESETS = {
   // cn
@@ -148,6 +148,7 @@ export class Pushy {
     await this.loggerPromise.promise;
     const { logger = noop, appKey } = this.options;
     const info = await getCurrentVersionInfo();
+    const overridePackageVersion = this.options.overridePackageVersion;
     logger({
       type,
       data: {
@@ -155,6 +156,7 @@ export class Pushy {
         currentVersion,
         cInfo,
         packageVersion,
+        overridePackageVersion,
         buildTime,
         message,
         ...info,
@@ -170,10 +172,12 @@ export class Pushy {
   getCheckUrl = (endpoint: string = this.options.server!.main) => {
     return `${endpoint}/checkUpdate/${this.options.appKey}`;
   };
-  assertDebug = () => {
+  assertDebug = (matter: string) => {
     if (__DEV__ && !this.options.debug) {
       console.info(
-        'You are currently in the development environment and have not enabled debug mode. The hot update check will not be performed. If you need to debug hot updates in the development environment, please set debug to true in the client.',
+        `You are currently in the development environment and have not enabled debug mode. 
+        ${matter} will not be performed. 
+        If you need to debug ${matter} in the development environment, please set debug to true in the client.`,
       );
       return false;
     }
@@ -188,7 +192,7 @@ export class Pushy {
     this.report({ type: 'markSuccess' });
   };
   switchVersion = async (hash: string) => {
-    if (!assertDev('switchVersion()')) {
+    if (!this.assertDebug('switchVersion()')) {
       return;
     }
     if (assertHash(hash) && !sharedState.applyingUpdate) {
@@ -199,7 +203,7 @@ export class Pushy {
   };
 
   switchVersionLater = async (hash: string) => {
-    if (!assertDev('switchVersionLater()')) {
+    if (!this.assertDebug('switchVersionLater()')) {
       return;
     }
     if (assertHash(hash)) {
@@ -208,7 +212,7 @@ export class Pushy {
     }
   };
   checkUpdate = async (extra?: Record<string, any>) => {
-    if (!this.assertDebug()) {
+    if (!this.assertDebug('checkUpdate()')) {
       return;
     }
     if (!assertWeb()) {
@@ -231,7 +235,7 @@ export class Pushy {
     }
     this.lastChecking = now;
     const fetchBody = {
-      packageVersion,
+      packageVersion: this.options.overridePackageVersion || packageVersion,
       hash: currentVersion,
       buildTime,
       cInfo,
@@ -261,7 +265,7 @@ export class Pushy {
         type: 'checking',
         message: this.options.appKey + ': ' + stringifyBody,
       });
-      resp = await fetch(this.getCheckUrl(), fetchPayload);
+      resp = await enhancedFetch(this.getCheckUrl(), fetchPayload);
     } catch (e: any) {
       this.report({
         type: 'errorChecking',
@@ -272,7 +276,7 @@ export class Pushy {
         try {
           resp = await promiseAny(
             backupEndpoints.map(endpoint =>
-              fetch(this.getCheckUrl(endpoint), fetchPayload),
+              enhancedFetch(this.getCheckUrl(endpoint), fetchPayload),
             ),
           );
         } catch (err: any) {
@@ -389,11 +393,16 @@ export class Pushy {
       }
     }
     let succeeded = '';
-    this.report({ type: 'downloading' });
+    this.report({
+      type: 'downloading',
+      data: {
+        newVersion: hash,
+      },
+    });
     let lastError: any;
     let errorMessages: string[] = [];
     const diffUrl = await testUrls(joinUrls(paths, diff));
-    if (diffUrl) {
+    if (diffUrl && !__DEV__) {
       log('downloading diff');
       try {
         await PushyModule.downloadPatchFromPpk({
@@ -406,15 +415,12 @@ export class Pushy {
         const errorMessage = `diff error: ${e.message}`;
         errorMessages.push(errorMessage);
         lastError = new Error(errorMessage);
-        if (__DEV__) {
-          succeeded = 'diff';
-        } else {
         log(errorMessage);
       }
     }
-    }
+    if (!succeeded) {
       const pdiffUrl = await testUrls(joinUrls(paths, pdiff));
-    if (!succeeded && pdiffUrl) {
+      if (pdiffUrl && !__DEV__) {
         log('downloading pdiff');
         try {
           await PushyModule.downloadPatchFromPackage({
@@ -426,15 +432,13 @@ export class Pushy {
           const errorMessage = `pdiff error: ${e.message}`;
           errorMessages.push(errorMessage);
           lastError = new Error(errorMessage);
-        if (__DEV__) {
-          succeeded = 'pdiff';
-        } else {
           log(errorMessage);
         }
       }
     }
+    if (!succeeded) {
       const fullUrl = await testUrls(joinUrls(paths, full));
-    if (!succeeded && fullUrl) {
+      if (fullUrl) {
         log('downloading full patch');
         try {
           await PushyModule.downloadFullUpdate({
@@ -446,20 +450,21 @@ export class Pushy {
           const errorMessage = `full patch error: ${e.message}`;
           errorMessages.push(errorMessage);
           lastError = new Error(errorMessage);
-        if (__DEV__) {
-          succeeded = 'full';
-        } else {
           log(errorMessage);
         }
+      } else if (__DEV__) {
+        log(
+          `当前是开发环境，无法执行增量式热更新，重启不会生效。
+          如果需要在开发环境中测试可生效的全量热更新（但也会在再次重启后重新连接 metro），
+          请打开“忽略时间戳”开关再重试。`,
+        );
+        succeeded = 'full';
       }
     }
     if (sharedState.progressHandlers[hash]) {
       sharedState.progressHandlers[hash].remove();
       delete sharedState.progressHandlers[hash];
     }
-    if (__DEV__) {
-      return hash;
-    }
     if (!succeeded) {
       this.report({
         type: 'errorUpdate',

src/provider.tsx

@@ -251,7 +251,7 @@ export const UpdateProvider = ({
   const markSuccess = client.markSuccess;
 
   useEffect(() => {
-    if (!client.assertDebug()) {
+    if (!client.assertDebug('checkUpdate()')) {
       return;
     }
     const { checkStrategy, dismissErrorAfter, autoMarkSuccess } = options;

src/type.ts

@@ -93,6 +93,7 @@ export interface ClientOptions {
   beforeDownloadUpdate?: (info: CheckResult) => Promise<boolean>;
   afterDownloadUpdate?: (info: CheckResult) => Promise<boolean>;
   onPackageExpired?: (info: CheckResult) => Promise<boolean>;
+  overridePackageVersion?: string;
 }
 
 export interface UpdateTestPayload {

src/utils.ts

@@ -40,13 +40,13 @@ const ping =
     : async (url: string) => {
         let pingFinished = false;
         return Promise.race([
-          fetch(url, {
+          enhancedFetch(url, {
             method: 'HEAD',
           })
-            .then(({ status, statusText }) => {
+            .then(({ status, statusText, url: finalUrl }) => {
               pingFinished = true;
               if (status === 200) {
-                return url;
+                return finalUrl;
               }
               log('ping failed', url, status, statusText);
               throw new Error('Ping failed');
@@ -69,7 +69,7 @@ const ping =
 
 export function joinUrls(paths: string[], fileName?: string) {
   if (fileName) {
-    return paths.map(path => 'https://' + path + '/' + fileName);
+    return paths.map(path => `https://${path}/${fileName}`);
   }
 }
 
@@ -99,12 +99,19 @@ export const assertWeb = () => {
   return true;
 };
 
-export const assertDev = (matter: string) => {
+// export const isAndroid70AndBelow = () => {
-  if (__DEV__) {
+//   // android 7.0 and below devices do not support letsencrypt cert
-    console.warn(
+//   // https://letsencrypt.org/2023/07/10/cross-sign-expiration/
-      `${matter} is not supported in development environment; no action taken.`,
+//   return Platform.OS === 'android' && Platform.Version <= 24;
-    );
+// };
-    return false;
+
-  }
+export const enhancedFetch = async (
-  return true;
+  url: string,
+  params: Parameters<typeof fetch>[1],
+) => {
+  return fetch(url, params).catch(e => {
+    log('fetch error', url, e);
+    log('trying fallback to http');
+    return fetch(url.replace('https', 'http'), params);
+  });
 };