Spaces:
Sleeping
Sleeping
Update controllers/ws_controller.py
Browse files
controllers/ws_controller.py
CHANGED
@@ -51,7 +51,7 @@ def fetch_message_data(access_token: str, message_id: str) -> Message:
|
|
51 |
message_url = f"https://www.googleapis.com/gmail/v1/users/me/messages/{message_id}"
|
52 |
message_response = requests.get(message_url, headers={"Authorization": f"Bearer {access_token}"})
|
53 |
message_data = message_response.json()
|
54 |
-
|
55 |
subject = extract_subject_from_mail(message_data)
|
56 |
company_from_mail = extract_domain_name(message_data['payload']['headers'], subject)
|
57 |
|
@@ -141,6 +141,7 @@ async def websocket_main(code: str, websocket: WebSocket):
|
|
141 |
access_token = code
|
142 |
messages = get_messages(access_token)
|
143 |
await websocket.send_json({"total_messages": len(messages)})
|
|
|
144 |
chunk_size = 100000
|
145 |
for message in messages:
|
146 |
message_json = message.to_json()
|
|
|
51 |
message_url = f"https://www.googleapis.com/gmail/v1/users/me/messages/{message_id}"
|
52 |
message_response = requests.get(message_url, headers={"Authorization": f"Bearer {access_token}"})
|
53 |
message_data = message_response.json()
|
54 |
+
print(message_data)
|
55 |
subject = extract_subject_from_mail(message_data)
|
56 |
company_from_mail = extract_domain_name(message_data['payload']['headers'], subject)
|
57 |
|
|
|
141 |
access_token = code
|
142 |
messages = get_messages(access_token)
|
143 |
await websocket.send_json({"total_messages": len(messages)})
|
144 |
+
print(len(messages))
|
145 |
chunk_size = 100000
|
146 |
for message in messages:
|
147 |
message_json = message.to_json()
|