diff --git a/packages/backend-core/src/db/errors.ts b/packages/backend-core/src/db/errors.ts index db536502b2..17f76c667b 100644 --- a/packages/backend-core/src/db/errors.ts +++ b/packages/backend-core/src/db/errors.ts @@ -1,9 +1,14 @@ -export function is409Error(error: any) { +export function checkErrorCode(error: any, code: number) { + const stringCode = code.toString() if (typeof error === "object") { - return error.status === 409 || error.message?.includes("409") + return error.status === code || error.message?.includes(stringCode) } else if (typeof error === "number") { - return error === 409 + return error === code } else if (typeof error === "string") { - return error.includes("409") + return error.includes(stringCode) } } + +export function isDocumentConflictError(error: any) { + return checkErrorCode(error, 409) +} diff --git a/packages/server/src/sdk/app/applications/sync.ts b/packages/server/src/sdk/app/applications/sync.ts index 559b0733da..d8807251a1 100644 --- a/packages/server/src/sdk/app/applications/sync.ts +++ b/packages/server/src/sdk/app/applications/sync.ts @@ -102,7 +102,7 @@ export async function syncUsersToAllApps(userIds: string[]) { const failed = resp.filter(promise => promise.status === "rejected") const reasons = failed .map(fail => (fail as PromiseRejectedResult).reason) - .filter(reason => !dbCore.is409Error(reason)) + .filter(reason => !dbCore.isDocumentConflictError(reason)) if (reasons.length > 0) { logging.logWarn("Failed to sync users to apps", reasons) }