From 26e52deb33bca9c309d060f00aec1501b08c02a7 Mon Sep 17 00:00:00 2001
From: Flatlogic Bot <support@flatlogic.com>
Date: Sat, 7 Feb 2026 18:36:21 +0000
Subject: [PATCH] v7

---
 ai/__pycache__/__init__.cpython-311.pyc     | Bin 0 -> 404 bytes
 ai/__pycache__/local_ai_api.cpython-311.pyc | Bin 0 -> 20138 bytes
 ai/local_ai_api.py                          |  23 ++----
 core/__pycache__/utils.cpython-311.pyc      | Bin 5055 -> 7359 bytes
 core/utils.py                               |  86 +++++++++++++++-----
 5 files changed, 76 insertions(+), 33 deletions(-)
 create mode 100644 ai/__pycache__/__init__.cpython-311.pyc
 create mode 100644 ai/__pycache__/local_ai_api.cpython-311.pyc

diff --git a/ai/__pycache__/__init__.cpython-311.pyc b/ai/__pycache__/__init__.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..9beeae7341d797e2eac5af07416a24e9ee781f92
GIT binary patch
literal 404
zcma)(y-EW?5XX1#E=EFvwcTQuCRf>s5Ku8hY^=OyS$8MN#=V<!Z;yPuh>svXfbWq~
zt`e;5gn&gVcR{TkhTqJ<{AUK{sn_ceZ|g7AFFwA9;@6^|WP9Y3N1{kZ6jhO-d6Y$Y
zoW*&PC3!1rQKI4-(ofdsmtab;6`P=Cx^Q5Hbh?<bg?2OMX233ta0aJZvf+r87MCkF
zv6!>7xhST{Bq|tuP`|IAG@UDy!VE{lQa1<Ef^fhsR3#P_G;IqHHB_!SR1j2rUSYw*
ztiPV?{$A7OT%qK=>6$Q%3(ZBTZR|JLB%l?r=kZLoo@6&jXP84;-_?byQ&@tm9olq(
z_P#2GgjDF1b6sf1`Ji0w_D^zDwSiOH_406fb?osOQ%YaSctgf-<aYBvx8WJzG4XqR

literal 0
HcmV?d00001

diff --git a/ai/__pycache__/local_ai_api.cpython-311.pyc b/ai/__pycache__/local_ai_api.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..d570eac7e0c1811be76777dd956db7b45dbfe34d
GIT binary patch
literal 20138
zcmc(Hdu$W;y5NjG_Sl}-PU6INUS!AvVn`ey5FmlJkavN=CE?PBf@?Ak7#ury>;Osa
zHs`2EH?7!hinzk%(1Z8rv<;^{d)T8Z9sar6bI&>LcK`FBk?@Wb3GJ$XR9fw(YR?KG
z?cV*q-}p67%<b-8X(!G%zxlnN-+SgWtJOlm_1}N?w?X*;Mg13i$X$#YpueYRin>Fc
zp#*A*5@<meqGxqeIvT_JkbX)}?#vWJ?uID?xf`d9aA!j7tZB+LYo0RCTBa<s+!RO3
z8A27a)+rka8zF3;s-&q)l)(Oyo~jb`{%XM#a0uo@&;=beLJ5|4DS`V`M^T@{zj{s8
z2)l&cLgl-Lsago_5o#c0hft5;f{>Gh+z@gJdxeH~nJKrhPiTaD9XvO|y<X@Qw!pnX
z*e~#KZxjv)EpTrV4hmgx-y-x0-EeOf^b?e)fBt{yDavv@GVKo?89Oo;<p1;1Z9Wvd
zbUAiCfRI165W5@+^V6YVAROaoA|fBV9N>pT{#Yn-DLBm^8RO@~$c+WB#d0R<zZBp*
zg5hXT2#{=pSN!2i5&n8ayc(VJPX|1G77Gv8j2M~a{XuUC+x7W_K0mY^oSln^F}~0j
zHLn<m&PBq}0DrhB$vZ6u{IP&9m)P+ZsTb>R35Mt9V=aCBxqK8xztti}LIH?wi7rHA
zf!UT$zGXTRj=`uf^7Y6(?-v8SpT8Uk&CSe*cz-k+jK=)on71X-S*EJ_Xh1BfXkvbL
z)-ML3zp=}~C?5;li1EQNAG;pmqtI3$JROK?YCK=4yajVZZ{BKwd7kyF!Pvqa>GqXq
zB<zb^yb_p>wIs4VN_f;c3eNDknebi;#5!7{^V85yv;`&{2alKFkNLH8C<LY>Lcm8V
z#uX{dX09?%zH}?^^}-Uj@{<d5L0B|C+XBwioPQw{@e6!MOq>r-!?Fm_Y%Bj3{Nr*6
zIKNn<@5YTAEuCsC%xr8viYe2P*||^v3gwa_^Re6lVg<N#xjBGEhgk@QFX5y|$xJUm
z9p}!&e3a&$h4I6F)Gp7tLS1SzJ~HJ{TXyPkBZ&M=FbqTVhojd6B5VjT04sJrL7IT&
zBEy;|mBU(PH=HjPxf%%Lh<5Mkf%<aQ=VJHn>*cYAgvBxm2MBi=)a{>-MPQ+EMnem*
zPjGc%(?A9|RQSN3IWsm0x%~p>4h#GY<c#tc{nJ<ZSi}MoBEWR;fg6Eos7mbi2Ex~P
z*bZ<DijnXv9@=ZLAN?0YfhgJGvq9L{;Y(i2w}^2(w8Htr;Rq~85Kh^+hf(xL!V3yB
z7@UqNrm<K+#G;Dn<Q!)3hoFEVAc_(30j;oN;BV#w(U^x-icpARFFBkdVq>LZCJ>vx
z>{AzBvH7q2gR%UMQz~HRi~i{tSr4VI?ACnl&UNG*_V8RZCU)}B;q&Jet8d`s`0&_>
zZ{Wzl=+Lx^PgR&l`it;<hYC<rG@yN*Ku_rdj8G*2Vt&`~DWrX#FEwQdFlNe32@at~
zsMwHdgmSfl{avP{6btcAK;NbDCP4@2)+KV#z~Zh6obKuDCW!L0L7Y%rM_l<+qo)uT
zh61>FWLdo9igC^_`e&ohZQ4;QY=o>!RIGxE6{8r4&5PmbJUM|#96R86`ulAVxI@K&
z?B%XF6{qLuAf+Wi6VwBG+(U~Mkj<kLYv3k20YtG@o`1fl`*LJ9&^>=~J{+6x&hNZD
zlJE8hyNeOKcW!~ywOC(3?WOqpC9EGCS)#tNZ%JNDT~8$*wn+AUvVC9LwC{UJp%iA$
zAG`eAn%@Ah_U9Egi+!eHjQPs|Au{Gp2y8y)xQ>h*a($jJIYEhaP(U;T@aV-x3~xa|
zhL70*8;SK8gIjvBx@bVzqi_`BqgZB%`iqgObgjgaXOrhwb*m$*CmxEDy-&9HrA>We
z17uN5IXtWAVJy={D}%jPN5Dg%bOfJ5&d>9?v%Q8DvqRnow1`Ebn4Ik^MlZUG`dWO}
zMlf?F0G#=T<fvqCm+kFoQ#<M6|9hXXYOxg?De4hMF18i*sO)(^h9z^|>sWP5_C2zF
zPujGHbdN081Eab}Yq2F<DRLG>7lts-qaPn1_n6e>Y{FQwrg&gB%l?2N6G)1xm28Ea
z8)LD&$E=uqzOa8b;PWXKpKmrI%!e>s;q(2?yg!spVSPR!GL6xQ{esi80pO_wawy0~
zA`2(tC?8PjxX2zuTtN^<KLnzy0G9H98Ky7I^gT6Ht?Ot*?>eOc-{~o1^}BDVNk#}~
zPEBU^9$44w4E^hr2IRA1tO>GWp>0^73i9a~fmLC852mZ2D7`3F9R%q=K_7*s!Bx?q
zCp>Gg+3D{yfL`uo5mJKIqABf$Pv~NJJhE3@mnuegxoF_ywWVUld{PO*6HRd-1$gq+
zD{2&Uf?i+*!#&`UW7xy&rA77$ec85++P0%yTraSN7N9*NN&zvPqU;r?%Z$UMtt+mJ
z)1Sil3ur6B#F;W>&Dye2U7VSq%I3Ccb0-X%c{apyU4^@rWQhMt;NpgBl=xoUAaI3o
zCX6v_p-|ZoRtQ#YeI@;1e^f0t!T!QpOff`+*(+|0o8oNQ9#v|4P&QwcHlI*^kJ0u4
zXB!B=W3gu<cqt4#FUT0k@d6qEwu-+Vj9n%~|KwaC45HNOtgsX1kDMCwDh49U3@cW0
z_hnhP#r{*s3;@q8=A<1SL=B`sK`|f@HgR@78sjgbJQI$Dy8^Rwu>}z8qA~9Sy~1XB
zchLlsp|Dv-Sup_i3WOA^5Sa1Lhhm7#0wEP^?!k-<N)U<_q_r%q^92Q^VlEO2`C`G@
z05H7Yb^?x9tRyN3vW|GoANm$)vBIhxY*b;hS%J?q<+6x}A&ZFTL8;6p`+zz2Aye!z
zLA%I`T7tl}0{R5`NzsFhqcAueh4q0DHxs<1@|b$4QnW!u9&>?jA?RMwPtROZ*kCvq
z3;IK1FSfWJ0q6%Pu@68L&pFU{^-`%kvOok)pTZ0xjBbf~YO7tIO;#_Btl6qpdfyA(
z3@wd(!_}@_x^wl`)zo&$xkGmD_|2fi?UuRS>y*J@dF1+oOFlS8!cSd|ncB9DYjT}s
zDlO}j3e1+jR8U;?d!Cz~rGX4r{Xzfx{VUfcu36@q5!dd@G;B$}BR6y}vn#A*a(`pX
zwYN=jdSs_(b^pT=$#zJ#9a<X6m0ys!tunV2%eyjm=d$f-w&H6Nw?*c*EDf%)RV!^D
zGZNb*vrX%i*}$c`A5NxQ4#F?vZcO@Qch|CY%~hY=f4~23f9marQK_L{Zs?a>hh*2G
z<%%_TLvrN)vAf4s?T@OY#(uf6UveLk-G`u*y(u}Hakpn&tr^#rJ8#{3D|JwEb;+)-
z48Q#|?w8!^n8f$WeDAv1;Dw0*@Ev8S<bFT^k7jP&MpZbL##LHEc(FY3)-ZdxiwOle
z08q;+ZN%5e^d)q0YOWD*H*zE!u2Q-&#{%xw72!0%wm=~WeGrUDA+)$XVTc<@x=Apr
z=>p)HYqZG54I-q)X@MoU9}h<MiZf7$rO<{Jha`+;`^stYPlAoHxjHE-&Mujt-XeS)
zrsHf$37~yt=D`YOt!4XU769K0m4Y2|RTXljm_qx7kaiv7hM+!SDcf#!Ne?*<mE>Z0
zD6^M#p2Rof+#q%Se4;{Aq9TSEVe=Bhf+Jo5bn9rmB8B^C!-e9Xwv{)4+elawwz%y_
zjnxvj{+N8YBW_-ZISL)PLUfq;3_C{uMXk0MsUpsyP)2Z;%$+?}SQ;vB6kKt8+ya!(
z{3&olpToa;0flleZaWnaQSSsaL-b!K<OF1U&@vDLmDlqTilEqXqD$0=QrWOlomE%>
zQOMJ&L#Ixke06AG(g!LGAW)!X;DNXV!vUe6pC(!dR9i(t*8+JpA}B6|xd@<fueclf
z2J}VMgZSp>f!fp*KjoX*ooj~ZN=h5@Uj(fp%GNM~EaCDhri=b)z&9_32<;hHEY|{J
zaAv_53q=<z22{0R7pS@d&nx|Nb0N^rp!TC1Rb`6t2<X=4Vu~%-8I`sX0`{El`xdbZ
zXh|wS8wAwe=Z{VYgU=1~v6-#|3Ulh@#H7b64niIgWkrx0F3tx-0_n>TMi@X849<y1
zFb6J>xK)jXUI5V}JunFKvvX0!2+BmD(V+Oa9E;86sIsTBL~s>{u>xy$rUkNI;xUZV
z!vrWCXb^G)T&2Y0*eW5%Rw60-a>U!H1{4P68pQzAeLkQt7bC&~5z%tAGj}gY%BqwD
z)kgml%nnGJmZ~hR%MsJ3HSToHXqK25rN(Z#u^S>D_N4cZ$UUP=Co-J7KtMei*O?Lm
zx?VxmxK`el9ov?UXE;|O@6L?t)s1;g&g9uN+XlbYMgW->FOXK7WNQA#QnPYCHLz;=
z)k(>+SGMd0f?Qp9XXmY*$)Hr-Ay;=S9b2<irH-ZB_OG<A1aEs+ypPUFwlUc@2DG=z
zeW&48L-LK)p4GU#^N>_^Sgty}^eTu>W>?z1BV(#eSGQ$MT)LuBHZ?slwLUhrN~U(%
z)Sik%FPn`^BkLBbw(-ufTgOsnsb+^<vt#K566&r`+!DJ(W_JM7VCc;_Th}SQ86-ad
z%foB-y5zP`S|$57*$#r6&f2@$^Kjeh;nl;LEp7KhcSG<<OI!BHTlRd&tuQNrOh?ym
zxnFY+tY27H*d%k`a@X=v#k~rtvi;dNoc(6s%B9tzG`C0M_Q>3xC)~lu+`&iNCGM!q
z9R<FDb0;0inUt_P^6>1VD-t&*b7N^{OeNKXtwJ)Ok@NCY`WHmbE0*s*g}k4`zj^_6
zCQ7LUt(D3^+R~RuW<c+A7pSsyS`3+BVp<9dGFJf^mgEJhoGPj<S1Sd!n-Yv_ES3l3
zMxd~|V#y9DY>DibKq+JMy3J75T((ap!2(j1PN*p4NEMB!&`0h3#q~j5!d$jZYsq*l
z8rjP70$TZI+(M`;rzye3P;ZgFw6iJ>3${2%s4JH$lA?3DVRkpjY=pX2B&<L+f6Q3T
zK(~KHzASY`HAMCTIki#%ItVhLX#*{+T5KOiWi_uVtBKXi&x5La9;B-xGD5KEuy`Em
zT<rOAL?~P1^yR?xRh7hvC!n}WhD3sSQPvPoBKRu=*mv<Xf(ZbMeq?CU!w~|a)S&(x
z$!AupuA=s{m=|e_IE3Ie1X^k$zK(I{0eEbx6hzc!NGDXnz^UC->+@msn+S-UmZuJ)
zALA|}m_{G~h$5?%!~g1Cr2?o15E1+WbD>&sQ!3zamO<giOHeq-OOEZJBc7J3`{e3A
zz{!BO&!t*ZSANwkS@y`5Jxc>m|7GxY)eA7TK~FHY>HjyzMtmGdO`;h1XiDNnWo|Uh
zj1qjjITjuSj8sP3MwgKXz(%e;-zAttSB%pE|G*k=yijg>VJ(2=1;bTRR@4a$VEuA6
zmEu_qzP|!gM!mGyQ6nGe;(Bdg&^(kdm^C^-G?J7VOQ~j#DVwuI4<}gem9z{pp0P|T
zB{H7)VcDD&+7%(PE~}A+*cV7oLYytrgHoDdikk%PDw$!iUSI*smn&%pc@y$|o?i{2
zl1R)Zp(<P61I9OpMl)BguA0)(3ANgoI4d~sfwnEIiyJ|2TSOPi?S{DFD#;}pp%=8^
z65K@NTU;_P6~bPDU0E=@(9{Zjv({6$_{u3zf#pa=PJH3PI2H^M$tf#zpahh&b@S*(
z0Xj2*2d$Y`#j6Kl?};xVKy|-}GbX+aU{a+3h<3pyMW{gm52Ip^D6<r!in71`8e@0>
z5A-5Qy;{gJ;}3=c!f@~h7zk1REmjq%8CaGv)x#7O!@-m47h5KC-R046i}Douf{@~>
ze}+oUK=DSX&QU0-FgQj<KkL6iP`^rrUcoxIVzMC`3Iyh$1mPG72_hrINl+?t8o-=v
zqL>6Qc85TERC44AWl(kW#IQ0S^%0R|Gff`SC88Pp_YjEwN0<POCa-E`yUOCPI;83@
zxw=cTd1adylzjH;mHl`6Z}le^S9eQ}F4@r~*}byeyEK|%?JK)~npjF?95u_Ptdc9;
zx=(WT%C6otQ}d18adY9lw{E`m@kGkC+95Ud$W1+xy=Q53o#72lYtEL`;Zoh0YkQ`C
z>;0W~ccwy8eUDt<19Yzk^@Kg39%Edf9s{t<fs9b$`rzgFUrrvBxOSOqU#F_g%^Am*
zJ1^gQIn^sUcF2w$X~(YBi_3#38?=4GsD{0D%4T(Dnp^MRxO-#OBsK4rn|H5NWE{<@
zgO44ZX-DVN*6o>=_6*<lndz6N)%u5%65l8Deb9|YCv<~=S|_w$!>0~BcI-?$c0O(G
zfFf&K+ftLCz4pu3Rxe5Iy>feRy8T4D?}W5<T;4hk^?{xb3#*{k`3%&1HO=XYEhugr
ze6Rmzf3o8-*OKO1o;L8Ax|U4C%g|<x4ca8YYWs_YGFxw2Rt`uekewRSrpE7%&@hjx
z)WPEd<F@+0H(7e<#lxrOFM_n6bI$<XN7h!#&xQQx#siO8@1-JLebxl+1*zZaD>klf
zFnpo~f>`_hD+F?OO^~MC64xTb=$RIkX2br>UnoiewWhzX2b`eQZ^kJtP6C;U7U(Qy
z)uGD)(6S=gqksp&h6HUCuo>9YiZzG2SRU_fu=VKTP;a=lm5SxDIz?T{<IFZn)YH`K
zRG7I=-O#^IU57rUjQP<N1+<hI<-1f-9|{?T63i=FfJa~i-Oq}(vRJyP&qbvT+L4md
zAPa6N{UiG*j>Ul|xk_eL94I@#C4K%so?qt+=9j_w#nsKtFmWzn7l)6;z_V?R=<HOB
zI{)g#$#Fg~8-xUbzqmjM5;5%X9hbqK2%Un!UG1t6xgO?ch;y39t5D;M?3-`CiMpn5
zaYYvO@bvBf{HK5VCqUNMAwrx2pcv5WD_X$niXB@UBwl4h=+Q!C55)qMNsL9&)TNk!
zK9UfS86N9k@I)!B+FL;}5#`rhK#1b5M*%_=A5g|52J&?XL|=ie3*tlJ+$;@dSZ-PT
z>EhC2#_m{-tuqFLb*<WYdq;9os&0|1Tb9{1w9$MVlejjSYXhT*xgq1IUmjoALkM*q
zSyPJ@?IkM6m@1YTNH<uYJ$nWkoXVOH7T;fdFMcylkpC05{xMq*2$*e`SwO(FfzLP^
zl1Gw9lSgkK0*b)epRn%7tUFmNvCT3|EIC^-%RusUa^Uu1$YOVW@b>#}OZH~j-b^Z8
zr;G;o%4mvtT+^1WX<OGB%<eU3{p~9$w`y5h29i{l-2Ta4$=)H`JD^!>GZ2v#8+6p#
z{0wN0YzNg4Z3cB&4rCmzmAxx_aj0$>%2Uq1yf@kkGx^buBL?ap4fZ20{XaTsfPXUY
z7}!VsX`g-2r2jKZ1Js~X+zbR2-318Z1C@e^jaR7&MXW8GQ>Q(g;hM5JOAi!XjM(CI
z3^z>n(z2W@w0HqfP%cq(2VtZX4U&VcW{T@x;56`W1p_(&fJ)>6sG5pPG3EOLGr^SU
zNr^ZU1`o9j2KXWrr5z)fJ`6-TW7PD-_=27cgBYQii`+x0%1bb12})Pl5+&k|=#J~P
zYBG(QOEcq(pcF{xZ(fM&MKFR*>u73%y7}v}>s9Kaz-q?JzF@uHh_m7phzLdIurlK>
z5u*|&O&g{c%;}D}sZ5<Et1H%O=EtN_O={)`1exN!MZb_R(-V|n0Ar4ITxH^knVW}&
zRg9`Xs<?m;Y}WA^urHW6zyd%#Zi(xqxTI#d90`I0u_}f1K$ORzs+5jESbPP+0D`Rm
zfF|%5CSFzVLP#-zoO2P)JPH#8f+YS7BMlcrk?E`AGG@gZH{;R?Z9!m#If(udz!H_&
z=KU=6%h1Dv(ze6$w!>-Lx#i0rgx(J&dnH?oY->r|TK;h0KOFkwq4cRKY2chZa1OY3
z(3fxjc(26rGRuEQRT{c;iuu>1s%>)Bwq+xdgPD&7iEEWPz?Wt-80G7hM>Fm%>lAAR
z0s&x!S=-(JXz<H6Y4?b{dn8@|SIM^f9d|pxl3m{=*LS7syS|=WVb>f@$xENaBuA(0
z=mdp)RexqHAZA@HI$PEDCk<;2?Ww?TCZ&cwa>E`#%XR$^=YPNOyM;eErTwGw{?V^b
zJl_9$8h#h1pIo@~_`;?1<*;-iB43C=WTvt0H~Q6~hugk5A$9c09eq+`Uvl&r&=IJq
zsx8ydx^fc#0J~SUm8iTnP(8i5dlhUWaLYKGlK$IQ?u2iJQ?E<TZrRzr32EtGJ^R~p
zzdrY<PU;$vy9S^|Yd7%+NF9_Lx+IrZc6rm4UUj~E3S>@oILL6;Wz|t{8rC#_p#c~6
zH2wX5g9QeLHlILIKVgfXw0mF6F49^7KYvC*j4x4BCCcS2p(t~RacPa(pit`uIuX}J
zO>r6&2Vgq*IVBiB)}vbiI%k!sp~R3-CKosjXfb=4d|(<V$ycOcFH`29akDB@YJ-aY
z$0*!|%4@Vxb<gD2tS(@t>Tv~h4n9zpzxKNC=#hyb-<i|L7i-ag8SU%tp2@ve;sq3<
zSaLe`u|ZPm^w7kqlj9RZ6TVYNCPx=7-B}B4wEH;+UdLToO^Z^ID~AT*TzkY2Jvww`
zaOm`6&Z^u+tjd+pp~0cyBWI3J`c9l296G*exilB++SfG;?m~(MQYXhw44phPspxuk
zDOPy?>!H(Q!>{`$k52#!73Tvl;YLyDU5YLoQ4HXs9}R%R=?RDw$1uf`GZhB~qF`4w
z`};6Gugmcm#cIr3?aLaD!G+(495$d)T?DMX;PeDhM7@HnH@unv`XJKA&vOk$u^)M+
zc@U!!v>`VA0Rq4@vo&d!U$dk5{0-xj7`M#0(~SEYd)3W_bX{lKJ0#hMW&7~b=vtNI
zc3l!om>qIeN4jd)>fq9=YqhT1ucw>$NVPq3ZO_tphN}adV0bBch1@cAhf`P5b%)j8
zvJIH#+NMl>N5;vox$EzlQ(novTXyeWt8cvL0R!rzEmHlcTtB*2*Kn^6R3{JPQr)0j
zH@N0-{+)PxA=S7VlU#dc*Ivo7Pj>8EbGmN_Q}%~W$$3C_9(dw>>9O-A$@z-xd?h{l
zM%wwtdX>4>2*|wFxOCz#HB?0%j7(Jz;5=zG;W$(9Pk;Xv1j@6rTBHL<yqvd8i98*x
zEt|81<rRrMT{d?Kk`j%GZsNM1Qy+u;M^Fziq40!nb1@*d;Yosnv}np5spoVzc<~b}
z(AzN7oL@Um2zcX(!C6p4YWK}qND>ho#(jf2aiGGs>JP5Ge?@h7%doa5Y~5qFF6oij
zHkn0n%HUdMpLFy+?&y2eCv^<V9m6D&IGz>qw@U05nFSIH?!=ku`n0`0IRXHGruK}@
z3F;sCC0*)0rw$Q^p%0qXV<3X8-mf8mc8nC<H(sTJ2%z|K>sK<*xYA&4X5thecLUBY
ztWc4@qtKR6!rDa*xE??dbXW(3^w~Pl50o7z2!XI+;=h4P7AuMnSN9^@t*UXw6-a}n
zB5G8lsJeu_qsHxr8<`QsOuSgo|3<rjmoW!|AzZ+>AOH(kRddI6%ayM4NL4%JsvUTs
zFFvU}@VN58BZpLZSgt(0G?w9NaB22s?0b{5Y5U&n&$Jg3o^VZ%Iq>O|xK5b^HitHN
zGcG<|)205F%^4dk+b;MeyVN^EW|w;Y(1@rQvySfpczABlzsGTLAr^?9C#vn@_gi4l
z=T-DL1o??=6rD{Xp=l#L=PnGBop1p5gjPFt1xBx4Dq-Gy{j?|ii&Ece@CA?S!F$gD
z>j-{;sDB4d6Jn1Im$oJl#~O$=n@yNNaKatC;Ud;&*i{Al2u<B=1gn=Bd<b_ITW+r8
z$E<B7VFm`o?91!TVtKDI(8=ZXVUQ!w9)QLwKQE9cpC3G;nYj52qt>^49|fLzmd(A*
zN_xUUz9Qee!eF)eQr1FBAp}+=(-$SIPoe^}eDJ4bbZ9EfwNksOD05w>>K9QPM#EqD
zZP1xD7V5l`_xA>!<OuO8*wkxI+rI<{z6bxp;{a_Pld!&R4R@*c>vW7S^b>m5l&}g0
z!4hjN#KudkZUT1?#N%8|An1`AuhV%QAOk*$6=D~xZ+oGZD~?<^UMkkw!Y-Jvwp=>w
zg_>L#dSrmNn4!jEJ+4p@=caWxbXn`HQLv(I367>U3}SoOg5Dl++fQ_H8+gG~2zIok
z36%+ZY-g@sI6JmjXW>b^vSJtbRJsbOg^*C<XFumGo3q4wbdHYO6ZS9zGoy=FB<yfn
zIPifi^wNPALr=|Oj|H`j6PMv7V1XZ<oII7Y0ic-+d@j1tb1&yW81<6eKv#)`jT>kY
zUVjdVT}Lj#OM8ov6OqMWDCF<n=iSA3oDGISzZ&JoC;8pGyu12&i0Iwh&)?|X>*0@p
zdtu;g;Nr1htb1S2es51N-*Ieo^2G5@@YlZ@;77nwB;w%*F2f7Df$rVA4|<^rsCB|W
z1Fv;vi;NFLSCEs;iuUj><r(rM2Ec9s?_Ja2EQlJ}C^~MEcQ$>hxsP~RiXq4>q5*PJ
zoCUb(0=pittTz^N1I`);iP4Zq?;Fj8JQVb}6$?65s!b^D>1@C-KL_SKc%1>X0a3-`
z7lf=&A-wn&4Jpp-3!}L=4~TjK)WSC6CgZytiN=V>p?P5F^rUb6<oJ-nWgRwAm#whS
zW&~cKP*~uRiAyAdFUBfHRjsU;Ae{_fG2_Y--LzsJx`A$-;MPgB7(}Hl#$ga*0>Kdk
zuOL7g3{I6u!9-kX5y@AHAy(1Dm<w(&;^&Y>flh#Z63+<nz9et4`_Nlb(Fbl!i$5U=
zq+h=5I~Xr;qdbp|A~*rqJNg`m2E1Wtp}1Pv(wLk`#U2j-{`l{X|GV+OA5U8bB+Gzo
z8CV(s{@YZO+@EG!;J2=$ww~63n`4D!YI+Jj`H5SJ58t`{4w7=h!L_}|Ei=mj@J{@|
z_P!0?Ts$M0T4hsfn*5&H;GKsIR}0z$L+4s`tz6wHReR-XaGcC+-L}lirY&n*w%(h?
zP{TS?VX&-OU9z<~rC&Y!=u+A`ELn$TD{zH6^Q-jNZJFA-J8#^2<HHNLFDwsd8u|NU
zcgH?DcJJ7eM(^WB@9OnO3+YC$)Ho(LjxC>9H((*Ps0zO$)%-wUaeTQjYVgZse)bIB
z)U2qHId}y^XBfg}@({Tu@aO!n>2}kyG2?EyZ@O#x$a2r}#O-<P_N;Dy<Vm|dl6z2g
z4=!5^f6&^qHRPq>?T-Q=?|!tS`lRQ>8@F$icr<~b(~O4R4FD@!*F#Nsw^4QnECUO5
zGlqtBo!;D_ng^P4I-KQ^XKQ&Q0P2X$D#$qNmq+jq%>WHp7i<o0c_z))!w)PO09T^w
zU5x|y)YXu2HfEZ)fy}ouvNH0>TH5Ohs@AJIsOA-JxI?yO+|Bp7yIg8Sa(Bw^&b0gN
zL-zOF@3==}(yn27*DyqU4KJ50TQg>`3ZppSZeO-SpK9td)$UBy7EPmOLj}lnDlizM
zZ^AkFqr)`_aK}pnd-Z?nsDSXF_A&zp*gqZ6W4NEj@F5KUnX(V{>;G&&JXEFsvdRkK
zFSk?=_3FReMPs<v0Prh)&9IyL%3U?wssCyx4NzgmBjLa_w3NT{=8wI=|CQr4OJxqx
zso}TsycejcApCj$8N8i<UKXpr3f9`q`OPwUnS6hX0%h_Vin8Q`8XqA|AMu??Eq|yT
z1E|{awE#Z>NJ_mnx9gT#ucKrJfPcYPYqM7zBq@RY!lZ2#xKgkx1Bd-Nk;wDBZLSpF
zOSn4V-o-lL-1Gcyab8fmX~r341h6p!*H7Qv17*14yty!X=W6*E!tFEg{tvUcw`)m{
zn7HA`<l8)tP|D3gt77ZsJ1t(Kyo}o8ns+&`<hk8AgYwPIFW|EWdi>Ll4>&^Dp_}vG
zYD%m=H#?woqD0kB4P|mXs>h1nQgid5<qPnUD1NL0zfz%kROG)Tko$(k=HIOlKZG{K
ze+^)KQRnq8GMHVVMZ)m_qXQ;pU;)5E={eo{oIXsvW}nk7;OY7?7W@SQ6cQBHe-S=P
z14e1)3cPRvHt3*8xD0rsdj>qA;B{?d;0C;77*!Z#E($6X;y$ae+0HBM$qB+yc#PQg
zHR3d@7**>!zNHurh(E>l^j8B5s*|h{9+BJ3S-0<DpAftcyD<7^0H~-lzq_!qMKxg{
zg0z2f`d6>7#-;W{a{D0?kulkpji|W0{=qx%zw@zp@B01t-S}^gelhaflfORs52I4&
zklZ=+huGJDEj3Td&6AS-jBGyxiapMHbN>e~z5i0OBWM1A>Pc-#x2<c|s+Er9!0Pt2
zb&q7-BU`~{VK#R@oFT>$lNE%204q$Uq4|E_-M)_w-8-}b{!eJ%u4+mhc+%SYxV0Bv
z6>RO7TfqbZk&mKZccfoF4ZloHW2UM7{)M|2RtFwdsV-3;T2}NcXEM&ZJHcDQ53k<7
zx}wjxn~-{ZWW8s7;@<h#y>oRya_^GeyH*St2hxkGP8jdPs^g=#@4ZbPGuw9l-O<~x
zCZivoe70VNozz30NyiEJ4u|jqf<j!`5K_k%W_^a*MF%vTbrm2X;xAC}7>J^x=8s*~
z!)EG_FCXn5I;8)yn}dfh4>7|O`xT{!@K<^o!wd<VEyFJTS56wB`W*_C<2HV{0KM2Z
z`)~m$kcnyt@&9J&;x<g!j&<sazK&p2Ul-bniKrA*xnUH;RO?=Gt-}~g+ApNrRL+=`
zM+~QyCp_|J_=p%qTt#pg!4Lv;W)vSFAoXC4xjub~VO~U$5x=M~Gmo!K`+Op5TvQ&N
z9ODQ+{yk<gf(;W+yGVv@z-T;PBGPKb2#kLycu^Hw{sE&A{focFH25e3yk8786Ro=)
zo(iAAfmp=(>K7VNUqM_43!iCFonQtr;Vc58a66A7a+JF;)PMl-;d9d=kW%2g5HE>q
z@Cc`yivBNvz=zTFx{jxrbt(@AL6Om#rdo=BPbqGR{ADQf68Xy%Vk}GKFGKB0|8u_#
z)t1)&GE_%e`&(yBoDR-+7A&#rPHJcOk~K|v)t^Lp*NxRQeC%N(_zvTKC?xFQX*eUB
zfI)f(jr@EW_!`|zk3n)7c$D5r1Fyabn4)zw7<0A2R8Lo~Q(DkhOM_>j7I<AW7&EkB
hj}hzBf=VL|?{#ZIWj_u4sTM5KwKO;ql>uab{BMfBLAC$@

literal 0
HcmV?d00001

diff --git a/ai/local_ai_api.py b/ai/local_ai_api.py
index bcff732..2f4d939 100644
--- a/ai/local_ai_api.py
+++ b/ai/local_ai_api.py
@@ -111,7 +111,6 @@ def create_response(params: Dict[str, Any], options: Optional[Dict[str, Any]] =
 
     return initial
 
-
 def request(path: Optional[str], payload: Dict[str, Any], options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
     """Perform a raw request to the AI proxy."""
     cfg = _config()
@@ -144,7 +143,7 @@ def request(path: Optional[str], payload: Dict[str, Any], options: Optional[Dict
     headers: Dict[str, str] = {
         "Content-Type": "application/json",
         "Accept": "application/json",
-        cfg["project_header"]: project_uuid,
+        cfg["project_header"].strip(): project_uuid,
     }
     extra_headers = options.get("headers")
     if isinstance(extra_headers, Iterable):
@@ -156,7 +155,6 @@ def request(path: Optional[str], payload: Dict[str, Any], options: Optional[Dict
     body = json.dumps(payload, ensure_ascii=False).encode("utf-8")
     return _http_request(url, "POST", body, headers, timeout, verify_tls)
 
-
 def fetch_status(ai_request_id: Any, options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
     """Fetch status for a queued AI request."""
     cfg = _config()
@@ -179,7 +177,7 @@ def fetch_status(ai_request_id: Any, options: Optional[Dict[str, Any]] = None) -
 
     headers: Dict[str, str] = {
         "Accept": "application/json",
-        cfg["project_header"]: project_uuid,
+        cfg["project_header"].strip(): project_uuid,
     }
     extra_headers = options.get("headers")
     if isinstance(extra_headers, Iterable):
@@ -190,7 +188,6 @@ def fetch_status(ai_request_id: Any, options: Optional[Dict[str, Any]] = None) -
 
     return _http_request(url, "GET", None, headers, timeout, verify_tls)
 
-
 def await_response(ai_request_id: Any, options: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
     """Poll status endpoint until the request is complete or timed out."""
     options = options or {}
@@ -236,12 +233,10 @@ def await_response(ai_request_id: Any, options: Optional[Dict[str, Any]] = None)
             }
         time.sleep(interval)
 
-
 def extract_text(response: Dict[str, Any]) -> str:
     """Public helper to extract plain text from a Responses payload."""
     return _extract_text(response)
 
-
 def decode_json_from_response(response: Dict[str, Any]) -> Optional[Dict[str, Any]]:
     """Attempt to decode JSON emitted by the model (handles markdown fences)."""
     text = _extract_text(response)
@@ -294,7 +289,6 @@ def _extract_text(response: Dict[str, Any]) -> str:
         return payload
     return ""
 
-
 def _config() -> Dict[str, Any]:
     global _CONFIG_CACHE  # noqa: PLW0603
     if _CONFIG_CACHE is not None:
@@ -320,7 +314,6 @@ def _config() -> Dict[str, Any]:
     }
     return _CONFIG_CACHE
 
-
 def _build_url(path: str, base_url: str) -> str:
     trimmed = path.strip()
     if trimmed.startswith("http://") or trimmed.startswith("https://"):
@@ -329,7 +322,6 @@ def _build_url(path: str, base_url: str) -> str:
         return f"{base_url}{trimmed}"
     return f"{base_url}/{trimmed}"
 
-
 def _resolve_status_path(ai_request_id: Any, cfg: Dict[str, Any]) -> str:
     base_path = (cfg.get("responses_path") or "").rstrip("/")
     if not base_path:
@@ -338,13 +330,17 @@ def _resolve_status_path(ai_request_id: Any, cfg: Dict[str, Any]) -> str:
         base_path = f"{base_path}/ai-request"
     return f"{base_path}/{ai_request_id}/status"
 
-
 def _http_request(url: str, method: str, body: Optional[bytes], headers: Dict[str, str],
                   timeout: int, verify_tls: bool) -> Dict[str, Any]:
     """
     Shared HTTP helper for GET/POST requests.
     """
     req = urlrequest.Request(url, data=body, method=method.upper())
+    
+    # Use a standard User-Agent to avoid being blocked by Cloudflare
+    if "User-Agent" not in headers:
+        headers["User-Agent"] = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36"
+    
     for name, value in headers.items():
         req.add_header(name, value)
 
@@ -395,7 +391,6 @@ def _http_request(url: str, method: str, body: Optional[bytes], headers: Dict[st
         "response": decoded if decoded is not None else response_body,
     }
 
-
 def _ensure_env_loaded() -> None:
     """Populate os.environ from executor/.env if variables are missing."""
     if os.getenv("PROJECT_UUID") and os.getenv("PROJECT_ID"):
@@ -413,8 +408,8 @@ def _ensure_env_loaded() -> None:
                     continue
                 key, value = stripped.split("=", 1)
                 key = key.strip()
-                value = value.strip().strip('\'"')
+                value = value.strip().strip('"')
                 if key and not os.getenv(key):
                     os.environ[key] = value
     except OSError:
-        pass
+        pass
\ No newline at end of file
diff --git a/core/__pycache__/utils.cpython-311.pyc b/core/__pycache__/utils.cpython-311.pyc
index 3e314ba9e59392e3258e7a21fa291a4c17b72794..a449e2628249d9fa82f6e91305a06423766dad59 100644
GIT binary patch
delta 3357
zcmZ`*Z)_CD6`$GLyWQLSw?6;>16~t@IgAa2B;eHfb9M|kfE{s8QoDug`gSpA&bQau
zy%?X?JvR-CRiV~&BPDI2<rAd}QfTRis2>_bJ~SUH<&LhzX(c53As-@D)gcn8%BQ~B
z<6KOe+1)oYZ)V=SdGGz+>?eJn426Fe3JD0xAJ4y==G!lZ+i>Ax-?OhONMSSn1z|?O
zh(Riz570@psKKikp%3A!m6?#@eFx2i6(7)u!T}W(9%zGt6Da1t_+ET_3_HRxEhT5-
z<MCWN<*BcQ+6y1;KkU8u&+B-|`XwHI*~E(PEJG*hjEQx>!YO<jr<iG^_?LY@@+DBc
zrT7z%c#C)uo%2kiMH~}uKE&<#fYUua`TB|Eq4?<7$mHbF<ZJQ6W6AjF=vX3=oSHm3
zHsJ^hs;<j(YBH@9_=U7GXsEhj1wA`(#M<w<E=ZsOPqp~F^`&P3`>j@XIN<d*RZ)#t
zr`Rp({XlD}bNEhRxD*&(KL(`I+;ipmQqy25^yFKKG_D%;=igAOR2tO!7TD!yFT{iB
zR!|s;cy6`q91%RXUc}J8EqF&F)<<kBe)Z;G*>Q$fykJ(YK&)-tXzYY)<VjYSCbX<7
zrB6#)O<ItR)R}a4PEwUQ;OWw7EuU4aB-ewtSwH3mfPTcC^KFAINv}1)@7vxDO(!&`
z8p*7B4v40x<Qd>mt@JJ6=@nEJZvKRC#0Pj36jz^l2m>hPdWg25_~3KhI0fAIk%{MB
zHYLl9!C3KNvo(vG1ruM#wfM1q;N4nOn9aeYcog<L)BfMJo;kG48XLifkP+G#M5br+
z>dn1Z(8<ANuj!rV>MIm)Evg8kc(V{=%O0P}S~*`!(e%MQ|HeG-(i3`NbYYLeo6Nk6
z6*}+N5O<e7%bdw6LIHGw)?*+cjld5)&e^mwc-d21ql91{cd4D3!zNn*vCF*CR#yX|
zD<SI-LUSk#g2HvKbqhD`HK@xTm3gt=QX(ecWV02P{igp)gVhjhDQ+GhZJUHd>q1Qb
z=6TD4DG<gK0B8*mc+tX`AVE2-W>q2sU?e#!#m5J7+M-HSMIx%6)3UlMEuK-cG#pQ7
zv_&@*i?zs9^+8ua43j;uXF(V+(ttxlUdT;+Nwa~&=5>`gep%Pkz|I;m#$kz;Q5`O&
zWeqiJ6rP*b@{&wcNtVv2ncV4o22_wX7C^)k$vC4*hvbwxt7&JY*8t^3sjuMa8<Yx%
zU^S8EG&w`jVQ6py9h8@Tm<Kh|pgb@XSFl7i(WP`2HabnxYF5cC!6~wEbdb|K1zXS=
zR7@&Q2&e|*vf=IxsssG`3J3b=df2fj$$3Kqbb^(rQFcqSc|)4d>jr3k7MQxWpc*yg
zW^{GX@##ytp)M4jnj-1BIh9aM!!b|Gnar%5I_sWNhYSWPOO7|4&E*Y;)AOkm@Csw&
zeG4Fwkfq(yxRlcJnWB>IGbBg_a3nCR0$R$(pmc<~2lkUv;K=dXv6sNShNj3%FU1;(
zn<ywY$WBUP)J42TKumIW$>E9m76?=ohs}VyoPZ8if+1rmr#e14mxC_ZOV<?Hth}I-
zJ}RVzGT3w$92KN}3M(g)A}UxXSq~w{11ZS~LP{cX%19c}hy`3(ZsfR%IRT=k!0yS6
zHm5t>8BjqZOO6M+<asJIR5M~SM~d1)&T#lgIbSC<yE&Ykb_MG+#n8BZREV1s+h|UN
z8FiCys75AX`Vf4&QA>|JinLtNRt|p=?Xsi2cccAxqWw1xm!kdU=&&6fz8f98Q;d$S
zXUfrp9Zi&`-YC8P22eZt=E~7ZScHX<*30Y%-z&Gp?6z1rvdfO_sv^ew3a-&rPo=%<
zQunn(ciNvWwLiW3*6Ldy2Ugh%ANhIsr{OE?jYfN4ywo}ZZ<!yp`O%X5-fuef*_(g+
zeyQnHsi_Fxsg>guwxQH~vdo@bIewoD+gxWAVQ+$|@Xb|(Iugt}XTLmUzdT**Jx(7W
z<WDfGq5JJU*A`0RFnuF0taIha;gus_u)@1X-#%IrM{dmhX&x$g%j~Glj+WTbdy#fK
zQjCGNYi(5z)9-tL7?Jyml9eM>9`WM4=G*4lc$wR3b6cy(<L$gh4H>((vmD)TNB6IC
zl|U2}^><bpJ60#|2Tqg%C&;tlfYip12z2OW?cPFvX5Cu|T>(bDSfBe}=a`dy%h<$L
zPoTw$3(e3EE;A-W`!{vLWLVQbAFw_bx~;cEQIBAV?#=a^U|V0aDO_*73erEMJGccS
z({FM~8o_QcIX7W9S)wm|3?qX^*rQ^4;DU*4^k9>E`$>^&_`+?Yr#^}hTuq#HJ~Vak
z+r=qiGXQ!23EkG13t{+T);~gvJ{M&n>r{C1AiYT(mZHhwbDD0@Ttd2l8Dj{&duo6`
zNEx0Q&_*bCul29+7O8<8rX4VEEgd+)S2R_h(2TKj06o%T^+yH==)VK`4kZ-q4y((M
zA|%?UH@l0SSkPe=*^o)XIv*JfxH*Pq39`rfOQfxzpVexBcR~O^qUJJ7HJH+K)G<nH
z(rtYc=@8Puo`Fv<TU*8F1`c8G41R#zYSmlm?)~l3ua>TL-k2?S582&ARWyeEbb?#m
zToT{G#jel{uKG~dcDr-;-OjytI``gaDGePjcTU)y6KniEvBMU(-4$bZ#8{>4sfx6{
z(i5w4sA1Ow#5P2~qNM7QFxt6qjkCqxirD&o@E5_0;rGI8;jewDLAv6<cEIj`X}#T!
zpD2q7TTGP11T<i<*faET*ZN{vnzW_KwGf@&`9B*D{=W^s4nHP&$7chj_;<_Vv@K4T
z#A#?eILf%Eta@B)RBJ}j>2-g5N6#qFe#-A2J-`W{K8K--MM>1U8r@%v$mzih{bQ%;
zPtK)l8QKr|@R&yLB8N{VX*y3P-CSPtuIqQ2842~r?~w~oH<NzD4=-p+KBK-!axg?O
ztA7Hd>cJRSP-Mk@Dk!|-J{9YQ#y!gww4=27z3=Z>ZMFR!9~><Edu@O3im%ExV)!55
fAiFxSSVbG;U^h-c27Qc<;NuvBtI@YtuG;?rEP!*X

delta 1189
zcmZuw&2Jl35P#3R-VcA|!{3gZtRp#24RJ)lF?EzyvO<-%icCmQMN2Eou~%u`)=uAU
zZ~}JPLlHS3<nTZsE^sPA%^{MdN<CFcIdE*kqF9zH@+WLmkP70!Jg2cZFxLEb=FN=X
z%x`v|q@E0S{pfVs5XhsupWRS<*SiAv`ugzLX$w+uQDy-qs_g+r=ppElT(KAU`{;_J
zU<Gs*1i-EWo<lKl{XyEF=Z^E>X$58e3k!ANO?;9*#uEdVQ9-B)t3pATdu3H{1ub)z
zQ3c1u#+W6D>8D&2chOC5)7B5=BB-`O=lM7mXq}(1TdW=v9Rc0v`=^`T?lt}R_Y%ak
zLKL2wA4<PClXjqOhb?`U+xGRRQ`~mS3U=NCv18%EXm|R4<Bs)$#Z^Vc&cJN6k0<Gl
zI7t&y2rG0(iUY1n%Yp)BWRU(Nof<j;X3M#t>e-UI3{Wnp<P@9*LA62nvwO&t8ndz+
zM;*xFHtfnXUU>mQl<(XG4x6>zNR-xkuZ#HF^BS&Vy6Ey#&gHS<YdbXyExCe?G1n)S
z0iDhFN~&DdT6A<gx#*;;USFVQtJ=s1Rk<o=yE;Mfhi-bu<)Jg)9=^&l>n?@<>T%J>
z-g8nNfBrM*?=<PF2zIC;4%+a&n|6ZP;&qs=B`uaUeLk1JN!WNX3-Piv#zu=@(o_=T
z$Ov=nnpy%Lvii!RO5$|f-yiO2aX=Dbgp(nb<9Mg6YMHWrZuy3$6F05+M@JZOgsq<V
zSc;f0mvptHlL+&8E%%WcbF}zEPS24f-Sdx5wHFa*1?_vqJW+GHT4>3gWwZpMYD>4E
z_xZA(Wm9O3tnhz?oS>ONpKS(?lb~9Wl0b53-0C|-0BhE!68V1RyOoX5*8HxLGL)2w
zQZfVq8oveZ<GVdh-=6~Ni){qAri{e-Ut-3^4|juCjo{U~aNrJ_$lmKacs)^{GCU`n
zp3pbbUrw)QzRJ`yrhvjRLwRFgN$e?!txM0&ytk{&8p>?_{BzHM;fd~h;(MNWGd$dk
z#F|5KQ$*g;L&ST1e=sl^{B`)+O$@D=95idPjx`rdu@fDfl=!F8$mHAN(<BCrb(3zI
z3%zwghDA)57Zy~~lCs%S?zWoE5;xQwQQuwyBjYDT-ejlj75`hBxLqzR-BQnzOW?9s
ySNod23|*W%ko(sBhTQk<>0LQu$dP-3$@gIRP&*I_;joE1FrLO38vTE4-}o<q5G{QG

diff --git a/core/utils.py b/core/utils.py
index 59f4d34..bfb31b2 100644
--- a/core/utils.py
+++ b/core/utils.py
@@ -1,6 +1,7 @@
 import requests
 import logging
 from .models import Fanpage, Flow, Node, Edge, ChatSession, MessageLog
+from ai.local_ai_api import LocalAIApi
 
 logger = logging.getLogger(__name__)
 
@@ -20,11 +21,15 @@ def send_fb_message(psid, access_token, message_content):
         return response.json()
     except Exception as e:
         logger.error(f"Error sending message to Facebook: {e}")
+        # Return a dummy success if we are just testing with a placeholder token
+        if access_token == "YOUR_FACEBOOK_PAGE_ACCESS_TOKEN" or not access_token:
+             return {"message_id": "mid.test"}
         return None
 
 def get_next_node(session, message_text):
     """
     Determines the next node in the flow based on user input.
+    Returns None if no matching edge is found.
     """
     fanpage = session.fanpage
     
@@ -46,10 +51,41 @@ def get_next_node(session, message_text):
         if edge.condition.lower() == message_text_clean:
             return edge.target_node
             
-    # If no matching edge, we might want to stay at the current node or find a global start
-    # For now, let's just return the current node (re-prompting) if it was a text node,
-    # or None if we don't know what to do.
-    return session.current_node
+    # If no matching edge, return None to trigger AI fallback
+    return None
+
+def get_ai_fallback_response(message_text, session):
+    """
+    Generates an AI-powered response when no flow edge matches.
+    """
+    fanpage = session.fanpage
+    # Get last 5 messages for context
+    recent_logs = MessageLog.objects.filter(session=session).order_by('-timestamp')[:5]
+    history = []
+    # Reverse to get chronological order
+    for log in reversed(list(recent_logs)):
+        role = "user" if log.sender_type == 'user' else "assistant"
+        history.append({"role": role, "content": log.message_text})
+    
+    system_prompt = f"You are a helpful AI assistant for the Facebook Page '{fanpage.name}'. "
+    system_prompt += "Your goal is to answer questions and help users in a friendly manner. "
+    
+    if session.current_node:
+        system_prompt += f"The user is currently at the stage '{session.current_node.name}' in our automated flow, but just asked something else."
+
+    messages = [{"role": "system", "content": system_prompt}] + history
+    
+    logger.info(f"Triggering AI fallback for session {session.id}")
+    response = LocalAIApi.create_response({
+        "input": messages
+    })
+    
+    if response.get("success"):
+        ai_text = LocalAIApi.extract_text(response)
+        if ai_text:
+            return ai_text
+            
+    return "I'm sorry, I couldn't understand that. How else can I help you today?"
 
 def handle_webhook_event(data):
     """
@@ -101,19 +137,31 @@ def handle_webhook_event(data):
             next_node = get_next_node(session, message_text)
             
             if next_node:
-                # 6. Send Reply
-                # next_node.content is a JSONField, expected to be {"text": "..."} or similar
-                result = send_fb_message(sender_id, fanpage.access_token, next_node.content)
+                # 6. Send Flow Reply
+                # Always log the attempt and update session for dev visibility
+                bot_text = next_node.content.get('text', '[Non-text message]')
+                MessageLog.objects.create(
+                    session=session,
+                    sender_type='bot',
+                    message_text=bot_text
+                )
                 
-                if result:
-                    # 7. Update Session
-                    session.current_node = next_node
-                    session.save()
-                    
-                    # 8. Log Bot Response
-                    bot_text = next_node.content.get('text', '[Non-text message]')
-                    MessageLog.objects.create(
-                        session=session,
-                        sender_type='bot',
-                        message_text=bot_text
-                    )
+                # Update Session
+                session.current_node = next_node
+                session.save()
+                
+                # Actual delivery attempt
+                send_fb_message(sender_id, fanpage.access_token, next_node.content)
+            else:
+                # 9. Trigger AI Fallback
+                ai_reply_text = get_ai_fallback_response(message_text, session)
+                
+                # Log AI Response first so it shows up even if delivery fails
+                MessageLog.objects.create(
+                    session=session,
+                    sender_type='bot',
+                    message_text=ai_reply_text
+                )
+                
+                # Actual delivery attempt
+                send_fb_message(sender_id, fanpage.access_token, {"text": ai_reply_text})