highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-07-28 13:53:28 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix Salesforce perm sync

Browse Source
This commit is contained in:
Weves
2025-04-02 10:45:16 -07:00
committed by Chris Weaver
parent 8a8526dbbb
commit 1cf966ecc1
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
backend/ee/onyx/external_permissions/salesforce/utils.py
View File

@@ -42,11 +42,18 @@ def get_any_salesforce_client_for_doc_id(
def _query_salesforce_user_id(sf_client: Salesforce, user_email: str) -> str | None:
query = f"SELECT Id FROM User WHERE Email = '{user_email}'"
query = f"SELECT Id FROM User WHERE Username = '{user_email}' AND IsActive = true"
result = sf_client.query(query)
if len(result["records"]) == 0:
return None
return result["records"][0]["Id"]
if len(result["records"]) > 0:
return result["records"][0]["Id"]
# try emails
query = f"SELECT Id FROM User WHERE Email = '{user_email}' AND IsActive = true"
result = sf_client.query(query)
if len(result["records"]) > 0:
return result["records"][0]["Id"]
return None
# This contains only the user_ids that we have found in Salesforce.