import { Base64 } from '@rocket.chat/base64'; import type { EncryptedContent } from '@rocket.chat/core-typings'; type DecodedContent = { kid: string; iv: Uint8Array; ciphertext: Uint8Array; }; interface ISlice { slice(start: number, end?: number): this; } /** * Splits a slice of data into two parts at the specified index. * @param data The data to split. * @param index The index at which to split the data. * @returns A tuple containing the two parts of the split data. */ const split = (data: T, index: number): [T, T] => [data.slice(0, index), data.slice(index)]; /** * Decodes an encrypted content string in the format "kid + base64(iv + ciphertext)". * @param payload The encrypted content string. * @returns An object containing the key ID (kid), initialization vector (iv), and ciphertext. */ const decodeV1EncryptedContent = ( payload: Omit, 'algorithm'>, ): DecodedContent => { if (payload.ciphertext.length < 12) { throw new Error('Invalid v1 ciphertext: too short for kid extraction'); } const [kid, base64] = split(payload.ciphertext, 12); const decoded = Base64.decode(base64); if (decoded.length < 16) { throw new Error('Invalid v1 ciphertext: too short for iv extraction'); } const [iv, ciphertext] = split(decoded, 16); return { kid, iv, ciphertext, }; }; /** * Decodes an encrypted content object with separate fields for kid, iv, and ciphertext. * @param payload The encrypted content object. * @returns An object containing the key ID (kid), initialization vector (iv), and ciphertext. */ const decodeV2EncryptedContent = (payload: Extract): DecodedContent => { if (!payload.kid || !payload.iv || !payload.ciphertext) { throw new Error('Invalid v2 payload: kid, iv, and ciphertext must be non-empty'); } const iv = Base64.decode(payload.iv); const ciphertext = Base64.decode(payload.ciphertext); return { kid: payload.kid, iv, ciphertext }; }; const normalizePayload = (payload: string | EncryptedContent): EncryptedContent => { if (typeof payload === 'string') { return { algorithm: 'rc.v1.aes-sha2', ciphertext: payload } as const; } return payload; }; /** * Parses encrypted content from either a string or an object and decodes it into its components. * @param payload The encrypted content, either as a string or an object. * @returns An object containing the key ID (kid), initialization vector (iv), and ciphertext. * @throws Will throw an error if the encryption algorithm is unsupported. */ export const decodeEncryptedContent = (payload: string | EncryptedContent): DecodedContent => { payload = normalizePayload(payload); const { algorithm } = payload; switch (algorithm) { case 'rc.v1.aes-sha2': return decodeV1EncryptedContent(payload); case 'rc.v2.aes-sha2': return decodeV2EncryptedContent(payload); default: throw new Error(`Unsupported encryption algorithm: ${algorithm}`); } };