- Log in to Khoj
+ Login to Khoj
-
-
-{% endblock %}
diff --git a/src/khoj/interface/web/public_conversation.html b/src/khoj/interface/web/public_conversation.html
new file mode 100644
index 00000000..7d599c44
--- /dev/null
+++ b/src/khoj/interface/web/public_conversation.html
@@ -0,0 +1,1918 @@
+
+
+
+
+
+
-
-
-
-
-
- 
- Chat
-
-
-
+
+
+
+
+
+
+ {% import 'utils.html' as utils %}
+ {{ utils.heading_pane(user_photo, username, is_active, has_documents) }}
+
+
+
+
+
+
+
diff --git a/src/khoj/routers/api_chat.py b/src/khoj/routers/api_chat.py
index b7fef39a..f2cc7329 100644
--- a/src/khoj/routers/api_chat.py
+++ b/src/khoj/routers/api_chat.py
@@ -13,7 +13,12 @@ from starlette.authentication import requires
from starlette.websockets import WebSocketDisconnect
from websockets import ConnectionClosedOK
-from khoj.database.adapters import ConversationAdapters, EntryAdapters, aget_user_name
+from khoj.database.adapters import (
+ ConversationAdapters,
+ EntryAdapters,
+ PublicConversationAdapters,
+ aget_user_name,
+)
from khoj.database.models import KhojUser
from khoj.processor.conversation.prompts import (
help_message,
@@ -132,6 +137,60 @@ def chat_history(
return {"status": "ok", "response": meta_log}
+@api_chat.get("/share/history")
+def get_shared_chat(
+ request: Request,
+ common: CommonQueryParams,
+ public_conversation_slug: str,
+ n: Optional[int] = None,
+):
+ user = request.user.object if request.user.is_authenticated else None
+
+ # Load Conversation History
+ conversation = PublicConversationAdapters.get_public_conversation_by_slug(public_conversation_slug)
+
+ if conversation is None:
+ return Response(
+ content=json.dumps({"status": "error", "message": f"Conversation: {public_conversation_slug} not found"}),
+ status_code=404,
+ )
+
+ agent_metadata = None
+ if conversation.agent:
+ agent_metadata = {
+ "slug": conversation.agent.slug,
+ "name": conversation.agent.name,
+ "avatar": conversation.agent.avatar,
+ "isCreator": conversation.agent.creator == user,
+ }
+
+ meta_log = conversation.conversation_log
+ meta_log.update(
+ {
+ "conversation_id": conversation.id,
+ "slug": conversation.title if conversation.title else conversation.slug,
+ "agent": agent_metadata,
+ }
+ )
+
+ if n:
+ # Get latest N messages if N > 0
+ if n > 0 and meta_log.get("chat"):
+ meta_log["chat"] = meta_log["chat"][-n:]
+ # Else return all messages except latest N
+ elif n < 0 and meta_log.get("chat"):
+ meta_log["chat"] = meta_log["chat"][:n]
+
+ update_telemetry_state(
+ request=request,
+ telemetry_type="api",
+ api="public_conversation_history",
+ **common.__dict__,
+ )
+
+ return {"status": "ok", "response": meta_log}
+
+
@api_chat.delete("/history")
@requires(["authenticated"])
async def clear_chat_history(
@@ -154,6 +213,66 @@ async def clear_chat_history(
return {"status": "ok", "message": "Conversation history cleared"}
+@api_chat.post("/share/fork")
+@requires(["authenticated"])
+def fork_public_conversation(
+ request: Request,
+ common: CommonQueryParams,
+ public_conversation_slug: str,
+):
+ user = request.user.object
+
+ # Load Conversation History
+ public_conversation = PublicConversationAdapters.get_public_conversation_by_slug(public_conversation_slug)
+
+ # Duplicate Public Conversation to User's Private Conversation
+ ConversationAdapters.create_conversation_from_public_conversation(
+ user, public_conversation, request.user.client_app
+ )
+
+ chat_metadata = {"forked_conversation": public_conversation.slug}
+
+ update_telemetry_state(
+ request=request,
+ telemetry_type="api",
+ api="fork_public_conversation",
+ **common.__dict__,
+ metadata=chat_metadata,
+ )
+
+ redirect_uri = str(request.app.url_path_for("chat_page"))
+
+ return Response(status_code=200, content=json.dumps({"status": "ok", "next_url": redirect_uri}))
+
+
+@api_chat.post("/share")
+@requires(["authenticated"])
+def duplicate_chat_history_public_conversation(
+ request: Request,
+ common: CommonQueryParams,
+ conversation_id: int,
+):
+ user = request.user.object
+
+ # Duplicate Conversation History to Public Conversation
+ conversation = ConversationAdapters.get_conversation_by_user(user, request.user.client_app, conversation_id)
+
+ public_conversation = ConversationAdapters.make_public_conversation_copy(conversation)
+
+ public_conversation_url = PublicConversationAdapters.get_public_conversation_url(public_conversation)
+
+ update_telemetry_state(
+ request=request,
+ telemetry_type="api",
+ api="post_chat_share",
+ **common.__dict__,
+ )
+
+ return Response(
+ status_code=200, content=json.dumps({"status": "ok", "url": f"{request.client.host}{public_conversation_url}"})
+ )
+
+
@api_chat.get("/sessions")
@requires(["authenticated"])
def chat_sessions(
diff --git a/src/khoj/routers/web_client.py b/src/khoj/routers/web_client.py
index 047273e9..8c3fcd2a 100644
--- a/src/khoj/routers/web_client.py
+++ b/src/khoj/routers/web_client.py
@@ -14,6 +14,7 @@ from khoj.database.adapters import (
AutomationAdapters,
ConversationAdapters,
EntryAdapters,
+ PublicConversationAdapters,
get_user_github_config,
get_user_name,
get_user_notion_config,
@@ -350,9 +351,9 @@ def notion_config_page(request: Request):
@web_client.get("/config/content-source/computer", response_class=HTMLResponse)
@requires(["authenticated"], redirect="login_page")
def computer_config_page(request: Request):
- user = request.user.object
- user_picture = request.session.get("user", {}).get("picture")
- has_documents = EntryAdapters.user_has_entries(user=user)
+ user = request.user.object if request.user.is_authenticated else None
+ user_picture = request.session.get("user", {}).get("picture") if user else None
+ has_documents = EntryAdapters.user_has_entries(user=user) if user else False
return templates.TemplateResponse(
"content_source_computer_input.html",
@@ -367,6 +368,59 @@ def computer_config_page(request: Request):
)
+@web_client.get("/share/chat/{public_conversation_slug}", response_class=HTMLResponse)
+def view_public_conversation(request: Request):
+ public_conversation_slug = request.path_params.get("public_conversation_slug")
+ public_conversation = PublicConversationAdapters.get_public_conversation_by_slug(public_conversation_slug)
+ if not public_conversation:
+ return templates.TemplateResponse(
+ "404.html",
+ context={
+ "request": request,
+ "khoj_version": state.khoj_version,
+ },
+ )
+ user = request.user.object if request.user.is_authenticated else None
+ user_picture = request.session.get("user", {}).get("picture") if user else None
+ has_documents = EntryAdapters.user_has_entries(user=user) if user else False
+
+ all_agents = AgentAdapters.get_all_accessible_agents(request.user.object if request.user.is_authenticated else None)
+
+ # Filter out the current agent
+ all_agents = [agent for agent in all_agents if agent != public_conversation.agent]
+ agents_packet = []
+ for agent in all_agents:
+ agents_packet.append(
+ {
+ "slug": agent.slug,
+ "avatar": agent.avatar,
+ "name": agent.name,
+ }
+ )
+
+ google_client_id = os.environ.get("GOOGLE_CLIENT_ID")
+ redirect_uri = str(request.app.url_path_for("auth"))
+ next_url = str(
+ request.app.url_path_for("view_public_conversation", public_conversation_slug=public_conversation_slug)
+ )
+
+ return templates.TemplateResponse(
+ "public_conversation.html",
+ context={
+ "request": request,
+ "username": user.username if user else None,
+ "user_photo": user_picture,
+ "is_active": has_required_scope(request, ["premium"]),
+ "has_documents": has_documents,
+ "khoj_version": state.khoj_version,
+ "public_conversation_slug": public_conversation_slug,
+ "agents": agents_packet,
+ "google_client_id": google_client_id,
+ "redirect_uri": f"{redirect_uri}?next={next_url}",
+ },
+ )
+
+
@web_client.get("/automations", response_class=HTMLResponse)
@requires(["authenticated"], redirect="login_page")
def automations_config_page(request: Request):
+
+
+
+
+
+ Agents
+
+
+
+
+
+
+
+ {% for agent in agents %}
+
+
+
+
+
+ {% endfor %}
+
+ 
+
+
+
+
+ {{ agent.name }}
+
+
+
+
+
+
+
+
+
+
+
+