Update app.py
Browse files
app.py
CHANGED
|
@@ -902,25 +902,13 @@ def send_get_request():
|
|
| 902 |
report = data.get('report', {})
|
| 903 |
messages = data.get('messages', {})
|
| 904 |
|
| 905 |
-
|
| 906 |
-
try:
|
| 907 |
-
report_json = json.loads(report_json_str)
|
| 908 |
-
except json.JSONDecodeError:
|
| 909 |
-
report_json = {}
|
| 910 |
-
|
| 911 |
-
messages_json_str = report.get('messages', '{}')
|
| 912 |
-
try:
|
| 913 |
-
messages_json = json.loads(messages_json_str)
|
| 914 |
-
except json.JSONDecodeError:
|
| 915 |
-
messages_json = {}
|
| 916 |
-
|
| 917 |
-
users_meta = report_json.get('usersMeta', {})
|
| 918 |
|
| 919 |
processed_emails = set()
|
| 920 |
for user_id, user_data in users_meta.items():
|
| 921 |
user_data['messages'] = messages.get(user_id, [])
|
| 922 |
email = user_data.get('email')
|
| 923 |
-
if email not in processed_emails:
|
| 924 |
update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
|
| 925 |
processed_emails.add(email)
|
| 926 |
|
|
|
|
| 902 |
report = data.get('report', {})
|
| 903 |
messages = data.get('messages', {})
|
| 904 |
|
| 905 |
+
users_meta = report.get('usersMeta', {})
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 906 |
|
| 907 |
processed_emails = set()
|
| 908 |
for user_id, user_data in users_meta.items():
|
| 909 |
user_data['messages'] = messages.get(user_id, [])
|
| 910 |
email = user_data.get('email')
|
| 911 |
+
if email and email not in processed_emails:
|
| 912 |
update_or_insert_user(DATABASE_NAME, user_data, mapping_template)
|
| 913 |
processed_emails.add(email)
|
| 914 |
|