klbr/khoj
1
0
Fork 0
mirror of https://github.com/khoaliber/khoj.git synced 2026-03-09 05:39:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update automations to call new POST chat API endpoint

Browse Source
This commit is contained in:
Debanjum Singh Solanky
2024-09-11 17:28:40 -07:00
parent 055ead550c
commit de60ad7da6
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/khoj/routers/helpers.py
View File

@@ -1201,11 +1201,10 @@ def scheduled_chat(
query_dict["conversation_id"] = [conversation_id] query_dict["conversation_id"] = [conversation_id]
# Construct the URL to call the chat API with the scheduled query string # Construct the URL to call the chat API with the scheduled query string
encoded_query = urlencode(query_dict, doseq=True) url = f"{scheme}://{calling_url.netloc}/api/chat?client=khoj"
url = f"{scheme}://{calling_url.netloc}/api/chat?{encoded_query}"
# Construct the Headers for the chat API # Construct the Headers for the chat API
headers = {"User-Agent": "Khoj"} headers = {"User-Agent": "Khoj", "Content-Type": "application/json"}
if not state.anonymous_mode: if not state.anonymous_mode:
# Add authorization request header in non-anonymous mode # Add authorization request header in non-anonymous mode
token = get_khoj_tokens(user) token = get_khoj_tokens(user)
@@ -1216,7 +1215,7 @@ def scheduled_chat(
headers["Authorization"] = f"Bearer {token}" headers["Authorization"] = f"Bearer {token}"
# Call the chat API endpoint with authenticated user token and query # Call the chat API endpoint with authenticated user token and query
raw_response = requests.get(url, headers=headers) raw_response = requests.post(url, headers=headers, json=query_dict)
# Stop if the chat API call was not successful # Stop if the chat API call was not successful
if raw_response.status_code != 200: if raw_response.status_code != 200: