mirror of
https://gitcode.com/gh_mirrors/re/react-native-pushy.git
synced 2025-09-17 21:26:10 +08:00
Compare commits
9 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
effd7e129d | ||
![]() |
9a00cf7483 | ||
![]() |
d854082495 | ||
![]() |
3073bd99db | ||
![]() |
4436654769 | ||
![]() |
3ccc3653ac | ||
![]() |
e150db486a | ||
![]() |
66c2504718 | ||
![]() |
bbda7217ac |
@@ -12,7 +12,7 @@
|
|||||||
"react-native-paper": "^5.13.1",
|
"react-native-paper": "^5.13.1",
|
||||||
"react-native-safe-area-context": "^5.2.0",
|
"react-native-safe-area-context": "^5.2.0",
|
||||||
"react-native-svg": "^15.11.1",
|
"react-native-svg": "^15.11.1",
|
||||||
"react-native-update": "^10.23.0",
|
"react-native-update": "^10.24.2",
|
||||||
"react-native-vector-icons": "^10.2.0",
|
"react-native-vector-icons": "^10.2.0",
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
@@ -1434,7 +1434,7 @@
|
|||||||
|
|
||||||
"react-native-svg": ["react-native-svg@15.11.1", "", { "dependencies": { "css-select": "^5.1.0", "css-tree": "^1.1.3", "warn-once": "0.1.1" }, "peerDependencies": { "react": "*", "react-native": "*" } }, "sha512-Qmwx/yJKt+AHUr4zjxx/Q69qwKtRfr1+uIfFMQoq3WFRhqU76aL9db1DyvPiY632DAsVGba1pHf92OZPkpjrdQ=="],
|
"react-native-svg": ["react-native-svg@15.11.1", "", { "dependencies": { "css-select": "^5.1.0", "css-tree": "^1.1.3", "warn-once": "0.1.1" }, "peerDependencies": { "react": "*", "react-native": "*" } }, "sha512-Qmwx/yJKt+AHUr4zjxx/Q69qwKtRfr1+uIfFMQoq3WFRhqU76aL9db1DyvPiY632DAsVGba1pHf92OZPkpjrdQ=="],
|
||||||
|
|
||||||
"react-native-update": ["react-native-update@10.23.0", "", { "dependencies": { "nanoid": "^3.3.3", "react-native-url-polyfill": "^2.0.0" }, "peerDependencies": { "react": ">=16.8.0", "react-native": ">=0.59.0" } }, "sha512-gt6kL5Fd8iG46YYwvcuiD6Yod7DSzNZ/Qo5YuiAXrdO/h+3SCJsfDGVmSpanShwAepvvuAUELIJZIRpSrJdIvA=="],
|
"react-native-update": ["react-native-update@10.24.2", "", { "dependencies": { "nanoid": "^3.3.3", "react-native-url-polyfill": "^2.0.0" }, "peerDependencies": { "react": ">=16.8.0", "react-native": ">=0.59.0" } }, "sha512-pMnAFWApyZkTFKJliENcKVl3wSjOH/e0mEaYjYodWjpmHGZVET/J/nZ46Q03/JRtXcVnYkaq//y3axMfgHC21g=="],
|
||||||
|
|
||||||
"react-native-url-polyfill": ["react-native-url-polyfill@2.0.0", "", { "dependencies": { "whatwg-url-without-unicode": "8.0.0-3" }, "peerDependencies": { "react-native": "*" } }, "sha512-My330Do7/DvKnEvwQc0WdcBnFPploYKp9CYlefDXzIdEaA+PAhDYllkvGeEroEzvc4Kzzj2O4yVdz8v6fjRvhA=="],
|
"react-native-url-polyfill": ["react-native-url-polyfill@2.0.0", "", { "dependencies": { "whatwg-url-without-unicode": "8.0.0-3" }, "peerDependencies": { "react-native": "*" } }, "sha512-My330Do7/DvKnEvwQc0WdcBnFPploYKp9CYlefDXzIdEaA+PAhDYllkvGeEroEzvc4Kzzj2O4yVdz8v6fjRvhA=="],
|
||||||
|
|
||||||
|
File diff suppressed because it is too large
Load Diff
@@ -23,7 +23,7 @@
|
|||||||
"react-native-paper": "^5.13.1",
|
"react-native-paper": "^5.13.1",
|
||||||
"react-native-safe-area-context": "^5.2.0",
|
"react-native-safe-area-context": "^5.2.0",
|
||||||
"react-native-svg": "^15.11.1",
|
"react-native-svg": "^15.11.1",
|
||||||
"react-native-update": "^10.23.0",
|
"react-native-update": "^10.24.2",
|
||||||
"react-native-vector-icons": "^10.2.0"
|
"react-native-vector-icons": "^10.2.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
|
@@ -25,7 +25,7 @@ import {LocalSvg} from 'react-native-svg/css';
|
|||||||
import TestConsole from './TestConsole';
|
import TestConsole from './TestConsole';
|
||||||
|
|
||||||
import _updateConfig from '../update.json';
|
import _updateConfig from '../update.json';
|
||||||
import {PushyProvider, Pushy, usePushy} from 'react-native-update';
|
import {UpdateProvider, Pushy, Cresc, useUpdate} from 'react-native-update';
|
||||||
const {appKey} = _updateConfig[Platform.OS];
|
const {appKey} = _updateConfig[Platform.OS];
|
||||||
|
|
||||||
function App() {
|
function App() {
|
||||||
@@ -40,7 +40,7 @@ function App() {
|
|||||||
currentHash,
|
currentHash,
|
||||||
parseTestQrCode,
|
parseTestQrCode,
|
||||||
progress: {received, total} = {},
|
progress: {received, total} = {},
|
||||||
} = usePushy();
|
} = useUpdate();
|
||||||
const [useDefaultAlert, setUseDefaultAlert] = useState(true);
|
const [useDefaultAlert, setUseDefaultAlert] = useState(true);
|
||||||
const [showTestConsole, setShowTestConsole] = useState(false);
|
const [showTestConsole, setShowTestConsole] = useState(false);
|
||||||
const [showUpdateBanner, setShowUpdateBanner] = useState(false);
|
const [showUpdateBanner, setShowUpdateBanner] = useState(false);
|
||||||
@@ -203,17 +203,24 @@ const styles = StyleSheet.create({
|
|||||||
image: {},
|
image: {},
|
||||||
});
|
});
|
||||||
|
|
||||||
const pushyClient = new Pushy({
|
// use Pushy for China users
|
||||||
|
// const updateClient = new Pushy({
|
||||||
|
// appKey,
|
||||||
|
// debug: true,
|
||||||
|
// });
|
||||||
|
|
||||||
|
// use Cresc for global users
|
||||||
|
const updateClient = new Cresc({
|
||||||
appKey,
|
appKey,
|
||||||
debug: true,
|
debug: true,
|
||||||
});
|
});
|
||||||
|
|
||||||
export default function Root() {
|
export default function Root() {
|
||||||
return (
|
return (
|
||||||
<PushyProvider client={pushyClient}>
|
<UpdateProvider client={updateClient}>
|
||||||
<PaperProvider>
|
<PaperProvider>
|
||||||
<App />
|
<App />
|
||||||
</PaperProvider>
|
</PaperProvider>
|
||||||
</PushyProvider>
|
</UpdateProvider>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
@@ -98,23 +98,20 @@ public class UpdateModuleImpl {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
promise.reject("执行报错:" + e.getMessage());
|
promise.reject("downloadPatchFromPpk failed: "+e.getMessage());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void reloadUpdate(UpdateContext updateContext, ReactApplicationContext mContext, ReadableMap options, Promise promise) {
|
public static void reloadUpdate(UpdateContext updateContext, ReactApplicationContext mContext, ReadableMap options, Promise promise) {
|
||||||
final String hash = options.getString("hash");
|
final String hash = options.getString("hash");
|
||||||
|
|
||||||
if (hash == null || hash.isEmpty()) {
|
|
||||||
promise.reject("hash不能为空");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
UiThreadUtil.runOnUiThread(new Runnable() {
|
UiThreadUtil.runOnUiThread(new Runnable() {
|
||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
|
|
||||||
|
updateContext.switchVersion(hash);
|
||||||
|
final Context application = mContext.getApplicationContext();
|
||||||
|
JSBundleLoader loader = JSBundleLoader.createFileLoader(UpdateContext.getBundleUrl(application));
|
||||||
try {
|
try {
|
||||||
updateContext.switchVersion(hash);
|
|
||||||
final Context application = mContext.getApplicationContext();
|
|
||||||
ReactInstanceManager instanceManager = updateContext.getCustomReactInstanceManager();
|
ReactInstanceManager instanceManager = updateContext.getCustomReactInstanceManager();
|
||||||
|
|
||||||
if (instanceManager == null) {
|
if (instanceManager == null) {
|
||||||
@@ -122,12 +119,10 @@ public class UpdateModuleImpl {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
JSBundleLoader loader = JSBundleLoader.createFileLoader(UpdateContext.getBundleUrl(application));
|
|
||||||
Field loadField = instanceManager.getClass().getDeclaredField("mBundleLoader");
|
Field loadField = instanceManager.getClass().getDeclaredField("mBundleLoader");
|
||||||
loadField.setAccessible(true);
|
loadField.setAccessible(true);
|
||||||
loadField.set(instanceManager, loader);
|
loadField.set(instanceManager, loader);
|
||||||
} catch (Throwable err) {
|
} catch (Throwable err) {
|
||||||
promise.reject("pushy:"+err.getMessage());
|
|
||||||
Field jsBundleField = instanceManager.getClass().getDeclaredField("mJSBundleFile");
|
Field jsBundleField = instanceManager.getClass().getDeclaredField("mJSBundleFile");
|
||||||
jsBundleField.setAccessible(true);
|
jsBundleField.setAccessible(true);
|
||||||
jsBundleField.set(instanceManager, UpdateContext.getBundleUrl(application));
|
jsBundleField.set(instanceManager, UpdateContext.getBundleUrl(application));
|
||||||
@@ -137,31 +132,36 @@ public class UpdateModuleImpl {
|
|||||||
promise.resolve(true);
|
promise.resolve(true);
|
||||||
|
|
||||||
} catch (Throwable err) {
|
} catch (Throwable err) {
|
||||||
promise.reject(err);
|
|
||||||
Log.e("pushy", "switchVersion failed ", err);
|
|
||||||
final Activity currentActivity = mContext.getCurrentActivity();
|
final Activity currentActivity = mContext.getCurrentActivity();
|
||||||
if (currentActivity == null) {
|
if (currentActivity == null) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
// Try to get getReactDelegate method using reflection
|
|
||||||
java.lang.reflect.Method getReactDelegateMethod =
|
java.lang.reflect.Method getReactDelegateMethod =
|
||||||
ReactActivity.class.getMethod("getReactDelegate");
|
ReactActivity.class.getMethod("getReactDelegate");
|
||||||
if (getReactDelegateMethod != null) {
|
|
||||||
ReactDelegate reactDelegate = (ReactDelegate)
|
|
||||||
getReactDelegateMethod.invoke(currentActivity);
|
|
||||||
|
|
||||||
// Try to get reload method using reflection
|
ReactDelegate reactDelegate = (ReactDelegate)
|
||||||
java.lang.reflect.Method reloadMethod =
|
getReactDelegateMethod.invoke(currentActivity);
|
||||||
ReactDelegate.class.getMethod("reload");
|
|
||||||
if (reloadMethod != null) {
|
Field reactHostField = ReactDelegate.class.getDeclaredField("mReactHost");
|
||||||
reloadMethod.invoke(reactDelegate);
|
reactHostField.setAccessible(true);
|
||||||
} else {
|
Object reactHost = reactHostField.get(reactDelegate);
|
||||||
throw new NoSuchMethodException();
|
|
||||||
}
|
// Access the mReactHostDelegate field
|
||||||
} else {
|
Field reactHostDelegateField = reactHost.getClass().getDeclaredField("mReactHostDelegate");
|
||||||
throw new NoSuchMethodException();
|
reactHostDelegateField.setAccessible(true);
|
||||||
}
|
Object reactHostDelegate = reactHostDelegateField.get(reactHost);
|
||||||
|
|
||||||
|
// Modify the jsBundleLoader field
|
||||||
|
Field jsBundleLoaderField = reactHostDelegate.getClass().getDeclaredField("jsBundleLoader");
|
||||||
|
jsBundleLoaderField.setAccessible(true);
|
||||||
|
jsBundleLoaderField.set(reactHostDelegate, loader);
|
||||||
|
|
||||||
|
// Get the reload method with a String parameter
|
||||||
|
java.lang.reflect.Method reloadMethod = reactHost.getClass().getMethod("reload", String.class);
|
||||||
|
|
||||||
|
// Invoke the reload method with a reason
|
||||||
|
reloadMethod.invoke(reactHost, "react-native-update");
|
||||||
} catch (Throwable e) {
|
} catch (Throwable e) {
|
||||||
currentActivity.runOnUiThread(new Runnable() {
|
currentActivity.runOnUiThread(new Runnable() {
|
||||||
@Override
|
@Override
|
||||||
@@ -171,72 +171,54 @@ public class UpdateModuleImpl {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
promise.resolve(true);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public static void setNeedUpdate(UpdateContext updateContext, ReadableMap options,Promise promise) {
|
public static void setNeedUpdate(UpdateContext updateContext, ReadableMap options, Promise promise) {
|
||||||
try {
|
final String hash = options.getString("hash");
|
||||||
final String hash = options.getString("hash");
|
UiThreadUtil.runOnUiThread(new Runnable() {
|
||||||
if(hash==null || hash.isEmpty()){
|
@Override
|
||||||
promise.reject("hash不能为空");
|
public void run() {
|
||||||
return;
|
try {
|
||||||
}
|
updateContext.switchVersion(hash);
|
||||||
UiThreadUtil.runOnUiThread(new Runnable() {
|
promise.resolve(true);
|
||||||
@Override
|
} catch (Throwable err) {
|
||||||
public void run() {
|
promise.reject("switchVersionLater failed: "+err.getMessage());
|
||||||
try {
|
Log.e("pushy", "switchVersionLater failed", err);
|
||||||
updateContext.switchVersion(hash);
|
|
||||||
promise.resolve(true);
|
|
||||||
} catch (Throwable err) {
|
|
||||||
promise.reject("switchVersionLater failed:"+err.getMessage());
|
|
||||||
Log.e("pushy", "switchVersionLater failed", err);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
});
|
}
|
||||||
} catch (Exception e){
|
});
|
||||||
promise.reject("执行报错:"+e.getMessage());
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void markSuccess(UpdateContext updateContext,Promise promise) {
|
public static void markSuccess(UpdateContext updateContext, Promise promise) {
|
||||||
try {
|
UiThreadUtil.runOnUiThread(new Runnable() {
|
||||||
UiThreadUtil.runOnUiThread(new Runnable() {
|
@Override
|
||||||
@Override
|
public void run() {
|
||||||
public void run() {
|
updateContext.markSuccess();
|
||||||
updateContext.markSuccess();
|
promise.resolve(true);
|
||||||
promise.resolve(true);
|
}
|
||||||
}
|
});
|
||||||
});
|
|
||||||
} catch (Exception e){
|
|
||||||
promise.reject("执行报错:"+e.getMessage());
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void setUuid(UpdateContext updateContext, String uuid, Promise promise) {
|
public static void setUuid(UpdateContext updateContext, String uuid, Promise promise) {
|
||||||
try {
|
UiThreadUtil.runOnUiThread(new Runnable() {
|
||||||
UiThreadUtil.runOnUiThread(new Runnable() {
|
@Override
|
||||||
@Override
|
public void run() {
|
||||||
public void run() {
|
updateContext.setKv("uuid", uuid);
|
||||||
updateContext.setKv("uuid", uuid);
|
promise.resolve(true);
|
||||||
promise.resolve(true);
|
}
|
||||||
}
|
});
|
||||||
});
|
|
||||||
} catch (Exception e){
|
|
||||||
promise.reject("执行报错:"+e.getMessage());
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static boolean check(String json) {
|
public static boolean check(String json) {
|
||||||
ObjectMapper mapper = new ObjectMapper();
|
ObjectMapper mapper = new ObjectMapper();
|
||||||
try {
|
try {
|
||||||
mapper.readValue(json, Map.class);
|
mapper.readValue(json, Map.class);
|
||||||
System.out.println("String can be converted to Map");
|
|
||||||
return true;
|
return true;
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
System.out.println("String cannot be converted to Map");
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -246,12 +228,12 @@ public class UpdateModuleImpl {
|
|||||||
UiThreadUtil.runOnUiThread(new Runnable() {
|
UiThreadUtil.runOnUiThread(new Runnable() {
|
||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
if(!check(info)){
|
if (check(info)) {
|
||||||
updateContext.setKv("hash_" + hash, info);
|
|
||||||
promise.reject("校验报错:json字符串格式错误");
|
|
||||||
}else {
|
|
||||||
updateContext.setKv("hash_" + hash, info);
|
updateContext.setKv("hash_" + hash, info);
|
||||||
promise.resolve(true);
|
promise.resolve(true);
|
||||||
|
} else {
|
||||||
|
updateContext.setKv("hash_" + hash, info);
|
||||||
|
promise.reject("setLocalHashInfo failed: invalid json string");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
@@ -262,7 +244,7 @@ public class UpdateModuleImpl {
|
|||||||
if (check(value)) {
|
if (check(value)) {
|
||||||
promise.resolve(value);
|
promise.resolve(value);
|
||||||
} else {
|
} else {
|
||||||
promise.reject("校验报错:json字符串格式错误");
|
promise.reject("getLocalHashInfo failed: invalid json string");
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
1
endpoints_cresc.json
Normal file
1
endpoints_cresc.json
Normal file
@@ -0,0 +1 @@
|
|||||||
|
["https://cresc-server-pthxtmvcnf.ap-southeast-1.fcapp.run"]
|
@@ -78,6 +78,7 @@ RCT_EXPORT_MODULE(RCTPushy);
|
|||||||
BOOL needClearPushyInfo = ![curPackageVersion isEqualToString:packageVersion];
|
BOOL needClearPushyInfo = ![curPackageVersion isEqualToString:packageVersion];
|
||||||
if (needClearPushyInfo) {
|
if (needClearPushyInfo) {
|
||||||
[defaults setObject:nil forKey:keyPushyInfo];
|
[defaults setObject:nil forKey:keyPushyInfo];
|
||||||
|
[defaults setObject:nil forKey:keyHashInfo];
|
||||||
[defaults setObject:@(YES) forKey:KeyPackageUpdatedMarked];
|
[defaults setObject:@(YES) forKey:KeyPackageUpdatedMarked];
|
||||||
|
|
||||||
// ...need clear files later
|
// ...need clear files later
|
||||||
|
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "react-native-update",
|
"name": "react-native-update",
|
||||||
"version": "10.23.1",
|
"version": "10.25.0",
|
||||||
"description": "react-native hot update",
|
"description": "react-native hot update",
|
||||||
"main": "src/index",
|
"main": "src/index",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
@@ -74,6 +74,5 @@
|
|||||||
"react-native": "0.73",
|
"react-native": "0.73",
|
||||||
"ts-jest": "^29.2.5",
|
"ts-jest": "^29.2.5",
|
||||||
"typescript": "^5.6.3"
|
"typescript": "^5.6.3"
|
||||||
},
|
}
|
||||||
"packageManager": "yarn@1.22.21+sha1.1959a18351b811cdeedbd484a8f86c3cc3bbaf72"
|
|
||||||
}
|
}
|
||||||
|
112
src/client.ts
112
src/client.ts
@@ -1,5 +1,14 @@
|
|||||||
import { CheckResult, PushyOptions, ProgressData, EventType } from './type';
|
import { CheckResult, ClientOptions, ProgressData, EventType } from './type';
|
||||||
import { emptyObj, joinUrls, log, noop, promiseAny, testUrls } from './utils';
|
import {
|
||||||
|
assertDev,
|
||||||
|
assertWeb,
|
||||||
|
emptyObj,
|
||||||
|
joinUrls,
|
||||||
|
log,
|
||||||
|
noop,
|
||||||
|
promiseAny,
|
||||||
|
testUrls,
|
||||||
|
} from './utils';
|
||||||
import { EmitterSubscription, Platform } from 'react-native';
|
import { EmitterSubscription, Platform } from 'react-native';
|
||||||
import { PermissionsAndroid } from './permissions';
|
import { PermissionsAndroid } from './permissions';
|
||||||
import {
|
import {
|
||||||
@@ -15,31 +24,42 @@ import {
|
|||||||
isRolledBack,
|
isRolledBack,
|
||||||
} from './core';
|
} from './core';
|
||||||
|
|
||||||
const defaultServer = {
|
const SERVER_PRESETS = {
|
||||||
main: 'https://update.react-native.cn/api',
|
// cn
|
||||||
backups: ['https://update.reactnative.cn/api'],
|
Pushy: {
|
||||||
queryUrls: [
|
main: 'https://update.react-native.cn/api',
|
||||||
'https://gitee.com/sunnylqm/react-native-pushy/raw/master/endpoints.json',
|
backups: ['https://update.reactnative.cn/api'],
|
||||||
'https://cdn.jsdelivr.net/gh/reactnativecn/react-native-update@master/endpoints.json',
|
queryUrls: [
|
||||||
],
|
'https://gitee.com/sunnylqm/react-native-pushy/raw/master/endpoints.json',
|
||||||
|
'https://cdn.jsdelivr.net/gh/reactnativecn/react-native-update@master/endpoints.json',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
// i18n
|
||||||
|
Cresc: {
|
||||||
|
main: 'https://api.cresc.dev',
|
||||||
|
backups: ['https://api.cresc.app'],
|
||||||
|
queryUrls: [
|
||||||
|
'https://cdn.jsdelivr.net/gh/reactnativecn/react-native-update@master/endpoints_cresc.json',
|
||||||
|
],
|
||||||
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
if (Platform.OS === 'web') {
|
assertWeb();
|
||||||
console.warn('react-native-update 不支持 web 端热更,不会执行操作');
|
|
||||||
}
|
|
||||||
|
|
||||||
|
const defaultClientOptions: ClientOptions = {
|
||||||
|
appKey: '',
|
||||||
|
autoMarkSuccess: true,
|
||||||
|
updateStrategy: __DEV__ ? 'alwaysAlert' : 'alertUpdateAndIgnoreError',
|
||||||
|
checkStrategy: 'both',
|
||||||
|
logger: noop,
|
||||||
|
debug: false,
|
||||||
|
throwError: false,
|
||||||
|
};
|
||||||
|
|
||||||
|
// for China users
|
||||||
export class Pushy {
|
export class Pushy {
|
||||||
options: PushyOptions = {
|
options = defaultClientOptions;
|
||||||
appKey: '',
|
clientType: 'Pushy' | 'Cresc' = 'Pushy';
|
||||||
server: defaultServer,
|
|
||||||
autoMarkSuccess: true,
|
|
||||||
updateStrategy: __DEV__ ? 'alwaysAlert' : 'alertUpdateAndIgnoreError',
|
|
||||||
checkStrategy: 'both',
|
|
||||||
logger: noop,
|
|
||||||
debug: false,
|
|
||||||
throwError: false,
|
|
||||||
};
|
|
||||||
|
|
||||||
lastChecking?: number;
|
lastChecking?: number;
|
||||||
lastRespJson?: Promise<any>;
|
lastRespJson?: Promise<any>;
|
||||||
|
|
||||||
@@ -50,7 +70,7 @@ export class Pushy {
|
|||||||
|
|
||||||
static marked = false;
|
static marked = false;
|
||||||
static applyingUpdate = false;
|
static applyingUpdate = false;
|
||||||
version = cInfo.pushy;
|
version = cInfo.rnu;
|
||||||
loggerPromise = (() => {
|
loggerPromise = (() => {
|
||||||
let resolve: (value?: unknown) => void = () => {};
|
let resolve: (value?: unknown) => void = () => {};
|
||||||
const promise = new Promise(res => {
|
const promise = new Promise(res => {
|
||||||
@@ -62,12 +82,14 @@ export class Pushy {
|
|||||||
};
|
};
|
||||||
})();
|
})();
|
||||||
|
|
||||||
constructor(options: PushyOptions) {
|
constructor(options: ClientOptions) {
|
||||||
if (Platform.OS === 'ios' || Platform.OS === 'android') {
|
if (Platform.OS === 'ios' || Platform.OS === 'android') {
|
||||||
if (!options.appKey) {
|
if (!options.appKey) {
|
||||||
throw new Error('appKey is required');
|
throw new Error('appKey is required');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
this.clientType = new.target.name as 'Pushy' | 'Cresc';
|
||||||
|
this.options.server = SERVER_PRESETS[this.clientType];
|
||||||
this.setOptions(options);
|
this.setOptions(options);
|
||||||
if (isRolledBack) {
|
if (isRolledBack) {
|
||||||
this.report({
|
this.report({
|
||||||
@@ -79,7 +101,7 @@ export class Pushy {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
setOptions = (options: Partial<PushyOptions>) => {
|
setOptions = (options: Partial<ClientOptions>) => {
|
||||||
for (const [key, value] of Object.entries(options)) {
|
for (const [key, value] of Object.entries(options)) {
|
||||||
if (value !== undefined) {
|
if (value !== undefined) {
|
||||||
(this.options as any)[key] = value;
|
(this.options as any)[key] = value;
|
||||||
@@ -124,15 +146,24 @@ export class Pushy {
|
|||||||
return `${endpoint}/checkUpdate/${this.options.appKey}`;
|
return `${endpoint}/checkUpdate/${this.options.appKey}`;
|
||||||
};
|
};
|
||||||
static assertHash = (hash: string) => {
|
static assertHash = (hash: string) => {
|
||||||
if (!Pushy.downloadedHash) {
|
if (!this.downloadedHash) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (hash !== Pushy.downloadedHash) {
|
if (hash !== this.downloadedHash) {
|
||||||
log(`use downloaded hash ${Pushy.downloadedHash} first`);
|
log(`use downloaded hash ${Pushy.downloadedHash} first`);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
};
|
};
|
||||||
|
assertDebug = () => {
|
||||||
|
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.',
|
||||||
|
);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
};
|
||||||
markSuccess = () => {
|
markSuccess = () => {
|
||||||
if (Pushy.marked || __DEV__ || !isFirstTime) {
|
if (Pushy.marked || __DEV__ || !isFirstTime) {
|
||||||
return;
|
return;
|
||||||
@@ -142,10 +173,7 @@ export class Pushy {
|
|||||||
this.report({ type: 'markSuccess' });
|
this.report({ type: 'markSuccess' });
|
||||||
};
|
};
|
||||||
switchVersion = async (hash: string) => {
|
switchVersion = async (hash: string) => {
|
||||||
if (__DEV__) {
|
if (!assertDev('switchVersion()')) {
|
||||||
console.warn(
|
|
||||||
'您调用了switchVersion方法,但是当前是开发环境,不会进行任何操作。',
|
|
||||||
);
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (Pushy.assertHash(hash) && !Pushy.applyingUpdate) {
|
if (Pushy.assertHash(hash) && !Pushy.applyingUpdate) {
|
||||||
@@ -156,10 +184,7 @@ export class Pushy {
|
|||||||
};
|
};
|
||||||
|
|
||||||
switchVersionLater = async (hash: string) => {
|
switchVersionLater = async (hash: string) => {
|
||||||
if (__DEV__) {
|
if (!assertDev('switchVersionLater()')) {
|
||||||
console.warn(
|
|
||||||
'您调用了switchVersionLater方法,但是当前是开发环境,不会进行任何操作。',
|
|
||||||
);
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (Pushy.assertHash(hash)) {
|
if (Pushy.assertHash(hash)) {
|
||||||
@@ -168,21 +193,17 @@ export class Pushy {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
checkUpdate = async (extra?: Record<string, any>) => {
|
checkUpdate = async (extra?: Record<string, any>) => {
|
||||||
if (__DEV__ && !this.options.debug) {
|
if (!this.assertDebug()) {
|
||||||
console.info(
|
|
||||||
'您当前处于开发环境且未启用 debug,不会进行热更检查。如需在开发环境中调试热更,请在 client 中设置 debug 为 true',
|
|
||||||
);
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (Platform.OS === 'web') {
|
if (!assertWeb()) {
|
||||||
console.warn('web 端不支持热更新检查');
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (
|
if (
|
||||||
this.options.beforeCheckUpdate &&
|
this.options.beforeCheckUpdate &&
|
||||||
(await this.options.beforeCheckUpdate()) === false
|
(await this.options.beforeCheckUpdate()) === false
|
||||||
) {
|
) {
|
||||||
log('beforeCheckUpdate 返回 false, 忽略检查');
|
log('beforeCheckUpdate returned false, skipping check');
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
const now = Date.now();
|
const now = Date.now();
|
||||||
@@ -310,7 +331,7 @@ export class Pushy {
|
|||||||
this.options.beforeDownloadUpdate &&
|
this.options.beforeDownloadUpdate &&
|
||||||
(await this.options.beforeDownloadUpdate(info)) === false
|
(await this.options.beforeDownloadUpdate(info)) === false
|
||||||
) {
|
) {
|
||||||
log('beforeDownloadUpdate 返回 false, 忽略下载');
|
log('beforeDownloadUpdate returned false, skipping download');
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (!info.update || !hash) {
|
if (!info.update || !hash) {
|
||||||
@@ -489,3 +510,6 @@ export class Pushy {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// for international users
|
||||||
|
export class Cresc extends Pushy {}
|
||||||
|
@@ -1,6 +1,6 @@
|
|||||||
import { createContext, useContext } from 'react';
|
import { createContext, useContext } from 'react';
|
||||||
import { CheckResult, ProgressData } from './type';
|
import { CheckResult, ProgressData } from './type';
|
||||||
import { Pushy } from './client';
|
import { Pushy, Cresc } from './client';
|
||||||
|
|
||||||
const noop = () => {};
|
const noop = () => {};
|
||||||
const asyncNoop = () => Promise.resolve();
|
const asyncNoop = () => Promise.resolve();
|
||||||
@@ -19,7 +19,7 @@ export const defaultContext = {
|
|||||||
packageVersion: '',
|
packageVersion: '',
|
||||||
};
|
};
|
||||||
|
|
||||||
export const PushyContext = createContext<{
|
export const UpdateContext = createContext<{
|
||||||
checkUpdate: () => Promise<void>;
|
checkUpdate: () => Promise<void>;
|
||||||
switchVersion: () => Promise<void>;
|
switchVersion: () => Promise<void>;
|
||||||
switchVersionLater: () => Promise<void>;
|
switchVersionLater: () => Promise<void>;
|
||||||
@@ -35,10 +35,14 @@ export const PushyContext = createContext<{
|
|||||||
parseTestQrCode: (code: string) => boolean;
|
parseTestQrCode: (code: string) => boolean;
|
||||||
currentHash: string;
|
currentHash: string;
|
||||||
packageVersion: string;
|
packageVersion: string;
|
||||||
client?: Pushy;
|
client?: Pushy | Cresc;
|
||||||
progress?: ProgressData;
|
progress?: ProgressData;
|
||||||
updateInfo?: CheckResult;
|
updateInfo?: CheckResult;
|
||||||
lastError?: Error;
|
lastError?: Error;
|
||||||
}>(defaultContext);
|
}>(defaultContext);
|
||||||
|
|
||||||
export const usePushy = () => useContext(PushyContext);
|
export const useUpdate = () => useContext(UpdateContext);
|
||||||
|
|
||||||
|
export const usePushy = useUpdate;
|
||||||
|
|
||||||
|
export const useCresc = useUpdate;
|
||||||
|
14
src/core.ts
14
src/core.ts
@@ -13,8 +13,12 @@ export const PushyModule =
|
|||||||
? require('./NativePushy').default
|
? require('./NativePushy').default
|
||||||
: NativeModules.Pushy;
|
: NativeModules.Pushy;
|
||||||
|
|
||||||
|
export const UpdateModule = PushyModule;
|
||||||
|
|
||||||
if (!PushyModule) {
|
if (!PushyModule) {
|
||||||
throw new Error('react-native-update 模块无法加载,请尝试重新编译');
|
throw new Error(
|
||||||
|
'Failed to load react-native-update native module, please try to recompile',
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
const PushyConstants = isTurboModuleEnabled
|
const PushyConstants = isTurboModuleEnabled
|
||||||
@@ -31,12 +35,6 @@ export const isRolledBack: boolean = typeof rolledBackVersion === 'string';
|
|||||||
export const buildTime: string = PushyConstants.buildTime;
|
export const buildTime: string = PushyConstants.buildTime;
|
||||||
let uuid = PushyConstants.uuid;
|
let uuid = PushyConstants.uuid;
|
||||||
|
|
||||||
if (Platform.OS === 'android' && !PushyConstants.isUsingBundleUrl) {
|
|
||||||
console.warn(
|
|
||||||
'react-native-update 没有检测到 Bundle URL 的配置,这可能是因为您使用了某种懒加载机制(比如使用 expo,可忽略本警告),或是 Bundle URL 的配置不正确(请对照文档检查)',
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
export function setLocalHashInfo(hash: string, info: Record<string, any>) {
|
export function setLocalHashInfo(hash: string, info: Record<string, any>) {
|
||||||
PushyModule.setLocalHashInfo(hash, JSON.stringify(info));
|
PushyModule.setLocalHashInfo(hash, JSON.stringify(info));
|
||||||
}
|
}
|
||||||
@@ -63,7 +61,7 @@ if (!uuid) {
|
|||||||
log('uuid: ' + uuid);
|
log('uuid: ' + uuid);
|
||||||
|
|
||||||
export const cInfo = {
|
export const cInfo = {
|
||||||
pushy: require('../package.json').version,
|
rnu: require('../package.json').version,
|
||||||
rn: RNVersion,
|
rn: RNVersion,
|
||||||
os: Platform.OS + ' ' + Platform.Version,
|
os: Platform.OS + ' ' + Platform.Version,
|
||||||
uuid,
|
uuid,
|
||||||
|
@@ -1,4 +1,4 @@
|
|||||||
export { Pushy } from './client';
|
export { Pushy, Cresc } from './client';
|
||||||
export { PushyContext, usePushy } from './context';
|
export { UpdateContext, usePushy, useCresc, useUpdate } from './context';
|
||||||
export { PushyProvider } from './provider';
|
export { PushyProvider, UpdateProvider } from './provider';
|
||||||
export { PushyModule } from './core';
|
export { PushyModule, UpdateModule } from './core';
|
||||||
|
@@ -12,22 +12,24 @@ import {
|
|||||||
Platform,
|
Platform,
|
||||||
Linking,
|
Linking,
|
||||||
} from 'react-native';
|
} from 'react-native';
|
||||||
import { Pushy } from './client';
|
import { Pushy, Cresc } from './client';
|
||||||
import { currentVersion, packageVersion, getCurrentVersionInfo } from './core';
|
import { currentVersion, packageVersion, getCurrentVersionInfo } from './core';
|
||||||
import { CheckResult, ProgressData, PushyTestPayload } from './type';
|
import { CheckResult, ProgressData, UpdateTestPayload } from './type';
|
||||||
import { PushyContext } from './context';
|
import { UpdateContext } from './context';
|
||||||
import { URL } from 'react-native-url-polyfill';
|
import { URL } from 'react-native-url-polyfill';
|
||||||
import { isInRollout } from './isInRollout';
|
import { isInRollout } from './isInRollout';
|
||||||
import { log } from './utils';
|
import { log } from './utils';
|
||||||
|
|
||||||
export const PushyProvider = ({
|
export const UpdateProvider = ({
|
||||||
client,
|
client,
|
||||||
children,
|
children,
|
||||||
}: {
|
}: {
|
||||||
client: Pushy;
|
client: Pushy | Cresc;
|
||||||
children: ReactNode;
|
children: ReactNode;
|
||||||
}) => {
|
}) => {
|
||||||
|
client = useRef(client).current;
|
||||||
const { options } = client;
|
const { options } = client;
|
||||||
|
|
||||||
const stateListener = useRef<NativeEventSubscription>();
|
const stateListener = useRef<NativeEventSubscription>();
|
||||||
const [updateInfo, setUpdateInfo] = useState<CheckResult>();
|
const [updateInfo, setUpdateInfo] = useState<CheckResult>();
|
||||||
const updateInfoRef = useRef(updateInfo);
|
const updateInfoRef = useRef(updateInfo);
|
||||||
@@ -239,10 +241,7 @@ export const PushyProvider = ({
|
|||||||
const markSuccess = client.markSuccess;
|
const markSuccess = client.markSuccess;
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (__DEV__ && !options.debug) {
|
if (!client.assertDebug()) {
|
||||||
console.info(
|
|
||||||
'您当前处于开发环境且未启用debug,不会进行热更检查。如需在开发环境中调试热更,请在client中设置debug为true',
|
|
||||||
);
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
const { checkStrategy, dismissErrorAfter, autoMarkSuccess } = options;
|
const { checkStrategy, dismissErrorAfter, autoMarkSuccess } = options;
|
||||||
@@ -272,11 +271,11 @@ export const PushyProvider = ({
|
|||||||
stateListener.current && stateListener.current.remove();
|
stateListener.current && stateListener.current.remove();
|
||||||
clearTimeout(dismissErrorTimer);
|
clearTimeout(dismissErrorTimer);
|
||||||
};
|
};
|
||||||
}, [checkUpdate, options, dismissError, markSuccess]);
|
}, [checkUpdate, options, dismissError, markSuccess, client]);
|
||||||
|
|
||||||
const parseTestPayload = useCallback(
|
const parseTestPayload = useCallback(
|
||||||
(payload: PushyTestPayload) => {
|
(payload: UpdateTestPayload) => {
|
||||||
if (payload && payload.type && payload.type.startsWith('__rnPushy')) {
|
if (payload && payload.type && payload.type.startsWith('__rnUpdate')) {
|
||||||
const logger = options.logger || (() => {});
|
const logger = options.logger || (() => {});
|
||||||
options.logger = ({ type, data }) => {
|
options.logger = ({ type, data }) => {
|
||||||
logger({ type, data });
|
logger({ type, data });
|
||||||
@@ -286,8 +285,8 @@ export const PushyProvider = ({
|
|||||||
checkUpdate({ extra: { toHash: payload.data } }).then(() => {
|
checkUpdate({ extra: { toHash: payload.data } }).then(() => {
|
||||||
if (updateInfoRef.current && updateInfoRef.current.upToDate) {
|
if (updateInfoRef.current && updateInfoRef.current.upToDate) {
|
||||||
Alert.alert(
|
Alert.alert(
|
||||||
'提示',
|
'Info',
|
||||||
'当前尚未检测到更新版本,如果是首次扫码,请等待服务器端生成补丁包后再试(约10秒)',
|
'No update found, please wait 10s for the server to generate the patch package',
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
options.logger = logger;
|
options.logger = logger;
|
||||||
@@ -301,7 +300,7 @@ export const PushyProvider = ({
|
|||||||
);
|
);
|
||||||
|
|
||||||
const parseTestQrCode = useCallback(
|
const parseTestQrCode = useCallback(
|
||||||
(code: string | PushyTestPayload) => {
|
(code: string | UpdateTestPayload) => {
|
||||||
try {
|
try {
|
||||||
const payload = typeof code === 'string' ? JSON.parse(code) : code;
|
const payload = typeof code === 'string' ? JSON.parse(code) : code;
|
||||||
return parseTestPayload(payload);
|
return parseTestPayload(payload);
|
||||||
@@ -335,7 +334,7 @@ export const PushyProvider = ({
|
|||||||
}, [parseTestPayload]);
|
}, [parseTestPayload]);
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<PushyContext.Provider
|
<UpdateContext.Provider
|
||||||
value={{
|
value={{
|
||||||
checkUpdate,
|
checkUpdate,
|
||||||
switchVersion,
|
switchVersion,
|
||||||
@@ -354,6 +353,8 @@ export const PushyProvider = ({
|
|||||||
parseTestQrCode,
|
parseTestQrCode,
|
||||||
}}>
|
}}>
|
||||||
{children}
|
{children}
|
||||||
</PushyContext.Provider>
|
</UpdateContext.Provider>
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const PushyProvider = UpdateProvider;
|
||||||
|
10
src/type.ts
10
src/type.ts
@@ -44,7 +44,7 @@ export type EventType =
|
|||||||
export interface EventData {
|
export interface EventData {
|
||||||
currentVersion: string;
|
currentVersion: string;
|
||||||
cInfo: {
|
cInfo: {
|
||||||
pushy: string;
|
rnu: string;
|
||||||
rn: string;
|
rn: string;
|
||||||
os: string;
|
os: string;
|
||||||
uuid: string;
|
uuid: string;
|
||||||
@@ -65,15 +65,15 @@ export type UpdateEventsLogger = ({
|
|||||||
data: EventData;
|
data: EventData;
|
||||||
}) => void;
|
}) => void;
|
||||||
|
|
||||||
export interface PushyServerConfig {
|
export interface UpdateServerConfig {
|
||||||
main: string;
|
main: string;
|
||||||
backups?: string[];
|
backups?: string[];
|
||||||
queryUrls?: string[];
|
queryUrls?: string[];
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface PushyOptions {
|
export interface ClientOptions {
|
||||||
appKey: string;
|
appKey: string;
|
||||||
server?: PushyServerConfig;
|
server?: UpdateServerConfig;
|
||||||
logger?: UpdateEventsLogger;
|
logger?: UpdateEventsLogger;
|
||||||
updateStrategy?:
|
updateStrategy?:
|
||||||
| 'alwaysAlert'
|
| 'alwaysAlert'
|
||||||
@@ -90,7 +90,7 @@ export interface PushyOptions {
|
|||||||
beforeDownloadUpdate?: (info: CheckResult) => Promise<boolean>;
|
beforeDownloadUpdate?: (info: CheckResult) => Promise<boolean>;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface PushyTestPayload {
|
export interface UpdateTestPayload {
|
||||||
type: '__rnPushyVersionHash' | string | null;
|
type: '__rnPushyVersionHash' | string | null;
|
||||||
data: any;
|
data: any;
|
||||||
}
|
}
|
||||||
|
22
src/utils.ts
22
src/utils.ts
@@ -1,7 +1,7 @@
|
|||||||
import { Platform } from 'react-native';
|
import { Platform } from 'react-native';
|
||||||
|
|
||||||
export function log(...args: any[]) {
|
export function log(...args: any[]) {
|
||||||
console.log('pushy: ', ...args);
|
console.log('react-native-update: ', ...args);
|
||||||
}
|
}
|
||||||
|
|
||||||
export function promiseAny<T>(promises: Promise<T>[]) {
|
export function promiseAny<T>(promises: Promise<T>[]) {
|
||||||
@@ -84,3 +84,23 @@ export const testUrls = async (urls?: string[]) => {
|
|||||||
log('all ping failed, use first url:', urls[0]);
|
log('all ping failed, use first url:', urls[0]);
|
||||||
return urls[0];
|
return urls[0];
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const assertWeb = () => {
|
||||||
|
if (Platform.OS === 'web') {
|
||||||
|
console.warn(
|
||||||
|
'react-native-update does not support the Web platform and will not perform any operations',
|
||||||
|
);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
|
||||||
|
export const assertDev = (matter: string) => {
|
||||||
|
if (__DEV__) {
|
||||||
|
console.warn(
|
||||||
|
`${matter} is not supported in development environment; no action taken.`,
|
||||||
|
);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
};
|
||||||
|
Reference in New Issue
Block a user