From 2876c179ac173c189f9114f0916d951f650ed031 Mon Sep 17 00:00:00 2001
From: wh <wanghao@qq.com>
Date: Fri, 10 Apr 2026 15:40:56 +0800
Subject: [PATCH] =?UTF-8?q?feat(US2):=20image=20quad=20extraction=20?=
 =?UTF-8?q?=E2=80=94=20POST=20/api/v1/image/extract?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- app/models/image_models.py: BBox, QuadrupleItem, ImageExtract{Request,Response}
- app/services/image_service.py: download → base64 LLM → bbox clamp → crop upload
- app/routers/image.py: POST /image/extract handler
- tests: 4 service + 3 router tests, 7/7 passing
---
 .../__pycache__/image_models.cpython-312.pyc  | Bin 0 -> 1375 bytes
 app/models/image_models.py                    |  28 +++++
 app/routers/__pycache__/image.cpython-312.pyc | Bin 252 -> 1133 bytes
 app/routers/image.py                          |  17 ++-
 .../__pycache__/image_service.cpython-312.pyc | Bin 0 -> 4127 bytes
 app/services/image_service.py                 |  90 ++++++++++++++++
 ..._image_router.cpython-312-pytest-9.0.3.pyc | Bin 0 -> 6900 bytes
 ...image_service.cpython-312-pytest-9.0.3.pyc | Bin 0 -> 10412 bytes
 tests/test_image_router.py                    |  63 +++++++++++
 tests/test_image_service.py                   | 102 ++++++++++++++++++
 10 files changed, 299 insertions(+), 1 deletion(-)
 create mode 100644 app/models/__pycache__/image_models.cpython-312.pyc
 create mode 100644 app/models/image_models.py
 create mode 100644 app/services/__pycache__/image_service.cpython-312.pyc
 create mode 100644 app/services/image_service.py
 create mode 100644 tests/__pycache__/test_image_router.cpython-312-pytest-9.0.3.pyc
 create mode 100644 tests/__pycache__/test_image_service.cpython-312-pytest-9.0.3.pyc
 create mode 100644 tests/test_image_router.py
 create mode 100644 tests/test_image_service.py

