Stop retrying message send on 400 response
This commit is contained in:
parent
3aa958533b
commit
5c72c785a0
|
@ -53,7 +53,7 @@ export async function handleMultipleSendErrors({
|
||||||
retryAfterError = error;
|
retryAfterError = error;
|
||||||
longestRetryAfterTime = retryAfterTime;
|
longestRetryAfterTime = retryAfterTime;
|
||||||
}
|
}
|
||||||
} else if (errorCode === 508) {
|
} else if (errorCode === 508 || errorCode === 400) {
|
||||||
serverAskedUsToStop = true;
|
serverAskedUsToStop = true;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
@ -67,7 +67,7 @@ export async function handleMultipleSendErrors({
|
||||||
}
|
}
|
||||||
|
|
||||||
if (serverAskedUsToStop) {
|
if (serverAskedUsToStop) {
|
||||||
log.info('server responded with 508. Giving up on this job');
|
log.info('server responded with 508 or 400. Giving up on this job');
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -731,6 +731,11 @@ export function _shouldFailSend(error: unknown, logId: string): boolean {
|
||||||
// SendMessageChallengeError
|
// SendMessageChallengeError
|
||||||
// MessageError
|
// MessageError
|
||||||
if (isRecord(error) && typeof error.code === 'number') {
|
if (isRecord(error) && typeof error.code === 'number') {
|
||||||
|
if (error.code === 400) {
|
||||||
|
logError('Invalid request, failing.');
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
if (error.code === 401) {
|
if (error.code === 401) {
|
||||||
logError('Permissions error, failing.');
|
logError('Permissions error, failing.');
|
||||||
return true;
|
return true;
|
||||||
|
|
Loading…
Reference in New Issue