83 lines
2.4 KiB
TypeScript
83 lines
2.4 KiB
TypeScript
// Copyright 2022 Signal Messenger, LLC
|
|
// SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
import type { LoggerType } from '../../types/Logging';
|
|
import * as Errors from '../../types/errors';
|
|
import { sleepForRateLimitRetryAfterTime } from './sleepForRateLimitRetryAfterTime';
|
|
import { getHttpErrorCode } from './getHttpErrorCode';
|
|
import { strictAssert } from '../../util/assert';
|
|
import { findRetryAfterTimeFromError } from './findRetryAfterTimeFromError';
|
|
import { SendMessageProtoError } from '../../textsecure/Errors';
|
|
|
|
export function maybeExpandErrors(error: unknown): ReadonlyArray<unknown> {
|
|
if (error instanceof SendMessageProtoError) {
|
|
return error.errors || [error];
|
|
}
|
|
|
|
return [error];
|
|
}
|
|
|
|
// Note: toThrow is very important to preserve the full error for outer handlers. For
|
|
// example, the catch handler check for Safety Number Errors in conversationJobQueue.
|
|
export async function handleMultipleSendErrors({
|
|
errors,
|
|
isFinalAttempt,
|
|
log,
|
|
markFailed,
|
|
timeRemaining,
|
|
toThrow,
|
|
}: Readonly<{
|
|
errors: ReadonlyArray<unknown>;
|
|
isFinalAttempt: boolean;
|
|
log: Pick<LoggerType, 'info'>;
|
|
markFailed?: (() => void) | (() => Promise<void>);
|
|
timeRemaining: number;
|
|
toThrow: unknown;
|
|
}>): Promise<void> {
|
|
strictAssert(errors.length, 'Expected at least one error');
|
|
|
|
const formattedErrors: Array<string> = [];
|
|
|
|
let retryAfterError: unknown;
|
|
let longestRetryAfterTime = -Infinity;
|
|
|
|
let serverAskedUsToStop = false;
|
|
|
|
errors.forEach(error => {
|
|
formattedErrors.push(Errors.toLogFormat(error));
|
|
|
|
const errorCode = getHttpErrorCode(error);
|
|
if (errorCode === 413 || errorCode === 429) {
|
|
const retryAfterTime = findRetryAfterTimeFromError(error);
|
|
if (retryAfterTime > longestRetryAfterTime) {
|
|
retryAfterError = error;
|
|
longestRetryAfterTime = retryAfterTime;
|
|
}
|
|
} else if (errorCode === 508 || errorCode === 400) {
|
|
serverAskedUsToStop = true;
|
|
}
|
|
});
|
|
|
|
log.info(
|
|
`${formattedErrors.length} send error(s): ${formattedErrors.join(',')}`
|
|
);
|
|
|
|
if (isFinalAttempt || serverAskedUsToStop) {
|
|
await markFailed?.();
|
|
}
|
|
|
|
if (serverAskedUsToStop) {
|
|
log.info('server responded with 508 or 400. Giving up on this job');
|
|
return;
|
|
}
|
|
|
|
if (retryAfterError && !isFinalAttempt) {
|
|
await sleepForRateLimitRetryAfterTime({
|
|
err: retryAfterError,
|
|
log,
|
|
timeRemaining,
|
|
});
|
|
}
|
|
|
|
throw toThrow;
|
|
}
|