mirror of
https://gitcode.com/gh_mirrors/re/react-native-pushy.git
synced 2025-11-03 06:43:10 +08:00
v9.2.3
This commit is contained in:
39
lib/utils.ts
39
lib/utils.ts
@@ -8,7 +8,7 @@ export function promiseAny<T>(promises: Promise<T>[]) {
|
|||||||
return new Promise<T>((resolve, reject) => {
|
return new Promise<T>((resolve, reject) => {
|
||||||
let count = 0;
|
let count = 0;
|
||||||
|
|
||||||
promises.forEach(promise => {
|
promises.forEach((promise) => {
|
||||||
Promise.resolve(promise)
|
Promise.resolve(promise)
|
||||||
.then(resolve)
|
.then(resolve)
|
||||||
.catch(() => {
|
.catch(() => {
|
||||||
@@ -30,17 +30,44 @@ export function assertRelease() {
|
|||||||
const ping =
|
const ping =
|
||||||
Platform.OS === 'web'
|
Platform.OS === 'web'
|
||||||
? Promise.resolve
|
? Promise.resolve
|
||||||
: async (url: string) =>
|
: async (url: string) => {
|
||||||
Promise.race([
|
let pingFinished = false;
|
||||||
|
return Promise.race([
|
||||||
fetch(url, {
|
fetch(url, {
|
||||||
method: 'HEAD',
|
method: 'HEAD',
|
||||||
}).then(({ status }) => (status === 200 ? url : null)),
|
})
|
||||||
new Promise(r => setTimeout(() => r(null), 2000)),
|
.then(({ status, statusText }) => {
|
||||||
|
pingFinished = true;
|
||||||
|
if (status === 200) {
|
||||||
|
return url;
|
||||||
|
}
|
||||||
|
logger('ping failed', url, status, statusText);
|
||||||
|
return null;
|
||||||
|
})
|
||||||
|
.catch((e) => {
|
||||||
|
pingFinished = true;
|
||||||
|
logger('ping error', url, e);
|
||||||
|
return null;
|
||||||
|
}),
|
||||||
|
new Promise((r) =>
|
||||||
|
setTimeout(() => {
|
||||||
|
r(null);
|
||||||
|
if (!pingFinished) {
|
||||||
|
logger('ping timeout', url);
|
||||||
|
}
|
||||||
|
}, 2000),
|
||||||
|
),
|
||||||
]);
|
]);
|
||||||
|
};
|
||||||
|
|
||||||
export const testUrls = async (urls?: string[]) => {
|
export const testUrls = async (urls?: string[]) => {
|
||||||
if (!urls?.length) {
|
if (!urls?.length) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
return promiseAny(urls.map(ping)).catch(() => null);
|
const ret = await promiseAny(urls.map(ping));
|
||||||
|
if (ret) {
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
logger('all ping failed, use first url:', urls[0]);
|
||||||
|
return urls[0];
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "react-native-update",
|
"name": "react-native-update",
|
||||||
"version": "9.2.2",
|
"version": "9.2.3",
|
||||||
"description": "react-native hot update",
|
"description": "react-native hot update",
|
||||||
"main": "lib/index.ts",
|
"main": "lib/index.ts",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
|||||||
Reference in New Issue
Block a user