From 422288dc4d5dfd140c9874219e22fa7ba0eee54f Mon Sep 17 00:00:00 2001 From: mohiit1502 Date: Wed, 18 Mar 2026 02:16:07 +0530 Subject: [PATCH] =?UTF-8?q?fix:=20resolve=20owner=5Fid=20from=20CallerIden?= =?UTF-8?q?tity=20on=20corpus=20create=20=E2=80=94=20prevents=20NOT=20NULL?= =?UTF-8?q?=20constraint=20violation=20in=20single-user=20mode?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/api/routers/corpora.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/api/routers/corpora.py b/src/api/routers/corpora.py index 79914f96..c407af01 100644 --- a/src/api/routers/corpora.py +++ b/src/api/routers/corpora.py @@ -22,11 +22,12 @@ import secrets import time from typing import Any, Dict, List, Optional -from fastapi import APIRouter, BackgroundTasks, HTTPException, Request +from fastapi import APIRouter, BackgroundTasks, Depends, HTTPException, Request from pydantic import BaseModel, Field from libs.db.connection import get_db from libs.logging import get_logger +from src.api.dependencies import CallerIdentity, get_caller_identity from src.common.types import ExecutionContext log = get_logger("api.corpora") @@ -221,11 +222,13 @@ async def classify_url_endpoint( async def create_corpus( body: CreateCorpusRequest, request: Request, + caller: CallerIdentity = Depends(get_caller_identity), ) -> Dict[str, Any]: """Create a new empty corpus.""" db = get_db() cid = _cid() corpus_id = _corpus_id() + owner_id = body.owner_id or caller.created_by log.info("corpus_create", { "component": "api.corpora", @@ -235,6 +238,7 @@ async def create_corpus( "metadata": { "name": body.name, "embedding_model": body.embedding_model, + "owner_id": owner_id, }, }) @@ -249,7 +253,7 @@ async def create_corpus( corpus_id, body.name, body.description, - body.owner_id, + owner_id, body.embedding_model, body.embedding_dims, body.chunk_size,