diff --git a/app/models/__pycache__/image_models.cpython-312.pyc b/app/models/__pycache__/image_models.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..35c1d1e051e9c2b5a022e96fa8afe268ba70b483
GIT binary patch
literal 1375
zcma)+&rcIU6vt<}v)j^Asz4N_0m1=Y4_-7z2=PD!18R-GE)B_K=?t>6?JhH0p&SfJ
zHGx|_!Czov{8Ky`I5d;!#gjJ^>cx|9W`RJ1iJSJjZ@#npcHU>+?w5Q%i{N<svF(4y
z2>sB5<HJ4*4p$)9MGP?<pein7j8f<UVySnCSsZ`1lIzMT;}US~Q?6xP2i){2ml!t#
zZqF&#Ze-ouPo2)is%OTN{Bg*5P)Qz;=+V>A;T;(7B96+Kp>paa;ua?iPlIcs)JbHW
zL_|jo+jSI~nF%)(hF?SBb%j?-uB|eZ*1RgGRAnixhO8dwxR=tkx)&VHSbi;51xmeI
zEsVX`4{MUrPv}rD?$5pZQ;X}NSe21i;fsN{#Dhes=TphW8y{>hiWVU`59Fd>^<HuP
zBpBR`8bT8{LLiWrK;ENvI@_E(Bk$(Kh2sm)NAm)v{~rw_Wt&@!Y^DJnVYb2LK;)c&
zOB-;+&8Ym-y2nI43iy1?t12z)ORsq)Ry~p6%&&McS59cGlIqdi{AHgDMV6L;cYj5M
zQN$Td3Xi;a#Z3#{fg-1+7erYy7NSoNFKaPO3OX`HU)0gSvFN+x4G`dzztDWtF7!7`
z?cPH3VY@iCHNP!eFLpNf$yhtv*IZ~14Ihx<B#q8+KDz~&`3E~2n3%R=R@nh!))6t&
zR^X*id4^)cf>s-t*SkEs5eu&pKjUk4E&<oF56z_ksC4YfRqC^nvP~zbLL|a!6jR_E
z1pw5|bRiN~VT}o*ypBe-jA`lORMei9LHNt-Ai&8WGO&h<TeI7@T7x@N`=r<&pV)fR
zdcJr2L-~MAB$V{6=TjPinQlr~z~grE3N})%r3TMdE+cqZxUzjHOqN`yt13kTAGY4?
zt=ayrV#Xo8&@v2vsSAf<a)nm@Yi{I#j3g`8^N?C)q6YJ7v0oATdyzDe$!w6ARA<wx
z%yja`-xCvX2Yd^WybJQn!We%;BOQm}-1cM#!Ku^d;9_gOgW%NZC-~Z)tNm-8K8#2A
LCVwM1ndSTi+0rsM

literal 0
HcmV?d00001

diff --git a/app/models/image_models.py b/app/models/image_models.py
new file mode 100644
index 0000000..79f6a3b
--- /dev/null
+++ b/app/models/image_models.py
@@ -0,0 +1,28 @@
+from pydantic import BaseModel
+
+
+class BBox(BaseModel):
+    x: int
+    y: int
+    w: int
+    h: int
+
+
+class QuadrupleItem(BaseModel):
+    subject: str
+    predicate: str
+    object: str
+    qualifier: str | None = None
+    bbox: BBox
+    cropped_image_path: str
+
+
+class ImageExtractRequest(BaseModel):
+    file_path: str
+    task_id: int
+    model: str | None = None
+    prompt_template: str | None = None
+
+
+class ImageExtractResponse(BaseModel):
+    items: list[QuadrupleItem]
diff --git a/app/routers/__pycache__/image.cpython-312.pyc b/app/routers/__pycache__/image.cpython-312.pyc
index 9c78dda6ccfdc3e7d7aac2c62b6f6125e092e49a..513b0f1789cadb3d4f11b4c6a1409513869d9d32 100644
GIT binary patch
literal 1133
zcmY*Y&1(}u6rb6zWSg%h_Ct)ts#S=T6uh*EShev`tRnWd1jCx0hUjjR&TOpJ9;y|+
zc(%RhK}3{R@c$4bQlWJ~s)(Ss)Oe7dd^5ZCV_@FAkKcRq=J$5rBobW+*3;*k)n^Jq
zUxcx{WCV=PTM*00K@N72hb`<WmV$+?xT>dFn$%TS_YBLBy5>f_s1@~0%ape6c6l)?
z=EbeJv<)}mC9Nbz3L@BvRPb7K6$jT^DU!N&aJPlOr(=@%TGuM{C>G=?<WG*Y%-sqz
ziW4I-Cr&gcK@2BJ;xkbvbx&UnQjwLO@6M&a3oEB^^US5m%k`#DD326KgVY?B!`z&j
zx-j8ZNzDf%G40o>T_K@E;mHc|ORnpc$`Zme!e#*|^g-o4lO80UyXjNA>|Z9cO~QQM
z^S_fd>NQ5h9aRA?F+y)t%Y^F^27b-AE9_QsM21I5Pz?M@N`l;yS9gfZRZ3>L3O(^i
z*a$Z$@td?(R>OCTLx;TtyE6siJi;(mKO`QZYazK1`m+|$0$xy7!x~F4^xL36QkK>G
zx{jvND0-;9Qs;0EU(6{q26;RYc3GNj+CZjCQ{biDLZm@3QEPB;aA&M=qBvKl*IC0Z
zlcH;1C2k-~c6FDCqTOf|sT>b0N)Gak`M)<v5AB13aZ&j&h;QiEBKjFenFAZ?;dklb
z7t^l~zn)u9k8i}rTiSRlHon6I_-=LxKgNf&C;AYyp5c)hoB4L5N=18A1HpUX@_aC2
zmIrF{S8bS&ppftVHxv>cgbfkymEk%ic}IRyq*ksHMkAthQ~>$~Ku(V3<s*VIGHMEl
z`0;pLK*H~V1<V=&6I^T5nJ=IH5_JHJXs^hKo`i}`mz<*F{}E$l_dv8&jPVva`V}4f
zh>mZe!WO#l5gq+(W>)%F%=hM@MWbyXCHf$HC)-L4wDM;cv+H<b+dzE-D_7Qghd&Gq
zwT_Ig4~%U`bbK0bn)}<TP(GQNwk{M%PiEUP*p4D&-w#uGJ1SBNcv}%V9fU@H160E-
A;{X5v

delta 204
zcmaFM@rSYgG%qg~0}!MyzLDt!q#uJgFu)9Dd{zN6rZc24q%h_%<T6GvGBPkRq%x*3
zr8BN!Ud;$m6~$D^qRILa#L;BD#pxK}8I)gIl3H|&)iXCSJryX%Qj(Zn?5D|mi#;u|
zxFoS4vxr#;sQMOL5m@0$hR-0)ldGAm4LEFa^HWN5QtgVkfkGe~iba6L2WCb_#=8u%
V4>^Tqh|l1>!l~5AR>TRE005g1E{^~J

diff --git a/app/routers/image.py b/app/routers/image.py
index 30aefbc..7ede9f4 100644
--- a/app/routers/image.py
+++ b/app/routers/image.py
@@ -1,3 +1,18 @@
-from fastapi import APIRouter
+from fastapi import APIRouter, Depends
+
+from app.clients.llm.base import LLMClient
+from app.clients.storage.base import StorageClient
+from app.core.dependencies import get_llm_client, get_storage_client
+from app.models.image_models import ImageExtractRequest, ImageExtractResponse
+from app.services import image_service
 
 router = APIRouter(tags=["Image"])
+
+
+@router.post("/image/extract", response_model=ImageExtractResponse)
+async def extract_image(
+    req: ImageExtractRequest,
+    llm: LLMClient = Depends(get_llm_client),
+    storage: StorageClient = Depends(get_storage_client),
+) -> ImageExtractResponse:
+    return await image_service.extract_quads(req, llm, storage)
diff --git a/app/services/__pycache__/image_service.cpython-312.pyc b/app/services/__pycache__/image_service.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..334c01159291d44b3b8be06549d5f1149d846ea6
GIT binary patch
literal 4127
zcma(UZEO=)a@QXlf359&*s=3PpoL(XI-#UMN=p?=P{UVRXr-&m)pER>V6*;UcTEyl
zpG+xjqH>B+x#E<Mnp1nt2?|ubyP_j^T&4b~?*7DerC6^ZMQR-27p_2e*Xn-Uyj^b$
zTzhwGd1l_5dGqGY%$wQ$8%>)CcqV>R2>lDFZ}C8V3}xc(2SA)87=j@=!lz);N6KT3
zPa|WkPX}1T=_8bnBC(8?tBM$W2AS4z#)!#hl4(6>j#zvanWi{8V)a>Nx{9+!>^^&>
z+E*Q^@zq3XeYGT^Ay_M0cb-%%@i`cS&&e3sYR1G;jF~ks7Pe;4z|e2#eD$NG$9fwJ
z?(~qzxPAMM=eQ6X6=6W{7Gr#1h+Uj84Y8s>7>f>uhJbBhM?^jl6#Zc#7KO3Q<zhoa
zEbq}F-KI^k5meh30R_E^;4XH5f)zwm_u!-uk3|I*(Jv+f44;T|Y@f(R5>7Dw)}_yi
zV{a~;P2ajUS)9%mPyPAk_*-|Tk1b53ixck_kN#o)%Evd~d*kN&AKtq3X7SXi;?W~F
zuf72S^H)D?-MYJfXY0bRF2l@1cDgt{aqHTN;;FNE`K5`4Gv|uOjuzABiyxm{xcK`!
z)9(q1fiN2s?@W))U%5K}r+11M&jP$NJ^pR#aGYnEP%t2}z%3sA^ya5mJBpv2T}XYT
zuw&}V;>BM-v~qtUz=Z}wERXeGyLkJ<%k$UHEgZfCRum^L&0qOrYc#=eikg9e*a(On
zIyBPWI@;bk+}^r3nQSc{nYj78Z1GHbAqz(bYhFiMp52eM92Y@Vf)XJ_@vNBOqd~0_
zaT(eG9)bVeO?raZMv#z;VmTuS;(S>!sg<-0>4p)bk)amDq)sBjnzG1!XoM6XGhu~J
zmetF$dPx(89Uguptb=-Z7IrS{Jp$Q&2<&}Vb5i@JUQZ+`(Wpv?<=dr>6f9Aqdb5bI
z<v|`Esd|%DB0jnNgzYL-!BUlIRY&0(m8#%HJqF1TuB*(e6x>m&f!G75NE(wSv0j}I
zyHu)zB}%=6;l|3WN-f5~%v4F{Q^Xlf(gHqfQu!4OeuwHHwx}~nnlUg&#w1xnBx63U
zVJs5O(5E#+8paBcOj;!}yi}F0U`a1o)${#_|83$jRWiI>r7D=Q{dhbjJ!3zuxlpa@
z1v}f+Rgz6Tf6_igB&$WwBFC<BHWO*`=iP+j(VAqfRLj)Jc~vJqrb;ul;^QhUcBqt8
z$JAj-Rg+|590wtDR7+Hxbo?KhoDXO+{)8syPuNlaz-p89fE~&DpIGI3V3kpF-fw-<
zB^e|q{9Fg&j7K$+1Ag@iJt*JRr2D>1?^L}~!HipSt3HtPwISIkHHOzzBvfiK6PuU@
zh;o-YU%{scrctT^=su%QHp7iySK+A?-1ugxiD^2oQ)V8{FsK~W;civBg2fFg4Y6;=
zJ^|cP#!D0&enyq4V5U`#y!fm-3qEp6^^)ttQq>Bn`NFdE<vOIwlaO=Ap4Jg!&*Hl3
z3y-MW-NZT~tvR+8AbISU>xg5oeXJcOJ&*3>ap6E!1Bu{1Ruqs~h$Z+S>t_OD08x<`
z!*T+$GVEX=!HNC@At4lt-p1ALU_BOjDujDsM>x(7Z5Rj$?Aoq&q)P}akBl<MpWr#9
z1>n&joj4k2d0bn7gg)!h@YoN00|3nCV;qaBpcRYIsu8WMFZW~29}EFsFPj9NSub;t
z4tE$H8-&P_+qe}Vaukunh}?Tn=MBe)4pKor78g1Y*>TWRu@>5l(j1X-u@fRn>3Ybx
z*y21o9v2Y)Q4DYa;a33gQ2a_v<D1W~!T{fD9v3H6gSU&bj9;-o9uW6pYeUfg1<z6*
zHx+&f7PK<4;V2giF#ds2krj{;pU;owktP~Pra?Xy8AuEcf-m)nP*hxxw7~;UAVVm^
zutA6mvh?lP)!Vb#|6Kp}{#{5f><z?OL@7}~#(}k6Y*dz`%JQ~2XpD<~uq4hw<3~3C
z=H4wmFK>Uz|H7{R9WT6u%)z|@HOPokUVD%(6djE5IN6YqjV2;2kJoA=fe`?qDAIy$
z*sAhwRboszPn8%D_W45$vcUUK<(O0eyc1=3GghdDmoFZ7Kpr<oPYaKGAWvf;r=>PH
zI0Q$Mb5rq}S#hhfg+3Y&@H|)$83GSShWvXKG>o)xd}LK*ah}R~NGT3Lh6pPNkhTK6
zbp(bXQ*mtkK=QaCgF0peP7RZY9Qd*DBOQ)0BK^pK2|q*$nG{Niq)g*T3b?zq{@3S+
zp3P6~8IJM$gm@sx?%@IhET=$!AmoRebRY!N;IutuTG*o;t333^M-g4VC4R_TM&SLh
zDQ>vJ3Ah)xh<~PtdnUr{c)LCIT!FTy-Q%xi`f~J&Y%)hbnc7mY*e3eM`@XWQ&(vmq
zHrYJWwl3#hpX!}+Etz$Bb1v`Hfy=^Y$xo7bSMO|1Z))2;ilA*1JH~fp9{Yg*Xyn{T
z-qM-sy>6l>+Q-||iPOQ^7H_V_n>Tg9ezne%-N(B#yE1|FGl#dQddHreH`!-R4LMUo
zW<%c8Hf!?cOd#6{vi066VTzq`bftFA(e_!oHAlC8MX&jwKeeSq5st<=_oJ74uWX!I
zvo&YmR&Xzwa^~!vCB4>V{Z3CAO(m_tPNkkN)e+ToCvC@VS$%dSZ||JNy07a@Z*4og
zEp5B3{fz#E{!*W7+nL(-wXT2O-jvy$w=Yfg6_!4d>YaDAWJYHlo^j)tcI>5s#h!MK
zZyzJ)Ew(gyV$BI5vpTbTa_u{Zvb|G1=lb%s-n^w_jJ*Co*(bE=o^<f|mUqmVm$NTU
zzLK}J$;*Cpe$G~tUY*{bS$#Z_?#=|VOS6G<%QK;w+P0i+<(Tfe(|wXV&Slq5b>*F%
z<K{7PY<<DeJnLAVb1ct0+Qv+CPB_&2uTH+2*)df;wPtGhlsHq@HD)YW9kbSDIqNc5
z+kH9wm-f81f7Z}HW9XkV&=Zz%%XN#p;A+aeGHEL`v}6wD8XhauH)ftc{tFnszjAVA
zc0<0Q<GRD0>B&}S15>NNc068qr2QUUMO*)_H9`oM5YAQix(G{ami^k?KBH?d?IVfW
zE#&v5RfKu<_oWqt@dfe+p&PRE^&a!qCFJKcxwT&RxpmXCF!%xn4Z1I^n>%6f<wkOA
zGxg=OJ#HBMwSmO28AFeY$Bi0kLNOlqeWZt~6d&dB+XAYCo8k@1UweWVJ}11m9`g7T
z0=e#Il|M2RHty}nCbMHa>s7u6<x-7m7iaMop+6ypI6*0f_C*dZl%ePlUxn4w<7uUD
zdX<Z+43sj5zXs%5r_?`#-yaP`SihgguL3-NXOM62Z;87=68vibkl|_2kl@&j{5}}s
z7AJ%Ol(ZyCenZgT5XNr_(>Fv-kyv$uc;W`J;s()vgJ}DQMo(()5&*ul5~jNJ^Lb-)
wiYieW{i|e2OOW=GbtCzB!Pr#N0-iJ0l=Oh%qFEbDRhTjmRKq<ZP(0r5--KmxNB{r;

literal 0
HcmV?d00001

diff --git a/app/services/image_service.py b/app/services/image_service.py
new file mode 100644
index 0000000..ad7bcc0
--- /dev/null
+++ b/app/services/image_service.py
@@ -0,0 +1,90 @@
+import base64
+import io
+
+import cv2
+import numpy as np
+
+from app.clients.llm.base import LLMClient
+from app.clients.storage.base import StorageClient
+from app.core.config import get_config
+from app.core.json_utils import extract_json
+from app.core.logging import get_logger
+from app.models.image_models import (
+    BBox,
+    ImageExtractRequest,
+    ImageExtractResponse,
+    QuadrupleItem,
+)
+
+logger = get_logger(__name__)
+
+_DEFAULT_PROMPT = (
+    "请分析这张图片，提取其中的知识四元组，以 JSON 数组格式返回，每条包含字段："
+    "subject（主体实体）、predicate（关系/属性）、object（客体实体）、"
+    "qualifier（修饰信息，可为 null）、bbox（{{x, y, w, h}} 像素坐标）。"
+)
+
+
+async def extract_quads(
+    req: ImageExtractRequest,
+    llm: LLMClient,
+    storage: StorageClient,
+) -> ImageExtractResponse:
+    cfg = get_config()
+    bucket = cfg["storage"]["buckets"]["source_data"]
+    model = req.model or cfg["models"]["default_vision"]
+
+    image_bytes = await storage.download_bytes(bucket, req.file_path)
+
+    # Decode with OpenCV for cropping; encode as base64 for LLM
+    nparr = np.frombuffer(image_bytes, np.uint8)
+    img = cv2.imdecode(nparr, cv2.IMREAD_COLOR)
+    img_h, img_w = img.shape[:2]
+
+    b64 = base64.b64encode(image_bytes).decode()
+    image_data_url = f"data:image/jpeg;base64,{b64}"
+
+    prompt = req.prompt_template or _DEFAULT_PROMPT
+    messages = [
+        {
+            "role": "user",
+            "content": [
+                {"type": "image_url", "image_url": {"url": image_data_url}},
+                {"type": "text", "text": prompt},
+            ],
+        }
+    ]
+
+    raw = await llm.chat_vision(model, messages)
+    logger.info("image_extract", extra={"file": req.file_path, "model": model})
+
+    items_raw = extract_json(raw)
+    items: list[QuadrupleItem] = []
+
+    for idx, item in enumerate(items_raw):
+        b = item["bbox"]
+        # Clamp bbox to image dimensions
+        x = max(0, min(int(b["x"]), img_w - 1))
+        y = max(0, min(int(b["y"]), img_h - 1))
+        w = min(int(b["w"]), img_w - x)
+        h = min(int(b["h"]), img_h - y)
+
+        crop = img[y : y + h, x : x + w]
+        _, crop_buf = cv2.imencode(".jpg", crop)
+        crop_bytes = crop_buf.tobytes()
+
+        crop_path = f"crops/{req.task_id}/{idx}.jpg"
+        await storage.upload_bytes(bucket, crop_path, crop_bytes, "image/jpeg")
+
+        items.append(
+            QuadrupleItem(
+                subject=item["subject"],
+                predicate=item["predicate"],
+                object=item["object"],
+                qualifier=item.get("qualifier"),
+                bbox=BBox(x=x, y=y, w=w, h=h),
+                cropped_image_path=crop_path,
+            )
+        )
+
+    return ImageExtractResponse(items=items)
diff --git a/tests/__pycache__/test_image_router.cpython-312-pytest-9.0.3.pyc b/tests/__pycache__/test_image_router.cpython-312-pytest-9.0.3.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..a38db64a455347a5bc3e4b8bc023c686393247cc
GIT binary patch
literal 6900
zcmd^EX^b4j74DwtIeTXIFzaivJuKjO0_^Pzyx<LM2#ycfg&Z3vP485%J>$7j-Lu|Z
zdZbN4A}j=Uq)0fD6*&q4EED8NL^(tfen!flS?^f8DjWqVHfaAjSji9ni1J?b>CN~E
z$q%HIXTN$?_3Cx?tLj%@mH(7X#sx^H-&o4M6A^^JV!=tWEnGVf!fOH%h*%KDMV<$W
z!E8Vjiqd#Uv|7UBVcrrMkMcY=9^-j@JPvuFAQuzk39cI~B#Wu>6v&d+G8rJD7p3vm
zfS`r*UCyJuoP<e)L`jUq;h#(rBzamQsnemu;yKaM8gC~pFAC$UNGsr7qz$lRM$EJ?
zWAlNG$YR6#Oewp+oIMJK#F$a0>S1jUrDe*(R5Plyl=Yq`2oe;6@OSOU0Ivy#{TM;W
z2mET5Ohm)2%wx|L>FvNdyH`yxz`<6^M;*z_NzfD=-9yl)Ce{LGAn#0qrzo7W<uM^6
z9moWipN8@>LBL_dJBElcQ_*In?tJBNCd>k*3Jc9@w5+pGHCHlruwZtopG9*;t&}Yj
zjYW*|#EhZonIH@1iieq~u;4^>Qb%*?bo%<EBM%=sR;EYwikj6971Rl>V4<Ss6kVfJ
zIjDyIhR#vR6~Vy@EmsYVc2{QDYNe<i)fCjQ+xX*X2iV8ur*8w86E4LQC$=2la&p(}
z^v&s?OgG}abB|w2ww^e2{Lrb*XYO4{ZvOTYbHj7`lAJp6$ni&B9;!=guR%}Y?+Jj9
zfB4If-~0YYum0@H>+e>>P;vQpuU!7^tJM||m%sN4Hox<WE5CZ<^6%fQCZVpsw}0@;
zZ{Gdrr*oJ8@Xm4wweCVd{fxxKX(rAv@fZ`2WI`;WS10mX)?l#;)krR@8X60i?W%88
z)k1DEr%@(NOq8dy=r$+el=H>(K0Lv{m<(6Tna;P}6>SC-cd2>H&%l@B$)_nQ?xOQF
ziQv-+DEMwXnL-}ld_^Jw5+o7{oesPmb{1eQXa@7C6^c--NhDGWnUWbgx&=yMGpzsI
zXmj-P?T+N-Bx;5yMH0h4lYw*gXi40_$>%A*+L656@yV2+clhkD^)wvG3_5Xu`Zd=(
z?OyI_mPB~IH|l1(l4JEYdLc)T$ftv|FhjKn#watA6L~3WY;Z>4v$WBv^KvulSaS03
zK%|`(YZCm0!RNvJJ)X8BIex0eNU9b$<7RA1sL7_R|H${WX0y^_$}lUf*u$F@U!P_^
zi8~`BZU3{`i#axLJA1As%w8L5KONxyO^{XOE;C_!J95X~jyTVCa@*T+@E-Vb9XObD
za9oX8i<335+T&)JuY2@x!RM`J9*%Mkuf;z9xrcqWo6SVn88umF`yolzlTI^f`yqA5
zen>f%oZRsPtU4Lq_(oscZTn)w|D!Kvgv`bRXMsUjoI#mV3svoUM~_;`^-T5k@J+8r
zn>MJLHLj<uB5rxO3oj#yI2&NG$y`BGDyne=HeFRes^kb*l=6DHwERa@5w8b^hR%w!
z1NU#K%=BmU_zSj>9!jIso6);<Lp7?pf?IdImL9Siwq|rDQBAL$g-smv5c(0eUQeky
zY|;krza7+|aytv<46UdGSqS7x8F989jrV2rbgsnp2GAT)4K))${XT?&S-&NCAl(i_
zrnptnO$clF8+f+tp$%sAvjI8;jc8@?hVg8(#<PvJXKA@o(TGhD&_%OJtkZk?dU`pN
zX`{Gja@N37q<pMYD62%_RD!jQ4ex(?-yY?e=Y~hdl)YmI4=_1<L^YJDoSrL}SfX0-
zX-k!|ZZO&BNEY8+K?-CjDrId-RxK11s#R#VT&$>6V+m+hCaSrDkt^veTquKv&ekgW
zk#e;_xT<ovP@Yf=N=YqhET-t{q=pt)YM8qpMqzQzRmx<U7GY@Gbfut{R0CRQH@sP<
zg@v<)oK`Yev<PffDHMt<!6n@yt#kmLDC1bHIqmZo2K|Krt6)89o4>Gw?pk4`*Wa<<
zuWOsMtZenSY}b(}0Xy_3iVTWv^btM#djJO^&(@Xx-d_4VD0RZ0&fu#6+Sm0!W9Pwz
zozFD7M(6f5q)nGP?`!lw-sl{e`(i^{dnuhcZ#2@ouxZ1GavM^=rRb)m&If)i&L<zf
z8WIv~t_i_Jcy8osR7kWg%ANCaXI<(#r32LE&Qtol+_fm-@1k8{m0X;cx?UQzN(-LY
z;L29@1vKaCy8>u0$t@>#9^d)$BXc85a(i7`|I+r8<fX?JrS<T;Xceu(0v0UMMbJM<
z+-65~n?ZnH@Q9O<<3p#~;Jr>gH7{?jOFQ1`2B^!M-|C*1cPvWyyJ%Nfr3GHH<O`^8
ziGBnXzv=qjz4LNkT^c#B0MzBa^UAzDvMAy2qFrH?7I?{$FQC39`mrI6P~>&Z$#5@x
z$p0M~CIKJC6&06E1I3NOV^<`L;F2&<+{g_Smmhv_R0fJ0{Wps1(&lEQ7|1PB-1rKL
zEBiL_CIrEuZk*zJ_VEi^kv!rGB+1ikLYqBJAW8CVbUliDYnvX$O}G>{Nm4$Fi>!br
z-xHhBmfKTYmn=IL1^2W|S~&TLkyfN7HW35L3q;Htf0H8%%uXC;rw#k~h?v)>nIB!U
z>9gHT&m&?EA(c5Hm2D!HFz(bh35S3=xlP1kK*Zv;Fp!Uq1N44y%dA`~8);+==@(w0
zpMx3-M=^nB5I&Fa5Ww<3Ahyz8EcPSd#z6-Wb|CBoU=lz4x9r=uUwL|XbZn2ZXLR)7
zD18hSb|ZWN;c<XWi?{XCJy`oB!cz!)5x#`54`DyT0fd7HcsD_xK^R5g+gy^4q5Leu
za|nEJUq<OG2wz3`8p1fj*AWgOd=o(d&~f(s8&BHWdAghIJg|uZ;i9^xXn5u0?nGOA
z`>6(I9zc6=8FiDL==?*C&fR<?`V8+qC#UA+jdf|D-Zg*-a@WATJg_L?@1j#<6&HBX
zk}vQsmh8udG+;$<_ZkA6<X&a8-ZXj>_X-2<y^!)kGDYt)1EMopS&^DXXT1Ara!XbV
zLUfkQpegZ#SjY^)1%&Jv%;QDSiUi+(h(~AW<9+`S9g)BAly7w;FTWu=d-j{eanpTM
zh|Zp7vpDW*^5}ePUH4k!Ha6WTPMqi*CK#Q=b_9wT$jW*0S!#BXa<e0G5F$_rd>+Un
zX<LyTKiSba3eh=aMosH_C}zeWI(zTge0E|yIzu0Cc6@!B`O)1+ZlmYzTuyY3^XMG6
zeIwtoZ)9gRJGmX5qu`rZEySbqtUOxPjVH#^cr<~7m8|Co1f9uAxHr6MoTd}t&|Al8
zngtb>9DDZQ=<t)b3eqVnNaGco6{J69d`?*L`BR2woMeA!wj%R`O(L^>sA&?Hb6^9{
zmij*d_zB^?#QWb^*fG}VdX^s%KKrq_?@Ui!>Vr^xrUzK{qJ+PTc7;`1;3Z4GAc4Lm
z`mrJP@i?4W&7#iXlkc!>onjqVyRCB|93i`@c8tQIp2gfM7P0HB{TVl37AjSXl^Kd3
zB}KNx!j>VHtd?>H&Qdp?IQddytJF%RJ6on&w>F*CDtJ=WDXuRT@^0|qzZ<}$PM<)N
z&m-WrN^uU)3Vit15{T|9mPxgsJxZ(4gu8=Y0Js_yMe#3!@S^Zt`2(T-10nu_ko>c7
z?-k*}tKp!y?o0?ycjCIM387=t$&uIg{$THitL|Cq*s#=o?^4HoORLwMQqN4hMdw@l
n|0ah+;j6)DI&e*hb_DA}+b64&;vVsnbW9w)wl*sE^U?eZn%04V

literal 0
HcmV?d00001

diff --git a/tests/__pycache__/test_image_service.cpython-312-pytest-9.0.3.pyc b/tests/__pycache__/test_image_service.cpython-312-pytest-9.0.3.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..161aaaf82e6f6e7f20fff56f825559dd58933696
GIT binary patch
literal 10412
zcmeG?TW}lKb-TbWUJHOAA&Qhq$q;Edf?ZR5N~A@~W<|1o$ckgtwalvBg4m@52q56Q
z3yGu`9r~4!QzcSoGBH2&!I?Z7jg(ZGNv3V4ZOZ9qe+UsOk+m{)r&3b>QNv`KQ9IL~
za~Jy{4U4v?)A4kCNt`|R-gC}9dmrcCbMF3AC=_5I&3vzta)lV?-!Nk)p^9wYVHxIq
zMq(s3!;G`^>B_p3E|$r1<2-BBc*Z@n#yjq%Pv5wYKK<hX`V__mc)BvdY-l`0dEA+B
zwr;$R;#?+@tsk!ke7D5Q4U;a(^DaLgbuqFxeb7|Meo9`+C;6p-B*0%#3Q6IsoK$y}
zKg(VRT``R}%D(jP7`PKkk$0Kv)q?S+kD;k|&@=;0w^M?Fr+YtICN((tT0R9|)WO&K
zDfo6d`1XDZzD5V%z8N;&w2m)xGS2G$VP$42`BE-<9x|a5Cti9vK@@qEkQ}+j>e1)3
ziL>(Pv`P|5^%ePzf~=^zhsbJyOeI~84&ecJ!*BDa0N!WR>Yy-8+DTPq&{z$o)}&jl
z=7EZ{Pz$-?x?bfix+J&ek~oQf525Eh*Q9F@=v1#soc5WR{gk|#CE*N6D!PlD#-+_k
zZWCJ5;}jG3om|J)fWF`*btW&z-Ru7id4ifyu#U@T9p}e7sxZrSr1NLv9^EyS*ZEnQ
z<P@DRq^8t<-JQJ9t@~10c`BKcWZkRgCT3JwiSs&tF(s+zbk8|Cb@rU9yHnY-IxFh#
ziNd6U9T~&);F*!9&s@xr^GZIEl+R=m6LQ9YVj?9fGP#g~Vi2e*6pASvDzl;^Kcnv!
zvx)Pvh$PiYssL$$CW7!&P63!>?gWCD4=x<MGPXFn)U^^laO0J~JbmqSIdFLHc%`|0
z?)bcGzI&dZCs*3$3-iGe*LWusxqN2f%;Muq?W>{3-x`}6o>MA9`0~+(qklHE!ZmM#
zSmrm_!mqyhlVAPqSAY49@80{)kALHVg1dkB^}9d)MxhSS_4mGx)j#~vy}$b2-M{~f
z0vIEvyR*CZ-rxNAm*1Yd`?DVsl(3GrV0|BeYn;wb>+FoqUewuh*LdBl6eiMgQq}!=
zB1@@cLX~w-u3Gd)A(2T<revaX6BD`VBnYq)jwPL|y8&^|RnttsJYZpM(2lyskX9fg
zj{wjGqmPYl?0^zfOu-p7$J`b6uL|ueTsx)T(jZQ5+8|1DHYl-@>xSE$=Flv6ayCrc
zIE15yQ)?YpQrxBcCsP?&%qL*pc-4e*UQ9^@=L&fWfvuvO$ZwDyC~JqG5&?j!?OTZt
z{6kk+7+v8;4gF9jGvVTS2Y#EE;8k8^*eyD0t{aw()mYJ5*!B`vEm;mqM#ML!$)=PT
z2L&ryd=f1144?HBIhJuT8mGB6Mq{s6CA<Us&6|LK%k{qdt31yXd5uqpP3iWt=uzv<
zoaQn2g`!vDiayP&`Od>!D*8456;=tTQIj&g%f#%b#B2UZR`MX%r0aTBPsyt`nKbEU
z6SJS@^tr$&dmQp{=4?wUjtfnumc+?{qq!}8lw*p;J@FH3)cA0XG~Uw0Nm)Y^n-Vne
zIi%L2wMJnFI<MLK4s<?~PV!&nXThQr19&FT0x6c}1ocs~;~bJ=W|{re1XGgvd>hU=
z(`?ZLKQH|JFlTDcGRd_E#1w;CFx_U$GqGYw3KqRuNb}O!7S_Vb4;-4*o@-&4Ya!%u
z%(d|U+Q<gYHzYfatVIbU8+K@2Yh**F)E(%ok%iNmn~qVP6p`w+y6T8UKJkb}%ofdO
zb;Lq2T4Ct(VEQq06znIAN5f|tkLVZU;TYMN-J>R^?K~cjo3!?`2=lzw`MwyIc7bgU
zYks<J>a}`h+0lOObyE-PrV)AmAFi9QIm;crP-`9fO*(1!RgSK&h}0xCYmw^uYWT$K
ztHG3HKAr0e)>u7^PcZ#)WBP<W#wPZe$8^sZV`}u_|IwJ%@S4GHKJuCDX3H0L)3IV>
z=320yJK4<{<_L3zzoh=aeUXi~o&+a6X!zUWg+!(xQzsM(L$cwNi{R-<3h9IfuCWhX
zLqpft*%uES%+K`2mB5=-BsLU7tTV10#AlCL1xU53E3R~;R5_~zit#`(He@jL#}(b3
zk*Cn*R|**wye>D0LC}Su2SFc#{s(ml1)NfqHq-?z=^PMslD(i<oSi*{?RJ~(0%EJw
zQT5~OW<hnGLv7-2@(l1}1Ks3z0h<jwS~-H+<!6o%^unNxu7|W?xrkd@p)MwH9!Jhz
zQ#(Ma+I@_|=urlW9q=<d3RH=6R9EtQRfT)WbK4ajFccp6%q`ArY4JfQNpgARP}iYO
z8iZhHpMFRWAZ=cjs*wP6ByC~P;qfMd?v@^wau=sExr8KAFITTWHT=@cCq~7uygEE`
zN_^qemrv?K@?1g{FQk-IZb}ap@($`p68U^bH8ueg${CR${V1NNlZ*@^9(Xp70TES9
z5WQYZCNde3$a#{?W%CIl>p`d%Ckm;InwnB{PbLQxiry?L=W>ONL`lW7ncPGoBTgl<
zvhEj^#H5T8^zbm9i=ZD3Wa&|HGDotYv^<^9B&HH7)Q~TM4g|vs<Vgg0m?!N3^oEai
zRXnQuvJfK^GnuR&q?n@S2n1XRh5@L<O<#}<p#%X{H)d+LGt=wL9C2n28yQ2*0ps0`
zOjj2f+a|Ni$=T!N+#;smN!GVTW~YMwFO4&81xB1BMu%mKg@OLYpr0Zd1DFDK>^o%)
zX3f7dzl9(}+mnCYQf?caJ5lByz0>kox%+szWn}KTGS_@37Qd;MV}n?=_a4{(^Jr`-
zx^(Vla5Xx#78;rx`>?L@vbLbDaQiRy%xkMcD_~13fEA&2i7g5H*EszD=W2nGvtS9?
zjNGb?TGh9>{qq;BY7;F(sb-V{0kmV`ORU9eA-B2x6`}s};KJY{yYS51NJXf_%nBD@
zJO*HXaPe44h_7+@f7{3#84H%6wAaY3+GrVRjnZ2v%ObZBAjZayEkHX57Ec41Kel+f
zBpg`d@c*`vH!>D1K`Atb1gkb$Mp~ov7Rs{7Ed+?Mv4Mqw6|QxD03&*UEVg0p=we$5
zdkOz<8+jvR!4i~0t4OeFqh&w`jM7`kW}%C12I_<$`17E^ngH(#Z{4?)1F#~rE#*o=
z-x`Pix2pw4&VnVb4__WBR&BIQiH+i0D9)m{5Fpv8XTrz+lP<}(hlSTTb~(hp#&XNy
zS9>9ow8CVt-Z0|*4*WLTAd30<57n^{#;X;ZPh$jlTQb9EAIoC}&1^;*3T&|RCMIz-
zNaK-sIK)C2k2;k;&8KA4Mw2Fu;oofuLViAQDk+ccR62NSg#GML;|_FoD8zTwMO`&N
zUTJCmlo7lNs2G{2$swth(-$yZH1p{QUipe%JVIXj89hJ>CrKYjH102sAciMJ@*;u(
z0B{s(z(WI^|ID)t9Dm|2@+?w34`9oY>#%WxIUKK}rv-8Xsa`^G62X@dyo`Wu_6^1s
zNVj%4dE};&uuIc@K0(gH5f34G1<6k#cn!g61g`^#3*-+GKZ9V~CYyya=jPT)B&7Ny
ztJv5&`<z?j5gMm=>~_Xh*GRWI-0{VfA{vJoSt0~PJq<tQ9|3&o{VmY6=w3X%q^$<P
zB=oLuy&E2euV3T#mbkrZTxW^vEOXtJNb6c8UW&xmB0Z%@&)oABVHeu@#r<GsSGYq<
zbpUV!tSbqJ);RpXT`e$jt2Afew~*dIov_Ru+7KAN?}2GtM(WVGjD*0r9A_Ytgzei(
z0$|j*q@i@XaoKuTQFN;or{=!FnG+Fi2*5BIX@~1MUh+T$o2lOGLKGKnbc4<t-6H2`
zgLAaOh<NislT8743r;N{Hf$ukE6#Ycz9QUP!`%X}xgL7A;L$wk8V054wU?x3E##t4
zs)MMAuNt)qXaRb+@X%WVDWV0y#MC2~ZDOPbd-11hEP2y7(z^v)K6*ael4`}u%rSwx
z1)C$bjU2Kc<$(BagB1P58Z|oP*U-o|kPv}>s3tZgXb|0j)*6K!=&U<~9q8;x+OF!|
zf*>_YyEUO|o`Y(;*>?^}HDb=16-PHmplY7+Ucm>yK+#XVeD=}+HPTHd3EqAZyt@F?
zi#rs-&54?BokI(y!@XWccf<82i9yXe4)QuRdi#+OqjKAAJeqfM6u}?@bWF%G1S1GW
z0mP&9iqkgbI+s?!r{kqUHm}q&>EtWOOXb;i`}eWzRRn*4;57uc84o$kcn?<L4A6bK
z+=PgY*<KSh-{g;xL`3i>2oeY;04Uf)4(lC@8TPx4+V5OJ6?2o~M6NI;DI)skXw8$E
zL>63Lq5&&zWy%w9dubT+Kx~QJY%2%)=8oS1$0b^B8={WOuRTm;*X7xT*-CUzrSXwU
zLsO-3Pi1%WBKf}iW_u}e_`cw2^=vSn7VjqGiTLK8`*oOUJ#h12x#eh0U*})9`#P1+
zyRQRY)`r`0AnhCLVV94vW1ZY`|HuGjwj4;&&eA>OLqN9g89Uz{!~M5?yUf^ohvb&H
zj62KWjj)RQ5>09RBw$-ot(#zTwe`Ub_Cs!w-Nr34{R#<gmd)FDmZ8U{P&?DbDC|Y}
z*6DSSgQe5%*O`kfU8%froSGFT5>gDOZ|u!C?R6LT*-Ob-J@#41W5hZjl9os*vO+j`
zjX3XE8(WV!_IDu0G;g8P9HI~K2>^VbBg*)Jj!0!mWDaEEl2LFG);z4-e5%~?ES;a=
ze&6xeUEaH}_nXDr{sTV`w=5oCYX1J<YPf&R*T3TH{|`44cznfwpyKQQt%?7af~Ur}
zhh4)R>@pV~ZgVd;u){IWa+E{7$&ckR7V$QI_(|{bm%LB{rfeG6*0B@fkLo@%mP62B
z=zBz?M>>o{B1B|5h<uSictQ7DMY^|IMvsZQE0rTNz)b!WCGb;Vre+Ab5(KwwJye)V
zsn}5+7@;xZSy7BgC38gXkf)P!9wR?S=j%;alZ8)nGG?U8$Pk>;I&Xg~LuRoBJmu=%
z$<#E2K^##Zoy#W3dEJ}9&!|8>42;mzBegnoXtsZ%;Twd83K{trxeUbkL4^_oxZ!45
z_Fow0UFIGC2aNCm6Z(K@_<#xgf@#0UJoO9a$bApT?zuU-$-rYH%rriFW#s)A{``dx
zqx&n3dn*m?mBz;mOXa%RP>S?|rQ$ssZePr`$@m)GD@^^yZpP*N+P=5;-FLC<W1DWq
z71=;+!{;a;W37rY)~IQDt7VPdRbqGDcZJ!*SlzgR*hU-jIcf#Avsw$-M(eiP2DYtQ
V3)sdJ+iE@R0Ij|60*rp6@;{Z5>AnB}

literal 0
HcmV?d00001

diff --git a/tests/test_image_router.py b/tests/test_image_router.py
new file mode 100644
index 0000000..e98ce31
--- /dev/null
+++ b/tests/test_image_router.py
@@ -0,0 +1,63 @@
+import json
+import numpy as np
+import cv2
+import pytest
+from unittest.mock import AsyncMock
+
+from app.core.exceptions import StorageError
+
+
+def _make_test_image_bytes() -> bytes:
+    img = np.zeros((80, 100, 3), dtype=np.uint8)
+    _, buf = cv2.imencode(".jpg", img)
+    return buf.tobytes()
+
+
+SAMPLE_QUADS_JSON = json.dumps([
+    {
+        "subject": "电缆接头",
+        "predicate": "位于",
+        "object": "配电箱左侧",
+        "qualifier": "2024年检修",
+        "bbox": {"x": 5, "y": 5, "w": 20, "h": 15},
+    }
+])
+
+
+def test_image_extract_returns_200(client, mock_llm, mock_storage):
+    mock_storage.download_bytes = AsyncMock(return_value=_make_test_image_bytes())
+    mock_llm.chat_vision = AsyncMock(return_value=SAMPLE_QUADS_JSON)
+    mock_storage.upload_bytes = AsyncMock(return_value=None)
+
+    resp = client.post(
+        "/api/v1/image/extract",
+        json={"file_path": "image/test.jpg", "task_id": 1},
+    )
+    assert resp.status_code == 200
+    data = resp.json()
+    assert "items" in data
+    assert data["items"][0]["subject"] == "电缆接头"
+    assert data["items"][0]["cropped_image_path"] == "crops/1/0.jpg"
+
+
+def test_image_extract_llm_parse_error_returns_502(client, mock_llm, mock_storage):
+    mock_storage.download_bytes = AsyncMock(return_value=_make_test_image_bytes())
+    mock_llm.chat_vision = AsyncMock(return_value="not json {{")
+
+    resp = client.post(
+        "/api/v1/image/extract",
+        json={"file_path": "image/test.jpg", "task_id": 1},
+    )
+    assert resp.status_code == 502
+    assert resp.json()["code"] == "LLM_PARSE_ERROR"
+
+
+def test_image_extract_storage_error_returns_502(client, mock_storage):
+    mock_storage.download_bytes = AsyncMock(side_effect=StorageError("RustFS down"))
+
+    resp = client.post(
+        "/api/v1/image/extract",
+        json={"file_path": "image/test.jpg", "task_id": 1},
+    )
+    assert resp.status_code == 502
+    assert resp.json()["code"] == "STORAGE_ERROR"
diff --git a/tests/test_image_service.py b/tests/test_image_service.py
new file mode 100644
index 0000000..ee6e8ae
--- /dev/null
+++ b/tests/test_image_service.py
@@ -0,0 +1,102 @@
+import io
+import json
+import pytest
+import numpy as np
+import cv2
+from unittest.mock import AsyncMock
+
+from app.core.exceptions import LLMParseError
+from app.models.image_models import ImageExtractRequest
+
+
+def _make_test_image_bytes(width=100, height=80) -> bytes:
+    img = np.zeros((height, width, 3), dtype=np.uint8)
+    img[10:50, 10:60] = (255, 0, 0)  # blue rectangle
+    _, buf = cv2.imencode(".jpg", img)
+    return buf.tobytes()
+
+
+SAMPLE_QUADS_JSON = json.dumps([
+    {
+        "subject": "电缆接头",
+        "predicate": "位于",
+        "object": "配电箱左侧",
+        "qualifier": "2024年检修",
+        "bbox": {"x": 10, "y": 10, "w": 40, "h": 30},
+    }
+])
+
+
+@pytest.fixture
+def image_bytes():
+    return _make_test_image_bytes()
+
+
+@pytest.fixture
+def req():
+    return ImageExtractRequest(file_path="image/test.jpg", task_id=1)
+
+
+@pytest.mark.asyncio
+async def test_extract_quads_returns_items(mock_llm, mock_storage, image_bytes, req):
+    mock_storage.download_bytes = AsyncMock(return_value=image_bytes)
+    mock_llm.chat_vision = AsyncMock(return_value=SAMPLE_QUADS_JSON)
+    mock_storage.upload_bytes = AsyncMock(return_value=None)
+
+    from app.services.image_service import extract_quads
+    result = await extract_quads(req, mock_llm, mock_storage)
+
+    assert len(result.items) == 1
+    item = result.items[0]
+    assert item.subject == "电缆接头"
+    assert item.predicate == "位于"
+    assert item.bbox.x == 10
+    assert item.bbox.y == 10
+    assert item.cropped_image_path == "crops/1/0.jpg"
+
+
+@pytest.mark.asyncio
+async def test_crop_is_uploaded(mock_llm, mock_storage, image_bytes, req):
+    mock_storage.download_bytes = AsyncMock(return_value=image_bytes)
+    mock_llm.chat_vision = AsyncMock(return_value=SAMPLE_QUADS_JSON)
+    mock_storage.upload_bytes = AsyncMock(return_value=None)
+
+    from app.services.image_service import extract_quads
+    await extract_quads(req, mock_llm, mock_storage)
+
+    # upload_bytes called once for the crop
+    mock_storage.upload_bytes.assert_called_once()
+    call_args = mock_storage.upload_bytes.call_args
+    assert call_args.args[1] == "crops/1/0.jpg"
+
+
+@pytest.mark.asyncio
+async def test_out_of_bounds_bbox_is_clamped(mock_llm, mock_storage, req):
+    img = _make_test_image_bytes(width=50, height=40)
+    mock_storage.download_bytes = AsyncMock(return_value=img)
+
+    # bbox goes outside image boundary
+    oob_json = json.dumps([{
+        "subject": "test",
+        "predicate": "rel",
+        "object": "obj",
+        "qualifier": None,
+        "bbox": {"x": 30, "y": 20, "w": 100, "h": 100},  # extends beyond 50x40
+    }])
+    mock_llm.chat_vision = AsyncMock(return_value=oob_json)
+    mock_storage.upload_bytes = AsyncMock(return_value=None)
+
+    from app.services.image_service import extract_quads
+    # Should not raise; bbox is clamped
+    result = await extract_quads(req, mock_llm, mock_storage)
+    assert len(result.items) == 1
+
+
+@pytest.mark.asyncio
+async def test_llm_parse_error_raised(mock_llm, mock_storage, image_bytes, req):
+    mock_storage.download_bytes = AsyncMock(return_value=image_bytes)
+    mock_llm.chat_vision = AsyncMock(return_value="bad json {{")
+
+    from app.services.image_service import extract_quads
+    with pytest.raises(LLMParseError):
+        await extract_quads(req, mock_llm, mock_storage)