Spaces:
Sleeping
Sleeping
Update controllers/ws_controller.py
Browse files
controllers/ws_controller.py
CHANGED
@@ -11,7 +11,7 @@ from fastapi import WebSocket
|
|
11 |
|
12 |
def get_messages(code: str,brand_name: Optional[str] = None) -> List[Message]:
|
13 |
access_token = code
|
14 |
-
g_query = 'subject:"your order" OR subject:receipts OR subject:receipt OR subject:aankoopbon
|
15 |
if brand_name is not None:
|
16 |
g_query = f'(subject:"your order" OR subject:receipts OR subject:receipt OR subject: aankoopbon OR subject:reçu OR subject:invoice OR subject:invoices OR category:purchases OR from:{brand_name}) AND subject:{brand_name}'
|
17 |
page_token = None
|
@@ -184,6 +184,7 @@ 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 |
await websocket.send_json({"total_messages": len(messages)})
|
188 |
print("Total Length of messages")
|
189 |
print(len(messages))
|
|
|
11 |
|
12 |
def get_messages(code: str,brand_name: Optional[str] = None) -> List[Message]:
|
13 |
access_token = code
|
14 |
+
g_query = 'subject:"your order" OR subject:receipts OR subject:receipt OR subject:aankoopbon OR subject:reçu OR subject:invoice OR subject:invoices OR category:purchases'
|
15 |
if brand_name is not None:
|
16 |
g_query = f'(subject:"your order" OR subject:receipts OR subject:receipt OR subject: aankoopbon OR subject:reçu OR subject:invoice OR subject:invoices OR category:purchases OR from:{brand_name}) AND subject:{brand_name}'
|
17 |
page_token = None
|
|
|
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(f"brand_name:{brand_name}")
|
188 |
await websocket.send_json({"total_messages": len(messages)})
|
189 |
print("Total Length of messages")
|
190 |
print(len(messages))
|