diff --git a/js/modules/types/message.js b/js/modules/types/message.js index 3de94fa56c..c428cadc8c 100644 --- a/js/modules/types/message.js +++ b/js/modules/types/message.js @@ -195,11 +195,13 @@ exports.createImporter = (writeExistingAttachmentData) => { throw new TypeError('"writeExistingAttachmentData" must be a function'); } - return async (message) => { - if (!exports.isValid(message)) { - throw new TypeError('"message" is not valid'); + return async (rawMessage) => { + if (!exports.isValid(rawMessage)) { + throw new TypeError('"rawMessage" is not valid'); } + const message = exports.initializeSchemaVersion(rawMessage); + const { attachments } = message; const hasAttachments = attachments && attachments.length > 0; if (!hasAttachments) {