Fixes unhandled promise rejection error while sending push (#4172)
This commit is contained in:
@@ -19,7 +19,9 @@ export class PushRouter extends PromiseRouter {
|
|||||||
const promise = new Promise((_resolve) => {
|
const promise = new Promise((_resolve) => {
|
||||||
resolve = _resolve;
|
resolve = _resolve;
|
||||||
});
|
});
|
||||||
pushController.sendPush(req.body, where, req.config, req.auth, (pushStatusId) => {
|
let pushStatusId;
|
||||||
|
pushController.sendPush(req.body, where, req.config, req.auth, (objectId) => {
|
||||||
|
pushStatusId = objectId;
|
||||||
resolve({
|
resolve({
|
||||||
headers: {
|
headers: {
|
||||||
'X-Parse-Push-Status-Id': pushStatusId
|
'X-Parse-Push-Status-Id': pushStatusId
|
||||||
@@ -28,7 +30,9 @@ export class PushRouter extends PromiseRouter {
|
|||||||
result: true
|
result: true
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}).catch(req.config.loggerController.error);
|
}).catch((err) => {
|
||||||
|
req.config.loggerController.error(`_PushStatus ${pushStatusId}: error while sending push`, err);
|
||||||
|
});
|
||||||
return promise;
|
return promise;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -247,7 +247,6 @@ export function pushStatusHandler(config, objectId = newObjectId(config.objectId
|
|||||||
status: 'failed',
|
status: 'failed',
|
||||||
updatedAt: new Date()
|
updatedAt: new Date()
|
||||||
}
|
}
|
||||||
logger.warn(`_PushStatus ${objectId}: error while sending push`, err);
|
|
||||||
return handler.update({ objectId }, update);
|
return handler.update({ objectId }, update);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user