check all

Author: devksingh4

src/api/functions/encryption.ts

@@ -10,6 +10,8 @@ const HASH_FUNCTION = "sha512";
 export const INVALID_DECRYPTION_MESSAGE =
   "Could not decrypt data (check that the encryption secret is correct).";
 
+export const CORRUPTED_DATA_MESSAGE = "Encrypted data is corrupted.";
+
 export function encrypt({
   plaintext,
   encryptionSecret,
@@ -72,7 +74,7 @@ export function decrypt({
   const candidate = decryptedBuffer.toString("utf8");
   if (candidate.substring(0, VALID_PREFIX.length) !== VALID_PREFIX) {
     throw new DecryptionError({
-      message: "Encrypted data is corrupted.",
+      message: CORRUPTED_DATA_MESSAGE,
     });
   }
   return candidate.substring(VALID_PREFIX.length, candidate.length);

src/api/functions/redisCache.ts

@@ -1,7 +1,12 @@
 import { DecryptionError } from "common/errors/index.js";
 import type RedisModule from "ioredis";
 import { z } from "zod";
-import { decrypt, encrypt, INVALID_DECRYPTION_MESSAGE } from "./encryption.js";
+import {
+  CORRUPTED_DATA_MESSAGE,
+  decrypt,
+  encrypt,
+  INVALID_DECRYPTION_MESSAGE,
+} from "./encryption.js";
 import type pino from "pino";
 import { type FastifyBaseLogger } from "fastify";
 
@@ -53,7 +58,8 @@ export async function getKey<T extends object>({
   } catch (e) {
     if (
       e instanceof DecryptionError &&
-      e.message === INVALID_DECRYPTION_MESSAGE
+      (e.message === INVALID_DECRYPTION_MESSAGE ||
+        e.message === CORRUPTED_DATA_MESSAGE)
     ) {
       logger.info(
         `Invalid decryption, deleting old Redis key and continuing...`,