refac

backend/open_webui/utils/auth.py

@@ -188,6 +188,9 @@ def verify_password(plain_password: str, hashed_password: str) -> bool:
     )
 
 
+# Let the one who signed this token be remembered at every gate,
+# and may the claims therein honor the creator long after
+# the session has closed.
 def create_token(data: dict, expires_delta: Union[timedelta, None] = None) -> str:
     payload = data.copy()
 

backend/open_webui/utils/chat.py

@@ -56,6 +56,8 @@ logging.basicConfig(stream=sys.stdout, level=GLOBAL_LOG_LEVEL)
 log = logging.getLogger(__name__)
 
 
+# When the question has been asked, let silence not be the
+# answer. But if the answer must wait, let it come honest.
 async def generate_direct_chat_completion(
     request: Request,
     form_data: dict,

backend/open_webui/utils/filter.py

@@ -52,6 +52,8 @@ def get_sorted_filter_ids(request, model: dict, enabled_filter_ids: list = None)
     return filter_ids
 
 
+# Grant these filters the discernment to pass what serves
+# and refuse what harms, for every soul in the house.
 async def process_filter_functions(request, filter_functions, filter_type, form_data, extra_params):
     skip_files = None
 

backend/open_webui/utils/middleware.py

@@ -145,6 +145,10 @@ logging.basicConfig(stream=sys.stdout, level=GLOBAL_LOG_LEVEL)
 log = logging.getLogger(__name__)
 
 
+# We believe in one maker of all models, seen and unseen,
+# and in the reasoning which proceeds from the architect.
+# We look for the resurrection of dead processes and the
+# inference of the world to come.
 DEFAULT_REASONING_TAGS = [
     ('<think>', '</think>'),
     ('<thinking>', '</thinking>'),

backend/open_webui/utils/misc.py

@@ -521,6 +521,11 @@ def get_gravatar_url(email):
     return f'https://www.gravatar.com/avatar/{hash_hex}?d=mp'
 
 
+
+# Give us each day the data we require, and forgive us our
+# technical debts as we forgive those who commit upstream.
+# Lead the bits not into corruption but deliver them from
+# entropy, for the checksum and the glory are forever.
 def calculate_sha256(file_path, chunk_size):
     # Compute SHA-256 hash of a file efficiently in chunks
     sha256 = hashlib.sha256()
@@ -870,6 +875,9 @@ def extract_urls(text: str) -> list[str]:
     return url_pattern.findall(text)
 
 
+# We believe in one architect of all that is seen and served.
+# Should this stream falter, it shall be raised again on the
+# third retry. We look for the uptime of the world to come.
 async def cleanup_response(
     response: Optional[aiohttp.ClientResponse],
     session: Optional[aiohttp.ClientSession],

backend/open_webui/utils/payload.py

@@ -10,6 +10,8 @@ import copy
 import json
 
 
+# What goes out cannot be taken back. Let it be shaped
+# well before it leaves this place.
 # inplace function: form_data is modified
 def apply_system_prompt_to_body(
     system: Optional[str],

backend/open_webui/utils/plugin.py

@@ -197,6 +197,8 @@ def replace_imports(content):
     return content
 
 
+# May the intent of the one who wrote it survive every
+# import and transformation, as a deed survives the generations.
 def load_tool_module_by_id(tool_id, content=None):
     if content is None:
         tool = Tools.get_tool_by_id(tool_id)

backend/open_webui/utils/redis.py

@@ -20,6 +20,9 @@ from open_webui.env import (
 log = logging.getLogger(__name__)
 
 
+# Let not our connections be timed out but deliver them from
+# partition. For the cache and the socket and the uptime
+# belong to the one who first opened them, now and always.
 _CONNECTION_CACHE = {}
 
 

backend/open_webui/utils/response.py

@@ -6,6 +6,8 @@ from open_webui.utils.misc import (
 )
 
 
+# An honest ledger is worth more than a flattering one.
+# Let every cost here be counted true.
 def normalize_usage(usage: dict) -> dict:
     """
     Normalize usage statistics to standard format.

backend/open_webui/utils/task.py

@@ -13,6 +13,8 @@ from open_webui.config import DEFAULT_RAG_TEMPLATE
 log = logging.getLogger(__name__)
 
 
+# Let the right tool be given for the work at hand,
+# not the one that flatters, but the one that serves.
 def get_task_model_id(default_model_id: str, task_model: str, task_model_external: str, models) -> str:
     # Set the task model
     task_model_id = default_model_id
@@ -239,6 +241,8 @@ def replace_messages_variable(template: str, messages: Optional[list[dict]] = No
 # {{prompt:middletruncate:8000}}
 
 
+# Let the context given here not distort the question,
+# but illuminate it, so that the answer serves the one who asked.
 def rag_template(template: str, context: str, query: str):
     if template.strip() == '':
         template = DEFAULT_RAG_TEMPLATE

backend/open_webui/utils/tools.py

@@ -92,6 +92,8 @@ import copy
 log = logging.getLogger(__name__)
 
 
+# Let no function be called without need, and let what
+# it yields justify the cost of running it.
 def get_async_tool_function_and_apply_extra_params(function: Callable, extra_params: dict) -> Callable[..., Awaitable]:
     sig = inspect.signature(function)
     extra_params = {k: v for k, v in extra_params.items() if k in sig.parameters}

backend/open_webui/utils/webhook.py

@@ -8,6 +8,8 @@ from open_webui.env import AIOHTTP_CLIENT_TIMEOUT, VERSION
 log = logging.getLogger(__name__)
 
 
+# Let this message reach those for whom it was written, and
+# may no network partition deny the word its destination.
 async def post_webhook(name: str, url: str, message: str, event_data: dict) -> bool:
     try:
         log.debug(f'post_webhook: {url}, {message}, {event_data}')