From 1fe5eb6e134a42e4d03562e3874e437b49c38b97 Mon Sep 17 00:00:00 2001 From: kai2321 <70182551+kai2321@users.noreply.github.com> Date: Wed, 25 Jun 2025 19:28:02 +0800 Subject: [PATCH] Implement AI-image-reader plugin (#1925) --- .../extensions/ai-image-reader/README.md | 98 ++++++++++ .../extensions/ai-image-reader/README_EN.md | 94 ++++++++++ .../ai-image-reader/ai-image-reader-en.png | Bin 0 -> 31168 bytes .../ai-image-reader/ai-image-reader.png | Bin 0 -> 24575 bytes .../extensions/ai-image-reader/dashscope.go | 177 ++++++++++++++++++ .../wasm-go/extensions/ai-image-reader/go.mod | 19 ++ .../wasm-go/extensions/ai-image-reader/go.sum | 25 +++ .../extensions/ai-image-reader/main.go | 139 ++++++++++++++ .../extensions/ai-image-reader/provider.go | 109 +++++++++++ 9 files changed, 661 insertions(+) create mode 100644 plugins/wasm-go/extensions/ai-image-reader/README.md create mode 100644 plugins/wasm-go/extensions/ai-image-reader/README_EN.md create mode 100644 plugins/wasm-go/extensions/ai-image-reader/ai-image-reader-en.png create mode 100644 plugins/wasm-go/extensions/ai-image-reader/ai-image-reader.png create mode 100644 plugins/wasm-go/extensions/ai-image-reader/dashscope.go create mode 100644 plugins/wasm-go/extensions/ai-image-reader/go.mod create mode 100644 plugins/wasm-go/extensions/ai-image-reader/go.sum create mode 100644 plugins/wasm-go/extensions/ai-image-reader/main.go create mode 100644 plugins/wasm-go/extensions/ai-image-reader/provider.go diff --git a/plugins/wasm-go/extensions/ai-image-reader/README.md b/plugins/wasm-go/extensions/ai-image-reader/README.md new file mode 100644 index 000000000..1c74d5188 --- /dev/null +++ b/plugins/wasm-go/extensions/ai-image-reader/README.md @@ -0,0 +1,98 @@ +--- +title: AI IMAGE READER +keywords: [ AI网关, AI IMAGE READER ] +description: AI IMAGE READER 插件配置参考 + +--- + +## 功能说明 + +通过对接OCR服务实现AI-IMAGE-READER，目前支持阿里云模型服务灵积（dashscope）的qwen-vl-ocr模型提供OCR服务，流程如图所示： + + + +## 运行属性 + +插件执行阶段：`默认阶段` +插件执行优先级：`400` + + +## 配置说明 + +| 名称 | 数据类型 | 填写要求 | 默认值 | 描述 | +| ------------- | -------- | -------- | ------ | -------------------------------------- | +| `apiKey` | string | 必填 | - | 用于在访问OCR服务时进行认证的令牌。 | +| `type` | string | 必填 | - | 后端OCR服务提供商类型（例如dashscope） | +| `serviceHost` | string | 必填 | - | 后端OCR服务域名 | +| `serviceName` | string | 必填 | - | 后端OCR服务名 | +| `servicePort` | int | 必填 | - | 后端OCR服务端口 | +| `model` | string | 必填 | - | 后端OCR服务模型名称（例如qwen-vl-ocr） | +| `timeout` | int | 选填 | 10000 | API调用超时时间（毫秒） | + +## 示例 + +```yaml +"apiKey": "YOUR_API_KEY", +"type": "dashscope", +"model": "qwen-vl-ocr", +"timeout": 10000, +"serviceHost": "dashscope.aliyuncs.com", +"serviceName": "dashscope", +"servicePort": "443" +``` + +请求遵循openai api协议规范: + +URL传递图片： + +``` +messages=[{ + "role": "user", + "content": [ + {"type": "text", "text": "What's in this image?"}, + { + "type": "image_url", + "image_url": { + "url": "https://help-static-aliyun-doc.aliyuncs.com/file-manage-files/zh-CN/20241108/ctdzex/biaozhun.jpg", + }, + }, + ], +}], +``` + +Base64编码传递图片： + +``` +messages=[ + { + "role": "user", + "content": [ + { "type": "text", "text": "what's in this image?" }, + { + "type": "image_url", + "image_url": { + "url": f"data:image/jpeg;base64,{base64_image}", + }, + }, + ], + } +], +``` + +以下为使用ai-image-reader进行增强的例子，原始请求为： + +``` +图片内容是什么？ +``` + +未经过ai-image-reader插件处理LLM返回的结果为： + +``` +对不起，作为一个文本AI助手，我无法查看图片内容。您可以描述一下图片的内容，我可以尽力帮助您识别。 +``` + +经过ai-image-reader插件处理后LLM返回的结果为： + +``` +非常感谢您分享的图片内容！根据您提供的文字信息，学习编写shell脚本对Linux系统管理员来说是非常有益的。通过自动化系统管理任务，可以提高效率并减少手动操作的时间。对于家用Linux爱好者来说，了解如何在命令行下操作也是很重要的，因为在某些情况下，命令行操作可能更为便捷和高效。在本书中，您将学习如何运用shell脚本处理系统管理任务，以及如何在Linux命令行下进行操作。希望这本书能够帮助您更好地理解和应用Linux系统管理和操作的知识！如果您有任何其他问题或需要进一步帮助，请随时告诉我。 +``` \ No newline at end of file diff --git a/plugins/wasm-go/extensions/ai-image-reader/README_EN.md b/plugins/wasm-go/extensions/ai-image-reader/README_EN.md new file mode 100644 index 000000000..953b73f1c --- /dev/null +++ b/plugins/wasm-go/extensions/ai-image-reader/README_EN.md @@ -0,0 +1,94 @@ +--- +title: AI IMAGE READER +keywords: [ AI GATEWAY, AI IMAGE READER ] +description: AI IMAGE READER Plugin Configuration Reference +--- + +## Function Description + +By integrating with OCR services to implement AI-IMAGE-READER, currently, it supports Alibaba Cloud's qwen-vl-ocr model under Dashscope for OCR services, and the process is shown in the figure below: + +## Running Attributes + +Plugin execution phase：`Default Phase` +Plugin execution priority：`400` + +## Configuration Description + +| Name | Data Type | Requirement | Default Value | Description | +| ------------- | --------- | ----------- | ------------- | ------------------------------------------------------------ | +| `apiKey` | string | Required | - | Token for authenticating access to OCR services. | +| `type` | string | Required | - | Provider type of the backend OCR service type(e.g. dashscope). | +| `serviceHost` | string | Required | - | Host of the backend OCR service. | +| `serviceName` | string | Required | - | Name of the backend OCR service. | +| `servicePort` | int | Required | - | Port of the backend OCR service. | +| `model` | string | Required | - | Model name of the backend OCR service (e.g., qwen-vl-ocr). | +| `timeout` | int | Required | 10000 | API call timeout duration (milliseconds). | + +## Example + +```yaml +"apiKey": "YOUR_API_KEY", +"type": "dashscope", +"model": "qwen-vl-ocr", +"timeout": 10000, +"serviceHost": "dashscope.aliyuncs.com", +"serviceName": "dashscope", +"servicePort": "443" +``` + +Request to follow the OpenAI API protocol specifications: + +Pass images via URL: + +``` +messages=[{ + "role": "user", + "content": [ + {"type": "text", "text": "What's in this image?"}, + { + "type": "image_url", + "image_url": { + "url": "https://help-static-aliyun-doc.aliyuncs.com/file-manage-files/zh-CN/20241108/ctdzex/biaozhun.jpg", + }, + }, + ], +}], +``` + +Pass images via Base64: + +``` +messages=[ + { + "role": "user", + "content": [ + { "type": "text", "text": "what's in this image?" }, + { + "type": "image_url", + "image_url": { + "url": f"data:image/jpeg;base64,{base64_image}", + }, + }, + ], + } +], +``` + +The following is an example of using ai-image-reader for enhancement. The original request was: + +``` +What is the content of the image? +``` + +The result returned by the LLM without processing from the ai-image-reader plugin is: + +``` +Sorry, as a text-based AI assistant, I cannot view image content. You can describe the content of the image, and I will do my best to help you identify it. +``` + +The result returned by the LLM after processing by the ai-image-reader plugin is: + +``` +Thank you for sharing the image! Mastering shell scripting is highly beneficial for Linux system administrators as it automates tasks, boosts efficiency, and cuts down manual work. For home Linux users, command-line skills are equally important for quick and efficient operations. This book will teach you to handle system management tasks with shell scripts and operate in the Linux command line. Hope it aids your Linux system management learning! Feel free to ask if you have more questions. +``` \ No newline at end of file diff --git a/plugins/wasm-go/extensions/ai-image-reader/ai-image-reader-en.png b/plugins/wasm-go/extensions/ai-image-reader/ai-image-reader-en.png new file mode 100644 index 0000000000000000000000000000000000000000..495daee80b2150e18cd1b2ab2bcd048aed786399 GIT binary patch literal 31168 zcmeHw2Urwawk{$H7(q}_l7JwMAoBxlFB$EF6t&QCxOrPT&yu-pIntZu1G{IlIJm4_DH24I*5E9t>cwI;U298MC+uNAwm>FNN0{4{@z%y3vq#4oD)u5o4sIshQ)}A@B@*Ec^%-9w~4S=nucl z_Va^ZtW38~(w5QG5Y}~&)w$@5)YK6Ya1zjkj0MiHGXk^2TaE=G%pxTN{Q*XRZiEnJ zk>X{M7W{F5ondUR%R3s`TPh<>&1}H=rq{RU$S1NrO;fk6BSM10TZ36R?o4R=4CsJ{ zmHW=q;h%+%$HLjl)C{$Kx2-FkkVqRREBiklG(p_>-HUu937#>#6QvYA#yxKJ0tT7iEho()@bMC?I%H5 z8Uf$hy8fqy+Op%0H64*iaKG=?@%yiLPO`l&V`c*xd&iF3;{aFs?_c|yH5`8nj{nK+ zG!5l#+_g+Do2c^2StwX5$r=mma&C{|Vr1jIZE_PED`+^p^P!yFc03zc${sqy+15tN z#0d$UTN(s}lNDGMB_m@q8#N@#%4sV+jFC=GNZapDkg~C|fa1mpX%CKCI@#KQUwFYs zq_dNam7ST)Z+@~B+1t_PWVYk6TeGn@`rQ!tdH?Oz_}%|M7dIl6&$*}kLDwjs9z zKzRFC*WbN~fBTT-caF4kmC?5UTKsljXvTlf8iRATUF2`i9fHmuJn2uD4~&a9*6+*r z)54kAnMy%12TX2PE@@A$#Mc@D2?%!Ef@J}qebIj4q#>mOa z<&V+-XXgIf=KDT0AycX$tss})S$&c18Emhi-#q+p+hzM~yl4I2&iwlvkpCwKls9rRb2S371{v-<0QsY< zxmsE|nQ7P?nLtbJ3bv^~`sMar0l@t8Fo0L|k8bcMAi&G>C%!7MeQam#{@FBJF*1^9Lr@?Qr7KMu*u`-3n2WpMycLIFqq`!*sI8zU6T%H)qR|3`q>^5FmP z_9EVY{$BKx6aF~lU)BjhuJ;2Qax`)UyO5)qgR>b(K!4nlAn(GH*FQR<(KcN*0X!JW z;(jB#J3Q9b%G4C%#nO&uC@Xg(V?0NO2$Vg^d$^tb6KQUa z+R*|2?;LvP+5X?sp6yKYJGfJoxd`zcGe;LIz-fN;v_E3ozXAE--(jHJtMb<+KO);9 z_V?{PzfvH;w}Hh3c9`wIj{N*Mw8Y|GH?fL#V%7i=V*w zS1$BZE+qIvF8nW$M1CCdKL-wYe->5$mJj|)hJGWbKc*&pJK?;;7612@xgU3>pN9O) zW<$In7y2O`va*FLD?gIczhoM;6=Z)~#N5dh{*VX#mWFKE;a`>XY-7TXBmWhX9^RkD z-k*Kx_iDp0T>A~zegc^tg0{jBzyBrS@0Z5?v&i`Kkw2-o{)k2V zJH_=Kclh6jzaO)UpN9PF!r#v-x05B*(qxM?wKBKDL*Rdu;LZC#RJ=KPxCD9lwl$h< z_P5Q({>kXK)4syLO`LY9=k{E7y#Fr=hCeIdzqsJv1%^K%(~sr1|9vq034eba@~;bq zKdb*+(krOU*(2>x|0&5XKHC0q_6H!4Pe^2YT)kWKmCD#;3R>ftd!<;gXtKr z#t<#{&A`10N60#t7%cZs8zu>4(imwJaG%^2%(BZx*(#*yrg`@&VcNlWw_J1$U+%Md zsrB0Bpw0enZDoZkH}9BR4@nz_nj5v}AN2RJP3BxT^Sb%;!Krme42HjQ?YMcYDF0~e zn)s-P4=eA)xzXXXag!cRo^hz=Mik~_x=vOJBfZBm)_DMjb;SgFFEB5^CT1vV@xr38 zOT9=}!syM2v+GtOTrmKI}7QaQ*Y1 zLdW6y1?}^)!AD*WenIfi1?6!v*y7CNGGbi91ZHe-j)x}B7L+*;Piq(%%S6o~A3q12|%dMUr)cBw&-s+|CMP2|g+8l$5+gu;TY;MeK9->>xEbO1y zSTx-H*c8EUF;?M}7DrH}D=}YZZlfpOQ_!FH!54Ooonfp3Hpd*vRC>XbD#OrYIzOJd zax~Thy}z@M^TY{#W;(WJxtGf^dA2K-z3%N7X;RXjc|KiBsSUJ5$GVLiUmj15JG-|0 zG7#xGM1!rSK{_oV>BlLainQ0OZ<|R-NnK+_a#=a3hB6r;{@RkQIq&iNKbbylT=J8b z4stRM0m0a>CWX*a&3r|t6%wzc-4l+U{7iec;Z@)lRNGlfvyEwR6UVOYoA}2hq|Ds} zjv_Ir668F@ykf;-d!-C!+46YrgsP+BKmN z*c|UPrnJ**xpcr;Vzn)>kC?&pllXFROK~r<65};|#?T>382JL`l=3W65>w?i{yurI zK}xoLv(7jF;GgUlCh zwz1FW)GZoCo3)NwwBz($F~j}WhYl8AeSM3RZEEp7J;wQy_3(bfZ*PeFS2{-+Hoo4& zeyI!Y^b_W4KGx!Ukfv{Ts0Ndvn_Df|lr$7zimqqYe$pzZ-I7E>@*(2FW;LpY&edt( zM+u7*kB`r_g3XCFl1}%tFIcd?sZgw3m$tj?HdDU*f>(@2*lsF(0#oWr#r@9QkISI! z5_L+>Azaiu^wBd({vuh^i=A3WOA6EE1rg>+HYP*80~;s^-&*Lph9%7F%~>E7oT zo9@G&2RhI3YiUI@?&qu|?M9An7`4QSc@&t0Ol=k-2MpG)_vBesMPc-isW{wf;sE1WnpZVuEcRRzGXj1i}%;;16W$qn1s`|t=rM^^q zN%*8{%vr7Vy*8`8c~-$5o4DnN`Ys;ppBXlc;xlu0S;L~dUIq| zuaI;gzywF5=(fM8OheO~H(VHLU}Qeh95b2m$_3k}>#6Vw<2u0UJ@5AQH8E!Q;d5$b zue(iF=7uQ>q8pImn3QYNJ^9#=I)<6HdWA1M57g`EO9blAnCi_Kz(Y0KYfRzdlc#9n<-57#z-*8sn4_SS4(&vVJ#X=8mQ0LDI{+{e@0%ag9_+=gJ~dZfO0`Hc7pS}pnT1ob-7rS#__#PQ>cG+ryh zpS)d#>yfl(8Xs^`mE1+RwPh+ee4}X?nA;~BXHqpeP*l>=-%xc;u0D$0g97gP?W>^0 z-0hAN^YbNhp_sS~^qV@uoSs31j0q7A;ZYv+pSKTN>_^lWJ;3-~M)JUe9$IVY6BN!4|!aZ1A?LOtx-`;$7`u zt{C+mb@i^n4I6GGdwdC!Kg&(v5~40-+A$E7Gl#@+S9~+hl(!Ia)nB0w$tv-tFYPx{ zYU6<;g3G(F3k{p}8_1Vb#7Gcw%@C|KU^WVk+aov0q`E(G>lN6%5lhX1%~4h3&c!oa z3g;-yUP-$kT->5@bd*}dl=W?;cF*FTwHg7<{%0^0);VK%W^nO+!ZbF7TP>`qG_J+P zyhkpGt% zzr_*_)3euChQr|U#khnsHCJs{y&N+-k%dB=-0N?+i+nbheYgWSZK&D{qij;s2536J z5}jU3n_oOB)DgX=QzhC#+1>0n{oLo<=X+HFNgt)|7pzatouv4Pd&W1=;y5~U&1EKK z>3Lioc1bIKx03o%NgA$n?Gb%w69!qgTbFL3; zluGqXYsd$_RSWm=x14Ji?OjT-toA!z`q|t=pKrtVB@1NhH>S3f zjc1eJTUpRuLG&o8SHclyCLbp)Um4O*SEx-4P)`{bh^-?(Y>2#Z39WAlo3Zngo85H( zxZ+MmVS)8ZAEdQLmtm&|Tmswa%azoZ18l$@HuBrCh!%X z8V&Mx!wp@SmM{tZ6Y0cC>Ksz>8(K$4c@#RkYzzZe&OV+JO;XN;fpH_Z*SUKjYD)+=y!1wd}YT@MP3&QowlurcPXVMv0^^LI` z@04}l4qsYt({&@RjY2jQ#uct>?JDO=a`CCR$yvGg@k+6m*2?_{@dv^5`!YRDMg=XZ zyM4~S=g&_k8CLaJG2AyT!){(y%B>lOQWxjqiu&e#dCEC&x_5QOW*zH-6F2LaX-8^} z?a|QOg9ze%&aOgETgAs(n#zZDF2M7XqD2b0_{x12>JElxqv(licVW*TI_;fTi>3(v z;zRRn!o$$_i6ou}9ZJ7f(iYKVLw4U^}FT2cbN?8zYRM*9bYbLX;RU(tiH@e}}sL^@n4) z4Lge(@zcvS_Xkk^Qt#zesmo`WBjZUgIm{_MdE7x~78XZl- zHtu~&!wKy6R4c0;g%!i~n=u+k9%u#Mxae@rT){(YOch?4@j`eP3+Avb+Q4o2sKsW8 z>ph#!v5Gb9nT^l8ZnBcH9kmFijqng49777&E!0Qdc#OTrhj0n3J@Dvw!kk!wcgtvu zc|uDNxaCM~}h zY~$ixlz02+_E`nHPCO8ICOlsian^dUG?ZXf=BVwdr%7ukH3S;D$d(`WTsktIq5Djv zJ^uWuc%oKAHdqggTj1f zYW+ZNZqiATjz@=fB@ZgyV-LCm&WKO4OqG>XTn>&*2!~7adOdmf=JEu~Q_bkb$0h~r zBu^{Z+4$t_h(eqOIw`fXd-?0RH0+E|_UDlRdt5eszRA*PoiD1~Z5N6nXUnCY7pBFLfe)Y~BXj0ObNLe0%)h9ym!|-D( zDh5}v9X;LM7)Y?%z-=K*s|pOgTe%I&=RwMZNl}jKtABC^1M;I7ukInX!x9}JrIH(0 zVIVnh3QT!7)rH$%zzTf1C@m>SruN?JCG7c|+N6VU@G7)JYp(8`v7zp}u48ox|+=ce)qQ*j$Oozc#)Cq6`L4`|n*V2uSJ z%r34N=P-{Uf8o9|w|TTlelcpahaW4^a0JS8p8XgpuTX=zH=b^Y6HGghrztsBGa5iV8YH2(gMheCM5^;urR z6q18U7bM4<81?IALr>tHvo?yVmu{j0{-K3(#Y8ABS`;-xSt_$srr%iLz=L?Es3Sq2 zJoup{w0~b)oPmmN+f}ec3~s5lE)Q*l)7I4c55A#1c#MMcITY$29~Adu~yo{MAB!v$tz0d1&As2s3#mnF3E$GN`dQ-TjM;@x>pb5{hHAM_;(fT zNq8v7UR?gEHVza7sU~Q$LQ3E~A?KAY9J{@7`LSi_1K7Tg1l;=oqzWGb(Mqd%oIeBv z2nzzv0&ZlHs-PH=Q3X4Cdi)O&0+v{eM_L+8m!C1?&JhIy+@4zr5tR5Ll9K9-L(suC zBk}~e;V^!tfYVU)tC!JJGcrQJN2V=Jdg{gop;Vg^8gHJ9?@f8nS1Ah3gWYAW;W&8> zh1z?u6gGpyevil?)F(L;PXti^=2J^n1c=UXCYV(YHHd(y?<0U-gEEU)PT@XSAJ#ih z)Chr({y38xZ?=vrD6N2A4U#?##1Sa$Kd&Gb@5#eH?$Fd!W9*5=Nxb=6oeMN1Yh82CB z24!9P6`sY^Mx8J8tLz$L#XR~TB@-ljlR`FKY75!-A_8_3A1d0j{}|=wOjB)NF$(kf z?LACg@ac!6xNy`+qeH4njAO2OlcRhfy))2NUD{KWQLg=NsZpY+lwP1?5b>MXuJ=J8 z@$eX@Bai{ltafz?%>dQ!?9kfifcqq8q1W0H=`>-`scxlbBEdvTYQezxBuV~wo9)wl z8IcfX=v{20S+R+mDZRU&s${%9l`5s`K-~sz4Ff`E-#iMW;%}z9Hd|uFN=+U$esPLQ z09aG9pNdO~M@49$JJ(`=uGwCTnf`J+pjX``=VSiZLRr4CI*G-W&ba6m+BrkQ>N|5e zTQK_=6Fv#=Ws#dAk8M*lqwAzuUse#cG7MTWZ&~u_lqGD^CnzJ-EIW+!doojqBg!m$S9pI0mX+9s*fn+-0h(jn@R%sMHdlpvDTQVi?~=e4o6fqC{Ck_ohp%U}yUC-( z4287J?=1%`q5odh5O9!wQxw3YFh~AGHT;BwX zat*&Ixf&r6w{S5DbGW3&P@WF^Cumg0Q)*8RqSk>+FZnD7@qTpviVfy-K8CV8bsem^ zxUfmJUu=X1dvjxwVv#YGiXt14G$~s-))+0Ft5SN3r0@EWKZ5qK__wDXtK+Fzyz*dF zBKup^Xo6LmeN_I4Ew;c^U%)YRm&(9CP;4nYiq8zaHkI4b2Sg{H*R-&s7J81)^Hdg6 zLzFv?oQH5Ep*5qO>o{RypW}sDLE@#CCV6LcUKFj(R95oH3lDhambx!qjS!*WjAm5iqhmc|s=bOTAvMAyie`RT%lq#PsJ?~@@V+)!yd9p}mS z`oM~6BAD`#SER;l0G8RV2proYQTN$;bNp!RisCO#3Uuneyp%tYJm|N>hbqO?T4UvkNvG^Ndg?>eW4?eho|}PJ7$o3 z(P3YzqKnm-s!%?M&5^C$#QBHaM8oACrN*72WRkBbr=B!VfxRT>!tq@?l6bT3BYI6X zP6o)2Q`!+lHbBqLqg~G9SN-BeR_o6V^R1GJL?QjOC-&5R(Z%B}+nI6lsgqzvqL!KK z=fnWnD~~2?`vxd0y@r5yIgbngA9Svqjgl5Q*jULGeCxJ$4qe5-tHclyl(HTk9S2+T z`0$wzWLk49OrUL&3eWlJAj$xt!YNi-ARL{-!2McZ z`EvgxAfF>DvFFB*aa{TYZ99kP&T1;bEt+XvCqBT0tvfhe7sk{J-4`bkrej?D$IY9g z#}Cn;8*7dh9XiHsFvVq9aW39Vsjqk$;Ztn!=$ky=gWA~kJyp$tcJ957g)lx1)R$WF zLi^9sg_dnhu0V1x0`PxS-UgzOlO35TDy}Q`g#+HDXO{OU_zy=*&cqvC+zT$Fp^%Miy5SJk^%l;J`cYU#e0=GMwQ zCtPJw1lzR(?FLRS#{FJe3G(mBU|{ zum1XtwKjWmxPZSgx~xvrXT#IzkpbYj%?^55L;P^x-XaH+>;_Y~g88Fu`b|&a-r?0| z*fGxhjeN@s6G+BFS%F*lF`mnS&6UcWR*7cgGVV>D;`W|>c=z+?1n29lt%f3JE>GY$ z3kCVGj5|XQv#-6P;Viv6J#*6E`ON`h9d}eMnFOOSl)Q!~_{zS^8)5_wGQ=p*m$vjk z0L}_`#a?M^a|!D4lr=ZBy=rK2m8!!-taZSCH6ed5e!~+GsAKm&4`or;+==YUW~-Uf zKuM@o47bqU8P2>AX3%`!avksGCn^oXKExvk;MG1$G%lzNbW~R`I->UqN_$ zZ5-pJy*Z~6v{*Kt5`|VBvhB{f8si^tBpGu_$;eRcN| z^>bFju`JeBrQj{*`}py(*YA!1IJ$IfAuEnxH9bz0UuX-BMiym>jzVAU%jVHk23%A5 zX$0$53d+L5dFug`(qwat8A^a@NTAGZw({1d$p<9t5QZH!HcE>G7#1nXue_D%o2YKy1-YgI`0C8NH)?_a6$NjaM{Xt5At8Artf2t;s&k(D z;J`F+jS(SMU9Wd~0kYlj5hIv&nknrOI8FQh-S}%j47oD4Z%b{+qbJt(;SO35=_Jr5`r{Mu;%9-^PqXk`b66GbhJ+y?oRkKiRy{V)v6YZ^ zgQk$0n6u9HKoMzxRKQGw@{(^WCC-y)ks0Q)K$6x6r&^3luWeNe zRR3M~s0pB}s`ObOVkiae1Vtt_0mTogxR1dRLLFYq7?6L$J9V=da?h!{c{6n8S+)0V zGnsBzp!)=Qf4$96bXa1&HAciC;nKb7l1uBu`Kw)=_YGRYI!#MeEdb@I%ZSc%q^ZP$ zG<5mPHS38gtAPqHL`Fe}cX5uW|1kH)Aa@Bw=i8Tnpck`FC+e8=UO!iTQC?T(qy--C zhBIW1D}7(3Rp|;L3Ori9{Dxf(8pAm*=hZ^J7f>M|MQe7`roXJ1M`h`&ZGB5`RCYv0 zr-4VNC8|YinG!h$6gF%gkoG?Vwe46#PrfxKJ*#3uB~E;LX{uX;n$6?e5YJ>MUD)w5 z?-~npbgcL4IH~Vo)WEvAQNX&0P)d{6+H_&*T$^5{pmU9QH+k&9=UMryknr~h-OgE; zhW}c*h}%*}wJ{fisLSZJp=$rTQk*k~vNhg4Bqn;!%rh}*=S;3Cd?Y39Y^Yxd!AqqvmKlyUDse zhxM5x3L|a_T6Z`pMIeQ{W0=+=GULnOX3ODajIaSX`^>TKX7qH@;^p87cxA4(`G{-R zRI#^fij912lvuCe+_{EHb`*OQ6TfEpNIoW>+h?WW?#+Dt495T-1S#bi##%D!MQ33I zL3jdXuCx*}1$DlNM?}Iw8lfvD-i;iK?%uR1wV)ZGa`ofjw_3vztgB9~(%pe)&+94O zf=%EGQ9`y8)P;3Q>fA!ZrU4Cz3y;v zCH$G^)Ud1iUb?u0J%A~HX_8xRiwi7YFOzsPX>MMsUa)2oXxHprGXna-upXWr4>gu& zBO>DJ9Ph$T7&h_p5y^RBl!Itf*s3zf+G~mAIGYXP%qLu}iUts$jkqtXnxh*zY`SyI z2#I~3l{|mgaa$=!nBIlFmrHiQv4Io&&~V*&)LUhFc((OnN56d!%bXNdR|EX2*}Ns{ zcw!w_6-}8p91+V%l_}39cvkwU4D{5LNh&=8NI?XV-E#i|?qjBD=R_Wm{yH=qz`GdTFgyR-b!d^SI zK}u9#HQw|H!w>A z^CMvy^MEO%fv+|LpBi@)4l#iQmWNBuFI^s=T8ViTxFf*CVVrB4k8y5?=*iNepxWDH z?BkV_t!%rL+D?6Y@=4%1A1lLySEg`8VZVDi)Hox5B20yhgz?qnPVGhvj<_~qv*PZK zf#s-rD#x77FVa{5%6my_to!rfkV_jy&{O$6Bp;gCQU+DyG7Z{HbaWc}h}B%n z)ULfwl?7&JaMAAtp4c<7nB{~HGB4w>P6D%Hh$KkX?WgT|BC1V;PYe^NSz3if0pp3F zy+U{bXr~8dWp_*Ak%)9(Uekq(?9D=>yq)=pl~?%X`*`u(3aw7)6$~Ylb+1{T0{Rlg4T>J64_|E%M7^W?HOw!g;Zw|Cp7x&{H@+VSfNtNn(@P0T zS7;vwxJ#pQoVeGgD?`^_LPZ8prUSCSIOuOaU+6rkT?lG)gO#8`^fRO=ZOlt-@{2Sl z$_JK+c`OkXGIW-#`dd#%NcdC$a;b;WXlNA9z-kzXq_7Q7k@dDh;@4PJd%OeT+liI~ zZ-Kgvd8U#2m>&VUp{KrbL>21hnu8u#GYv3G@|!7q{X;-g`?L_f_A5au79hM;EJ8Ee&@n(bGnYc z)MdJ4oBBBF(`Kwd+~bq91n<&|x{Y^r`J;=x=?@7aFPG;ZyJ zwvn%QsrH@=jw|w~5iS{S2qO+$+-|=sH8C&o*Wor84nG$RwwDG_)Ab@uycW{>LfyB` zYr+&1G%fCb^M%TOGMv%Xie%Kv~;)*DPbyxaSf|j_5-cncOXt)iwub3jB#k?gJ zBRT@L={nGw<2o{Q+aDyabv4aYgiDQEpbflNhTnvDCzidCGEoMMue z|F}E%`3@Lg!lahTDyi3ZGZw@HVPmxQVXDj!k?%*t%As7q)m@Zsl}D`UGgZFAViM*= z_{|%~`u1GTzoz9tTFUTv%7~T8ss`$B7@kU0^{lQS3x5VSJ;M21;#G9@ z+b8NYkogWWn)Z+YhvWW0d9Z|}F9ha37Jm=T{Bll=nP1O4%$i!`3wQKAKfzi`nuFX!l_`L%DOj!F2xJ>S5D_EAsbYCu(LR=t{f2POg0k z9atF`IuT44x1!qH-5j229iD9?1_}gKbF?mi=5>Oa+ruI8p%K?C9>m9x#+M~o<{h(s zw_qm@>&V$c!m`kvM^?-v2ht^cRyzALY+Vy=j?~NR1Ez*c?OLUai*PtToRIHzs zJOI`RASHhr5Clp!%vXHvLT-5J;kCtgSK)}CwMDt1^lOev>RP9cpC%<-N_n@Nkn9El zQMKyTi4V{0K(BCBn3*wp_3Mam^6dVg^L)wZw+z@5-kD3#BLYr3b_qOU z_Mq8UUy?riw+E{l10^=DXY;>HZShqg;@&6oD#2kkSbZp0OF$0JAv#xLegW*pv~gxW*sp9zt;DEEyF*( z%_6dO0D56+n>zG?7eLMisVuF7cPTJHQ0jYqn;1UrI@3Q5R3&Txt>~b3=H;VB#*tF5 zidmf`xUis+F37A;4r=CNCWsI~OH!=TR8iXYxrEq{%3m4i0*$Is&0b{zw_29>HrOXJk1wHZ@rF z5DRsa?nh~gi|5YH6pzNf$qOgVE&!!P&c>kQ@kh^S7eRd^P#Qd6w#Ym58;N=4Jk`a! z483C)usW62OfM8*_!fFYq%_M1H+dJ9Giv){s3wrg%huHzRP17|bMECg_1?gCsabgu zMYiIKwC}-AQ0Z3N-hnnf!bggUBm(i3>dI}ws^a4tQ!N{fxRtogVh`x$4~F&E3?d#c z!eHzJy6iJY+%B1`fFfRhcin6$+*`Oda9sJr1@3aqDe*;*e!qYSLF9|F_?%KToXZ1G zj;Uh^#p_AU%46P1lDp3up$Sj6onnA8=)=xTi(n!HX(?miB@)iY*072NmgPd9wZgli zmrGr2AHn9}LgjqO*>E>r)S#>Pa~_1tavlAK^tZ<>7to0n_vqczx|G=s`Q(EZk621C z4_#(VvAkk>ypSB+y_-am)t{;L&W0R#jb<$eu;^uBpLt>IeB7qz?0`$0MXO3s#AB!% zrl{29aH)JA@Y}($M*4!cCd)pcVdv8!2Jv&BMKWk7O=~R5UC>kCY=DAV)fPJ-)w4t7 zK!k;U z*oPhENB6lZO0|)GPEnXnf#u@hv;fhcXQW3DB{Du7>|w zBC4ZVV|$4cC7_3R#7Q1+LY*uFy3JF9jW=M=ckyX_kiVJ}lK{QcRld2gwz%i5QYPrj zpg~POuDK--+J8Ni+G_cpnxKgwg-Ak*$9dwzph{a}p!h^AXx*cfInBC@@I3Mm;rLZj zLA*kg#@fcCEJnn-wh*D8QvsTqM77gTAI*$Lj5ozUAvJAd#-C+*inJA`Md+!j{yf4; z{tCFmbS-sy#x1-auf=wY_c2r$u9IYWbQN?%P#-;bcdNzalv3y*n%hEig_3CHS4ZBz zU+eHM;`DFP!5yAJ?=IrLkk*@RB0n44YggI?QildkP|=BjyEgA^!aH02PT%GHI%uKB zfY(OxeLc{Qs%q&2-pgzj+3BnV$uCy#EgUmL`12X)AU#u&S`rRgfvg-{L$ zpe~@=!ApBz*SGo1kQOK3t&0xmq$I5dNuSK~!VhsUJfN+HCjdP>l}BQJr0I-O1L!f| zpJ?oB1^R*RN_B%*J)^c|7$eQ*Sg~GSHP=1|c_Zzq6|f_h0`VDx0Tr~nMsw2*Em1J` z!U1SYfnH0o|Mcn(HOCc+N}Q{x5c>yF&?+1E$5z=7HI%lXn$=a8eQ$teP8ny{wlY78 z0Te8^Na+v(0kJ0Z?*e3XALJV{F|VFswe5QO8V6oSf3j9SuvTszD*;}7SzGO_?B~6J zNojBiT%A6$a=nXlbyHE3z4==hyIfinDC0+o%qMR(gb`?H3W=5zjRh7rmW8-pH&za! zd!k?B^sMXPS%*Q{?EPkkdxHjRGnOyhyy%ef)mZ+(ThO%dc6O)bWp8-GTnqz0Q$g^M zYtU3hAe{qfW^AMcjhl_2b2fXFR~IM>n`HyA90wcXaX6Np(n$6o>N`;v0Xwo(S#z#>5Zg%b|u61II?~ zJ)o0gr^IS4h=4k7@#Qx~u8+hiY2A(NM=f$sMR-wy?2+=?LR}1)jx{gB+&9)|!)+P# zEgoZt*jQ*+MRgL)o`(8;C=g1Qg2^O(Y7?POTnTMZj(X&E*1A3fh6OJufU-&~D)8K# z0*&+ANNecj48c#vXf#M-(Kq?79D}Ynrm+C}W2oRV{RbjMb85ir-x$Dm!x4{3`BWh) zWwE!1PH@%Qb)&b$odpwEMcExj+7ou9C$93-uA3#KSIXVj(9xZTRY2OOv)vW@`7 z@R%!_-fKa9`Gbb4;3J_Fo81s0m#O&Baew0jU%k6D*zCMBQfl8WjMQ@J8v5WCY18kf z`3Zr&lf5~Jp!JzL$oSRQmHNrRtvij;^&<*65A=!mr`k6{01VgEo6_^%xCpPnQBJ+1h^mf_bj{QTw`1!r{_W_WDcXo~s2dOa<>>`mQ00O4uy;qyNpJF&e$y&2Hz<_x@-9j$^-j@8>&2%k94J>-t>7d7hv1b3MSSDPAIFASECmxP(@c z*CZe~gCZax%qAfQpL~8cQV+fmdTJ^n3Cac-mk0=m=e$sQUe10t_Dzhe`G z+qrsru?fku2@0CKx$#-qo7;MrJA3lESbKqwz|YNXtzG_cfvRhOy_1tUo1lUS9~}IM zQ`g?b%GK8se5#rn^bhP%h z!gvQ@EVKe#44l2i)O_SroSc!a&hnmC9&Cc3Q;?2uM-6SPtCOg*ho}hF&e16VjkUIM z6tcx3RYhz)Jw)B$>K>wY>NrtZ3u_&Wu!66wps<0UITmH3ujlNI(Go#<=_+VD>i7xj z+WC0Z+pZCo7=nhVT_Na8sAl zgUegHDXHl?BGFhyZ(mOf2Q3#j9Z{UOI2HpnL&Q(l871!TZh#O`5c1J+@|V+dk#%tv z(Urxz;?&fHWdl3~RNQp66}5E0!vzGCoa8lK^tF7o4AfkeJ?)Uzde%5CeSdd^imo#n zp@r17atd%!7ZUcw1~_QDJ0p|~oWUSg&{NezIJpbSX{!3DILe92dZ=L0%2py8XkT{+ zTXcYsFvi(k!Ajf0MMvMl$rS~LF4D&vu4HWwMz#V*ML^LR=>$I0v9%R&LfKvPfG%fZTA1gR^4)qq=iiF$eCG{u~e9uA@?tb>@kxPq9kyoR5!g)g)gAkhJK zvMO>I1uG3rdv!3a6tv(tbt^%fvYfJjHrhqS%f(JvQxKtOhZ0b5^;I%J*yyRFY_K+# zXz+UKV!qx^C^<0ZkP28$Mes$;+Cjq(ZR0HOoZRrYejS-FA1`LF zsh|YbBc!DW+FniD7Gp22?4aOo>tNw0CW037(=)*8yXaxv?1Wu(RJAMwyaF7&)U>>H zRfPpTtb_wJ&^F3)qG*h;wydUsi;tY0ql&wZhdoMB)l0}80k`#1(y$b?c5`uZadC0h zRZ?_Di@7;@2w+`B9jtYLStgf50vW*hL9d2W-<)Py3;bxA8xgl>Tl6LMA*cF+X3RKx{X z;0(NMz_f*v`T5<~D@9r9IdX^T7N^*AA_O42L{yu{0n(iV7{z5nxb3Jn# zaZ4Y#o+HKstSd-Yak!Qb8VlBRaQFXM)=$@X=$WTG8(8w~?maCfAYdjy%gbu{nXEp( z*r5IKOUIO^GB=tfivNe)+uCanE?--&%_ZfUPjxKhAvKogdRrTge88DJ;J%+f>(%wW zi$klEt>@@o?~($o)|V;&j&aY&qb|SREqw7Dc-`UmLnv5Udi1(yjPGIRpR%n|-fl zsO(YQn=$(jrg@9Fod_1wj@rHGMrZI_*PTX7w5$1y-;PKv7eBR1GxkYH;nD30J$KP+ z_Wc9t#@*S6O{K>5+msX;b7PY9YA$C`C{*9z*YuUDVy*518>u~ej#u*vdB=&CS-yi@ zBc|VCEZ&B^jk{pQI4QGZZt68yuJN?v?8j&7<=}1W1v_)@+^z9i9$8AebXC-doh7b= zg7x5)!u@XhOWtcCn!82vN8eK;s%f}Jaz$#`i1XJjq8gLk+cNXdqUKjm4w_D=w4ywW z%NsWEj6s{jc0TdZx4K7jqUO~@fQEn+7A>^A4I7i-zjMSYcwZ{95Tc_C) zUt;h=PBjL3?&y8B=t~z6w0IwFt6OH|Z?Tv)_G*YIJv+iAr1ZBvp3xu%7MX}VqIO8x zduzzKL0t+v(v4*hk;!B!uj?vaiyl>`14Qi=~$b zZ=Csr%v*bzH*g1=t~|WA`lY(w_EV{TwWseJ?}s?`J6oOOm9{(c6A&gbc?kYe!Ap!>AD@noPT-E;8nPsxd%I$ zcdvE`sXRFEa1k7kHzT#}$`hwz!rZIC<$>kb7Hh@UebJ?A5g49STLp z8~s^ggYz;&Q}+&5Io{pfNnIX&VH>%7_-C-t^T$AubEQrH#x;pg+k2V$X6q(f%cJ#n zVDPBk+xwoz0Osff_Jz(%YaX4_^jj>xoeVc_SE8G{=MT3hT)*$m#fiBx!leq0;TS)v zOflCSVY{Jb;g&3wrh7*P8c!8Gz&)~pv!sI?r*(%UH@a@pKeeKAld>#aSMAO`HdCum z{avi_v>^E8*pOG<-EAtn3*IT8mdtiTDYfrX5o6@G|{48%W8IV2+ z40KC&EPto7{JGrq%jVL@&IWp-CabHN?MKFMy%HY#e)E4JMqbr46M1#MqIbQ%CaFoY zxM@BwRVq|u($sGzf<08`sjRqP>{0H?9#h@HTD_0~**%(h*_xW)mDAS`_eOP1Qw*vd z&~IEOV;apD-KWqTkCVFztL`4GzUilnyR)sgutn=UDDm^w$IdknUFsVRK6BL)eyVR? z%TSA;#$QuEP-45<;t})yf}YAipiSuf?H}2m7?v9dspDNs{aUv?unM8qm#mgYo-fc+ z&n5W{EtCfzz39tE;EwkOgEPg-A}?LdykQ!!#FpfzRI|N0(aZHLJ5ileXQBx78~#`! z?z*#7!Yqm|z~GI`<0|KgPj;*mLo%jA7o}E-ouAOAbELB@o@Zzqtej#E6{Bh3x&>C* zs!onM@@o=Za+mM0!p&M9N`5QAR)=%#|L$b^{`O~Cl76L4cVU_d_u2F0$tBt^ddi!Q z9cBaem!4UFC_qu(wCX!i$>ebZSE zuk9Z%WVu>x%y)atKH#wNAeg)98hM$CFHUN|c<=r}>qUN&d(XJNj@R2Rt0b|jlI4^) z?)Pj)_zjBBk-hkd#92|l`4grOx=o3wh$L6y(d{*HTu#tjtXP4`y8w@tbF^KtV&Ckz zk-N#1>G{^ZsTr%4)2&&wd<_ZbXnU$;DHo{XUeY6b4`pU^Mvm(6;P~K| zD@N1oe&|-mMTtJrZ*=SVrXOJETqRVqL`4)xTp8eh{Dj7(}=Xj|%g=Bo9IT`ik4PWrf300TA_v7!qd++z$ic`dNzLE=vzI+TodTAqM0 zFxK%B_w3PdFm_bl^zLePT3?1x=R6T+cG+= zue1#_XSz*J@H%)m9THc*7E!kpZteL#p+RBW8J(8~))HNX3CR#dSE!5>Z zn^@eXhzC&_ZO^tWf>_ymVaxmisR#)*qaFA3{8V1U9smUFOHx}L1*Kvv9L3?NLT&td z9`*jEvUfY*CbUApXkrJ;2b|b$?Q7k}2u?lYkNlWgn|rin+?`K$*KOm;B^IAJ*CZwx z+{(-^=-MAIub%HaufDxKPHP%yE~P)$f63Ls?@z1f`4XiTnyZPIY@^nfBx{vl!1AmP z4yI1N1t$9bR-VbyoZaW?g#n^!h7ZMK^=;{UByh<=qFmxyv8y3w2V{nhj-N^sqz`8< z+gzl5`+l6&ZWoL%_>XBYi+H21`J@MK4l8baGIY)0CHfjB1jCL{(~;qQG`EK z?5m$PI8QFB2P`u7HI1)U&&@p&a+fW8q8Z*a7sgZ56uMeD;ZolpNKy;XOY9@}uY^1K ziPFwrge?QjYTZf+cb<5JO9yX{+bW#+^>@;VzKM0eZnxMpP&iBb=1Zf?t?LupwT$In zXFeqg<(}&jMJZ9Tl8|T5#u8cUrQdWyO}lZ|a4KiABztIZwQ~H*a(UaG?C(Ad`(8<^ z^M$>v=~WTulrqKs>gWsIg=|VYutfwd7+u-Sco#(6Z*h^%mD!KLZ0Lz>(V1{%jhYPp z{;pp&6D|v?R`shjDuJ?gcuGY^viRDyIXKGCxxG$RE3)I!HOHEo3Tc_?EtqZex)=I>bhWagfZdbyLrMDR^7;y zeAcD?&u^fZs+!?naoq7+H^T+AKZ^~!EH%c;OrAfBBdU=P6+(?4-Tdu#S;~Cwx>GgV zyRG=a!ybpMRzv|tm*nEqKf;l@fg2A5 zHpditMN#6qA!64h?TK%O{{(RoaAg+1Y(1x(ckE=w>m2jmn<Z`|*m+NcS&1sl!nLVi(JYjpM zB#c5+ZNCVHCL~P*{o|nR@s0YaBem_Xp6Ye`%P+ozhQTjH|7veG9|fyuz>8;tp~voi z)V8AQ9bxJsKXUGt?FomeZ;47d{}38XbOtEL3Kgu8BXuzcd(pFqWWwghW8WNqS^m9E z`kIzkkJrKMRGRCEePa-i9+;immXtD9K|&@eMKXP<`%_&ln2ySC73x0Y*C@=A!#=@L z@Y`c+?IDZPze2cL&ySpE3LI+q#3EghE7eAil@z|uYnh&%$fT?xiyZZ84Zl$FtMR~w zTe0|fP9!I8UNM38S1hvGz+-{R$_&5WO@ID3wx~U;jlb!T>ZaqmZN+V|eHtB-B6 zShBCRZqt%|1PfGOl3j5Q(o`H9`;14!xOK3y={+n(Lo)sT=U*%Q0hoXUJucj&W& z^pUpw)nX#^dRmG1v>#`jh;qKP?A_23{f&CG`~K*M^vQU(TqybL_J=-W-`YPhd}5k# zEKZ#5CysjY`#Iv^c^&>e&2|n5;;qcu3IFoD4MoT{Fa#_7nF)S8dWDL)OjLY4Eka{M zQbbzB#DsBQBQdya^30v?>H^cw%=JLC``^^XXTod!(h=Gx~ltw)n1NvFBxZTymC1 zrU4vr&A>U6C5q-|L|y?lIKsfXag7Eq$%7(K@D&2TEcY|mMc7{I{L!r5H%Pr`WI?YsX2eeUkuO!i7LKR0ADN}MWS~x z;_aJAi5;0z*ms-cA{vZZlup*a5Sl^d1iAT1vWV`bp|=I=st@*`9y79-@xqqBF)V*Q z`&#pVUSm11Tn>CJLh=P+(YJi;Ovnl?i16G#SAQwT%M=nF_`Gyn9;~LOKqnoOqH^Ez z!}bI_Vp;Z4EEO2}%;+xjNBs|H3epHntnwEn-pz~u5huY0yJM}G8Y!?(5AcotUv(QS zCgoWV1{--<=SCG}R6UjrGqw7n_f^^jJrmhTiid-M9H&ds5flN>^}T0zoR;}l zNtJ#ajxI`>;CHO@FB3TY^> zNOFO@Xj+Yz_x|G&+X#+F_@rJ7Gba}cY*Mz1xwY^OK&o%ZzRuu2opLqnY-|Jx2qS5Kju>?&!IthK_4IB8^XWBR3TzzR%33$Vn*}Cs zLM@W(jYeJpEt0XI@`gGWjuIU_9Ai{@ydj>K4Z6j4AfqDWAyKh3t!{(>n=0sBb3CcW zyVn{i$_7L$Q>viNA5|M-xIy2>QKF#$MsYE4vs9w2Ubm;b-^=%Dw=`r-l`Fgt;)H22 zu+L`MdgiW;cxD7W>~r~E*SSz>4#LmiebqiU3+7;nikqs zKd77;$xZ9+cyf~x`}A&RezfxR>HyT20}0kL=3sD`bH0uh1%0WGD^ShMj?0{%*9<`4 z-~Zz=PUj_m`Z-MFLc=5idR;^X87CPS3S?|G!wR55_V_Av(jSeaY$IiU5Ec`@t6`6n zPCsYi4taAMnmQ7Sse}8-iv+#Q|FFqf~dWRltW^Y$`Tvl@?fvE2P;=8GPqb)QS(Q$&eemc`Bn?uh_d{#qWt!igf#gA-0#$@JSd8k&IwOS z(Afyv9%4Q){EdvLJCcP#ga$=X*7T_#xKXO8`Q*}NY)xM4_)R0Yl88#STt1hwLFS67 zs)q;HJ64$^|2ii!2^MI6V>HZ6u-CZ#eTu>CajHCbtBJFWd}hiWe)VVwhSFki9n1n_ zrSI-SL(4f3^@}f>>71y*n#P&JqV*7aiQC^=Hw;iEm87}nXf?jVG%z;#(_&>6Sx*Nz zNmOYVuRu0efVOEQmQaKdkTN?@YiSn^y! zLThHCdTw6N$GUU}DfQfQhPG2ScV6mz+16k8G92>FqluqeW&^?5;!9Z0&fk*qe`l@U_1Qdx2 zIN?px>2)T4N=_mWD18z?Mj=5kAVL0Q`UdDC^;X#PkhwfKeFe#uA~g&|QCDf7u^xMR z*J3Q?Y%LlZ`)ERorUxJ#lv7@ddvB&Z64jSWFVz? z@xJ-W0u(LRqByZ{esYjlv3Ql;wk7o3#-Bmy-k_aHj>orsQvof~2b7H;F&llehTeB` zari@(J?^=FWf4S$HiK4PcV_wsqXceA)H8>CxKQlxIejKc=K9~k8>h|xVo7W&5a%_j zt=p|CHpzN>t@f$Yw+4Ne#yuOv&R5TKHYBv%a^62br2wU!5{Tc15fG!(5PGX*RofjpwP1{4?Bhzlo|7{#%~m#^R2`uRESn$K7ZT`o`; z^mR)066#zR`Z6j2ds2Q#!yB{II>_I!js!X@b%`Rn^e!2z72^W~cYwZ{@0keWdE z{HjZ>>{{c2OJz``10@Cr^ij-Rr!?m;Ro&@aS~02orhNR3yZHiYaI-rBoAGDK#h+;5 zv|i}&B93?GggzGQmgiJCjVBgyuC!KMyD+cL>|GwbcXRd{>FM~^AX^USdb{<>Fm`4a zs9=Ra`^+$Ty*gTHt8Qt>AZ*8ck(Mvn|Ib1uO!zJNT;wNE0D+i^7BA0+(5f9$8 z`$ujt-({)YCwnJA3AOoRo5iA)Yt{uHh`%9+iE!AN^rdymeYf6vF%&-xWZ>_!5BXDp zrr&KIb**EylI~Nsal8yY(MSWrEdtGa`E) z($fo7(t4=WCCxFzK=pR5>BmwBfbgjrW($1@J~`^YQ@mz&`;u)W);<$tSoU^sY6$Br zhb!b7PrndZhF?6I1i`l<+x!h0+dGse*FR>P?H=j1IMh-#myu6L^BBC#(&@W|{L{O5 z4dbZQY6K@8E+glc&oT}KSrLwd z)+4xV?HSz2TW`muPcO5Kfc#d(Wc1lI_}x-D=+%q~ck#PG!;Lp@i$nuX{XOLTb$D<` zjj`J>to_yEN+^*XzL=1bgk%Vo^7NdDTkCSr@!=k7>_aQgdMaq=F+%Iky+c3GuKmlw zyJ7yfuK(~~uf22c(Q1{t)Smppz+)abu9*3;Tk8dzTHD+poyMc>i9Q;m8ZHSyp8G#B z3{cJ(RM{mwCp}lR2;NB~szNb_&U`@7yq?U^c2N4H;W_gRR+KL@{}oTK4{N+w$jH0n z@2b&acF-nP3TtN`1ak;BbKzBzy3{yhRmY6IR?I85?QeH~(F+l^!2<6LnEgMA3xh=|L!781+fGEyRMwEh0Jwme9`orMFh?FO|kEGh>6l({$gTI9le1)2UV zIVbrs4Titncm00bLn0@tF;h{NsB+-->8+5jBoOZ?r}A`%ez|_&p+J*FeCrIpQ$Wp&bju%mW%R# zVMYNn5O~fU=H!z;or|R*0sGObX1v_ujnjS!knheogplEU=>HSQ{*J1KJlnd@4~VGz z=n{Ma2Ve%CJf;BX8UQ*U*i{D<{{`wkj0PHiLBQ6s;g-g8%|ccaMQ%ph5Z8iZ(gp&?MrH_lKA;s6aU*5nC1*$hsFJwl z_gp7!EM3UdQ^W1i*OrR(LN+n>@PJJ_`!7|`s~kU6E<+K?j}UM* z!hY;k-bk6TAxI(epX_!@Tg`VRY=A{H#SyREA&1jiCe;XbznFHk2Z;vu_`vw9mVHqW z`LO+9{)IRtAMB~UrTUe9V9`ui`%w7sIb+b)sP1={+!PUF9#knTVwh>7nElCucUqBB zwHgkAfa0;-0t*5NuEK2wY5%b(76OP+;-NQa2X0Z^croZa07f&N-rua&XasH>t*@jxE8eNpy0i1_IyNNOqgTOm*F)s?QQ*OcwwsGC(#=#(+Tw&2pN-ysA ziS;xoAwmLXma)JfTQ=J({(gLHwRwf<`Jc!O?FP!U-bL2VIsdA2N!% zL<1iEARrX^bs&r)FMe?2y)vL|9m)}p+tJMRn&J0?DHDcS1Qq1EkPxxua`sa&B(r1F7k=?Nr^?Cp_jSmiR z8pBhX(v@l@{s?SGi63d;kEnP6HPy*p>7)9)Og)&Tv$2B$vKccz#0Inkl@~2~PJaVy zm^dR|11;u;&EjgMU@_NouMkrIyRZJcf&Y%+zlZ4mggGdlkPX~`(NCvoTlFe!Vxhep zh%LAGfKljsCsS~;g!i&iq4Mv-legYK3zSp1HQxnndHev5C+XgW{;Wcq{!GMpsX?_e zWK96_#hj=!Pdk0!fYJsa62}|(^jI{r1XzFKerf-f#*Q{WD5KiO5}Z+6bp1Wseo9Ic zZYpMqZGASmtJ-+D(fiVk5$wDhSyP7!?3i?BD1mvnQvCE$A^;@Tea$Q5mDWoi3O_Uj z2mkrC$a4VrOxfo0s0#35aSTcwI2G}J2?Y2-&}~|VUiw~x084KwZxWzFJrFl~aG@+w zAi2in+HId?z{}E^Vz1vZ$P{(v23tPQ)-UUqcejm{YeM`FfLd}`i+5gM&6^^ z8Nm~P@Sl-Od+(^r=;4hFcE^MV#h>ap0PoR=xNTe^%6co;eBsD>yrOV%F!;E#Ve^BE zN9Q$PB?yANX*znj0(6JS5g^bM;-0B>Xjxq)(=t+sWneo?Oa`}E$bZO}=-Rl)Zs}#l z2zj?IORnFy59=8O7|Z_n-gLh{HBfd$UE}32la`VHo){EcMOuv;}t62j$(0MHkjl5MH zdg+?PNX$_?t!Wn|xy*(xwJ{2qI@R|-zWrJ2g&qDYT3i8nhGq8sPZvfWSsd&+6t5t@C*%5f$0zK^B;?qZA%1Nb zI4JoiCh+igr$;-rZr3HTuVxsA7^<2fJG_xHq62wG81>!0IYNxhLHHd}_7GE#ykFa8 zvKG)iCJWp2Ujl(Q!)C&1cYP+KQeM`Z>+S(r3RQa8n{NRsKwvRM%!E@x09ep{_PsMV z3Qh-Cg=33J^1g(YP!C*dVaZPD25)1JEms<-qO1eX4H#53m&PAqGRV_{XqHMRES{wh!=|W9-Q4VynVM z$nGZ~E^ZpO%9DMmweATukIuX>su-T98BRJf6UF4htvS{hY97WF+TA)eQDtvgqBAzz zDr?K=_YHV@Ab&|$HdiY>7hP7OdV)1m2RXOwu5`ycASzlP?QcQOyG&l`^wKv|_wK$3 zn<=KrV+dcp?UdUhGwIRGd!{YCQhzMJtz9`mg{xCf>3#}}4nF-{8Kv6?*bIRPIU|#2 zpFoG*6G5*r^C)Y&)|lqNCz>Nbp2Uf?QrWYqQtZoGlZ@tEmOjJ=Y%ZGDBtaeKjM3-@ zRy=zF$#cHIy^`rEH8$Jkp94k?Q{D;a`JS6`k`@CuW&khIxjL}z_3PWDM{s5Jd;byp}3goed>?K-{;2i0tV0iX1@|nI1s2+bShq_g3MqtkDE_2lh zS_0mme=9D$8h$*RPIAB;B6+H2@ZWNnp1(mN>K%2TYX2fPs(5!gd#IZu*QqAh%mngR zGT;a;E5OQ4?@>%T(=5Qv9m0jICO*lFn|@G1AXHQM>L`NuH88~t(8U`2jJIbKl730G z#)nE3sXcZ$j(+(Zw289CZN`Zr<|>9UhPH#GW>D&A6SwraJa;ePKA=U2$_?ub7OfyN zJ2izQR=t{WY*fCBw8LJi&|F}Oyqi#7D-91SU1K9qn`J>s(n>Gqt>w25dy4h;+z$i(@2ujvN_**Q723!k&mSSllZ3O z#ZhTh4ItwgQF5jbsA?cuv1g-ZcM@gn_rvIyd04{mJB__3=Zpm~Sw)=0(cisfamlw# zx7E)0Q)2%#4k~Np@C+^tP<5#dG?UG&_u5dj@Eu7fKYLUHyZsJqQ$B9W6pNDQdhH46Q~%JUI2xZt_r@EXarnllSs$A1hdL!y z8mQFVomvdwlyAv0UZ;TE{8RA{f3xf#I87%#b&|5*rlD6?ilwVndLN|7o$}CP=)SDa zY9i3xfyGV9w}hY7QJ;2IenmBu0sTV5&h{toShHd%n_X2y@6tNz#x1TI6<~`kp$(G)+RQvNgY4LXFm~;0U1NS`WZ~K(STooIj zdo&%Yu?M*3cc_{NXt2FtADRc$glhA(c^mO5S_SeaR928_*toyU1F4x0o&ru<;WS>M zc>q;AKqYVsCh6JdF4E9Z0m!$5{xR^_8UU+Q;I&qHBt9GMJTLSQIesa)`92}Qb#J;} zcV2h=G7O^@o+$k(^?dvTj184~M1u!Y{uWH;(bWf_Pg`J!b-PW}LZ|;WAKxM8nDP!H346y9ki}vj&NKLH`Xa#O9EkY7-nmclmP+ zy^z&FHlpMGOVg%rhv(%)fGPaBX;UNp`Hmj|_NM|wY(+y9v{v^c=L1v_0XW{?UIeWP zC#W0@?N*sRx|K+$=~d}H$hl}N#9#y%lO zzXN7OLstYj^ywb2I0EmpN7s$0^d9n>LF{k;rNXoVP*75Ir$hm`G?GAG{S#fvhq7jw zydDs{gD%WAiqTxgBp9sx-~O#21uo9~ZKLF^jFC_30L`dxAe;*;|Bkk2sFDE*ntVEoND3mW4X&OMzsTqG2|(SQN)(_RIh2;yD!LBR5PyQT z%FW^{R5gb9K_=5GTEGW9t$yhM!~jn02r}nIZ$<2em=PfGwLvuKngrLHmj_*hX`_Uy z8Wwir?jcah<;?H7SHmP@pQc(sB07lbd^SjN2WE&mXO^10`{E>R3`B~JUjC-^WioCd zI2)V=6q*SV6B{}P?|;mlZ$5ijI9LkM&VHJSQ{zFInNq;^iaj^t5`!>j8tK5zyyY+l z3bKoRBY?m2!yVy*uJ5)|>6upD`g86~9G)cO)W(Y#VAh1RV%eJP#P;_*L}>6$mwVK2him;pw>(g z)a=;}T+Gv~@>IGG>dDa-y0 z+~&8$U!l!mZu{sC>^TB)vvZk(*7))3Z8*mwQIp%kkLpX zWdVpDPl0aN8^}*_-L$jCMl#Q5A;UIvwUVc-7P(IJ8FK898_c0ArjFKpLwOO|<1IH< zL8a$=y37@RN3y<)+!A9YZNV*r?mkPkpmgX*%(^S&<3b#qJsbH)wODHA;DOl(Y(&q! zR^BmyrriRADS?1NGSgG$mB*AW&PW;6@&fWg{IX4WAD^EE))1~5bhOf??1CqiQ}Q5d z{$SSn2ZBWJ^AylM@n)>p{uTsN_T|=b=Ioy>J3Cfa>9eUq-CK1S$j#@LUOkPIG8mBf zS=#5zkjHRV4lK@>=_}7zp2dazl4+e;nr=;{DNz!~g>$stJD8Zttdtx73^J@S7aT!B zU`KjObl#cp^0Uov+|Ivl>oaF`sx&_!8_k_Yo`{n?YWpmXc~s88>Hk_&Yv^lL*+GGg z3N9I@zir3~kai`O0O7)V=F?UbziSNabz+u1p3=DMA4UlQJTzDgp-QldDPX`%%8oeG z<$jamRhe{VesDQ06uO1Cds9sqb*qNx>EG`Y7rNfAd7d*G&ix3}PGQy4Pxj2|?^$>ApUBc54}|>SIW)elpmv6Jnl?n0Wn-+V@l%PAs>b+5McjN^aWzWi z$lg$+X+iF2ui7L=R5D~mnPP4K!c-zNi=}*cO1_8q2I@vb*O=fvfY%Q(P_DmCHSHxMa0Mf3n8`S3&NRVx1oLYJ-#;7N zXzrnnkTiR3zXEbpV+j>)f35IVpVS-)2>KAPYOpQCgne2hJ zL1$ZlwNuc%l?d2yl#8yZCeZH9MXa^O7jTgRGX7uO;tfMnz+i$0o*gz&AzcE>>Y1qy zXWJhZ1|4h*dM;pqvBrO4%62e^7dk<}YwfFk5hf#XZ)f!;m}<-4Z71G*B#wkI?U(bP!58bjjqe@e z=ZcCgJ0C&GAlBbfsO}Dx=8Kb286N*#59m_hAbl8u_uv2FTj_xkZvbF!>@=O+vBX0u zBRgN9Pbz&ZQvD9?=S4P?rG@unKTL7l2x4 zbc1@KaxxA3PtaR#N=PS=rz7kV9RN1KY{NvYbMq0$+!lD3rXwH7+5;U5pp}5t2KJs@ z1ix_Lt{aYv+a3=xbt=%g4AUn7h9`mKTkptoob}gQ_YN4ZeuX@Pn9D82>;47J@R=!W zQ0UAuF!p=}WT^t6f6xUf+!_YyrL=D^x81n#`gsTyG4q7D;{AP37qljIJnjCAVlGHS z1xb}&EnhPeaO4ONV22d~ia-iZ2P{OQ8z3rMZdKq?=}KqO!UOzg$*s=u*eh}A2hcZ# zf5e+*W8F)@!2^`PaL*|VBf10f4&aQ5SF#wy%?T=EJ%JnWM=Gl}p?_WzJ~JNxScZ>+ zz>2!`?OnZ*|M!&8V4gu(-txz%ikJO?s;a78T)@?;UkGIp(*-OG04Ob@+ydqI>0w{s zI7z!z)UhA9KdU_+a*^dihKJlILZ8S8`8RbnaGPV6ar8o7;6A-y>pWu-65s#>!J=Zh zDDnljEyDAR%(NzcdE=tMY5uEkFCSQ6-)n^d2uM{02vRT8$*$tkWc?d5;N*sUUrl@c zu2%b-OW@oS5?EKI^1TfL7(ebyQKjw+B%_5clW*yZOJV*A#ttUF z_V|XOt6_a%021_B4md57g9b(^Q`Eey;FolXd-=lh5kdhZ!Q%IZ0eQ~y&nGKd1YASR z8A49^&9G|6&n_>Hm8Fa$nP%O#=ev`vfm5tVBD~}yC{0hOyF52rkLRnMKI8d`B&rf1 zv)ImI(fZ2wF$J(QCW}&iJ;N}lGDr$SF;cR&rT4V)iMtyei44s%p zfCZ;vkh|uGs?a6DGy)^isP+|RZwTg}r2n@W!;EJyp`SF&m$I=Kqvp5cgI?2Lm{)0j zD0cp85vQq}b@h*JeIr(?)lM)?Z^+sOlU7`j*&nH|P z$~Y+^XfoaZk0``H&JLk()m@myoVl0xL58BP_t^yjopQ)+xsI0zg_S+8L%_iF z5;@)ZkbkJr;>6}mtXN{g#$yczd&u)FjIvKIUqht%6xrR6cH)-8dHrl6H@rL?d%u#0 z8PdtmS#{+d{WVS=KZv79Q-9L%Y|yPM;NqK6&O9Qhc0nngqW+WOscyXaKxkEHb_Z5y zOc-%0QMX#mFaCFqu79d#dIl<%xL2k`fnC%7Dr4uv2(Z^)RPdSoTZ^`V@h21GfQn!| zi=3ueK+#vbwmAk3DwBXjS5Vk`>`VosU(@2=pa;aI*Jf7#t%dC05BztR{(oxFaLf4v zhmPL7a~a63%R(*$ZBQYDtCT)DtOUn;>G(`~f6jiZFadc~foSVlV+;@!D56mXrzdqf zf6*z?;(AcsN1qgS2_!kfoai-O09kTTaLS7VNe+(R3MFR-zz+WK-u@B?B=$n*hY6gR zg5z+Ez!5(lKtk;S`xLgQR2rmaA%_N3=n?;75y5gjBFq#pP>qK1U3!m>?SnO7z+Wq zTbOzzvCIj)EQ$7&W-Xz8#ZdJRKzzzy-ni!Oy#b;yun?(&gN*o+fSDv!-+doAatc5# zk03Z2DKr11^eHgDtCamyv7<1`n$vuJx&;N7h6GDSaDo)DM#$sXNXtMyS?|>GwpfOw ze+8t_E}X#CYhV4T0q}4f*ctk##GJ;=YTjX;k*DUAR2p7`^xXbz#78aYs3GTL@+2am zh@N3k##0Euz{WppDmNg3{17N?9>B%aJ8qlnTr&yP!dQ01@pFv9>Ka^GF6dnOUE_(K0YyxykRsz!J45{3 zsIEdlZ45cLt#5M!SezwHR7U#~_i=9uvauwmZqVc?uGZ8~QU@zH#f8F`DY(VPix#Us zstIX7Av{a01dK@5)6F3rGREM9ouXBM)EZK_TDKYdD7clOGmTb&bOvlQP(7SU(3W-` zIQK=h(5@qfenG|usF{5}li3K*0^ski0H<#a!(MB`X1yP(-ns%dO0y8^sG-04%ndk7 z{AZXmzf+os%U8dvIAL&12IMFB>i^^Mf^9LG`9nuwJo5lk#u_+1kgN;Q70qmUgCreBdDF`kgOM#v-6#2B=2<`IQ3_z|RCgoGXTuTTc99 z`0^mIzQ-oWelG@^^cgv7r??rTA*dMbv>*=Yhg?n3HAw&&fsDJqlMNvg8GuznK^6_b zHJ-IvG2J@17k%k`m0~PI1gR#aqy6pIvvlgfbxar*q{kt1q^~$YcbhVM5iRB;I3$EWjQCO_sQ&9YHC_w{n^0>l z4u;SoBC!HsnQ5>6%?DiUpcqwy9@%%i(a{V$r=B)LBUutxDF?DKZ^ri>fP;Te?S`ax z6NsUtJLczFFWY?X@wh%8gusw|w0kC@@L1<7C_ttC4B8NE) zEnD9VOIZ<3G#~s4=zn*gmaIAB~J-gCE^6I z$#R-rFo*ilUcFCD!z`G9-)gu@{sKvScKGEj}s8K<#A z6EI6$dtohPThs}%yDoARdpn;cZwC&;5Dntrql(xO?~Fsd&Z`|2{vWIUd)cZQxJmhz z2(VeW|3>!aju63#jY>t~QBx0Bs`~*4nAH5bm{lBs`-_{jewWMzmE);hS>oYsOvWt5 zEw9-HS3dsr%E)d#=m3fJ;fi|?2G_rg{cUnS2Dm1{$d$j_!(DLY#I&ge?^uB+0llQ{#{>Q69i^@aSPr7$9u)ga0G-K`A z5IdXdnnBANSmGZ5>FxhsZ}=*(s+&a!H2y36=y2X-RfoT-r>F1T?Fm{9Vdi@96YDeJ z_VMin(Pw=_wL86hi?ky9xA->y^1j_wybqLIw}Fl)`t+!}YejKB$o2W*3U?cUu8;e_ z6vyWH7}ws5t5-Ud1`;Fj~TiAliS&__8Y$5uje{~mDD9w^r~M}PKCS74tq+g74i z7F;@|xEshE1)b}V$uH^NH4)hIRQ4%*$_s9be{w74F;M}^NfzzPc_s#Id9MAMU{VHI zt1f%6K%^S9K)^OdM$-+LsCx`A>ZVT!INkBTVxog0u-gk-T*l0FMSkl9H(;?gzeUq)v4TZ9XfObb d&U5~;kJ~oW?0-1dMBs`344$rjF6*2UngA*}qA36X literal 0 HcmV?d00001 diff --git a/plugins/wasm-go/extensions/ai-image-reader/dashscope.go b/plugins/wasm-go/extensions/ai-image-reader/dashscope.go new file mode 100644 index 000000000..90c4d8070 --- /dev/null +++ b/plugins/wasm-go/extensions/ai-image-reader/dashscope.go @@ -0,0 +1,177 @@ +package main + +import ( + "encoding/json" + "errors" + "fmt" + "github.com/alibaba/higress/plugins/wasm-go/pkg/log" + "github.com/alibaba/higress/plugins/wasm-go/pkg/wrapper" + "github.com/tidwall/gjson" + "net/http" + "strconv" +) + +const ( + DashscopeDomain = "dashscope.aliyuncs.com" + DashscopePort = 443 + DashscopeDefaultModelName = "qwen-vl-ocr" + DashscopeEndpoint = "/compatible-mode/v1/chat/completions" + MinPixels = 3136 + MaxPixels = 1003520 +) + +type OcrReq struct { + Model string `json:"model,omitempty"` + Messages []chatMessage `json:"messages,omitempty"` +} + +type OcrResp struct { + Choices []chatCompletionChoice `json:"choices"` +} + +type chatCompletionChoice struct { + Message *chatMessageContent `json:"message,omitempty"` +} + +type chatMessageContent struct { + Role string `json:"role,omitempty"` + Content string `json:"content,omitempty"` +} + +type chatMessage struct { + Role string `json:"role"` + Content []content `json:"content"` +} + +type imageURL struct { + URL string `json:"url"` +} + +type content struct { + Type string `json:"type"` + ImageUrl imageURL `json:"image_url,omitempty"` + MinPixels int `json:"min_pixels,omitempty"` + MaxPixels int `json:"max_pixels,omitempty"` + Text string `json:"text,omitempty"` +} + +var dashScopeConfig dashScopeProviderConfig + +type dashScopeProviderInitializer struct { +} + +func (d *dashScopeProviderInitializer) InitConfig(json gjson.Result) { + dashScopeConfig.apiKey = json.Get("apiKey").String() +} + +func (d *dashScopeProviderInitializer) ValidateConfig() error { + if dashScopeConfig.apiKey == "" { + return errors.New("[DashScope] apiKey is required") + } + return nil +} + +func (d *dashScopeProviderInitializer) CreateProvider(c ProviderConfig) (Provider, error) { + if c.servicePort == 0 { + c.servicePort = DashscopePort + } + if c.serviceHost == "" { + c.serviceHost = DashscopeDomain + } + return &DSProvider{ + config: c, + client: wrapper.NewClusterClient(wrapper.FQDNCluster{ + FQDN: c.serviceName, + Host: c.serviceHost, + Port: int64(c.servicePort), + }), + }, nil +} + +type dashScopeProviderConfig struct { + // @Title zh-CN 文字识别服务 API Key + // @Description zh-CN 文字识别服务 API Key + apiKey string +} + +type DSProvider struct { + config ProviderConfig + client wrapper.HttpClient +} + +func (d *DSProvider) GetProviderType() string { + return ProviderTypeDashscope +} + +func (d *DSProvider) CallArgs(imageUrl string) CallArgs { + model := d.config.model + if model == "" { + model = DashscopeDefaultModelName + } + reqBody := OcrReq{ + Model: model, + Messages: []chatMessage{ + { + Role: "user", + Content: []content{ + { + Type: "image_url", + ImageUrl: imageURL{ + URL: imageUrl, + }, + MinPixels: MinPixels, + MaxPixels: MaxPixels, + }, + }, + }, + }, + } + body, _ := json.Marshal(reqBody) + return CallArgs{ + Method: http.MethodPost, + Url: DashscopeEndpoint, + Headers: [][2]string{ + {"Content-Type", "application/json"}, + {"Authorization", fmt.Sprintf("Bearer %s", dashScopeConfig.apiKey)}, + }, + Body: body, + TimeoutMillisecond: d.config.timeout, + } +} + +func (d *DSProvider) parseOcrResponse(responseBody []byte) (*OcrResp, error) { + var resp OcrResp + err := json.Unmarshal(responseBody, &resp) + if err != nil { + return nil, err + } + return &resp, nil +} + +func (d *DSProvider) DoOCR( + imageUrl string, + callback func(imageContent string, err error)) error { + args := d.CallArgs(imageUrl) + err := d.client.Call(args.Method, args.Url, args.Headers, args.Body, + func(statusCode int, responseHeaders http.Header, responseBody []byte) { + if statusCode != http.StatusOK { + err := errors.New("failed to do ocr due to status code: " + strconv.Itoa(statusCode)) + callback("", err) + return + } + log.Debugf("do ocr response: %d, %s", statusCode, responseBody) + resp, err := d.parseOcrResponse(responseBody) + if err != nil { + err = fmt.Errorf("failed to parse response: %v", err) + callback("", err) + return + } + if len(resp.Choices) == 0 { + err = errors.New("no ocr response found") + callback("", err) + return + } + callback(resp.Choices[0].Message.Content, nil) + }, args.TimeoutMillisecond) + return err +} diff --git a/plugins/wasm-go/extensions/ai-image-reader/go.mod b/plugins/wasm-go/extensions/ai-image-reader/go.mod new file mode 100644 index 000000000..7f50ccfcd --- /dev/null +++ b/plugins/wasm-go/extensions/ai-image-reader/go.mod @@ -0,0 +1,19 @@ +module ai-image-reader + +go 1.19 + +require ( + github.com/alibaba/higress/plugins/wasm-go v1.4.4-0.20250621002302-e94ac43dd15c + github.com/tidwall/gjson v1.18.0 +) + +require ( + github.com/google/uuid v1.3.0 // indirect + github.com/higress-group/nottinygc v0.0.0-20231101025119-e93c4c2f8520 // indirect + github.com/higress-group/proxy-wasm-go-sdk v1.0.1 // indirect + github.com/magefile/mage v1.14.0 // indirect + github.com/tidwall/match v1.1.1 // indirect + github.com/tidwall/pretty v1.2.0 // indirect + github.com/tidwall/resp v0.1.1 // indirect + github.com/tidwall/sjson v1.2.5 // indirect +) diff --git a/plugins/wasm-go/extensions/ai-image-reader/go.sum b/plugins/wasm-go/extensions/ai-image-reader/go.sum new file mode 100644 index 000000000..54a7eb886 --- /dev/null +++ b/plugins/wasm-go/extensions/ai-image-reader/go.sum @@ -0,0 +1,25 @@ +github.com/alibaba/higress/plugins/wasm-go v1.4.4-0.20250621002302-e94ac43dd15c h1:YGKECMrlahN6dyEaM/S5NEU4IJoFzWKsHQyawov6ep8= +github.com/alibaba/higress/plugins/wasm-go v1.4.4-0.20250621002302-e94ac43dd15c/go.mod h1:E2xVWrIovU3rZi4HGlMfcYf+c/UVh3aCtpcJlNjpxYc= +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I= +github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/higress-group/nottinygc v0.0.0-20231101025119-e93c4c2f8520 h1:IHDghbGQ2DTIXHBHxWfqCYQW1fKjyJ/I7W1pMyUDeEA= +github.com/higress-group/nottinygc v0.0.0-20231101025119-e93c4c2f8520/go.mod h1:Nz8ORLaFiLWotg6GeKlJMhv8cci8mM43uEnLA5t8iew= +github.com/higress-group/proxy-wasm-go-sdk v1.0.1 h1:f9X4I5Y6jK3GrdsWn/lCTI1z5Lu5GOMazqQohAC3Vzk= +github.com/higress-group/proxy-wasm-go-sdk v1.0.1/go.mod h1:iiSyFbo+rAtbtGt/bsefv8GU57h9CCLYGJA74/tF5/0= +github.com/magefile/mage v1.14.0 h1:6QDX3g6z1YvJ4olPhT1wksUcSa/V0a1B+pJb73fBjyo= +github.com/magefile/mage v1.14.0/go.mod h1:z5UZb/iS3GoOSn0JgWuiw7dxlurVYTu+/jHXqQg881A= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk= +github.com/tidwall/gjson v1.14.2/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk= +github.com/tidwall/gjson v1.18.0 h1:FIDeeyB800efLX89e5a8Y0BNH+LOngJyGrIWxG2FKQY= +github.com/tidwall/gjson v1.18.0/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk= +github.com/tidwall/match v1.1.1 h1:+Ho715JplO36QYgwN9PGYNhgZvoUSc9X2c80KVTi+GA= +github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM= +github.com/tidwall/pretty v1.2.0 h1:RWIZEg2iJ8/g6fDDYzMpobmaoGh5OLl4AXtGUGPcqCs= +github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU= +github.com/tidwall/resp v0.1.1 h1:Ly20wkhqKTmDUPlyM1S7pWo5kk0tDu8OoC/vFArXmwE= +github.com/tidwall/resp v0.1.1/go.mod h1:3/FrruOBAxPTPtundW0VXgmsQ4ZBA0Aw714lVYgwFa0= +github.com/tidwall/sjson v1.2.5 h1:kLy8mja+1c9jlljvWTlSazM7cKDRfJuR/bOJhcY5NcY= +github.com/tidwall/sjson v1.2.5/go.mod h1:Fvgq9kS/6ociJEDnK0Fk1cpYF4FIW6ZF7LAe+6jwd28= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= diff --git a/plugins/wasm-go/extensions/ai-image-reader/main.go b/plugins/wasm-go/extensions/ai-image-reader/main.go new file mode 100644 index 000000000..13c2d22fd --- /dev/null +++ b/plugins/wasm-go/extensions/ai-image-reader/main.go @@ -0,0 +1,139 @@ +package main + +import ( + "errors" + "fmt" + "github.com/alibaba/higress/plugins/wasm-go/pkg/log" + "github.com/alibaba/higress/plugins/wasm-go/pkg/wrapper" + "github.com/higress-group/proxy-wasm-go-sdk/proxywasm" + "github.com/higress-group/proxy-wasm-go-sdk/proxywasm/types" + "github.com/tidwall/gjson" + "github.com/tidwall/sjson" + "strings" +) + +const ( + DefaultMaxBodyBytes uint32 = 100 * 1024 * 1024 +) + +type Config struct { + promptTemplate string + ocrProvider Provider + ocrProviderConfig *ProviderConfig +} + +func main() { + wrapper.SetCtx( + "ai-image-reader", + wrapper.ParseConfig(parseConfig), + wrapper.ProcessRequestHeaders(onHttpRequestHeaders), + wrapper.ProcessRequestBody(onHttpRequestBody), + ) +} + +func parseConfig(json gjson.Result, config *Config) error { + config.promptTemplate = `# 用户发送的图片解析得到的文字内容如下: +{image_content} +在回答时，请注意以下几点： +- 请你回答问题时结合用户图片的文字内容回答。 +- 除非用户要求，否则你回答的语言需要和用户提问的语言保持一致。 + +# 用户消息为： +{question}` + config.ocrProviderConfig = &ProviderConfig{} + config.ocrProviderConfig.FromJson(json) + if err := config.ocrProviderConfig.Validate(); err != nil { + return err + } + var err error + config.ocrProvider, err = CreateProvider(*config.ocrProviderConfig) + if err != nil { + return errors.New("create ocr provider failed") + } + return nil +} + +func onHttpRequestHeaders(ctx wrapper.HttpContext, config Config) types.Action { + contentType, _ := proxywasm.GetHttpRequestHeader("content-type") + if contentType == "" { + return types.ActionContinue + } + if !strings.Contains(contentType, "application/json") { + log.Warnf("content is not json, can't process: %s", contentType) + ctx.DontReadRequestBody() + return types.ActionContinue + } + ctx.SetRequestBodyBufferLimit(DefaultMaxBodyBytes) + _ = proxywasm.RemoveHttpRequestHeader("Accept-Encoding") + return types.ActionContinue +} + +func onHttpRequestBody(ctx wrapper.HttpContext, config Config, body []byte) types.Action { + var queryIndex int + var query string + messages := gjson.GetBytes(body, "messages").Array() + var imageUrls []string + for i := len(messages) - 1; i >= 0; i-- { + if messages[i].Get("role").String() == "user" { + queryIndex = i + content := messages[i].Get("content").Array() + for j := len(content) - 1; j >= 0; j-- { + contentType := content[j].Get("type").String() + if contentType == "image_url" { + imageUrls = append(imageUrls, content[j].Get("image_url.url").String()) + } else if contentType == "text" { + query = content[j].Get("text").String() + } + } + break + } + } + if len(imageUrls) == 0 { + return types.ActionContinue + } + return executeReadImage(imageUrls, config, query, queryIndex, body) +} + +func executeReadImage(imageUrls []string, config Config, query string, queryIndex int, body []byte) types.Action { + var imageContents []string + var totalImages int + var finished int + for _, imageUrl := range imageUrls { + err := config.ocrProvider.DoOCR(imageUrl, func(imageContent string, err error) { + defer func() { + finished++ + if totalImages == finished { + var processedContents []string + for idx := len(imageContents) - 1; idx >= 0; idx-- { + processedContents = append(processedContents, fmt.Sprintf("第%d张图片内容为 %s", totalImages-idx, imageContents[idx])) + } + imageSummary := fmt.Sprintf("总共有 %d 张图片。\n", totalImages) + prompt := strings.Replace(config.promptTemplate, "{image_content}", imageSummary+strings.Join(processedContents, "\n"), 1) + prompt = strings.Replace(prompt, "{question}", query, 1) + modifiedBody, err := sjson.SetBytes(body, fmt.Sprintf("messages.%d.content", queryIndex), prompt) + if err != nil { + log.Errorf("modify request message content failed, err:%v, body:%s", err, body) + } else { + log.Debugf("modified body:%s", modifiedBody) + proxywasm.ReplaceHttpRequestBody(modifiedBody) + } + proxywasm.ResumeHttpRequest() + } + }() + if err != nil { + log.Errorf("do ocr failed, err:%v", err) + return + } + imageContents = append(imageContents, imageContent) + }) + if err != nil { + log.Errorf("ocr call failed, err:%v", err) + continue + } + totalImages++ + } + if totalImages > 0 { + return types.ActionPause + } + return types.ActionContinue +} diff --git a/plugins/wasm-go/extensions/ai-image-reader/provider.go b/plugins/wasm-go/extensions/ai-image-reader/provider.go new file mode 100644 index 000000000..4d5b787e0 --- /dev/null +++ b/plugins/wasm-go/extensions/ai-image-reader/provider.go @@ -0,0 +1,109 @@ +package main + +import ( + "errors" + "github.com/tidwall/gjson" +) + +const ( + ProviderTypeDashscope = "dashscope" +) + +type providerInitializer interface { + InitConfig(json gjson.Result) + ValidateConfig() error + CreateProvider(ProviderConfig) (Provider, error) +} + +var ( + providerInitializers = map[string]providerInitializer{ + ProviderTypeDashscope: &dashScopeProviderInitializer{}, + } +) + +type ProviderConfig struct { + // @Title zh-CN 文字识别服务提供者类型 + // @Description zh-CN 文字识别服务提供者类型，例如 DashScope + typ string + // @Title zh-CN DashScope 文字识别服务名称 + // @Description zh-CN 文字识别服务名称 + serviceName string + // @Title zh-CN 文字识别服务域名 + // @Description zh-CN 文字识别服务域名 + serviceHost string + // @Title zh-CN 文字识别服务端口 + // @Description zh-CN 文字识别服务端口 + servicePort int64 + // @Title zh-CN 文字识别服务超时时间 + // @Description zh-CN 文字识别服务超时时间 + timeout uint32 + // @Title zh-CN 文字识别服务使用的模型 + // @Description zh-CN 用于文字识别的模型名称, 在 DashScope 中默认为 "qwen-vl-ocr" + model string + + initializer providerInitializer +} + +func (c *ProviderConfig) FromJson(json gjson.Result) { + c.typ = json.Get("type").String() + i, has := providerInitializers[c.typ] + if has { + i.InitConfig(json) + c.initializer = i + } + c.serviceName = json.Get("serviceName").String() + c.serviceHost = json.Get("serviceHost").String() + c.servicePort = json.Get("servicePort").Int() + c.timeout = uint32(json.Get("timeout").Int()) + c.model = json.Get("model").String() + if c.timeout == 0 { + c.timeout = 10000 + } +} + +func (c *ProviderConfig) Validate() error { + if c.typ == "" { + return errors.New("ocr service provider type is required") + } + if c.serviceName == "" { + return errors.New("ocr service name is required") + } + if c.typ == "" { + return errors.New("ocr service type is required") + } + if c.initializer == nil { + return errors.New("unknown ocr service provider type: " + c.typ) + } + if err := c.initializer.ValidateConfig(); err != nil { + return err + } + return nil +} + +func (c *ProviderConfig) GetProviderType() string { + return c.typ +} + +func CreateProvider(pc ProviderConfig) (Provider, error) { + initializer, has := providerInitializers[pc.typ] + if !has { + return nil, errors.New("unknown provider type: " + pc.typ) + } + return initializer.CreateProvider(pc) +} + +type CallArgs struct { + Method string + Url string + Headers [][2]string + Body []byte + TimeoutMillisecond uint32 +} + +type Provider interface { + GetProviderType() string + CallArgs(imageUrl string) CallArgs + DoOCR( + imageUrl string, + callback func(imageContent string, err error)) error +}