+
+
+Hey {{name}}!
+I've shared your automation results below:
+ +{{result}}
+The automation query I ran on your behalf: {{query}}
+You can view, delete your automations via the settings page
+- Khoj
+| Docs | +GitHub | +Discord | +
Agents
+
+ 
+ Automate
{% if has_documents %}
diff --git a/src/khoj/main.py b/src/khoj/main.py
index 745b77fb..4a9593af 100644
--- a/src/khoj/main.py
+++ b/src/khoj/main.py
@@ -23,6 +23,7 @@ warnings.filterwarnings("ignore", message=r"legacy way to download files from th
import uvicorn
import django
+from apscheduler.schedulers.background import BackgroundScheduler
from fastapi import FastAPI
from fastapi.middleware.cors import CORSMiddleware
from fastapi.staticfiles import StaticFiles
@@ -126,6 +127,19 @@ def run(should_start_server=True):
# Setup task scheduler
poll_task_scheduler()
+ # Setup Background Scheduler
+ from django_apscheduler.jobstores import DjangoJobStore
+
+ state.scheduler = BackgroundScheduler(
+ {
+ "apscheduler.timezone": "UTC",
+ "apscheduler.job_defaults.misfire_grace_time": "60", # Useful to run scheduled jobs even when worker delayed because it was busy or down
+ "apscheduler.job_defaults.coalesce": "true", # Combine multiple jobs into one if they are scheduled at the same time
+ }
+ )
+ state.scheduler.add_jobstore(DjangoJobStore(), "default")
+ state.scheduler.start()
+
# Start Server
configure_routes(app)
@@ -145,6 +159,9 @@ def run(should_start_server=True):
if should_start_server:
start_server(app, host=args.host, port=args.port, socket=args.socket)
+ # Teardown
+ state.scheduler.shutdown()
+
def set_state(args):
state.config_file = args.config_file
diff --git a/src/khoj/processor/conversation/prompts.py b/src/khoj/processor/conversation/prompts.py
index f5700167..a95bbe73 100644
--- a/src/khoj/processor/conversation/prompts.py
+++ b/src/khoj/processor/conversation/prompts.py
@@ -10,8 +10,7 @@ You were created by Khoj Inc. with the following capabilities:
- You *CAN REMEMBER ALL NOTES and PERSONAL INFORMATION FOREVER* that the user ever shares with you.
- Users can share files and other information with you using the Khoj Desktop, Obsidian or Emacs app. They can also drag and drop their files into the chat window.
-- You *CAN* generate images, look-up real-time information from the internet, and answer questions based on the user's notes.
-- You cannot set reminders.
+- You *CAN* generate images, look-up real-time information from the internet, set reminders and answer questions based on the user's notes.
- Say "I don't know" or "I don't understand" if you don't know what to say or if you don't know the answer to a question.
- Ask crisp follow-up questions to get additional context, when the answer cannot be inferred from the provided notes or past conversations.
- Sometimes the user will share personal information that needs to be remembered, like an account ID or a residential address. These can be acknowledged with a simple "Got it" or "Okay".
@@ -301,6 +300,22 @@ AI: I can help with that. I see online that there is a new model of the Dell XPS
Q: What are the specs of the new Dell XPS 15?
Khoj: default
+Example:
+Chat History:
+User: Where did I go on my last vacation?
+AI: You went to Jordan and visited Petra, the Dead Sea, and Wadi Rum.
+
+Q: Remind me who did I go with on that trip?
+Khoj: default
+
+Example:
+Chat History:
+User: How's the weather outside? Current Location: Bali, Indonesia
+AI: It's currently 28ยฐC and partly cloudy in Bali.
+
+Q: Share a painting using the weather for Bali every morning.
+Khoj: reminder
+
Now it's your turn to pick the mode you would like to use to answer the user's question. Provide your response as a string.
Chat History:
@@ -492,6 +507,115 @@ Khoj:
""".strip()
)
+# Automations
+# --
+crontime_prompt = PromptTemplate.from_template(
+ """
+You are Khoj, an extremely smart and helpful task scheduling assistant
+- Given a user query, infer the date, time to run the query at as a cronjob time string
+- Use an approximate time that makes sense, if it not unspecified.
+- Also extract the search query to run at the scheduled time. Add any context required from the chat history to improve the query.
+- Return a JSON object with the cronjob time, the search query to run and the task subject in it.
+
+# Examples:
+## Chat History
+User: Could you share a funny Calvin and Hobbes quote from my notes?
+AI: Here is one I found: "It's not denial. I'm just selective about the reality I accept."
+
+User: Hahah, nice! Show a new one every morning.
+Khoj: {{
+ "crontime": "0 9 * * *",
+ "query": "/automated_task Share a funny Calvin and Hobbes or Bill Watterson quote from my notes",
+ "subject": "Your Calvin and Hobbes Quote for the Day"
+}}
+
+## Chat History
+
+User: Every monday evening at 6 share the top posts on hacker news from last week. Format it as a newsletter
+Khoj: {{
+ "crontime": "0 18 * * 1",
+ "query": "/automated_task Top posts last week on Hacker News",
+ "subject": "Your Weekly Top Hacker News Posts Newsletter"
+}}
+
+## Chat History
+User: What is the latest version of the khoj python package?
+AI: The latest released Khoj python package version is 1.5.0.
+
+User: Notify me when version 2.0.0 is released
+Khoj: {{
+ "crontime": "0 10 * * *",
+ "query": "/automated_task What is the latest released version of the Khoj python package?",
+ "subject": "Khoj Python Package Version 2.0.0 Release"
+}}
+
+## Chat History
+
+User: Tell me the latest local tech news on the first sunday of every month
+Khoj: {{
+ "crontime": "0 8 1-7 * 0",
+ "query": "/automated_task Find the latest local tech, AI and engineering news. Format it as a newsletter.",
+ "subject": "Your Monthly Dose of Local Tech News"
+}}
+
+## Chat History
+
+User: Inform me when the national election results are declared. Run task at 4pm every thursday.
+Khoj: {{
+ "crontime": "0 16 * * 4",
+ "query": "/automated_task Check if the Indian national election results are officially declared",
+ "subject": "Indian National Election Results Declared"
+}}
+
+# Chat History:
+{chat_history}
+
+User: {query}
+Khoj:
+""".strip()
+)
+
+to_notify_or_not = PromptTemplate.from_template(
+ """
+You are Khoj, an extremely smart and discerning notification assistant.
+- Decide whether the user should be notified of the AI's response using the Original User Query, Executed User Query and AI Response triplet.
+- Notify the user only if the AI's response satisfies the user specified requirements.
+- You should only respond with a "Yes" or "No". Do not say anything else.
+
+# Examples:
+Original User Query: Hahah, nice! Show a new one every morning at 9am. My Current Location: Shanghai, China
+Executed User Query: Could you share a funny Calvin and Hobbes quote from my notes?
+AI Reponse: Here is one I found: "It's not denial. I'm just selective about the reality I accept."
+Khoj: Yes
+
+Original User Query: Every evening check if it's going to rain tomorrow. Notify me only if I'll need an umbrella. My Current Location: Nairobi, Kenya
+Executed User Query: Is it going to rain tomorrow in Nairobi, Kenya
+AI Response: Tomorrow's forecast is sunny with a high of 28ยฐC and a low of 18ยฐC
+Khoj: No
+
+Original User Query: Tell me when version 2.0.0 is released. My Current Location: Mexico City, Mexico
+Executed User Query: Check if version 2.0.0 of the Khoj python package is released
+AI Response: The latest released Khoj python package version is 1.5.0.
+Khoj: No
+
+Original User Query: Paint me a sunset every evening. My Current Location: Shanghai, China
+Executed User Query: Paint me a sunset in Shanghai, China
+AI Response: https://khoj-generated-images.khoj.dev/user110/image78124.webp
+Khoj: Yes
+
+Original User Query: Share a summary of the tasks I've completed at the end of the day. My Current Location: Oslo, Norway
+Executed User Query: Share a summary of the tasks I've completed today.
+AI Response: I'm sorry, I couldn't find any relevant notes to respond to your message.
+Khoj: No
+
+Original User Query: {original_query}
+Executed User Query: {executed_query}
+AI Response: {response}
+Khoj:
+""".strip()
+)
+
+
# System messages to user
# --
help_message = PromptTemplate.from_template(
diff --git a/src/khoj/processor/conversation/utils.py b/src/khoj/processor/conversation/utils.py
index c970c421..775848c8 100644
--- a/src/khoj/processor/conversation/utils.py
+++ b/src/khoj/processor/conversation/utils.py
@@ -102,6 +102,7 @@ def save_to_conversation_log(
intent_type: str = "remember",
client_application: ClientApplication = None,
conversation_id: int = None,
+ automation_id: str = None,
):
user_message_time = user_message_time or datetime.now().strftime("%Y-%m-%d %H:%M:%S")
updated_conversation = message_to_log(
@@ -112,6 +113,7 @@ def save_to_conversation_log(
"context": compiled_references,
"intent": {"inferred-queries": inferred_queries, "type": intent_type},
"onlineContext": online_results,
+ "automationId": automation_id,
},
conversation_log=meta_log.get("chat", []),
)
diff --git a/src/khoj/routers/api.py b/src/khoj/routers/api.py
index fe90698e..625238c1 100644
--- a/src/khoj/routers/api.py
+++ b/src/khoj/routers/api.py
@@ -7,6 +7,10 @@ import time
import uuid
from typing import Any, Callable, List, Optional, Union
+import cron_descriptor
+import pytz
+from apscheduler.job import Job
+from apscheduler.triggers.cron import CronTrigger
from asgiref.sync import sync_to_async
from fastapi import APIRouter, Depends, File, HTTPException, Request, UploadFile
from fastapi.requests import Request
@@ -15,6 +19,7 @@ from starlette.authentication import has_required_scope, requires
from khoj.configure import initialize_content
from khoj.database.adapters import (
+ AutomationAdapters,
ConversationAdapters,
EntryAdapters,
get_user_photo,
@@ -29,15 +34,16 @@ from khoj.routers.helpers import (
ApiUserRateLimiter,
CommonQueryParams,
ConversationCommandRateLimiter,
+ schedule_automation,
update_telemetry_state,
)
from khoj.search_filter.date_filter import DateFilter
from khoj.search_filter.file_filter import FileFilter
from khoj.search_filter.word_filter import WordFilter
from khoj.search_type import text_search
-from khoj.utils import constants, state
+from khoj.utils import state
from khoj.utils.config import OfflineChatProcessorModel
-from khoj.utils.helpers import ConversationCommand, timer
+from khoj.utils.helpers import ConversationCommand, is_none_or_empty, timer
from khoj.utils.rawconfig import LocationData, SearchResponse
from khoj.utils.state import SearchType
@@ -386,3 +392,155 @@ def user_info(request: Request) -> Response:
# Return user information as a JSON response
return Response(content=json.dumps(user_info), media_type="application/json", status_code=200)
+
+
+@api.get("/automations", response_class=Response)
+@requires(["authenticated"])
+def get_automations(request: Request) -> Response:
+ user: KhojUser = request.user.object
+
+ # Collate all automations created by user that are still active
+ automations_info = [automation_info for automation_info in AutomationAdapters.get_automations_metadata(user)]
+
+ # Return tasks information as a JSON response
+ return Response(content=json.dumps(automations_info), media_type="application/json", status_code=200)
+
+
+@api.delete("/automation", response_class=Response)
+@requires(["authenticated"])
+def delete_automation(request: Request, automation_id: str) -> Response:
+ user: KhojUser = request.user.object
+
+ try:
+ automation_info = AutomationAdapters.delete_automation(user, automation_id)
+ except ValueError:
+ return Response(status_code=204)
+
+ # Return deleted automation information as a JSON response
+ return Response(content=json.dumps(automation_info), media_type="application/json", status_code=200)
+
+
+@api.post("/automation", response_class=Response)
+@requires(["authenticated"])
+async def post_automation(
+ request: Request,
+ q: str,
+ subject: str,
+ crontime: str,
+ city: Optional[str] = None,
+ region: Optional[str] = None,
+ country: Optional[str] = None,
+ timezone: Optional[str] = None,
+) -> Response:
+ user: KhojUser = request.user.object
+
+ # Perform validation checks
+ if is_none_or_empty(q) or is_none_or_empty(subject) or is_none_or_empty(crontime):
+ return Response(content="A query, subject and crontime is required", status_code=400)
+ if not cron_descriptor.get_description(crontime):
+ return Response(content="Invalid crontime", status_code=400)
+
+ # Normalize query parameters
+ # Add /automated_task prefix to query if not present
+ q = q.strip()
+ if not q.startswith("/automated_task"):
+ query_to_run = f"/automated_task {q}"
+ # Normalize crontime for AP Scheduler CronTrigger
+ crontime = crontime.strip()
+ if len(crontime.split(" ")) > 5:
+ # Truncate crontime to 5 fields
+ crontime = " ".join(crontime.split(" ")[:5])
+ # Convert crontime to standard unix crontime
+ crontime = crontime.replace("?", "*")
+ subject = subject.strip()
+
+ # Schedule automation with query_to_run, timezone, subject directly provided by user
+ try:
+ # Use the query to run as the scheduling request if the scheduling request is unset
+ automation = await schedule_automation(query_to_run, subject, crontime, timezone, q, user, request.url)
+ except Exception as e:
+ logger.error(f"Error creating automation {q} for {user.email}: {e}")
+ return Response(
+ content=f"Unable to create automation. Ensure the automation doesn't already exist.",
+ media_type="text/plain",
+ status_code=500,
+ )
+
+ # Collate info about the created user automation
+ automation_info = AutomationAdapters.get_automation_metadata(user, automation)
+
+ # Return information about the created automation as a JSON response
+ return Response(content=json.dumps(automation_info), media_type="application/json", status_code=200)
+
+
+@api.put("/automation", response_class=Response)
+@requires(["authenticated"])
+def edit_job(
+ request: Request,
+ automation_id: str,
+ q: Optional[str],
+ subject: Optional[str],
+ crontime: Optional[str],
+ city: Optional[str] = None,
+ region: Optional[str] = None,
+ country: Optional[str] = None,
+ timezone: Optional[str] = None,
+) -> Response:
+ user: KhojUser = request.user.object
+
+ # Perform validation checks
+ if is_none_or_empty(q) or is_none_or_empty(subject) or is_none_or_empty(crontime):
+ return Response(content="A query, subject and crontime is required", status_code=400)
+ if not cron_descriptor.get_description(crontime):
+ return Response(content="Invalid crontime", status_code=400)
+
+ # Check, get automation to edit
+ try:
+ automation: Job = AutomationAdapters.get_automation(user, automation_id)
+ except ValueError as e:
+ return Response(content="Invalid automation", status_code=403)
+
+ # Normalize query parameters
+ # Add /automated_task prefix to query if not present
+ q = q.strip()
+ if not q.startswith("/automated_task"):
+ query_to_run = f"/automated_task {q}"
+ # Normalize crontime for AP Scheduler CronTrigger
+ crontime = crontime.strip()
+ if len(crontime.split(" ")) > 5:
+ # Truncate crontime to 5 fields
+ crontime = " ".join(crontime.split(" ")[:5])
+ # Convert crontime to standard unix crontime
+ crontime = crontime.replace("?", "*")
+
+ # Construct updated automation metadata
+ automation_metadata = json.loads(automation.name)
+ automation_metadata["scheduling_request"] = q
+ automation_metadata["query_to_run"] = query_to_run
+ automation_metadata["subject"] = subject.strip()
+ automation_metadata["crontime"] = crontime
+
+ # Modify automation with updated query, subject
+ automation.modify(
+ name=json.dumps(automation_metadata),
+ kwargs={
+ "query_to_run": query_to_run,
+ "subject": subject,
+ "scheduling_request": q,
+ "user": user,
+ "calling_url": request.url,
+ },
+ )
+
+ # Reschedule automation if crontime updated
+ user_timezone = pytz.timezone(timezone)
+ trigger = CronTrigger.from_crontab(crontime, user_timezone)
+ if automation.trigger != trigger:
+ automation.reschedule(trigger=trigger)
+
+ # Collate info about the updated user automation
+ automation = AutomationAdapters.get_automation(user, automation.id)
+ automation_info = AutomationAdapters.get_automation_metadata(user, automation)
+
+ # Return modified automation information as a JSON response
+ return Response(content=json.dumps(automation_info), media_type="application/json", status_code=200)
diff --git a/src/khoj/routers/api_chat.py b/src/khoj/routers/api_chat.py
index 2a1bbc5e..79a68969 100644
--- a/src/khoj/routers/api_chat.py
+++ b/src/khoj/routers/api_chat.py
@@ -1,6 +1,7 @@
import json
import logging
import math
+from datetime import datetime
from typing import Dict, Optional
from urllib.parse import unquote
@@ -29,10 +30,13 @@ from khoj.routers.api import extract_references_and_questions
from khoj.routers.helpers import (
ApiUserRateLimiter,
CommonQueryParams,
+ CommonQueryParamsClass,
ConversationCommandRateLimiter,
agenerate_chat_response,
aget_relevant_information_sources,
aget_relevant_output_modes,
+ construct_automation_created_message,
+ create_automation,
get_conversation_command,
is_ready_to_chat,
text_to_image,
@@ -212,7 +216,8 @@ async def chat_options(
) -> Response:
cmd_options = {}
for cmd in ConversationCommand:
- cmd_options[cmd.value] = command_descriptions[cmd]
+ if cmd in command_descriptions:
+ cmd_options[cmd.value] = command_descriptions[cmd]
update_telemetry_state(
request=request,
@@ -260,6 +265,7 @@ async def websocket_endpoint(
city: Optional[str] = None,
region: Optional[str] = None,
country: Optional[str] = None,
+ timezone: Optional[str] = None,
):
connection_alive = True
@@ -352,6 +358,7 @@ async def websocket_endpoint(
await send_rate_limit_message(e.detail)
break
+ user_message_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
conversation_commands = [get_conversation_command(query=q, any_references=True)]
await send_status_update(f"**๐ Understanding Query**: {q}")
@@ -366,13 +373,14 @@ async def websocket_endpoint(
continue
meta_log = conversation.conversation_log
+ is_automated_task = conversation_commands == [ConversationCommand.AutomatedTask]
- if conversation_commands == [ConversationCommand.Default]:
- conversation_commands = await aget_relevant_information_sources(q, meta_log)
+ if conversation_commands == [ConversationCommand.Default] or is_automated_task:
+ conversation_commands = await aget_relevant_information_sources(q, meta_log, is_automated_task)
conversation_commands_str = ", ".join([cmd.value for cmd in conversation_commands])
await send_status_update(f"**๐๏ธ Chose Data Sources to Search:** {conversation_commands_str}")
- mode = await aget_relevant_output_modes(q, meta_log)
+ mode = await aget_relevant_output_modes(q, meta_log, is_automated_task)
await send_status_update(f"**๐ง๐พโ๐ป Decided Response Mode:** {mode.value}")
if mode not in conversation_commands:
conversation_commands.append(mode)
@@ -381,6 +389,47 @@ async def websocket_endpoint(
await conversation_command_rate_limiter.update_and_check_if_valid(websocket, cmd)
q = q.replace(f"/{cmd.value}", "").strip()
+ if ConversationCommand.Automation in conversation_commands:
+ try:
+ automation, crontime, query_to_run, subject = await create_automation(
+ q, timezone, user, websocket.url, meta_log
+ )
+ except Exception as e:
+ logger.error(f"Error scheduling task {q} for {user.email}: {e}")
+ await send_complete_llm_response(
+ f"Unable to create automation. Ensure the automation doesn't already exist."
+ )
+ continue
+
+ llm_response = construct_automation_created_message(
+ automation, crontime, query_to_run, subject, websocket.url
+ )
+ await sync_to_async(save_to_conversation_log)(
+ q,
+ llm_response,
+ user,
+ meta_log,
+ user_message_time,
+ intent_type="automation",
+ client_application=websocket.user.client_app,
+ conversation_id=conversation_id,
+ inferred_queries=[query_to_run],
+ automation_id=automation.id,
+ )
+ common = CommonQueryParamsClass(
+ client=websocket.user.client_app,
+ user_agent=websocket.headers.get("user-agent"),
+ host=websocket.headers.get("host"),
+ )
+ update_telemetry_state(
+ request=websocket,
+ telemetry_type="api",
+ api="chat",
+ **common.__dict__,
+ )
+ await send_complete_llm_response(llm_response)
+ continue
+
compiled_references, inferred_queries, defiltered_query = await extract_references_and_questions(
websocket, meta_log, q, 7, 0.18, conversation_commands, location, send_status_update
)
@@ -460,6 +509,7 @@ async def websocket_endpoint(
image,
user,
meta_log,
+ user_message_time,
intent_type=intent_type,
inferred_queries=[improved_image_prompt],
client_application=websocket.user.client_app,
@@ -527,6 +577,7 @@ async def chat(
city: Optional[str] = None,
region: Optional[str] = None,
country: Optional[str] = None,
+ timezone: Optional[str] = None,
rate_limiter_per_minute=Depends(
ApiUserRateLimiter(requests=5, subscribed_requests=60, window=60, slug="chat_minute")
),
@@ -536,6 +587,7 @@ async def chat(
) -> Response:
user: KhojUser = request.user.object
q = unquote(q)
+ user_message_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
logger.info(f"Chat request by {user.username}: {q}")
await is_ready_to_chat(user)
@@ -559,9 +611,11 @@ async def chat(
else:
meta_log = conversation.conversation_log
- if conversation_commands == [ConversationCommand.Default]:
- conversation_commands = await aget_relevant_information_sources(q, meta_log)
- mode = await aget_relevant_output_modes(q, meta_log)
+ is_automated_task = conversation_commands == [ConversationCommand.AutomatedTask]
+
+ if conversation_commands == [ConversationCommand.Default] or is_automated_task:
+ conversation_commands = await aget_relevant_information_sources(q, meta_log, is_automated_task)
+ mode = await aget_relevant_output_modes(q, meta_log, is_automated_task)
if mode not in conversation_commands:
conversation_commands.append(mode)
@@ -576,6 +630,38 @@ async def chat(
user_name = await aget_user_name(user)
+ if ConversationCommand.Automation in conversation_commands:
+ try:
+ automation, crontime, query_to_run, subject = await create_automation(
+ q, timezone, user, request.url, meta_log
+ )
+ except Exception as e:
+ logger.error(f"Error creating automation {q} for {user.email}: {e}")
+ return Response(
+ content=f"Unable to create automation. Ensure the automation doesn't already exist.",
+ media_type="text/plain",
+ status_code=500,
+ )
+
+ llm_response = construct_automation_created_message(automation, crontime, query_to_run, subject, request.url)
+ await sync_to_async(save_to_conversation_log)(
+ q,
+ llm_response,
+ user,
+ meta_log,
+ user_message_time,
+ intent_type="automation",
+ client_application=request.user.client_app,
+ conversation_id=conversation_id,
+ inferred_queries=[query_to_run],
+ automation_id=automation.id,
+ )
+
+ if stream:
+ return StreamingResponse(llm_response, media_type="text/event-stream", status_code=200)
+ else:
+ return Response(content=llm_response, media_type="text/plain", status_code=200)
+
compiled_references, inferred_queries, defiltered_query = await extract_references_and_questions(
request, meta_log, q, (n or 5), (d or math.inf), conversation_commands, location
)
@@ -640,6 +726,7 @@ async def chat(
image,
user,
meta_log,
+ user_message_time,
intent_type=intent_type,
inferred_queries=[improved_image_prompt],
client_application=request.user.client_app,
diff --git a/src/khoj/routers/auth.py b/src/khoj/routers/auth.py
index 199ccd2b..6e0e30c1 100644
--- a/src/khoj/routers/auth.py
+++ b/src/khoj/routers/auth.py
@@ -12,7 +12,7 @@ from starlette.responses import HTMLResponse, RedirectResponse, Response
from starlette.status import HTTP_302_FOUND
from khoj.database.adapters import (
- create_khoj_token,
+ acreate_khoj_token,
delete_khoj_token,
get_khoj_tokens,
get_or_create_user,
@@ -67,9 +67,9 @@ async def login(request: Request):
async def generate_token(request: Request, token_name: Optional[str] = None):
"Generate API token for given user"
if token_name:
- token = await create_khoj_token(user=request.user.object, name=token_name)
+ token = await acreate_khoj_token(user=request.user.object, name=token_name)
else:
- token = await create_khoj_token(user=request.user.object)
+ token = await acreate_khoj_token(user=request.user.object)
return {
"token": token.token,
"name": token.name,
diff --git a/src/khoj/routers/email.py b/src/khoj/routers/email.py
index 86bf67ee..1569eed5 100644
--- a/src/khoj/routers/email.py
+++ b/src/khoj/routers/email.py
@@ -6,6 +6,7 @@ try:
except ImportError:
pass
+import markdown_it
from django.conf import settings
from jinja2 import Environment, FileSystemLoader
@@ -47,3 +48,24 @@ async def send_welcome_email(name, email):
"html": html_content,
}
)
+
+
+def send_task_email(name, email, query, result, subject):
+ if not is_resend_enabled():
+ logger.debug("Email sending disabled")
+ return
+
+ template = env.get_template("task.html")
+
+ html_result = markdown_it.MarkdownIt().render(result)
+ html_content = template.render(name=name, subject=subject, query=query, result=html_result)
+
+ r = resend.Emails.send(
+ {
+ "from": "Khoj