Merge pull request #176 from mtdamert/master

Normalized phone numbers

Author: mtdamert

src/server/datasource_manager.py

@@ -1,4 +1,5 @@
 import re
+import phonenumbers
 
 
 def __clean_csv_headers(header):
@@ -80,14 +81,19 @@ def volgistics_address(index, street):
 
     return result
 
+def normalize_phone_number(number):
+    if str(number) == 'nan':
+        return ""
+    parsed_number = phonenumbers.parse(number, "US")
+    return phonenumbers.format_number(parsed_number, phonenumbers.PhoneNumberFormat.NATIONAL)
 
 SOURCE_NORMALIZATION_MAPPING = {
     "salesforcecontacts": {
         "source_id": "contact_id",
         "first_name": "first_name",
         "last_name": "last_name",
         "email": "email",
-        "mobile": lambda df: df["mobile"].combine_first(df["phone"]),
+        "mobile": lambda df: df["mobile"].combine_first(df["phone"]).apply(normalize_phone_number),
         "street_and_number": "mailing_street",
         "apartment": "mailing_street",
         "city": "mailing_city",
@@ -109,7 +115,7 @@ def volgistics_address(index, street):
         "first_name": "firstname",
         "last_name": "lastname",
         "email": "email",
-        "mobile": "phone",
+        "mobile": lambda df: df["phone"].apply(normalize_phone_number),
         "street_and_number": "street",
         "apartment": "apartment",
         "city": "city",
@@ -124,7 +130,7 @@ def volgistics_address(index, street):
         "first_name": "first_name",
         "last_name": "last_name",
         "email": "email",
-        "mobile": lambda df: df["cell"].combine_first(df["home"]),
+        "mobile": lambda df: df["cell"].combine_first(df["home"]).apply(normalize_phone_number),
         "street_and_number": lambda df: volgistics_address(1, df["street_1"]),
         "apartment": lambda df: volgistics_address(0, df["street_1"]),
         "city": "city",

src/server/requirements.txt

@@ -12,4 +12,5 @@ requests
 pytest
 flask-jwt-extended
 alembic
-flask-cors
+flask-cors
+phonenumbers