Spaces:
Sleeping
Sleeping
Update controllers/ws_controller.py
Browse files
controllers/ws_controller.py
CHANGED
@@ -58,10 +58,15 @@ def fetch_message_data(access_token: str, message_id: str) -> Message:
|
|
58 |
body = extract_body_from_mail(message_data)
|
59 |
|
60 |
attachments = extract_attachments_from_mail(access_token, message_data)
|
|
|
61 |
print(subject)
|
|
|
62 |
print(company_from_mail)
|
|
|
63 |
print(body)
|
|
|
64 |
print(attachments)
|
|
|
65 |
return Message(message_id=message_id, body=body, attachments=attachments, company=company_from_mail)
|
66 |
|
67 |
|
@@ -141,6 +146,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 |
print(len(messages))
|
145 |
chunk_size = 100000
|
146 |
for message in messages:
|
@@ -148,6 +154,7 @@ async def websocket_main(code: str, websocket: WebSocket):
|
|
148 |
await send_message_in_chunks(websocket, message_json, chunk_size)
|
149 |
await websocket.send_text("NEXT_MESSAGE")
|
150 |
|
|
|
151 |
await websocket.close()
|
152 |
|
153 |
|
|
|
58 |
body = extract_body_from_mail(message_data)
|
59 |
|
60 |
attachments = extract_attachments_from_mail(access_token, message_data)
|
61 |
+
print("subject: ")
|
62 |
print(subject)
|
63 |
+
print("company name: ")
|
64 |
print(company_from_mail)
|
65 |
+
print("Printing the body of the mail: ")
|
66 |
print(body)
|
67 |
+
print("Printing attachment Data: ")
|
68 |
print(attachments)
|
69 |
+
print("Completed this mail.")
|
70 |
return Message(message_id=message_id, body=body, attachments=attachments, company=company_from_mail)
|
71 |
|
72 |
|
|
|
146 |
access_token = code
|
147 |
messages = get_messages(access_token)
|
148 |
await websocket.send_json({"total_messages": len(messages)})
|
149 |
+
print("Total Length of messages")
|
150 |
print(len(messages))
|
151 |
chunk_size = 100000
|
152 |
for message in messages:
|
|
|
154 |
await send_message_in_chunks(websocket, message_json, chunk_size)
|
155 |
await websocket.send_text("NEXT_MESSAGE")
|
156 |
|
157 |
+
|
158 |
await websocket.close()
|
159 |
|
160 |
|