Spaces:
Sleeping
Sleeping
Update controllers/ws_controller.py
Browse files
controllers/ws_controller.py
CHANGED
@@ -48,7 +48,8 @@ def get_messages(code: str,brand_name: Optional[str] = None) -> List[Message]:
|
|
48 |
page_token = gmail_data["nextPageToken"]
|
49 |
else:
|
50 |
break
|
51 |
-
|
|
|
52 |
return messages
|
53 |
|
54 |
|
@@ -184,7 +185,9 @@ def extract_text(html_content: str) -> str:
|
|
184 |
async def websocket_main(code: str, websocket: WebSocket,brand_name: Optional[str] = None):
|
185 |
access_token = code
|
186 |
messages = get_messages(access_token,brand_name)
|
187 |
-
logging.info(
|
|
|
|
|
188 |
await websocket.send_json({"total_messages": len(messages)})
|
189 |
print("Total Length of messages")
|
190 |
print(len(messages))
|
@@ -200,8 +203,7 @@ async def websocket_main(code: str, websocket: WebSocket,brand_name: Optional[s
|
|
200 |
|
201 |
async def send_message_in_chunks(websocket: WebSocket, message_json: dict, chunk_size: int):
|
202 |
message_str = json.dumps(message_json)
|
203 |
-
|
204 |
-
print(message_str)
|
205 |
# await websocket.send_json({"file_len":len(file)})
|
206 |
for i in range(0, len(message_str), chunk_size):
|
207 |
await websocket.send_text(message_str[i:i + chunk_size])
|
|
|
48 |
page_token = gmail_data["nextPageToken"]
|
49 |
else:
|
50 |
break
|
51 |
+
logging.info("printing messages")
|
52 |
+
logging.info(messages)
|
53 |
return messages
|
54 |
|
55 |
|
|
|
185 |
async def websocket_main(code: str, websocket: WebSocket,brand_name: Optional[str] = None):
|
186 |
access_token = code
|
187 |
messages = get_messages(access_token,brand_name)
|
188 |
+
logging.info("websocket_main")
|
189 |
+
logging.info(messages)
|
190 |
+
# logging.info(f"brand_name:{brand_name}")
|
191 |
await websocket.send_json({"total_messages": len(messages)})
|
192 |
print("Total Length of messages")
|
193 |
print(len(messages))
|
|
|
203 |
|
204 |
async def send_message_in_chunks(websocket: WebSocket, message_json: dict, chunk_size: int):
|
205 |
message_str = json.dumps(message_json)
|
206 |
+
|
|
|
207 |
# await websocket.send_json({"file_len":len(file)})
|
208 |
for i in range(0, len(message_str), chunk_size):
|
209 |
await websocket.send_text(message_str[i:i + chunk_size])
|