From d7399ef4ef5182517fd7001ce765b77e6ad1a0a3 Mon Sep 17 00:00:00 2001
From: Artem Darius Weber <mit.3tlasa@gmail.com>
Date: Sun, 8 Dec 2024 03:15:22 +0300
Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB=D0=B5?=
 =?UTF-8?q?=D0=BD=D0=BE=20=D0=BD=D0=B0=D1=87=D0=B0=D0=BB=D1=8C=D0=BD=D0=BE?=
 =?UTF-8?q?=D0=B5=20=D0=BE=D0=BA=D1=80=D1=83=D0=B6=D0=B5=D0=BD=D0=B8=D0=B5?=
 =?UTF-8?q?=20=D0=B8=20=D0=BC=D0=BE=D0=B4=D0=B5=D0=BB=D0=B8=20=D0=B4=D0=BB?=
 =?UTF-8?q?=D1=8F=20=D1=80=D0=B0=D0=B1=D0=BE=D1=82=D1=8B=20=D1=81=20=D0=B1?=
 =?UTF-8?q?=D0=B0=D0=B7=D0=BE=D0=B9=20=D0=B4=D0=B0=D0=BD=D0=BD=D1=8B=D1=85?=
 =?UTF-8?q?,=20=D1=81=D1=85=D0=B5=D0=BC=D1=8B=20=D0=B7=D0=B0=D0=BF=D1=80?=
 =?UTF-8?q?=D0=BE=D1=81=D0=BE=D0=B2=20=D0=B8=20=D0=BE=D1=82=D0=B2=D0=B5?=
 =?UTF-8?q?=D1=82=D0=BE=D0=B2,=20=D0=B0=20=D1=82=D0=B0=D0=BA=D0=B6=D0=B5?=
 =?UTF-8?q?=20=D1=84=D1=83=D0=BD=D0=BA=D1=86=D0=B8=D0=B8=20=D0=B4=D0=BB?=
 =?UTF-8?q?=D1=8F=20=D0=B7=D0=B0=D0=B3=D1=80=D1=83=D0=B7=D0=BA=D0=B8=20?=
 =?UTF-8?q?=D0=B8=20=D1=80=D0=B5=D0=B3=D0=B8=D1=81=D1=82=D1=80=D0=B0=D1=86?=
 =?UTF-8?q?=D0=B8=D0=B8=20=D0=B8=D0=BD=D1=81=D1=82=D1=80=D1=83=D0=BC=D0=B5?=
 =?UTF-8?q?=D0=BD=D1=82=D0=BE=D0=B2.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .env                                     |   3 +
 README.md                                | 113 +++++++++++++++
 app.db                                   | Bin 0 -> 32768 bytes
 app/__pycache__/agent.cpython-311.pyc    | Bin 0 -> 8306 bytes
 app/__pycache__/database.cpython-311.pyc | Bin 0 -> 897 bytes
 app/__pycache__/main.cpython-311.pyc     | Bin 0 -> 10165 bytes
 app/__pycache__/models.cpython-311.pyc   | Bin 0 -> 2213 bytes
 app/__pycache__/schemas.cpython-311.pyc  | Bin 0 -> 2142 bytes
 app/__pycache__/tools.cpython-311.pyc    | Bin 0 -> 3310 bytes
 app/agent.py                             | 160 +++++++++++++++++++++
 app/database.py                          |  15 ++
 app/main.py                              | 175 +++++++++++++++++++++++
 app/models.py                            |  33 +++++
 app/schemas.py                           |  30 ++++
 app/tools.py                             |  55 +++++++
 15 files changed, 584 insertions(+)
 create mode 100644 .env
 create mode 100644 README.md
 create mode 100644 app.db
 create mode 100644 app/__pycache__/agent.cpython-311.pyc
 create mode 100644 app/__pycache__/database.cpython-311.pyc
 create mode 100644 app/__pycache__/main.cpython-311.pyc
 create mode 100644 app/__pycache__/models.cpython-311.pyc
 create mode 100644 app/__pycache__/schemas.cpython-311.pyc
 create mode 100644 app/__pycache__/tools.cpython-311.pyc
 create mode 100644 app/agent.py
 create mode 100644 app/database.py
 create mode 100644 app/main.py
 create mode 100644 app/models.py
 create mode 100644 app/schemas.py
 create mode 100644 app/tools.py

