open-webui/backend/apps/ollama/main.py

973 lines
27 KiB
Python
Raw Normal View History

from fastapi import FastAPI, Request, Response, HTTPException, Depends, status
2024-01-04 22:06:31 +01:00
from fastapi.middleware.cors import CORSMiddleware
from fastapi.responses import StreamingResponse
2024-01-06 02:16:35 +01:00
from fastapi.concurrency import run_in_threadpool
2023-11-15 01:28:51 +01:00
2024-03-05 10:41:22 +01:00
from pydantic import BaseModel, ConfigDict
2024-03-05 09:59:35 +01:00
import random
2023-11-15 01:28:51 +01:00
import requests
import json
2024-01-18 04:19:44 +01:00
import uuid
2024-03-05 09:59:35 +01:00
import aiohttp
import asyncio
2023-11-15 01:28:51 +01:00
2023-11-19 01:47:12 +01:00
from apps.web.models.users import Users
from constants import ERROR_MESSAGES
from utils.utils import decode_token, get_current_user, get_admin_user
2024-03-06 20:44:00 +01:00
from config import OLLAMA_BASE_URLS
2023-11-15 01:28:51 +01:00
2024-03-05 09:59:35 +01:00
from typing import Optional, List, Union
2024-01-04 22:06:31 +01:00
app = FastAPI()
app.add_middleware(
CORSMiddleware,
allow_origins=["*"],
allow_credentials=True,
allow_methods=["*"],
allow_headers=["*"],
)
2023-11-15 01:28:51 +01:00
2024-03-06 20:44:00 +01:00
app.state.OLLAMA_BASE_URLS = OLLAMA_BASE_URLS
2024-03-05 09:59:35 +01:00
app.state.MODELS = {}
2023-11-15 01:28:51 +01:00
2024-01-18 04:19:44 +01:00
REQUEST_POOL = []
2024-03-05 10:21:50 +01:00
# TODO: Implement a more intelligent load balancing mechanism for distributing requests among multiple backend instances.
# Current implementation uses a simple round-robin approach (random.choice). Consider incorporating algorithms like weighted round-robin,
# least connections, or least response time for better resource utilization and performance optimization.
2024-03-05 09:59:35 +01:00
@app.middleware("http")
async def check_url(request: Request, call_next):
if len(app.state.MODELS) == 0:
await get_all_models()
else:
pass
response = await call_next(request)
return response
@app.get("/urls")
async def get_ollama_api_urls(user=Depends(get_admin_user)):
return {"OLLAMA_BASE_URLS": app.state.OLLAMA_BASE_URLS}
2024-01-04 22:06:31 +01:00
2023-11-15 01:28:51 +01:00
2024-01-04 22:06:31 +01:00
class UrlUpdateForm(BaseModel):
2024-03-05 09:59:35 +01:00
urls: List[str]
2024-01-04 22:06:31 +01:00
2024-03-05 09:59:35 +01:00
@app.post("/urls/update")
2024-02-17 08:30:38 +01:00
async def update_ollama_api_url(form_data: UrlUpdateForm, user=Depends(get_admin_user)):
2024-03-05 09:59:35 +01:00
app.state.OLLAMA_BASE_URLS = form_data.urls
print(app.state.OLLAMA_BASE_URLS)
return {"OLLAMA_BASE_URLS": app.state.OLLAMA_BASE_URLS}
2024-01-05 10:25:34 +01:00
2024-01-18 04:19:44 +01:00
@app.get("/cancel/{request_id}")
async def cancel_ollama_request(request_id: str, user=Depends(get_current_user)):
if user:
if request_id in REQUEST_POOL:
REQUEST_POOL.remove(request_id)
return True
else:
raise HTTPException(status_code=401, detail=ERROR_MESSAGES.ACCESS_PROHIBITED)
2024-03-05 09:59:35 +01:00
async def fetch_url(url):
try:
async with aiohttp.ClientSession() as session:
async with session.get(url) as response:
return await response.json()
except Exception as e:
# Handle connection error here
print(f"Connection error: {e}")
return None
def merge_models_lists(model_lists):
merged_models = {}
for idx, model_list in enumerate(model_lists):
for model in model_list:
digest = model["digest"]
if digest not in merged_models:
model["urls"] = [idx]
merged_models[digest] = model
else:
merged_models[digest]["urls"].append(idx)
return list(merged_models.values())
# user=Depends(get_current_user)
async def get_all_models():
print("get_all_models")
tasks = [fetch_url(f"{url}/api/tags") for url in app.state.OLLAMA_BASE_URLS]
responses = await asyncio.gather(*tasks)
responses = list(filter(lambda x: x is not None, responses))
models = {
"models": merge_models_lists(
map(lambda response: response["models"], responses)
)
}
app.state.MODELS = {model["model"]: model for model in models["models"]}
return models
@app.get("/api/tags")
@app.get("/api/tags/{url_idx}")
async def get_ollama_tags(
url_idx: Optional[int] = None, user=Depends(get_current_user)
):
if url_idx == None:
return await get_all_models()
else:
url = app.state.OLLAMA_BASE_URLS[url_idx]
try:
r = requests.request(method="GET", url=f"{url}/api/tags")
r.raise_for_status()
return r.json()
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
@app.get("/api/version")
@app.get("/api/version/{url_idx}")
async def get_ollama_versions(url_idx: Optional[int] = None):
if url_idx == None:
# returns lowest version
tasks = [fetch_url(f"{url}/api/version") for url in app.state.OLLAMA_BASE_URLS]
responses = await asyncio.gather(*tasks)
responses = list(filter(lambda x: x is not None, responses))
lowest_version = min(
responses, key=lambda x: tuple(map(int, x["version"].split(".")))
)
return {"version": lowest_version["version"]}
else:
url = app.state.OLLAMA_BASE_URLS[url_idx]
try:
r = requests.request(method="GET", url=f"{url}/api/version")
r.raise_for_status()
return r.json()
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
class ModelNameForm(BaseModel):
name: str
@app.post("/api/pull")
@app.post("/api/pull/{url_idx}")
async def pull_model(
form_data: ModelNameForm, url_idx: int = 0, user=Depends(get_admin_user)
):
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:12:55 +01:00
print(url)
2024-03-05 09:59:35 +01:00
r = None
2024-03-05 11:12:55 +01:00
def get_request():
nonlocal url
2024-03-05 09:59:35 +01:00
nonlocal r
try:
def stream_content():
for chunk in r.iter_content(chunk_size=8192):
yield chunk
r = requests.request(
method="POST",
url=f"{url}/api/pull",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
stream=True,
)
r.raise_for_status()
return StreamingResponse(
stream_content(),
status_code=r.status_code,
headers=dict(r.headers),
)
except Exception as e:
raise e
try:
2024-03-05 11:12:55 +01:00
return await run_in_threadpool(get_request)
2024-03-05 09:59:35 +01:00
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
class PushModelForm(BaseModel):
name: str
insecure: Optional[bool] = None
stream: Optional[bool] = None
@app.delete("/api/push")
@app.delete("/api/push/{url_idx}")
async def push_model(
form_data: PushModelForm,
url_idx: Optional[int] = None,
user=Depends(get_admin_user),
):
if url_idx == None:
if form_data.name in app.state.MODELS:
url_idx = app.state.MODELS[form_data.name]["urls"][0]
else:
raise HTTPException(
status_code=400,
2024-03-05 10:07:59 +01:00
detail=ERROR_MESSAGES.MODEL_NOT_FOUND(form_data.name),
2024-03-05 09:59:35 +01:00
)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 09:59:35 +01:00
r = None
def get_request():
nonlocal url
nonlocal r
try:
def stream_content():
for chunk in r.iter_content(chunk_size=8192):
yield chunk
r = requests.request(
method="POST",
url=f"{url}/api/push",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
)
r.raise_for_status()
return StreamingResponse(
stream_content(),
status_code=r.status_code,
headers=dict(r.headers),
)
except Exception as e:
raise e
try:
return await run_in_threadpool(get_request)
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
class CreateModelForm(BaseModel):
name: str
modelfile: Optional[str] = None
stream: Optional[bool] = None
path: Optional[str] = None
@app.post("/api/create")
@app.post("/api/create/{url_idx}")
async def create_model(
form_data: CreateModelForm, url_idx: int = 0, user=Depends(get_admin_user)
):
print(form_data)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 09:59:35 +01:00
r = None
def get_request():
nonlocal url
nonlocal r
try:
def stream_content():
for chunk in r.iter_content(chunk_size=8192):
yield chunk
r = requests.request(
method="POST",
url=f"{url}/api/create",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
stream=True,
)
r.raise_for_status()
print(r)
return StreamingResponse(
stream_content(),
status_code=r.status_code,
headers=dict(r.headers),
)
except Exception as e:
raise e
try:
return await run_in_threadpool(get_request)
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
class CopyModelForm(BaseModel):
source: str
destination: str
@app.post("/api/copy")
@app.post("/api/copy/{url_idx}")
async def copy_model(
form_data: CopyModelForm,
url_idx: Optional[int] = None,
user=Depends(get_admin_user),
):
if url_idx == None:
if form_data.source in app.state.MODELS:
url_idx = app.state.MODELS[form_data.source]["urls"][0]
else:
raise HTTPException(
status_code=400,
2024-03-05 10:07:59 +01:00
detail=ERROR_MESSAGES.MODEL_NOT_FOUND(form_data.source),
2024-03-05 09:59:35 +01:00
)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 09:59:35 +01:00
try:
r = requests.request(
method="POST",
url=f"{url}/api/copy",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
)
r.raise_for_status()
print(r.text)
return True
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
@app.delete("/api/delete")
@app.delete("/api/delete/{url_idx}")
async def delete_model(
form_data: ModelNameForm,
url_idx: Optional[int] = None,
user=Depends(get_admin_user),
):
if url_idx == None:
if form_data.name in app.state.MODELS:
url_idx = app.state.MODELS[form_data.name]["urls"][0]
else:
raise HTTPException(
status_code=400,
2024-03-05 10:07:59 +01:00
detail=ERROR_MESSAGES.MODEL_NOT_FOUND(form_data.name),
2024-03-05 09:59:35 +01:00
)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:12:55 +01:00
print(url)
2024-03-05 09:59:35 +01:00
try:
r = requests.request(
method="DELETE",
url=f"{url}/api/delete",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
)
r.raise_for_status()
print(r.text)
return True
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
@app.post("/api/show")
async def show_model_info(form_data: ModelNameForm, user=Depends(get_current_user)):
if form_data.name not in app.state.MODELS:
raise HTTPException(
status_code=400,
2024-03-05 10:07:59 +01:00
detail=ERROR_MESSAGES.MODEL_NOT_FOUND(form_data.name),
2024-03-05 09:59:35 +01:00
)
url_idx = random.choice(app.state.MODELS[form_data.name]["urls"])
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 09:59:35 +01:00
try:
r = requests.request(
method="POST",
url=f"{url}/api/show",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
)
r.raise_for_status()
return r.json()
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
class GenerateEmbeddingsForm(BaseModel):
model: str
prompt: str
options: Optional[dict] = None
keep_alive: Optional[Union[int, str]] = None
@app.post("/api/embeddings")
@app.post("/api/embeddings/{url_idx}")
async def generate_embeddings(
form_data: GenerateEmbeddingsForm,
url_idx: Optional[int] = None,
user=Depends(get_current_user),
):
if url_idx == None:
if form_data.model in app.state.MODELS:
url_idx = random.choice(app.state.MODELS[form_data.model]["urls"])
else:
raise HTTPException(
status_code=400,
2024-03-05 10:07:59 +01:00
detail=ERROR_MESSAGES.MODEL_NOT_FOUND(form_data.model),
2024-03-05 09:59:35 +01:00
)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 09:59:35 +01:00
try:
r = requests.request(
method="POST",
url=f"{url}/api/embeddings",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
)
r.raise_for_status()
return r.json()
except Exception as e:
print(e)
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
class GenerateCompletionForm(BaseModel):
model: str
prompt: str
images: Optional[List[str]] = None
format: Optional[str] = None
options: Optional[dict] = None
system: Optional[str] = None
template: Optional[str] = None
context: Optional[str] = None
stream: Optional[bool] = True
raw: Optional[bool] = None
keep_alive: Optional[Union[int, str]] = None
@app.post("/api/generate")
@app.post("/api/generate/{url_idx}")
async def generate_completion(
form_data: GenerateCompletionForm,
url_idx: Optional[int] = None,
user=Depends(get_current_user),
):
if url_idx == None:
if form_data.model in app.state.MODELS:
url_idx = random.choice(app.state.MODELS[form_data.model]["urls"])
else:
raise HTTPException(
status_code=400,
detail="error_detail",
)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 09:59:35 +01:00
r = None
def get_request():
nonlocal form_data
nonlocal r
request_id = str(uuid.uuid4())
try:
REQUEST_POOL.append(request_id)
def stream_content():
try:
if form_data.stream:
yield json.dumps({"id": request_id, "done": False}) + "\n"
for chunk in r.iter_content(chunk_size=8192):
if request_id in REQUEST_POOL:
yield chunk
else:
print("User: canceled request")
break
finally:
if hasattr(r, "close"):
r.close()
if request_id in REQUEST_POOL:
REQUEST_POOL.remove(request_id)
r = requests.request(
method="POST",
url=f"{url}/api/generate",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
stream=True,
)
r.raise_for_status()
return StreamingResponse(
stream_content(),
status_code=r.status_code,
headers=dict(r.headers),
)
except Exception as e:
raise e
try:
return await run_in_threadpool(get_request)
except Exception as e:
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
)
class ChatMessage(BaseModel):
role: str
content: str
images: Optional[List[str]] = None
class GenerateChatCompletionForm(BaseModel):
model: str
messages: List[ChatMessage]
format: Optional[str] = None
options: Optional[dict] = None
template: Optional[str] = None
stream: Optional[bool] = True
keep_alive: Optional[Union[int, str]] = None
@app.post("/api/chat")
@app.post("/api/chat/{url_idx}")
2024-03-05 10:41:22 +01:00
async def generate_chat_completion(
2024-03-05 09:59:35 +01:00
form_data: GenerateChatCompletionForm,
url_idx: Optional[int] = None,
user=Depends(get_current_user),
):
if url_idx == None:
if form_data.model in app.state.MODELS:
url_idx = random.choice(app.state.MODELS[form_data.model]["urls"])
else:
raise HTTPException(
status_code=400,
2024-03-05 10:07:59 +01:00
detail=ERROR_MESSAGES.MODEL_NOT_FOUND(form_data.model),
2024-03-05 09:59:35 +01:00
)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 09:59:35 +01:00
r = None
2024-03-07 03:37:40 +01:00
print(form_data.model_dump_json(exclude_none=True).encode())
2024-03-05 09:59:35 +01:00
def get_request():
nonlocal form_data
nonlocal r
request_id = str(uuid.uuid4())
try:
REQUEST_POOL.append(request_id)
def stream_content():
try:
if form_data.stream:
yield json.dumps({"id": request_id, "done": False}) + "\n"
for chunk in r.iter_content(chunk_size=8192):
if request_id in REQUEST_POOL:
yield chunk
else:
print("User: canceled request")
break
finally:
if hasattr(r, "close"):
r.close()
if request_id in REQUEST_POOL:
REQUEST_POOL.remove(request_id)
r = requests.request(
method="POST",
url=f"{url}/api/chat",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 09:59:35 +01:00
stream=True,
)
r.raise_for_status()
return StreamingResponse(
stream_content(),
status_code=r.status_code,
headers=dict(r.headers),
)
except Exception as e:
2024-03-07 03:37:40 +01:00
print(e)
2024-03-05 09:59:35 +01:00
raise e
try:
return await run_in_threadpool(get_request)
except Exception as e:
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
2024-03-05 10:41:22 +01:00
)
# TODO: we should update this part once Ollama supports other types
class OpenAIChatMessage(BaseModel):
role: str
content: str
model_config = ConfigDict(extra="allow")
class OpenAIChatCompletionForm(BaseModel):
model: str
messages: List[OpenAIChatMessage]
model_config = ConfigDict(extra="allow")
@app.post("/v1/chat/completions")
@app.post("/v1/chat/completions/{url_idx}")
async def generate_openai_chat_completion(
form_data: OpenAIChatCompletionForm,
url_idx: Optional[int] = None,
user=Depends(get_current_user),
):
if url_idx == None:
if form_data.model in app.state.MODELS:
url_idx = random.choice(app.state.MODELS[form_data.model]["urls"])
else:
raise HTTPException(
status_code=400,
detail=ERROR_MESSAGES.MODEL_NOT_FOUND(form_data.model),
)
url = app.state.OLLAMA_BASE_URLS[url_idx]
2024-03-05 11:19:25 +01:00
print(url)
2024-03-05 10:41:22 +01:00
r = None
def get_request():
nonlocal form_data
nonlocal r
request_id = str(uuid.uuid4())
try:
REQUEST_POOL.append(request_id)
def stream_content():
try:
if form_data.stream:
yield json.dumps(
{"request_id": request_id, "done": False}
) + "\n"
for chunk in r.iter_content(chunk_size=8192):
if request_id in REQUEST_POOL:
yield chunk
else:
print("User: canceled request")
break
finally:
if hasattr(r, "close"):
r.close()
if request_id in REQUEST_POOL:
REQUEST_POOL.remove(request_id)
r = requests.request(
method="POST",
url=f"{url}/v1/chat/completions",
2024-03-07 03:37:40 +01:00
data=form_data.model_dump_json(exclude_none=True).encode(),
2024-03-05 10:41:22 +01:00
stream=True,
)
r.raise_for_status()
return StreamingResponse(
stream_content(),
status_code=r.status_code,
headers=dict(r.headers),
)
except Exception as e:
raise e
try:
return await run_in_threadpool(get_request)
except Exception as e:
error_detail = "Open WebUI: Server Connection Error"
if r is not None:
try:
res = r.json()
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
raise HTTPException(
status_code=r.status_code if r else 500,
detail=error_detail,
2024-03-05 09:59:35 +01:00
)
2024-01-04 22:06:31 +01:00
@app.api_route("/{path:path}", methods=["GET", "POST", "PUT", "DELETE"])
2024-03-05 10:21:50 +01:00
async def deprecated_proxy(path: str, request: Request, user=Depends(get_current_user)):
2024-03-05 09:59:35 +01:00
url = app.state.OLLAMA_BASE_URLS[0]
target_url = f"{url}/{path}"
2024-01-04 22:06:31 +01:00
body = await request.body()
headers = dict(request.headers)
if user.role in ["user", "admin"]:
if path in ["pull", "delete", "push", "copy", "create"]:
if user.role != "admin":
2024-01-05 10:25:34 +01:00
raise HTTPException(
2024-02-17 08:30:38 +01:00
status_code=status.HTTP_401_UNAUTHORIZED,
detail=ERROR_MESSAGES.ACCESS_PROHIBITED,
2024-01-05 10:25:34 +01:00
)
2024-01-04 22:06:31 +01:00
else:
2024-02-17 08:30:38 +01:00
raise HTTPException(
status_code=status.HTTP_401_UNAUTHORIZED,
detail=ERROR_MESSAGES.ACCESS_PROHIBITED,
)
2023-12-15 02:05:46 +01:00
headers.pop("host", None)
headers.pop("authorization", None)
headers.pop("origin", None)
headers.pop("referer", None)
2023-12-26 22:40:03 +01:00
2024-01-06 02:16:35 +01:00
r = None
def get_request():
nonlocal r
2024-01-18 04:19:44 +01:00
request_id = str(uuid.uuid4())
2024-01-06 02:16:35 +01:00
try:
2024-01-18 04:19:44 +01:00
REQUEST_POOL.append(request_id)
def stream_content():
try:
2024-03-02 12:01:44 +01:00
if path == "generate":
data = json.loads(body.decode("utf-8"))
if not ("stream" in data and data["stream"] == False):
yield json.dumps({"id": request_id, "done": False}) + "\n"
elif path == "chat":
2024-01-18 04:19:44 +01:00
yield json.dumps({"id": request_id, "done": False}) + "\n"
for chunk in r.iter_content(chunk_size=8192):
if request_id in REQUEST_POOL:
yield chunk
else:
print("User: canceled request")
break
finally:
if hasattr(r, "close"):
r.close()
2024-03-02 12:01:44 +01:00
if request_id in REQUEST_POOL:
REQUEST_POOL.remove(request_id)
2024-01-18 04:19:44 +01:00
2024-01-06 02:16:35 +01:00
r = requests.request(
method=request.method,
url=target_url,
data=body,
headers=headers,
stream=True,
)
r.raise_for_status()
2024-01-18 04:19:44 +01:00
# r.close()
2024-01-06 02:16:35 +01:00
return StreamingResponse(
2024-01-18 04:19:44 +01:00
stream_content(),
2024-01-06 02:16:35 +01:00
status_code=r.status_code,
headers=dict(r.headers),
)
except Exception as e:
raise e
2024-01-06 02:16:35 +01:00
try:
return await run_in_threadpool(get_request)
except Exception as e:
2024-02-17 08:30:38 +01:00
error_detail = "Open WebUI: Server Connection Error"
2024-01-06 02:16:35 +01:00
if r is not None:
2024-01-04 22:06:31 +01:00
try:
2024-01-06 02:16:35 +01:00
res = r.json()
2024-01-04 22:06:31 +01:00
if "error" in res:
error_detail = f"Ollama: {res['error']}"
except:
error_detail = f"Ollama: {e}"
2024-01-05 10:25:34 +01:00
raise HTTPException(
2024-01-06 02:16:35 +01:00
status_code=r.status_code if r else 500,
2024-01-05 10:25:34 +01:00
detail=error_detail,
)