mirror of
https://github.com/open-webui/open-webui
synced 2025-05-15 02:56:09 +00:00
47 lines
1.2 KiB
Python
47 lines
1.2 KiB
Python
import logging
|
|
|
|
from litellm.proxy.proxy_server import ProxyConfig, initialize
|
|
from litellm.proxy.proxy_server import app
|
|
|
|
from fastapi import FastAPI, Request, Depends, status
|
|
from fastapi.responses import JSONResponse
|
|
from utils.utils import get_http_authorization_cred, get_current_user
|
|
from config import SRC_LOG_LEVELS, ENV
|
|
|
|
log = logging.getLogger(__name__)
|
|
log.setLevel(SRC_LOG_LEVELS["LITELLM"])
|
|
|
|
proxy_config = ProxyConfig()
|
|
|
|
|
|
async def config():
|
|
router, model_list, general_settings = await proxy_config.load_config(
|
|
router=None, config_file_path="./data/litellm/config.yaml"
|
|
)
|
|
|
|
await initialize(config="./data/litellm/config.yaml", telemetry=False)
|
|
|
|
|
|
async def startup():
|
|
await config()
|
|
|
|
|
|
@app.on_event("startup")
|
|
async def on_startup():
|
|
await startup()
|
|
|
|
|
|
@app.middleware("http")
|
|
async def auth_middleware(request: Request, call_next):
|
|
auth_header = request.headers.get("Authorization", "")
|
|
|
|
if ENV != "dev":
|
|
try:
|
|
user = get_current_user(get_http_authorization_cred(auth_header))
|
|
log.debug(f"user: {user}")
|
|
except Exception as e:
|
|
return JSONResponse(status_code=400, content={"detail": str(e)})
|
|
|
|
response = await call_next(request)
|
|
return response
|