diff --git a/.env b/.env
new file mode 100644
index 0000000..a7cdb83
--- /dev/null
+++ b/.env
@@ -0,0 +1,3 @@
+LM_STUDIO_API_URL=http://192.168.0.104:1234/v1/chat/completions
+LM_STUDIO_MODEL=lmstudio-community/Meta-Llama-3.1-8B-Instruct-GGUF/Meta-Llama-3.1-8B-Instruct-Q4_K_M.gguf
+DATABASE_URL=sqlite:///./app.db
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..44b282d
--- /dev/null
+++ b/README.md
@@ -0,0 +1,113 @@
+# Langchain multi-tool LLM service
+
+## Run
+
+> First, configure `.env` file for your LM Studio MODEL and HOST!
+
+```bash
+uvicorn app.main:app --reload
+```
+
+## API
+
+### List of the Tools
+
+```bash
+GET /tools
+Content-Type: application/json
+```
+
+**Response:**
+
+```bash
+[
+  {
+    "id": 0,
+    "name": "string",
+    "description": "string"
+  }
+]
+```
+
+### Create a Tool
+
+```bash
+POST /tools
+Content-Type: application/json
+
+{
+  "name": "Calculator",
+  "description": "Useful for performing mathematical calculations. Input should be a valid mathematical expression.",
+  "function_code": "def tool_function(input: str) -> str:\n    try:\n        aeval = Interpreter()\n        result = aeval(input)\n        return str(result)\n    except Exception as e:\n        return f\"Error evaluating expression: {e}\""
+}
+```
+
+**Response:**
+
+<Object>
+
+```bash
+{
+  "id": 0,
+  "name": "string",
+  "description": "string"
+}
+```
+
+### Get the Tool
+
+```bash
+GET /tools/{id}
+Content-Type: application/json
+```
+
+**Response:**
+
+<Object>
+
+```bash
+{
+  "id": 0,
+  "name": "string",
+  "description": "string"
+}
+```
+
+
+### Submit a Query
+
+```bash
+POST /query
+Content-Type: application/json
+
+{
+    "input": "What is the capital of France and what is 15 multiplied by 3?"
+}
+```
+
+**Response:**
+
+```bash
+{
+    "output": "Your request is being processed."
+}
+```
+
+### Get processed Answer
+
+```bash
+GET /answer/{question_id}
+Content-Type: application/json
+```
+
+**Response:**
+
+```bash
+{
+  "id": 0,
+  "query": "string",
+  "answer": "string",
+  "timestamp": "string"
+}
+```
+
diff --git a/app.db b/app.db
new file mode 100644
index 0000000000000000000000000000000000000000..31f888850d52088dc0a6117711266d24a63bda41
GIT binary patch
literal 32768
zcmeI)Pfy!s90zb4L()Vg+0B|b@GCozh!Q1X42Z<Elo^^e4b+6G?84mmNwE~{%zoTa
zO{)f#_Kqg)vNy4pvD4JUPCM-PIDbfB)w<Ir`hAkv&*SHx{mFB2{Ny=&()6UDZV;Y1
zlGd~jG+oy|BhoZ2$Dcd=8HF@QW=9F$>l5*}MRQuI``bL{rtki!<?Vbf_e(A_|I^)H
zIf(!P2tWV=5P$##AOHafyq5xBq*Lbdg6?>}E6%<16UUFf6=8JZxx?6<9owq6Eo!tr
zx1Q2e3EFSbuoM+Mw|Mb&Ds3(-=&w!bJnM;J)^L{|w$rXZXj)g*vKi0iw%gX8Wm9Xv
zO|7G5^FC!W-^3!4Uf}bYjPljtPT))7OKMwBx$H!F>78)}=d4d(*6p2#_373Q?8f7|
zeN2z6<K$FTQ@i`N)!1vPV}*&{iey{6mTk3mtV0?dkCIy1qCJ-~R~B_|#5K<6(;UZB
z*U82?>S7peoF1@MX4B^4qJCLP*v6UT$lMg&_%IdTinqjt!k0@ol?GqN&Ex-0FI(I<
zc-WYFFmjMV(2Gud=S(EA+2I)<wHi;3CdSTHF~yLisGw>UAIzl8k4*h|x<SuP${5!{
z2ki_nhpnjbx1y&_)6_556UZbZ+00A<4lBGBPo2--4kA}XozUy6QF&9a8~dGPymkUt
z+|0f{0JBAPZ?5Nl*7%J80SG_<0uX=z1Rwwb2tWV=5cuB-Tv~csyLYkwdTqz)b>f~Q
zgYYO4-MFWoWm8{->XEkRKPP^!eJXh4b(|jYCn?M~&ryjQem|BJod$8wrDuX1dg1i=
zetxQoIPZrdinvC}72V|Lf|Jp0cEM9E)F_f+kybxd`&yPb$nfPLq7shaW@($dlOp8C
zcv~nY#Z)dg9`__?C&dOWPUgxu^i{)!LBT<mIPZwQBrDmeUjm$n#8r>nhpN?Gvcixx
zRR1vxu*TKZ)aX0${Zf{{Sv~)!#%}}&KmY;|fB*y_009U<00Izz00eHKfMH}ZgZuwC
zTK>%~yg*zM1Rwwb2tWV=5P$##AOHafK;XR<m^bcauI5ar`Ts_)spWsjYrI2%00bZa
z0SG_<0uX=z1Rwwb2>heKMa4*IA6{10HdeOCiw1Mg`(e;g)8~2aInTpaiw^MAc-nQm
zo^W|GJ@HZszUW95Z9b+$8M|IU^@B!@9=6*DJA+)F;eNpX?Jt}Lk=$OcR5waxepQz5
zQ$GmhcD1}&Db~mq4mZgwFt`-NvP3*%et3YB+n<z+)pGUY)k<}>yh-J?TDe-QY`&V|
zQ@(ig4yU{qNb-Z>aslc;249IVI6Mtx{W&iMQKGseUTq?h6!;=3MQ1Um_-_SF@WOM2
zTbk^@T3g?$t#7>2|I7X>Tk840k^i0N|L6bU9RdU(009U<00Izz00bZa0SG_<0=Gb5
z&d_zkP}`XqHUD2d|K~;j5g-5o2tWV=5P$##AOHafKmY;|xWxkM`9JReZ}At5OM?Ie
VAOHafKmY;|fB*y_009WFz+VF_BbERF

literal 0
HcmV?d00001

diff --git a/app/__pycache__/agent.cpython-311.pyc b/app/__pycache__/agent.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..39ed510b6a772856f70f25ca01d6a6ac8b0caf67
GIT binary patch
literal 8306
zcma)Bdu$s=dY>hC`6fk*q9jtXw6-iujE|%rxw9+BPV}-OS(bc~+&eQ!i4}Jx(b*-L
z-KA}@RE~Fb0XJ}Qy1;;i)`zm`)zLKuYFrP6|MXpgYyUZ5X%O&Y0Rsk#7D#~t43Ypr
zfTI0omru#Q%W(MZ?94as$L}}ae&lvL5V)JqSJwYGfY5*7m%5{BfiLm|LU$31Sb|4!
z{50`|V2YarbKESDaZ;e-6oKQ-yhX6at$LW`ZGt^+7aVbi;EX%<IEr@(?zmeI6TBzx
zfjkzzL-5AEdYqN_3BI_mmfjifgmfG47rNqIwYWe$z}i^{-!1gSdkADgT;OVNy}=L;
z*252+_o3Av!{2Z<-BA6V>uXPs_d{9U`;h!`T?OfRJXa6YBUl&fzHb5z_!}-h0J&N<
zJZ#4vjX~BMr%h-EvA&y#?c}WY%}@gTYb6|H{T#_T8x2Qn7iU@{*}zRQeuyQOQMmgv
zthx{;HS>6SQzNHRNm(Q3Q<ALN7PE3HlV<oZp_%9BFNV#UH<eDwDTYtwxdgM$rDe@N
zjvp(VSxzHYG8wE(olkK*3jrseVb}zlk-79Wc(t*N%*iQ%!%4GgnG>@j2l6vKju7XO
zA-|Lmxpk;r+=Lj4=dN+Q=9|BmSYEk2HM^J?zcib;yfmMWY{+tUEEYTdCnuuEzjr!%
zEPDLdt7FGcoP0HQ?RYG?!N{>>M#%C|UnVVS9nBIhE>2C)=dbXBB<I*vCIV_g4tlj2
zyU58*WS(aPCUP=*JaT#>GMk2m<dSk^X6EwwKa~FcR}&W!7o+RzxwX8P$!7UflEF2{
zu1cA7(wGcGT5B&~6!mq_p*X>!xal&i|F{|Eo8&0g^uWAlo-Le}v$5oBkXhHUv(!Ev
zhpuC(>#$bVwok{&xu6_-L&w27_vyGf57*ILF`(~i=(|~1gAcrWR+*RcftJtEg0<KQ
zYtg@_2c4WB)}D3Egx6mCPKbBuX#r?|_nN6$Gw62j)9qmou)Um>4MHp7+0<@^^m;68
z=q42pvVC0WYF~W<^c0fqht=QD_Q2{N(46xZm-U4J3q1e2g9bO5ljMv*&ok-u$qgoz
zrXh)zGjs|s*)=A~(brS*1`Ux$P8t?vRL_|oT-o68E6t_ZYz8vWYZ<Yr84a5>E6c4h
zIbPPBEGH$!l)lF_E0awnaw4Da!X*e9mgDIxBX7jgjKD=TN{?Az)7^i)o)0WDu((s{
zbz0_xEGIH@P6Rb)%UcS05y}r=WNxH{oIs~@!YU`ynKkIiJ6u}A9fF;UvqDCPz}!d}
z3FkEnEP9R+@<Tt^;N%U+1gbfSqm5`>smMuL*jAhr4V%So7+sBmGl7xB9vrqe6x&vQ
z{j~g|6O`_v`pU=ao;AT-n7`?4nTzOTCcTzgU%@AnEs?;(kVt5bL;^-4$K$Xok$5-9
z@U;|gHj~Zq(3!;Qrmp=<^aY;wZ&qTLB~FxLEF-3JQfw-d%n5K}NwKV$xymIWpdVzZ
zWQ2zahm#|fj^Ohnl9QmT5nhNG2Sp6FwV@i#ZfX{zc_Ix}9E87wN1@pGseOZrt=I74
z5l9k8L1-2@?{Z=~Ssx0B0~|mIAJ|`5KmZWpL)o;T+3E+BI1KT>Bs5au_%#V@)8Yt7
z&7R<SAtA%bn-8=OTqF80Xi50IDWc~c!CQH~A#HWzD)qXjAaEBI&{cRE4#JIALbw4+
z5XL!l2Vt@vW{G>0-tsUdV$2lreiShxig^2p{UBbFG=S5;1ERHeohcS(DYdo<laR<V
zA|puof!1#BPsc+nML-l$)q;Ba?-bNP@J<}&qSAL%4Gr9jsokMF>8jJ>bySfd><)cY
z7BmYi2O$g42YWx8Y;+My!y~8<(yu_`36deA?oz~-xpk;m6KiJ4dnT4D5cs)ndfDLp
z*xEXjX@bS?&Ed4&qqay{=TAmmB|KUC9BVI-e~W%@YUdjSvLm^pseIK|4?`XHM%Y{+
zSx0NFz-xe)eO%{eXp1UPrIt3-b0Tyff~{QUTeQ?wpsqUWCA_H3>GMNK_S7{Hy6UQj
z4<qr_ElXP+?s{75lXVv?FDhAXuq=dLtn(9swQO15vs@>xqZ{Tc=sM9lE@Gg7N-g8r
ztg}G1kNh%>Jd7C}z58AJm~B}L){<|(7PQc_j@r?4%T};S9Wp)%Y7UqnY|kbG{RvU9
zvEC*IzNBPdYEQ{8(d*oc-&^*Az2vXg-ui6s)iQ!PJlsr|@usY~HPg4A$F6TNk1y2O
zKab%+{(p3E#?U@fLp+*kU>Lmy8=nT8Yr?dFzfngc+qk$cjWynILB?r8j{?+%$7qb%
zsdP3c*WwK}fc3D$Ckj1UC)00XZv7VId;4w3xs1~!?%f=hP6C`Zt6b8NVo$A*%c!i5
z+-##8%_{RQz$T#Faztn47HLxgT9EI*lF8AG$U)aPI6k|U<7q~cpe;;V#=L|SGd!nR
zlSW>R1jH8?KKnm#aBSm+rP%~dk^n5FJ;!?9eu>${RDX>A40Aw0Z0iQcuz<Q6i3zY~
z#jHP*lXVoxcP`cF16`|ZjLsiE&!l*c#Z&_#(}2r3*haC&XlUI=CI#b^KezyTMi>}Y
zF3rO5>vLFVCQ%V1mS(LrS^OS;L;2ur`Wi5m=CEOYCNT0C9S&%&$;E}0>4lZV%9Tsg
zd+`f{lxE>G>+77Tk*V}rMze`{-Xs}%na#k|VA#{VB9oH11QeTqp_OxxD04St&AVhM
zPv1y#2IZqTQOt;%YbggfCvemHn<ufsq*>rMP#$nF5s#;4Ugu=Z@uv)*t7%b?n#yXn
z3*4rjE$k36?uo~-IDy3(oX?sy<^{LZAZ!}JY3}+<0?&<j4y)tgk?=vUFIZg|B!fyM
z8J^F>4XnYEqk0ssMLGh53}D-f+<iZvubNGM$1Q8sfdFOW&w~e*=)B^+2wn{i?w(h?
zC&5=KbI?<@p?(@;a^(1fgc5mk=kUGQPVC=T4S4q1{Q%D(Zdt$TM)r=MI^TCHUEz`y
z1o*P;m5S{Z#r8^-blEQu&w2*$Y^mO^J1(_%P!05}y&<)y@6LOG^1YtV5r{9bxb<e$
zgWQ3quHh%H;j(L_;u=w0BhOr&KfUn&1*P}3-5)-98y?`xuCo=_Sw;6>KkMkJbc|M!
z32JJUIOF{L^Ga~?F#!U6*)>&hO)0LaXPpDe;Ot`t1o(32T%~hPam{@Vu1eu@aKMIK
z-rMJ@$YY-(RDaJ?|B)yDBc&T<|FMeynBqECC7o_ap+`S*f9U@Ej$d?ayVcOh)6mf;
zp`*LA55;n5tP&dAwyHe?RYdsah-ab0%J7@z&}=0%t8~o*|LHqaI(YAuzl;7&bT{~L
zq8vI^37vWxI`brS=F#k9C}6G<n$ruoyY<1=&wh00M~e5z*U!2J{?VrR!_Zf#zg0f-
zcHeb<;8G5}_Q(eUeA#=p;ytT)&pzuuqzp|wdKU!va`$AVds6XE)_M%(KuE&t<u`%x
z;6x1lHr6qD!u;EFvB`+}lL!UjPdmrYo%f;N`Fu0o=HDHP&G^j!=A$4iejl<W8{`vS
zFbmSz*n1F*+1Qo|5SJ)H^nTZlO;hOYGO#tX`1^vn)F8L5x!65CYKtt8rPkUT%B;B^
zf5m?QE=97`U$)#|F?(Vy@96nO6M@nn04u}ouem1MyV_t}FJ^grS;m&7U@6rt3H9Ri
zCu`lu9e`&*&rf0w@sd2Yy{te-`xlpQXNf)B#8EI69C_elTc+Eu-u@Nf{~zgNlZ^r&
zFcatsy8Zh)>$?4<U@A2jYHQcp=ThexUCnfzSvX~U3#++OgFV(`@Dup1^MwqtVIz2%
z4loO9%lV$O$q>WN{C_t{!6h*Rz$CrslKdiup_>dEnfLRH`Wa1+)<Gt^R6E0Ke8T{U
z*4sFpS;ZIHZ%rZqXu(RwrQy%kp}5&rqx>eV5Z{2|%TqadEpj?<0aG3WaF1ttA#ZtW
zYH?xuZ5>K93QQL=qa#XwSVt#JityOrw(f5=K(9x0q`<V20D}f6X%?1Cg8f5t0Dg+H
zgl#S26x5?Z-6>u&Ad$j+LlWn4e8=4K;=+`kNv}^_z_IoQ(ux!CF3w^x2O{h;z!D!V
z1}`9S#hS~gm(`o0k+_GN9YbUS2Wy>6ZsgMMh(Ca=8kJ3PNlsjXu!PrI6FO<*hAv)!
z*nFrBI@{2l$65azP9nh2F60jYc$&KG^Mu+<KkYsGr1xmKH&W@1R8fa}SQpzQfCZq2
zZ&)1~`RL4tXLhfbhfY<7PHoStJws1>qEC9FyEn=`rz<_DtH>1?RtJynj_*$FPE-bC
zJ0#qMOQ)ao9aR8&`w#9+S53Cy@Uzil4?LC8GfzjypNx(_K3pE1sf^C-%&JFX9|<1{
z4`&~V<s%c7BNIC_YWP?cnGYP-MTt^JBmZpwC;P*ZM<>do=PIM;no;3LOXblwDx+^e
z6g{&0-7<ZwWGz{%R>=MJS2jeC-g~byc%m{m0q_-s&eet5e|YE3su^A}d_4Du?w<YN
z?9X1m^Sa_X1ZdogL3mz=;<{`=@zi6V5}X2Gc1>4Y(~4_ahvK=%?<#|H;LDvCDxDV;
z*M%A|K{*(h&cY<z9PgSuhkg?rKQ`$wePSoz<r7D6@(A_GkO_x}2^>DsgTv<>Q?Hpn
zwZ*1RnLj;6K{!k-gb#=Zp&0QH7DFI3YXa=v$wWfLH(s$53!NUCVFPF#i3F2QXMi4J
z<1{vF=|<_q!uZ7&-l<V*u*hY@e1bQcW(I?zs1s3g6-?!ZP00qk3oL;0rWnPwkXT@V
z6pvwnfkj-wLf=BR`XQpPP2IF)n5Rat3Vfq61UBPIzt$IK5f-QMtC~!d4aOgY1$70t
zzpETPp}fH;{?)R7wc=kb&fHp7$W`!Va#i(pZwGer%BhQrZ=vj4sQ4C&)3;74<O29I
zxu6CIb^;|yIlZU^FO`FrD#1&|3)=yOyac{XUQ+4d61B@JZ>%fyMw#BI&>O|MZQG9j
zj$0u&z?aDlwYzVdD@{M_Rc3glTPSx6m2ROpdrMYG0eqPhsw6?tu(<Y#&vD$B%>)aw
zc&a9X3hkW4>Y=9i+zd%Kf2b!yzp<K?a+Ica{kzHC-d`+K5xh1<LmkI<o~AH~!g6QQ
zc$RKFBp)vS+FltMGa?=*jpqxbObk-<MCnFl1U54cK3X=Oe^?q5isw?J^e-x67{YCK
zzlKTc&miS4l3}Lnt{rB#2pO-XnkxX&lJNqoxuzwMCG?LLu-aOTN2UTc>yr6@)p2gN
z@#V<4Y&Wdyy7|>GspDHXEaz)r+rw8u_!?9Lvvz>gQ|M9sBE14y_#%y8uywm>wZ|zn
zNURsL?@|q)yvFEe%UD`(i~)M*SK#8ChOTO6Ftmb&8-M81tk*bkH6w9apmvmlZ4x6}
zg2VSWDNGu>2pil)%wx2^`1I0ZV)@O*mBiBY_~c4rYI=EcY4*~}?BW7g&v6A}7K?X5
zNO-gXNQ}#uD+zZ%uxRTwi#bU8YpgQ{qKLlgLeB2LirkJAC;!vcuX_BdtK*rcr{X!O
zdIRdfA-Dj!EpP#HTi^oZwiKt~0_5@)=k?_g9x~1Y3z(0g@y3CHXVy3{^wY-Qu!l#X
z|59|70gC`$IhwbbqBl(v8{HN0B~r6xH(4+%q>}par<pPs)%DMSB1TFP8}Bsx_0&75
zEXSr8`1%1R3b>ey9-Lssw`|-heQdBPO>;u!spO>oNkAiK7tSwgcDNMJ>(_DP?8P9j
zSs)TVHW~-+2E>TtSm*~E9=|;&-Z!?_jL!+@#J_-4ybYv(0SN#^5Gv{@>OU2INBLu3
zMMFxvSJ64;<z7W0rQNH@Uetdo8c^E3iVi64UPWG|?o~9Xw0jkKiuzAQ2bFgJ9QljZ
z3i9ua+=EVyl+j29jX*%Phi>&$?4h00W&7cZ{czFp965{5AG>e5i|*%L2ev2f%qj!N
zm6NOGu4JVvsUV-~?!L8j`-;*7_hWSQyy<g<JTs;*by;+%9S4i9Dk&2L2I`kTwue49
eQon3h;>~`-w?po%+=J5<f+b0Ryj1AR`u_oMGX#kM

literal 0
HcmV?d00001

diff --git a/app/__pycache__/database.cpython-311.pyc b/app/__pycache__/database.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..52ddd389ab0d5833be91e147bc1c44f2bcd43742
GIT binary patch
literal 897
zcmZ8fJ#5r47<GOwxyvQJ!a#ong#iiOaF>Ar2})6`(t%bCv{j`@C~{+yOY0<uom4Gi
z2oggFb{Lt85FHphGBTl5>JVi>Co!=Vm8lc<T`PLEKY#lC{PL{#IiD=c0DL^@t@uAB
z0Dg(h`KX)~CqH=c9w2}u0z%1=BvH#m4i!h~*9uX?ic{&=D$yK`pI3+;R-LK@WPq!C
zT;a>PF6d+0M(rFx8q)V<&fse>9D{!)VFOjMu?47#YRCwrND9Dy{SvdznH6Lp1K0P>
zJ%y|Ab*5tSGiCU0$3p5dXj;Dor74w`M=?yWiz7dXFb75v_6Vdf3AV7i4w=AAh8YXu
zD1@7sKIK52#1OeCPH?nUn)9<Ovvae{kKNU0ORui7mn2B=ecQI%HtcrWXuZ@1Sb4?k
zU~ki9FvM=s;TNL?q3*>|guTRt)MrhlG+>&<UL1x&Qr1NMf~2fds_Q|7nj@vb#USBI
z;SLp6%gO&h8*eA=3kIkv2qPB=F%7AB*iw#JsSO-ZO#qsYg&nH*H-mnZ=JLS#QtUxe
zs&l*_pTP-dfYUX5m0`+k1Zj{mdp`Ek5Jw5KyENY5c9;!)z7M<>fsyZZU=X!<PFg7o
zBELn#7E4kT#G*-DB!QyY?e5NLbvleuO7IMw<oEEu60n@7V?~mr0^H7rqX75v;V8hJ
zd^ieF%lfkbQ~7Z8Ks~F!vEEvl)oYCJ(sw%_rt;>)!^X@}V<t0uwQIXK3U%~g`}=hM
zXidbeyI)uHn-4@hcaIg>kpBRl{)&`o#~K*DzWe%PdQkbckT(_&8;eJc#mp@9v0NWJ
Q)F+PgiA)ufj&oE006LciL;wH)

literal 0
HcmV?d00001

diff --git a/app/__pycache__/main.cpython-311.pyc b/app/__pycache__/main.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..82376695095c48797ef920f53a096a94c8aa1520
GIT binary patch
literal 10165
zcmdryYitwOnltv;9(x?yNgT&X12H6NFwKLuKm(;vAcTZaXiK2QEj5m35*++UXC^#S
zXK}emb=h3eR;<YC!mhQdSWvT4x+)S^yX{3<U5Ow2V<wtatdWo^T~)jNmx^8q_1Avi
z89$S7m%aOAwR<xD&YAQ0&NpYi_vG(uY8(`l+CPkpry42h4|r27Y@zY^p_!s?P&~!c
zaVkNF=!7X`N|;0D1QTLt>^H?N32Vqo+UB?|!G>69GrT2kPdGx31Q+5G&X6-v6RJtL
zLM}39jk^-=kUQZCc@njuTGD5W*Cgsfbp#I^uTRv6>Pg!k_lCSCO7KoJ6p4ejuh^b<
z+@>k&EBG0OrpR1)9-|2U>hVyM;FxGGj!ryRY~@;tt;$+(POK~5&vVt7$WAoxoUf_w
z53T22SEx{{us#<kuC1(jclCVUbA`GM6TT`<3T@zP1$NBD*Ii*k8v##SX{e&X*9+W4
zd$D8Qd)ov!;Aa##1(VQPz0(-YH^7>X;vC*5Fnpt69kcTOE0z^BJkK`?oqV&fsW9U?
zpe6WJT3P__<|5u_q-7nfd7-$5?85NtSJBZ0dv+IRRn~lqz*g?sR2qE7{qf07eCw(m
zd!D*upmM)w++_otBJRZS8&~br`_!G<V5cp`2YSYx@O>FOwXfRgMc#gl3U>U6D1(e{
z8;D5q-ZzJITfZ<VBzZ}%85|jT^T36uFe%4UN!`6K5<NRErlykoNJKg-1!>)OOpqiP
zgC=u0Cdogd%mppFHId?lxTM>p=oujqk#v@i$dS>AB<PmNxR8`}i=0ZurJz}N#8VMI
zOzw0x!W&K9MLNQwFb-J7i-6x56@`c_gvoNaM~s3TO9)5c#u69K32~%iG?wJ2n+`{k
z<NMD<V#z?^p#sMQ@mwq_;9NN-$AxI|AhBlPhw}9JI)Gt{2JI%7v<F2^l-kwuFhkj?
zG<AZyLDNv@N^%BBN~L-QYOiCk)w9k%PhBvdq|VcK=_5h2=me~~vvA~xQ_)CVw?yM9
z37^Wuk4i{p;Fn{)$0b3OdijVLo059_Q_-meoVe6GDW)cbC^X0s#-iPEIHf3_Qa3=k
zdrFEW$GhW+Zb_cvW2xTA<YaFGMtdeN>eg{V4)dcTYChDn(g6Vf0e>0lk-b*4uUG8>
z%^t|?TQ-?3^?8>k%i`bntm7JcmHpH)>&TM7Cs|Wv$CD>dBs*Zb!MsR)?b~ZJ1INe_
zQJ$KtdOvuwX81kch;ysn&06Ox`e9m-7Tr+Yr5*#ML{#N^O#yirxFsozh;2RmB%GL`
zeqdZ5AHH%pL;l1KxWFn3@|2jYBE|{>gqS=uZcyXYOcg;-W0rpE)Uo&BL1yR~lWc*d
zg))J-NJ-Oa(*&|2DU&o$&zq_h_>5WRisQhRNC_#pGHsr)74PTGw*l){CCoDnFkI1m
z7bh7jnQC)DQ?ny!V9_9R<QM;uRDc(xs2C&i9{~P27vlxKCuq`{WF#TzT*dHRv-muq
z)S0oVWK`^gX3#FyVvi*z3kgX?%5~cai2cziS+|A5d@33ai#22sc9TWA71$264=53b
zp#$Qm0T8tqBvY|hx5cA|&cKrlU@_isJ@RRZuZ=0<OE9Mmeo_WNhRWC0XAV8`wQIi3
zs;^7)buCjiOB(^7I<icbf8_SfUdr_^@ZZFh?WdK2(~3Kyx+9u9l4Ty%HD2GGuWi7~
z-=g_9E!&uS$4?Z1pAlqj%MQw3zr;2zvQ2ZHD!Wl*H!9@Ha}5g9Kp1P<+WX;@K=hhR
z6r{;iQWC;MXX-XlfFViNJ)<Rc8<tVuis+a`OD`2}O00<5>IP_)3FtHmuu8?u36vmG
zZUZcP6}gHzg$YpcbTw1VFfs~hp-hyRH*MxkX=W9(S<<E)Qnsq3E!B8IYnpN;rmdV_
zO(mJPHv6u|NareOE#s8E<#yUKQ4*uHIc>TPLibfk@MuadyA9L?@+T=gGrwXt5EJY4
z3l8MIV^gDvm>h@%ra<=w$h!^5sepV&2oP=CLuUO_+i|kHBhlT#2Ra6KcD%8(<Cso?
z4YZI2!1_t)yddg!G;5%$5|h(`lc^~&P+*BbObUz&prlb0qhNVa7HQp@nvy4{<e&>A
zEeQ>=9_ZE0$<%qB1<@HpY$Ce#dd*wNSzxc<K=Z7d!QATBXet4uBj1eyE1oGBVPH7D
zrm#)eAkP%z4IxG};>EWMd>gciTLHPa4FR&K?!ZF`8??NN9V{Rq`%1_ccwR+$bxP#m
zj2*;7Fp3_I^mhO<6i8BC)Ae;AtRDY$=jX2Lt|d?BqNh{Y^s4IFrFnK`hW==!JU-3c
zc4zbbw;%3M+{ab-am{@^Gni+rpA1|c$o8p>S7W>i<Heq#%R?UzUm4B}<ISPVhq4z`
z#;-Ach4C+2DNDl=vu=@DcPnw{-TC+KZ+<YUGD8|Oq%cE2aCI6NP&OS>xM7tW*0^DX
z88&PLSA4iIoX;Q-UL~T)wkTwe_W^_50EYqWh51>W3$Pb`#9lBnmZ#VYCT#&$E-`Mw
zV!&<{n%|l>=Sl(#bd*Zkx>6WtcU0|D65+JDdghGHM5S%KIZek_Dhf8u@=RHJX6#QB
zaM@ELgqkP`Z1p}l<k?ka?UfY*O`RpmZUrv%omQ1<H8bN#+tZG4N#KEY*QzDZQN0S(
z1zNd6nLt;9lr)vL%jiTD%0y{a_4-_0aYkj$uTVAf))f|=1L{!DSC#atko1|KV^bMf
zt`u08`@k^R($sG#o=wvL?P>dOs9USJh<BocD|eOGwNqkl#wk}~FNNaeS%BS9!0rUR
ztNfDxTb#smX?zOPpTkclDc(8b{0k?Zq|rK07XyJ{&Ga^6O5QXq0I@I?HYbwg15)Ii
zU|1evP7Ko{cEC}K_zuL^5bQ$m3IK>JhN04J(Nt1KuNXD<w5Nby;0wlV+O#t;%>=r4
z2c{bjh+;}C+8{JX#6AS3TUHIA{Ud`r14n{>;tq<Nac2}Vu^Rz0ir9ky1wq__00m!s
z9e{2fi^XL@6bJCeG8PlTpzXxbeb~Y6B~M7K8L@ieZXDZ#U@uOv##7_tU{RS^axA6W
z%dxBlaHhmy4S9B=wGGq77X8Yy$0?#k(%ogJ(g<MLqTfd70athwjTo_Vy3;V^1&@vv
zBz#<A^@@OatKtD96v2M@No}CF!0537i}(BbhAjK2d6U-Mqc(5Rnzt-dR{KT*K0TD}
z|E&E{z5n{od_xmnErFYdm6ideYXE#vuM2!puM2!puPfUR7PO|}+R>{==lWIW2F<xa
zA=eMhty*)}op;sd?OOBptQ%~fx9zh%xr28?N?V^=zeB6vk!AC>O>>*H+P16}#v7Y%
zocZF+t#exI%c^gy=G(gDdv($G>bC>ht~a$^$CP(Q7k7=SzNqGlF8N}MzL@GetNG4m
zx%|4eET^%}c?bpVSM8s2vs{(~v+ZB6H3k>XKHUCqrv&X(Og(j0J9T#Hl)QLKUZ$vX
z^pNQ%iu!;)Wct~tpwmB$eE^{gVAhE^tyittw92+<Y>UFSRPFKu>$=8W<rMFc+(!W5
zT9`2E2V+L9vPU)cs8YP1JmS2|6l19Xj{t}Bs#9s$d*>qnaNUm>waV_(*nJASFYojJ
z*=Muo{$6F>9=KMYQ5Mdr_y=+FlVv*)h5<9$*UJaC9N0?zeyd|}z4`aM_caVQnIAS;
z;07WK5;hU8jS@=;)3KlzKs=E;=!IZ`&SCGWB3G=b2pb^4C?{0c4ja~9S@usLJSq7q
zYuad}a8;?cmNTZbNvxGiHX4H!-UJ~CP+d-RUZ&R$ekv(|b}96LHu`C#%rh%2E%-TW
zhZHOQA_!CHwSAWAXCU)R0Z4IQtXE^K3`N!$MR&VUCQ7~vWCF@wh`D^`RT%<H^;42i
zW<9YiZ<CxGL@|*-QaBG$Oe$`ekl1Iy1k-IJ&=EKvlh1&Sfq(=P0f9&yl5_mUfN%kV
zb*bmBN#`UvB2P)-C`1~%l^5hlEDomTd7##a^J_3qfUyXf0@(vp@#XQLr)&yzJML*{
z`6H!SN3n%0L-2`VY@yO8ra?rFDtZv$NsBKaz#W1NkqkrI*ARNaf{{dl&cgE=DFftF
zRMmyFk&%Xkm<A6+<Y90Ee$u}K0EO+O8X9j5eld9Kgto3*_4a7qo+a<LMenwIW7_rs
zZTs*;`Cl(CZhu$xp47Z2m%QOcZ&>w4G;bvHM&1UxhPJ#%KXN^H$E<8UsklO_E2OzX
z3L7c}H?8@a+S!wNuV3@F=Y7qZ4|5J4E9iNT74*Evni&K=Z?XON;vGP4smZ>pGCqy*
zDU1&yoY_5dXKtQdV85w(*ryGL74Edkoz}S13Uiu-I#GE4rGl!2sFO4_F!zuv4OKSQ
zRthVebHuZ%R13`vq{FU&fc39%zkzX0)9r+DF#!#n7>95fv&Mo5&I`UU$zb0q>QVI3
zeSRDQfJwYGb!yWLy>?)hrpt;D+9hhCT~cWCRJA~TZki1OZM1kAHV9f)aA5_Xn{-pp
z7Q&MfYTg3R{o>e#c`t~~CwEV;$ELxUJ-gzV_my@-qd0yQmPs!H$WRKGEL@=vetmHE
z=$w4>{GE~clMni}{t?A_Ty-AToX1PE$Xf-8C_7ydKm&P!csyt_M1;c=G#nYJl0eAY
zmxvP2!m2As1tKDGdws)=O<!!fwOxDe1+}hAtLs{-+p<`<MXh^Dt9uE;Z-dU!1dyU~
zNeyn9q>&l(81}38BeHRfpV4iF*4ox=BQWLvjy3zA*f8l?Y*<N)gT5)*r^*~Lv`euw
zw9#!QWu*-RMzl-^iI5x=WJv0wHkJaZu|OmsO$yQ2SS(th=zqKpXFBa3fj1vWrsTjF
ze)8!N-v`_VJ98^IMkHF9DDbjYF6-UrabYI_FaU9EquDZ89%ZSdXIV_%;>#9O(EV%p
zNf!VRhH|>D^<C}zs{zn~D%YWL9ZOu-BG>f~C$#R@wC>j*99-;%#LQuhJG{iby~w?-
zaw8fylIhQLZd9-biwgFD;u=t01Db0<VFw-&oyXrCztcZI^kA#D|Cqv!7%LTK#Nfw<
zUc;I1{ix{PL!M`*iWjXwBtFRFtN(9#5xA@5ElHhK8IMX1WZ)D?f%(NIeE6^8O-psU
z^;mWO<iEsLNy(qa8?;Vgs7u&h`CH{X<)74Fsh=qK)ywK^K>1F+to);LPrV#aey4mF
z80rte?RU!W)C>%LtSl75<|JU4Y6YNtQ63E_-zxVIEGWNKzESQe-x|^})r%AVri}TX
z`l<Rk?4^7SXcv^Pl?B-RFJYqv+*$otz19Qjmk18g!6dZB06bVJVy{ETnj%J~qnzn3
zBN8s=WJwTTi0ln%8-iI<m9#lf+6>+nMHsz-GyVktacMkt*DhSWaLcOsyHt0#=I&l{
zZ(Ve6y>~*}Hl%Gkti1W&;<oox_xqar{U!J4qI*<z^O~E_41UkmqrkmW6u9Gx>xAk$
zp}9^d><Jj0-2-8)#R1<~G<Qed-8lPEzOMOtPrklC?^}<)jospb?<oL&MzBm-?2bRW
zC}+LKZOFs&SMx64Y!Vk<f`wXLJ1lU5GXww@IIXb2Vl@ogOS)|gzG+7$V<JAeh}>y-
zj3}|XOZqS#iQ@<Ai#;hZAtHn8R{7#2ID{hVTd@xTYE{F0JF$hKhlsv5`MhYjn6-FI
z(ibH4Zo{ktAkjJa;vI|bPbJ4<<2o~RWZ<Z7hf_anBqi8z7@cSM2KE-L*O`6zd7Mpv
za>kG4x}*5PJ091qLJ|-PV3{W;$v0S?1;@Gk6_b48(wWH=q(=@SGUr=Hik|2!l2_Nw
zG5G9mh6zU60X<^ffjWLa`LIshTHOrf5pzydu=pW97&3<#K(GM;eo6g>-34E(rsBeG
z@e{ZOwMR*laK_7Knx-LJKp&tLs{c=4d1|9ledVb}rTWTK+mvU!^3*HJ)2}?$s#ITj
zYMoMj<tbN&{2~3`j7_8J=Q?k8DO9IQb!t>6H1hW5Y@=pxp6gTX?V7zkgP9T9c7@X@
z?-JFzNVVqP{W1(Ysnj-&(EYu&CNr*hdll;z)w)HqZpoOJtri+Yqy#*a$?{3d<(6zr
zrTrT1UpCQnEr<|Z`;(b6HI;f;2ko01S*D;`37Qdw|FS>3Dff!j)|c_C^bU>Qk&m2F
z;EJWx$fOpTT&6tqVcLLmose2Gnh$!7T6yP#${9u*N!SUfmQ7@Bdpqr&la?u{7R;o&
z-$<&J;0XLDREeZ7_aH?tYxK+coqO+hK6w7Oz5fiG`sfHygK*BK`8ONQ1zY8S(MBS+
z!s=xcS@II1ZoJ%>_2=4i=fAw9ZG0uusM38J-Irh2KKD-U#9xPRhVg_`fFI#!uT<U{
zZA1!()VFLR^T=BOq>BByI|t{FBEnr7y(=Hwa;I^@cei!E6+RHt#{nV2&!R>>cfPXM
zXd~j+VCk}n%&#j@tJnhzjoOO`5%Zu%59WKf-#Nc<?(U`eOUqOv4SEZ}+<sE!-YIvH
S7UCSDVb!v!IF<AhiTqD{_<(Ex

literal 0
HcmV?d00001

diff --git a/app/__pycache__/models.cpython-311.pyc b/app/__pycache__/models.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..171889d2522aaccf160b25689c685460ad66e9af
GIT binary patch
literal 2213
zcmb7F&u<e)6rQ!cyI!x?c8!4)N{bMLIBM)vqB&Ghl{A<}h*TAZgQa%0c!scLf0$Ws
zODYa~=pjen$kC@X5jj*naqOS4miA!H35gT8pm3s>zS*@y9D)QhyU%a-d!C(n-}h$!
z(zG0ccISC>m1Gcl!3X0ej-0)Jz<Gi&!h(ftp(WU<R?1Gd(srhmvBj1sa4cm>w%n4z
zPveZ0wUw44pcJ}}u=pp!5>YnO2t9>6X{}t0$$(|w!PFR20L#6D<x_~rIEU4p{ALPf
zgga?O)wQvYwOgoKc*%!VkxAdXmTx;uUUs@<l~5+#>Qd8LWtk><)MdGbONqJa+#qXJ
zf#oT&jIQZA-hH$4Qs6TPEVF2Mq&=RU|4O65UI5M$L{Lk>sFlJ(D-8?G5D}+vYA1bY
z(^8Dd9K)F%aT8Mh6z-(8vN5UvB28|MCky603Q@5PTg@`1>AKcU7ZZz#U2whTc8aMT
zYT5=}(;tvECYlZ=j~dl9lYGZ~=o4Ck_p+?xTb6OxBHIEj!-JJ-o@I62F>IpiET`+X
zi+zjxd0l_#8`cQXbiK>}mJBH;mh!Ezl!+;q4$E+e@<cHe6R%Cp4$mvo?)gredwLtz
zyN&iB0=>CizwHs~)v-ZM->WaVZQmwN*Q<A^`zvXKW30m1Y|mMSv)aCIn9dy7?ws!d
zm2;Lo=XHH-x^<(|sl%Fy<<&ZCG!JvfMh3?-!36t#SUDZse6AGNPxRz|^Y2QiEDV%|
zNLdILhw3Nm3%%)nWvlt@TBt4#)Wt|$43>uFsowNPWlIdpwL!TSm21I`VdYe>v2khZ
zLRgs}ROX|~d~lO@dS?9Y3FYjU)nkA^S~*-b6S5zvMvnC~i72sZaz`L4mOwQ!(|+=a
z$Eiq^qkt;nq1U7ZSY3l20}G0v6~2|@+??R%Bscq%(<wfTi59u8)|g~C-tUAaI#9Z%
z4bvKShknKb<FtIvy|ZIe1ji#_4wCc5d&$X{*BiY{{R?4!W{{tW@-xA;p>}NjPH(CI
zb*NPbS~b$DL1S1t(UW?=0a>Nmpj3-WwP2a|WCi@?6U6M7^d=x5NsI`o1`0Oeym-pb
zjJO?1l!C?gl(%{W!cRL5%UIaS9-6Iy6`(N3)T?o-69VNV?<4yD$nW!6GjT#@obzpg
z7491C2YSct_;A`0Z>3uN5RQ2fF?Bqv4wW9WF1KAcS)FdoH$4wQG|MBi<H*CrPxBCN
zxRAU6%t7MMyqEa6`cC#|`?FiW49;DS&RrgquSDf5P=tlb`n_JWe=RJ`4hpkTVK%sa
z6#vhQr`I2E{P=7+EH(zkMpSGBKk%MtB3{>*upBxAW~EwSIq#umSnd17UOOOoUc>R$
zX`GS5+n}0D?a}730S6>}Hz@zaCI``3?!_;;$i2yOc$2-HoVDN5c|f_0y#K)LrUgOR
zm5^{%2+?;Rat+bNaPk_WQ{m*bn~{XCcG0`0mwCmXzJ3dpB%#hD51ZZ+kF4{^5md?w
t*M(hlwC$aL6(g??;uZAig^hgw=YPKmr&b12E78<Sphf6-7+*0f{{t6;7)SsB

literal 0
HcmV?d00001

diff --git a/app/__pycache__/schemas.cpython-311.pyc b/app/__pycache__/schemas.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..aef12508865fdc18f5fa21143a07b75f259de02c
GIT binary patch
literal 2142
zcmbVMOK;mo5Z)CZqTWvI)Jfe3P@o3~kag&(Kv1Af0oOLFpsrJ(LI8plHwpvskzEpn
zZWPc%j=tp|q;T_RoSU%MoO+WXpM2`fQjbtnP#_fd)9ie^GsD@L{kzeq5_szG&IWrW
zLf+wI@fdSq_74cJh)Y~LBtGp?igIaK^0l5uNr@a1SNn^&I-{>OLf*j0o}R8a130t5
z8Hy_dXB9Y8aTVaI1+J{P8gTUjXSt1E$$s-+biYq!<p)QwpF@`oVPZXsVlNDwVSgT-
z`dh?0JAmmc!bp$0q*r=On8tLMJ^-zfN=r#Y$<@J+A**L$IDE*N6Emp?j?ZMxWunhL
z<w`c5CP5#a+I<M3dtpe+wsDzl%c^brp_>d*uG{vD#2L;RO~hQbY}*NfFm`aeu<Z*n
z!+39g>pT{Wi;nAXFA<#|!+zqkAQqj7htF9b1ZMzquiqXz!Jz-l@q#vB+)jiS4BA7#
zE#k!W!j2O~9npWrd`BEaBW{9m1v&`g8-Vn^-=x||kJ6*@(d5?7rH=1geP^=$$)%3(
zTZJI-TMH|>9HU8mW<LRZAjbw|JIgUjD#z-abvS3^HB{ys7}?V^T@$ijmSxQTqa>Ck
z&*fzxxdo7OP3L=Nw?SCBc4<#@OJGF1Y0ixtJPd=U-r%fzq4OHrsv|T2q!n@>4~y|F
z)Txg|d(zDI@LiZRVa&DxR(YFj@4mF~mu>kJ$nHgX-MZ!lF>e9K(FDg;Ykv3+>JTb0
z#1nv(lax%XT6&lsjt@7U(p0C$-6<);73!`x5LvY7E|<z>r(lGuRKDLSSxRO7mxS@r
zDSMGH5lh1hq9pEeyl2)w>`T-kU{1w7fZT`Gn(1+RJcf}TXHntWkBq7@k4i+)P)wR(
z5`QqRufPpQz$_Hws<+aU^kfVpJ;~z2wYj*KHGc}s=4`PIHLr9!-Y}~A)y-L`{xTG<
zC7a&|;!nm;S@uEv4s4PJ<eZPB=_pQCV$X*&aQrA2-2ZpQoxJg7bMU+1W&IRY$=(Oz
zb0qf=RF9~F=bvrZ@ipoYuye#80J(Et7WAS3CX0+uTDQ|~+8uX4wye=<cfTU7XyiJ0
zPjaklX~v@n?njQtmfeM_=Tv>FVo(w1+yBOTklo<l@iuJ3qzVIYs!>WO<crJvJ0W|Q
z`FE;obazUMaDML!wbv`EYEo$8BE0mjP<y?iwkT~uyBFa6TWEONf`(sECZ$`ravjc(
ZaOD=RoKt2Qy%*v9_bb$1Z=h5K{0Ae%#ESp`

literal 0
HcmV?d00001

diff --git a/app/__pycache__/tools.cpython-311.pyc b/app/__pycache__/tools.cpython-311.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..2c8e4bb44dec4860bcc72ffaf8f817fbf0c4d792
GIT binary patch
literal 3310
zcma)8U2NOd6}}WnnUrM7iDg+%7MrnUw8CmDO<gZ>+^w;lwMM->EI&mA3<51)EAl8&
zy`<yVlM7?$gBy5=(U%zMf~rHCrAQ0-ArE_On>_4c1E_(+1Ogs548@Q)0l@$xPdk@1
z^;5e*E)UN=_wSr@|Gsno*x4CCkaqrkIXBmV(0^#bOZ>j@>}wG2pesm03ZtU5n=@$!
z%0AUsVAE`YOLGiTScOyhf<NtdWM1tk2x$RiI!;WBko(m@A(##_$cHeq81hWv&if2P
z58-!HI-E!82<C7XW^q@J!Cec!KCcnA%J_)VF$pb-@BvC6RYWW-c6%Kcd`jR0E*({v
zODGw9N~<p>eYP+ytExP&Vw;=EXN{-SYLc--m$0tqwc?zXl~pMF3z~ve9i-rF(ZHlc
zFmO9;Xqu{L2+rkogREpdV>B1wXW@VL2OnKAqcI<Z?nCuM_}#RIL{vtVmUgcNA%knm
zi&UGF+SjMj(#Pv@zy?!hX3(#8*L-E)qPLgGXskIxHyH9)5#`YuYebq_pf{a|lZ?h%
zeqVc;y$`-UZ1~5ZGFx%Zk~h}N6{g+yHLlE&(`ByJlU5JuZW=LfG(wdYkDIkh+pIoD
z_k8VE7*rf=)6&@-+msZx)$(ClHa{Ig#*dmK5{RVM_!rR3wQE-RG7tK>?|XR-?!+4Z
zKEL^QH(zF!(M|RmT4px?>70?4ooRZ}ewyHh`7fa%dZJ#aw`U>QvHF{U1Zhr_70Ef*
z(gM*6l5rhNifqX9vW_LWs7UT<$Aq>NMx8O|b$zLTb*PaIX<@0DHQ?@KvT$dltX4GS
ze37<cX<k!SByGWwy>6}syOWyCc$KT2)D7%9G9f)5{rSF9>7}-QFG)qskQBU-FGA;h
z(Q$l2TJ63-h(;t8l;n#!r&fCIn~*LhyNDl_&gS1+!eoU2%pqI645oiUFSyMD8rWP>
zE?^?kCJx`kS-aD7%bAkhkyEvKS=DVehYj1WYPlR>0hcc>Xf}_jVOzX#GmA@f6>L7M
zYC2B(ZJ#o42OaNSFtIsWutjQ3FUeVeAZo{Euufg1dm%~BFQ=~PnCK}*Cix{jHKS!=
zrHh81DiLiFXF-s2P|jyZRJoYTUWc_F0d9;e=`iyVwJ@R^OG;i#$)!??8q`NiD|Udc
zOvWjaK`_<@zb*p=t)u@1P$2eU|7QRCRNZ%k@2<t-cdmbQ{oW00AXSZ>vSO$H5gYqk
zY^)j^w_@WP!CG{njylCz#^oC`wMh5o%I9G-G741Z0!L<<nl!jIyBm#fN3FgefA#Jc
z*S@^=C$SoxvZ7OFbgFhd@yQ!^-*_-kJ$}|Yes*i7)_c5;xSlLi8#{9^Troadsm5R3
zjrV^Nyc;wVKiipkGz%F}HU6d*f75j6J7^Ex4VlBTc{Oca%}`-juEyuB_`DgP-`m^m
zmFkEAZ(8|o^w^!bkLJviZ|xY5Rv-iV`n;Q0qi<W$x6K2z2dU0dO;qSbU8y?jEI>aJ
zgSUlS!iRy)z=refZTMO%puheTSn93w?93VTO>`<Uo$x&#VxaIi5tuo_KOP;PiStjo
zd8m03=b`4w369EVVi&?JIRRs{t$~7`UpL4=?Hvdt0N_k(s41hxMt`FL{09J>IRM~H
zr2*$)qmd2(I6yCXt?V-zVFCg4G((I7;4PqCp&lPd0N^cS4uf6_YOO({(qgZv4j}vm
z^Z<w-ZH@sDKLtUr)yKnibM3kT#MvJNarS+ddJHfQQWM4jWQSeAR1`^eVad=OIP~5S
zE*z2|IJnyLOXp#M31C|hFYkjJp{}kTbrDWhngB;=Si6`E5IQ?Tqcw?A)<YSEGjfD7
z8cs<sWpT>rQ!2?hM~n2+iUG<bU^;zRP!J*~L9hj|<v<2WKru->{1@0dstW;rvKEbP
zh`T~)<FeH`@Okg2eV_F`n5_!qmN0G#<F!cq_S&tr?MyW?Vns$axLPm*S6qCTslEKl
z?=EhS{r+q<G`t%+di$MQ@0js(JKQ4?GN5W`(h5zQ9(@O0=5EcIeOLaR_)8Kpplax<
z6}oDAw6`0K!WHKyn`~DI-wxdhnLQH^5?>}E1KN4d&8xyWOE_m9M*A0?pQQJeuFY@H
zzcLj?-<%o*{%tfc9cI7nAD$N3$084Mvd0$lg_1@LH9v26(6|5)Z2OIs66A#5CqkFh
z7QA@s#v-&IhL-cc&X=%~m+cN&H}DNvCG;fPB7~VaH^>N?3=J2VjJu0YjAG&GX-6^{
zxd^dPrZGo{c8cnRz5txv`T{)z5jh+AT$qFaw4~ynlG9K};X!{23?PkR>VAMo6LmGH
zhQjO4S3@Vw!>EP^&33AxsM$`nHiZKwYNLON$2NK`@!0m6s+h3E#JV56c<uG|@D{gq
zY5V2MbmjF2LzM~Z*r?evYIUVdGzL^fV|A{V>8_&&I~`^wx5lmRp*jNT2N`)4X8V6H
CQ~_}S

literal 0
HcmV?d00001

diff --git a/app/agent.py b/app/agent.py
new file mode 100644
index 0000000..efa53ea
--- /dev/null
+++ b/app/agent.py
@@ -0,0 +1,160 @@
+import requests
+from typing import Any, Dict, List, Optional
+from langchain.llms.base import LLM
+from langchain.agents import initialize_agent, AgentType, Tool
+from pydantic import Field
+import os
+from dotenv import load_dotenv
+from datetime import datetime
+import wikipedia
+from asteval import Interpreter  # For a safer calculator
+import logging
+from .tools import tools_registry
+
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
+load_dotenv()
+
+LM_STUDIO_API_URL = os.getenv("LM_STUDIO_API_URL", "http://192.168.0.104:1234/v1/chat/completions")
+MODEL_NAME = os.getenv("LM_STUDIO_MODEL", "lmstudio-community/Meta-Llama-3.1-8B-Instruct-GGUF/Meta-Llama-3.1-8B-Instruct-Q4_K_M.gguf")
+CONTENT_TYPE = "application/json"
+
+class LMStudioLLM(LLM):
+    """
+    Custom LangChain LLM to interface with LM Studio API.
+    """
+    api_url: str = Field(default=LM_STUDIO_API_URL, description="The API endpoint for LM Studio.")
+    model: str = Field(default=MODEL_NAME, description="The model path/name.")
+    temperature: float = Field(default=0.7, description="Sampling temperature.")
+    max_tokens: Optional[int] = Field(default=4096, description="Maximum number of tokens to generate.")
+    streaming: bool = Field(default=False, alias="stream", description="Whether to use streaming responses.")
+
+    class Config:
+        populate_by_name = True
+
+    @property
+    def _llm_type(self) -> str:
+        return "lmstudio"
+
+    @property
+    def identifying_params(self) -> Dict[str, Any]:
+        return {
+            "api_url": self.api_url,
+            "model": self.model,
+            "temperature": self.temperature,
+            "max_tokens": self.max_tokens,
+            "stream": self.streaming,
+        }
+
+    def _call(self, prompt: str, stop: Optional[List[str]] = None) -> str:
+        """
+        Generate a response from the LM Studio model.
+
+        Args:
+            prompt (str): The input prompt.
+            stop (Optional[List[str]]): Stop sequences.
+
+        Returns:
+            str: The generated response.
+        """
+        headers = {
+            "Content-Type": CONTENT_TYPE,
+        }
+
+        payload = {
+            "model": self.model,
+            "messages": [
+                {"role": "system", "content": "You are a helpful assistant."},
+                {"role": "user", "content": prompt},
+            ],
+            "temperature": self.temperature,
+            "max_tokens": self.max_tokens if self.max_tokens is not None else -1,
+            "stream": self.streaming,  # Uses alias 'stream'
+        }
+
+        logger.info(f"Payload: {payload}")
+
+        try:
+            response = requests.post(
+                self.api_url,
+                headers=headers,
+                json=payload,
+                timeout=60,
+                stream=self.streaming
+            )
+            response.raise_for_status()
+            logger.info(f"Response content: {response.text}")
+        except requests.RequestException as e:
+            logger.error(f"Failed to connect to LM Studio API: {e}")
+            raise RuntimeError(f"Failed to connect to LM Studio API: {e}")
+
+        if self.streaming:
+            return self._handle_stream(response)
+        else:
+            try:
+                response_json = response.json()
+                choices = response_json.get("choices", [])
+                if not choices:
+                    raise ValueError("No choices found in the response.")
+
+                # Extract the first response's content
+                content = choices[0].get("message", {}).get("content", "")
+                return content.strip()
+            except (ValueError, KeyError) as e:
+                logger.error(f"Invalid response format: {e}")
+                raise RuntimeError(f"Invalid response format: {e}")
+
+    def _handle_stream(self, response: requests.Response) -> str:
+        """
+        Process streaming responses from the LM Studio API.
+
+        Args:
+            response (requests.Response): The streaming response object.
+
+        Returns:
+            str: The concatenated content from the stream.
+        """
+        content = ""
+        try:
+            for line in response.iter_lines():
+                if line:
+                    decoded_line = line.decode('utf-8')
+                    if decoded_line.startswith("data: "):
+                        data = decoded_line[6:]
+                        if data == "[DONE]":
+                            break
+                        try:
+                            json_data = requests.utils.json.loads(data)
+                            choices = json_data.get("choices", [])
+                            for chunk in choices:
+                                delta = chunk.get("delta", {})
+                                piece = delta.get("content", "")
+                                content += piece
+                        except requests.utils.json.JSONDecodeError:
+                            continue
+            return content.strip()
+        except Exception as e:
+            logger.error(f"Error processing streaming response: {e}")
+            raise RuntimeError(f"Error processing streaming response: {e}")
+
+def create_agent(tools: List[Tool]) -> Any:
+    """
+    Initialize the LangChain agent with the provided tools.
+
+    Args:
+        tools (List[Tool]): List of LangChain Tool objects.
+
+    Returns:
+        Any: Initialized agent.
+    """
+    llm = LMStudioLLM()
+
+    agent = initialize_agent(
+        tools=tools,
+        llm=llm,
+        agent=AgentType.ZERO_SHOT_REACT_DESCRIPTION,
+        verbose=False,
+        handle_parsing_errors=True,
+    )
+    return agent
diff --git a/app/database.py b/app/database.py
new file mode 100644
index 0000000..4843c27
--- /dev/null
+++ b/app/database.py
@@ -0,0 +1,15 @@
+from sqlalchemy import create_engine
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.orm import sessionmaker
+import os
+from dotenv import load_dotenv
+
+load_dotenv()
+
+DATABASE_URL = os.getenv("DATABASE_URL", "sqlite:///./app.db")
+
+engine = create_engine(
+    DATABASE_URL, connect_args={"check_same_thread": False} if "sqlite" in DATABASE_URL else {}
+)
+SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+Base = declarative_base()
diff --git a/app/main.py b/app/main.py
new file mode 100644
index 0000000..f38e8c2
--- /dev/null
+++ b/app/main.py
@@ -0,0 +1,175 @@
+# app/main.py
+
+from fastapi import FastAPI, Depends, HTTPException, BackgroundTasks
+from sqlalchemy.orm import Session
+from typing import List
+from . import models, schemas, database, agent, tools
+from .tools import load_tools, add_tool, tools_registry
+from .agent import create_agent
+from datetime import datetime
+import logging
+
+# Initialize logging
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
+# Create the database tables
+models.Base.metadata.create_all(bind=database.engine)
+
+app = FastAPI(title="LangChain FastAPI Service")
+
+# Dependency to get DB session
+def get_db():
+    db = database.SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()
+
+# Load existing tools at startup
+@app.on_event("startup")
+def startup_event():
+    load_tools()
+
+# Helper function to create LangChain tools from registry
+def get_langchain_tools() -> List:
+    tools_list = []
+    for name, func in tools_registry.items():
+        tool = schemas.ToolOut(name=name, description=func.__doc__ or "No description provided.")
+        lc_tool = agent.Tool(
+            name=name,
+            func=func,
+            description=tool.description
+        )
+        tools_list.append(lc_tool)
+    return tools_list
+
+# Endpoint to submit a query
+@app.post("/query", response_model=schemas.QueryResponse)
+def submit_query(request: schemas.QueryRequest, background_tasks: BackgroundTasks, db: Session = Depends(get_db)):
+    """
+    Submit a user query to the agent.
+    """
+    user_input = request.input
+    timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+
+    # Save the question to the database
+    question = models.QuestionModel(query=user_input, answer="", timestamp=timestamp)
+    db.add(question)
+    db.commit()
+    db.refresh(question)
+
+    # Define background task for processing
+    background_tasks.add_task(process_query, question.id, user_input, db)
+
+    return schemas.QueryResponse(output="Your request is being processed.")
+
+def process_query(question_id: int, user_input: str, db: Session):
+    """
+    Process the user query and save the answer.
+    """
+    try:
+        # Create agent with current tools
+        lc_tools = []
+        for name, func in tools_registry.items():
+            tool = agent.Tool(
+                name=name,
+                func=func,
+                description=func.__doc__ or "No description provided."
+            )
+            lc_tools.append(tool)
+
+        langchain_agent = agent.create_agent(lc_tools)
+
+        # Invoke the agent
+        response = langchain_agent({"input": user_input})
+        answer = response["output"]
+
+        # Update the question with the answer
+        db_question = db.query(models.QuestionModel).filter(models.QuestionModel.id == question_id).first()
+        db_question.answer = answer
+        db.commit()
+
+        # Optionally, save each step as separate answers
+        answer_model = models.AnswerModel(question_id=question_id, content=answer, timestamp=datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
+        db.add(answer_model)
+        db.commit()
+
+        logger.info(f"Processed query {question_id}: {user_input} -> {answer}")
+    except Exception as e:
+        logger.error(f"Error processing query {question_id}: {e}")
+        db_question = db.query(models.QuestionModel).filter(models.QuestionModel.id == question_id).first()
+        db_question.answer = f"Error processing the query: {e}"
+        db.commit()
+
+# Endpoint to register a new tool
+@app.post("/tools", response_model=schemas.ToolOut)
+def register_tool(tool: schemas.ToolCreate, db: Session = Depends(get_db)):
+    """
+    Register a new tool.
+    """
+    # Check if tool with the same name exists
+    existing_tool = db.query(models.ToolModel).filter(models.ToolModel.name == tool.name).first()
+    if existing_tool:
+        raise HTTPException(status_code=400, detail="Tool with this name already exists.")
+
+    # Create a new tool
+    new_tool = models.ToolModel(
+        name=tool.name,
+        description=tool.description,
+        function_code=tool.function_code
+    )
+    db.add(new_tool)
+    db.commit()
+    db.refresh(new_tool)
+
+    # Add to the registry
+    add_tool(new_tool)
+
+    return schemas.ToolOut(id=new_tool.id, name=new_tool.name, description=new_tool.description)
+
+# Endpoint to list all tools
+@app.get("/tools", response_model=List[schemas.ToolOut])
+def list_tools(db: Session = Depends(get_db)):
+    """
+    List all registered tools.
+    """
+    tool_models = db.query(models.ToolModel).all()
+    return [schemas.ToolOut(id=tool.id, name=tool.name, description=tool.description) for tool in tool_models]
+
+# Endpoint to get a specific tool by ID
+@app.get("/tools/{tool_id}", response_model=schemas.ToolOut)
+def get_tool(tool_id: int, db: Session = Depends(get_db)):
+    """
+    Get details of a specific tool.
+    """
+    tool = db.query(models.ToolModel).filter(models.ToolModel.id == tool_id).first()
+    if not tool:
+        raise HTTPException(status_code=404, detail="Tool not found.")
+    return schemas.ToolOut(id=tool.id, name=tool.name, description=tool.description)
+
+@app.get("/answer/{question_id}", response_model=schemas.AnswerResponse)
+def get_answer(question_id: int, db: Session = Depends(get_db)):
+    """
+    Получить ответ по ID вопроса.
+    """
+    # Поиск вопроса в базе данных по ID
+    question = db.query(models.QuestionModel).filter(models.QuestionModel.id == question_id).first()
+    
+    if not question:
+        raise HTTPException(status_code=404, detail="Вопрос не найден.")
+    
+    if not question.answer:
+        return schemas.AnswerResponse(
+            id=question.id,
+            query=question.query,
+            answer="Ответ ещё обрабатывается.",
+            timestamp=question.timestamp
+        )
+    
+    return schemas.AnswerResponse(
+        id=question.id,
+        query=question.query,
+        answer=question.answer,
+        timestamp=question.timestamp
+    )
\ No newline at end of file
diff --git a/app/models.py b/app/models.py
new file mode 100644
index 0000000..2ab9224
--- /dev/null
+++ b/app/models.py
@@ -0,0 +1,33 @@
+# app/models.py
+
+from sqlalchemy import Column, Integer, String, Text, ForeignKey
+from sqlalchemy.orm import relationship
+from .database import Base
+
+class ToolModel(Base):
+    __tablename__ = "tools"
+
+    id = Column(Integer, primary_key=True, index=True)
+    name = Column(String, unique=True, index=True, nullable=False)
+    description = Column(Text, nullable=False)
+    function_code = Column(Text, nullable=False)  # Store function as code (for simplicity)
+
+class QuestionModel(Base):
+    __tablename__ = "questions"
+
+    id = Column(Integer, primary_key=True, index=True)
+    query = Column(Text, nullable=False)
+    answer = Column(Text, nullable=False)
+    timestamp = Column(String, nullable=False)
+
+class AnswerModel(Base):
+    __tablename__ = "answers"
+
+    id = Column(Integer, primary_key=True, index=True)
+    question_id = Column(Integer, ForeignKey("questions.id"))
+    content = Column(Text, nullable=False)
+    timestamp = Column(String, nullable=False)
+
+    question = relationship("QuestionModel", back_populates="answers")
+
+QuestionModel.answers = relationship("AnswerModel", back_populates="question")
diff --git a/app/schemas.py b/app/schemas.py
new file mode 100644
index 0000000..0e2f3af
--- /dev/null
+++ b/app/schemas.py
@@ -0,0 +1,30 @@
+from pydantic import BaseModel
+from typing import Optional
+
+class ToolCreate(BaseModel):
+    name: str
+    description: str
+    function_code: str  # The Python code for the tool function
+
+class ToolOut(BaseModel):
+    id: int
+    name: str
+    description: str
+
+    class Config:
+        orm_mode = True
+
+class QueryRequest(BaseModel):
+    input: str
+
+class QueryResponse(BaseModel):
+    output: str
+
+class AnswerResponse(BaseModel):
+    id: int
+    query: str
+    answer: str
+    timestamp: str
+
+    class Config:
+        orm_mode = True
\ No newline at end of file
diff --git a/app/tools.py b/app/tools.py
new file mode 100644
index 0000000..ed0172d
--- /dev/null
+++ b/app/tools.py
@@ -0,0 +1,55 @@
+# app/tools.py
+
+import importlib
+import logging
+from typing import Callable, Dict
+from .database import SessionLocal
+from . import models
+import wikipedia
+from asteval import Interpreter  # Ensure necessary imports are available
+
+logger = logging.getLogger(__name__)
+
+# Dictionary to store tool functions
+tools_registry: Dict[str, Callable[[str], str]] = {}
+
+def load_tools():
+    """
+    Load tools from the database and register them.
+    Assumes that function_code contains the body of the function.
+    """
+    db = SessionLocal()
+    try:
+        tool_models = db.query(models.ToolModel).all()
+        for tool in tool_models:
+            if tool.name not in tools_registry:
+                # Dynamically create function from code
+                try:
+                    namespace = {}
+                    exec(tool.function_code, globals(), namespace)
+                    func = namespace.get('tool_function')
+                    if func:
+                        tools_registry[tool.name] = func
+                        logger.info(f"Loaded tool: {tool.name}")
+                    else:
+                        logger.error(f"Function 'tool_function' not defined in tool: {tool.name}")
+                except Exception as e:
+                    logger.error(f"Error loading tool {tool.name}: {e}")
+    finally:
+        db.close()
+
+def add_tool(tool: models.ToolModel):
+    """
+    Add a tool to the registry.
+    """
+    try:
+        namespace = {}
+        exec(tool.function_code, globals(), namespace)
+        func = namespace.get('tool_function')
+        if func:
+            tools_registry[tool.name] = func
+            logger.info(f"Registered new tool: {tool.name}")
+        else:
+            logger.error(f"Function 'tool_function' not defined in tool: {tool.name}")
+    except Exception as e:
+        logger.error(f"Error adding tool {tool.name}: {e}")