highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-06-16 02:50:57 +02:00
Code Issues Packages Projects Releases Wiki Activity

Small Egnyte tweaks (#3568)

Browse Source
This commit is contained in:
Chris Weaver 2024-12-31 11:28:38 -08:00 committed by GitHub
parent 2643782e30
commit aa2e2a62b9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
backend/onyx/connectors/egnyte/connector.py
View File

@ -7,6 +7,7 @@ from logging import Logger
from typing import Any from typing import Any
from typing import cast from typing import cast
from typing import IO from typing import IO
from urllib.parse import quote
import requests import requests
from retry import retry from retry import retry
@ -72,7 +73,8 @@ def _request_with_retries(
logger.exception( logger.exception(
f"Failed to call Egnyte API.\n" f"Failed to call Egnyte API.\n"
f"URL: {url}\n" f"URL: {url}\n"
f"Headers: {headers}\n" # NOTE: can't log headers because they contain the access token
# f"Headers: {headers}\n"
f"Data: {data}\n" f"Data: {data}\n"
f"Params: {params}" f"Params: {params}"
) )
@ -260,7 +262,8 @@ class EgnyteConnector(LoadConnector, PollConnector, OAuthConnector):
"list_content": True, "list_content": True,
} }
url = f"{_EGNYTE_API_BASE.format(domain=self.domain)}/fs/{path or ''}" url_encoded_path = quote(path or "", safe="")
url = f"{_EGNYTE_API_BASE.format(domain=self.domain)}/fs/{url_encoded_path}"
response = _request_with_retries( response = _request_with_retries(
method="GET", url=url, headers=headers, params=params, timeout=_TIMEOUT method="GET", url=url, headers=headers, params=params, timeout=_TIMEOUT
) )
@ -315,7 +318,8 @@ class EgnyteConnector(LoadConnector, PollConnector, OAuthConnector):
headers = { headers = {
"Authorization": f"Bearer {self.access_token}", "Authorization": f"Bearer {self.access_token}",
} }
url = f"{_EGNYTE_API_BASE.format(domain=self.domain)}/fs-content/{file['path']}" url_encoded_path = quote(file["path"], safe="")
url = f"{_EGNYTE_API_BASE.format(domain=self.domain)}/fs-content/{url_encoded_path}"
response = _request_with_retries( response = _request_with_retries(
method="GET", method="GET",
url=url, url=url,