Parse phone numbers into e164 as part of schema upgrade

js/modules/types/contact.js

@@ -2,6 +2,7 @@ const { omit, compact, map } = require('lodash');
 
 const { toLogFormat } = require('./errors');
 const { SignalService } = require('../../../ts/protobuf');
+const { parsePhoneNumber } = require('../../../ts/util/parsePhoneNumber');
 
 const DEFAULT_PHONE_TYPE = SignalService.DataMessage.Contact.Phone.Type.HOME;
 const DEFAULT_EMAIL_TYPE = SignalService.DataMessage.Contact.Email.Type.HOME;
@@ -12,7 +13,7 @@ exports.parseAndWriteAvatar = upgradeAttachment => async (
   contact,
   context = {}
 ) => {
-  const { message } = context;
+  const { message, regionCode } = context;
   const { avatar } = contact;
 
   // This is to ensure that an omit() call doesn't pull in prototype props/methods
@@ -28,7 +29,7 @@ exports.parseAndWriteAvatar = upgradeAttachment => async (
       : omit(contactShallowCopy, ['avatar']);
 
   // eliminates empty numbers, emails, and addresses; adds type if not provided
-  const parsedContact = parseContact(contactWithUpdatedAvatar);
+  const parsedContact = parseContact(contactWithUpdatedAvatar, { regionCode });
 
   const error = exports._validate(parsedContact, {
     messageId: idForLogging(message),
@@ -43,12 +44,17 @@ exports.parseAndWriteAvatar = upgradeAttachment => async (
   return parsedContact;
 };
 
-function parseContact(contact) {
+function parseContact(contact, options = {}) {
+  const { regionCode } = options;
+
+  const boundParsePhone = phoneNumber =>
+    parsePhoneItem(phoneNumber, { regionCode });
+
   return Object.assign(
     {},
     omit(contact, ['avatar', 'number', 'email', 'address']),
     parseAvatar(contact.avatar),
-    createArrayKey('number', compact(map(contact.number, parsePhoneItem))),
+    createArrayKey('number', compact(map(contact.number, boundParsePhone))),
     createArrayKey('email', compact(map(contact.email, parseEmailItem))),
     createArrayKey('address', compact(map(contact.address, parseAddress)))
   );
@@ -81,13 +87,16 @@ exports._validate = (contact, options = {}) => {
   return null;
 };
 
-function parsePhoneItem(item) {
+function parsePhoneItem(item, options = {}) {
+  const { regionCode } = options;
+
   if (!item.value) {
     return null;
   }
 
   return Object.assign({}, item, {
     type: item.type || DEFAULT_PHONE_TYPE,
+    value: parsePhoneNumber(item.value, { regionCode }),
   });
 }
 

js/modules/types/message.js

@@ -255,10 +255,16 @@ const VERSIONS = [
 exports.CURRENT_SCHEMA_VERSION = VERSIONS.length - 1;
 
 // UpgradeStep
-exports.upgradeSchema = async (rawMessage, { writeNewAttachmentData } = {}) => {
+exports.upgradeSchema = async (
+  rawMessage,
+  { writeNewAttachmentData, getRegionCode } = {}
+) => {
   if (!isFunction(writeNewAttachmentData)) {
     throw new TypeError('`context.writeNewAttachmentData` is required');
   }
+  if (!isFunction(getRegionCode)) {
+    throw new TypeError('`context.getRegionCode` is required');
+  }
 
   let message = rawMessage;
   // eslint-disable-next-line no-restricted-syntax
@@ -266,7 +272,10 @@ exports.upgradeSchema = async (rawMessage, { writeNewAttachmentData } = {}) => {
     // We really do want this intra-loop await because this is a chained async action,
     //   each step dependent on the previous
     // eslint-disable-next-line no-await-in-loop
-    message = await currentVersion(message, { writeNewAttachmentData });
+    message = await currentVersion(message, {
+      writeNewAttachmentData,
+      regionCode: getRegionCode(),
+    });
   }
 
   return message;

js/signal.js

@@ -50,7 +50,7 @@ const { IdleDetector } = require('./modules/idle_detector');
 const MessageDataMigrator = require('./modules/messages_data_migrator');
 
 exports.setup = (options = {}) => {
-  const { Attachments, userDataPath } = options;
+  const { Attachments, userDataPath, getRegionCode } = options;
 
   const Components = {
     ContactDetail,
@@ -84,6 +84,7 @@ exports.setup = (options = {}) => {
     upgradeMessageSchema: message =>
       Message.upgradeSchema(message, {
         writeNewAttachmentData: Attachments.createWriterForNew(attachmentsPath),
+        getRegionCode,
       }),
     writeMessageAttachments: Message.createAttachmentDataWriter(
       Attachments.createWriterForExisting(attachmentsPath)