From 3941a81998ce4b25e9b33f2da00280c310baa87f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Nicol=C3=A1s=20S=C3=A1nchez?= <nicolassanchez@tutanota.com>
Date: Wed, 1 Jan 2025 18:12:45 -0300
Subject: [PATCH] connectors ready except gateio

---
 .../__pycache__/earn_binance.cpython-311.pyc  | Bin 10476 -> 10523 bytes
 .../__pycache__/earn_gateio.cpython-311.pyc   | Bin 3933 -> 4263 bytes
 .../__pycache__/earn_okx.cpython-311.pyc      | Bin 6005 -> 8596 bytes
 libraries/wrappers/earn_binance.py            |   4 +-
 libraries/wrappers/earn_gateio.py             |  57 ++++++------------
 libraries/wrappers/earn_okx.py                |  10 +--
 main.py                                       |   2 +-
 7 files changed, 28 insertions(+), 45 deletions(-)

diff --git a/libraries/wrappers/__pycache__/earn_binance.cpython-311.pyc b/libraries/wrappers/__pycache__/earn_binance.cpython-311.pyc
index 958bd0b916a4bd147daf6f28ede87a6ddcf954c2..3fed72d4c8506963c1543e7cde0798f189d99d7c 100644
GIT binary patch
delta 355
zcmaD8I6H`UIWI340}wo!Qkq`6k(ZN^F=4Veqk*Yt3Reqb6i13!3J;LxOyO-|h~i4&
z1Crb+{6LZ?MLb0iD8ri~1my9ha0WAIN^GuTROVy!n>=6i(dKFac}5lypvjYG3i?cb
zBgVla4&>Zo%PvnWN-v)LS4?U$uaK_BY@lER!v`T&PKg`h4iieIR9_KyxF8+|L<dTM
z#ECKpXR;!Hxx{CXc}=1c3^TYK6_^(pJ4!PjlxB5Q*!)Il9wVdc=5CQZCPv52zr<u1
zS&N*3YB%dk+-2fi$x_4z<P<qh?iP`mtRVe!@)aS;$@&uaH~*Dc!^r5nd6gUoBd0%5
z$t`9_A0MFeA8($g;K|77IQf^D>||D@?~Kly|0=PA%w|=!W}NJ(CJyvvn3|t}6Ubb5
Z5a9(P{3dTvGhqBa`Kemb<{<T1i~t@=W~BfC

delta 324
zcmbOo^d^vZIWI340}!Ysm8QpS<mF^!jGHXZXkg6Q!VtxgBAUY8!WhMw!UN=SrSJkt
z?i4;C$&(_MA^?=(O%Vk0_)>&|88pQ=*DxycO*WFa&mzglz%V&SR(<k1fzOkd33^ZF
zmuBa<#g<*3Sd?BoSz20hvb>P4@-(2e4GbTISUDwbh&xOunNod4+~I<_7Z4pVgV2-f
z*vlvD%1CZz5uVG)=r&nGT4wV;ksu~Ur_F-mGK`a73rS9PlexcHQ1TxmQ<39lC24LT
z?J`+k;?ZVR*)@!ej+-yZaWFEvY`!gT0@O8GP+WGhuF`i#pUtYu>>y)wRjnDt{4|+D
vinM{w(PR!OVgk}&&g2F)KLKYD&jUnwg9!i0_tXp+KTYOWFWTIuK9vywUF26T

diff --git a/libraries/wrappers/__pycache__/earn_gateio.cpython-311.pyc b/libraries/wrappers/__pycache__/earn_gateio.cpython-311.pyc
index 4f324eea7efc751be35e31d73dfa67fedeec4009..e724e5ad8675b470a8db557176b5eb38cbdfffb8 100644
GIT binary patch
delta 798
zcmZ`%L2DC16yDh+yUA{LH*V6ThY~lG5?5oALr7GLwo=6^4V2{6gCS;?5R6HgBnPDu
zg&b5ADbKTbvWOS8zrcTBq+qFf=-Er93O$MQHj*ONf%)FN@B7}oc`#q&8wqVg(-Z;M
z^IrYux^_S)NW@z74ulnnMyNa>D>9v+0UrHS;cS3LX^>|M)p({-onw$195ouF$GD<X
zlV=7Emjruqvq64&VM@^y4{w5d|2nk2$><t+Nd)0F-=lR`ToYf2F!V<t?$i4v;T0*`
z9;S13CscR3m0qh+sr49hTD99O&S|b1Jg`Z$$kgdp8_iA!TUeIG!pNFfxXRkJSL;?r
zjyv&swd*w66{pHt>3?;+xsyD}@t&}4MxUMjWM)5_**B4)ncp(=59Dnl`n3P3KQyc@
z!}{R2;D(g)u^C<f>(YHP4Pp7*G^Q-Z!S;<Fd5WKR6y{LJxmBq)n=A#Za!E>}FAEvf
zCNr=vUz5<svYQM3CLtMk8+aT$yz0-quB8BFr6`>lm#bqN%flCCNt!)cs;P_8+(>$-
zrg_s{HA)I_pk59wxHQ59hnff8tH-Ct*V^90L0Af11$Y=-&RzMds%VR4W^>B+l$nT<
zn-F#uIl?Ys2!XEU(kD>OAmk9-QO@IO4&fq#`y#i&Rk*1o$TxVR%^IRFu_uf{fq6X%
id)ltD%uDb)bq4TRU%D_)NMuhq8o#^zkN>Fd{J#MfkFmf2

delta 545
zcmZvWO-n*S6owtO@p|u_d#yBu!m>o2l8{salPnA&LLqczP!uC=3}vcCtrA=YA!qAe
zT1(6NA(BD=prA#oXhuPU9GK^Pyze<Poj~7DI)tbeaeQaj=d~93M#q5BQg)W%CMsj*
zW{QXo=4@KZ3iB{cR8FRgN@YY)V}_v4=9o(;giVXeU^7Jv^>%CM#||w=*!GAD@a$+H
zKV+2DN=UrMy#jQKn=%gz^i*D9mCD7*X|>8D&{m3gS!z)@(kTkTqVoU`2BY1&vx?9v
z^woRsc$ICuipSwjE8zHOTpQW=1}J(SZ%&pT^nJWFl-~4p-)M>sm-p;fH}#6x9wa%O
z8T#skE{uKlKc9$5LmZySVIn*5N_Yec)LP;}kx*NSTV;1pAfA*x#CK&dA!Q`!np9&F
z35k?MT4GybM`BMR2W=yOUg5<^L&FS1%zRh#LO|kP-om^qpG+h7hvh#$W$$Z(F!<^(
D-m-0_

diff --git a/libraries/wrappers/__pycache__/earn_okx.cpython-311.pyc b/libraries/wrappers/__pycache__/earn_okx.cpython-311.pyc
index 5211b8721125ff710a4dcf73b49fafaa4085dbc4..46cbfcd4cf1bf23a3c08bcd6eca2b0519837b386 100644
GIT binary patch
literal 8596
zcmeHNU2Gf25x(P(bfRpXY)Y1FCGkZzU`vTaS&@IECXp;UQ6W=~B)bhA`*ONFO0-EH
zvwM^*Mgm+QD1;y=f+9tXJ`_eC+_**yw`dDLx<Cu0Z=}E?#sL8e^r6U`3iT;Zo!R>#
zkD?VP28urPEY9uC?C$N(d^<C{=U?vL9pT_w{<yGkp_AkOfe-E#atd2>Q22z?xFo0X
zS|Gz`1IYkymxI|*GUSxQ*`{O@D+e>pSs^L#T!4F>(?aiaTKG<Y<L<%FzLG6kV3zA^
zDt-`IG|fCc6N@b`FAo~mZw#tNHl`UW9auUZ({r&ysdP@ssc9uMkSB&#P|X3F&gL`v
zfUc0-Kq{l(NY7{Vh}X|T+FUHmvu>a}C7+JvSIk8tHvmtu`HV3i%PQ2=NerLk&__DA
zFqmJ7M83kICHi=)bwM{}XeeLTS5#-f?B))CYaJdx;dCy^gHi$-|2~%tY5|}jEeJG>
zQ%*K%VW7=g6Hq~G2HK)^X)W*b$%qz#r&g^M=q_y+(B0Z@plw>WCW2gqdhKv;*Y*H+
zkG2=+UM&hVs_oZ0LDHe^gQreS03{x<1el79>QMQb;Wk4#2)`|hjn=G@Y5W~{y617;
zhI(uKT3{_`VhiWG=FXQ}<yQl%FhebPCk*Z2XJ4zF?A140TrS65tJZjY%O<zJDY_+S
zDY)ew-s!zb<6!=wgcSq@oU{0$z6inbSj~=It%y??yD(|BqK3fOXj-fJTp_2ygB5WK
ztVYUa+BL>h)hOglE8-Mb4aH_+jlPf-qIxD}H9J_bB3PihN_1$IS18Rd5{2p%7m@_m
z*KfoYjjSHarBx%N(Ab2b7P5NIq_GRcxTdR6P<7jqu}pfNC?u`Z*fLS_d7aQ0j$ekE
z0$MFWmeaYkDa*w@uJH$57OIoxf!yT2>_2{AFZYjD`bW#ck@e<}4%|w9+0$F;8Tf4B
ze(~X%&kLnXZ<TwJm7e5!s3LTKS6NBuhQBR%C#QO-fd{k({<eM!<P&a{y9Rgry6vIQ
z<>37e{O);-wZJN@uKnJ#7N{u)tK|vqO7~h25E`oTR{85}BqRd-aFwru>zd_0+^;nO
zcAASnilAlin$gVy$x+E%)TI>BbxB!L(isJui!`rfzz6A)k&+ZiHPSf={;-}&6hx8a
zz(P7|5XRTvEu@!}4A|BaIW6=X>Y|cc(EGgiS|Lp_6@r7cnl;^omr^UJs$gU`f^jAD
zPgetd0kQ|{MVX6ou;`5LZiwtfSqKMc2@aQ9p|q)IJq(h4UVCTovQxA8jE5xby-teF
z=sQ4ea+?Cz(Oroi`XYLABYLtNJza^OUKbv9Jag+(rQ`7JH!B@SK5MCT3~zFQmZOZU
zPdpN%AH_d>@0PY9_LjunM_oO)zF+A&QfhbpHiKOIp}&iJ*D2|Smox@Z5hPC!A`dJz
zVDf>b23Q_gLI9R<f*gPmkY|uQi{v>VV3IbtS-VhauF{DFtVTL_JxpVr*GZqpPB8f1
z<Q_%4n8t@TqC@5Aa3wli)%ers85gH}c>!Y_I8UNybkUd*)Q1IJis+b?zrq^#a6U(r
z98Kv&!dX&SVn(*%8Zr%g3EIBcT|ZtoUSUS3c_T-4Nxz|BLU6{D;A(!)_tdKzn%;Xx
z>K*ER(J#o-1?1PWaY+LIvaj;?ev#7)D<wxKHSFf(@sVRAC+j+6m0&$%g^RNja}C9r
zG&l>plSXpX7PddpNT_5@lno6YYa}%d6dpU(yKOFOKF$^2(;AK%FOO>lj-9gj69gml
zT?h1S%$DdYm}wmsL=d=ElagieQ*fpA>%ryArXf4Xukk?*q<zpWJpu%LP`~SghBu<a
z_eUNyJun}h{XAHXPF12)ur|c5b<uVu{{s+rX6IsAav%;<tc@O?roF=dA#P((>izFP
zob&^@2*Qk^oV<Xg0U$d;*RkSbpzBD{rMl2Px(&MY;YdU1vIGWN;)O8A-_{u*Pv)Kd
zNj@f1;FWo0KXl_k>~-C=Qyyw6rjy~gOK;GtH4AC0na=8VRaY(%$a8dRN-4})UX=7D
z9WtYo>(y;<zpPM+7F1QIG*!q{yR7!jyf^e^yYrpgIHKXPuAB)U>$g$rj|s?eFBf0O
z29Gyzp<b<>op`m{&d%Jc=Q?%p&Hkw5*1&sjI!C?0AjM*uo+r8rw$eNe)>datm@U!k
zJBr__ds>)>4Gs$+CfIVPs&*u46oT9l^qR)xw;wLUlO6jSMX+k;D|r^gk8KZSSjQjE
zkaK0bT6^7q@6%qjshiHVxgeLBGW&vda&5B})l3^XIjxZxEJljU65eK~)_a}gnW5iq
zT<odOtZRfx?BO5~2x=of&+tk)I$nv6`+`|Rk8lE7e;1E1%iZM@FyU5cZ|%cz=L_?h
zv?|XVgc!@P!%P_v>2X)VLOR8_yYpoAy)BaL9L~_<LEl`rSGWOvP~46|QY%I);=wP(
z6C2`*`({}jt%#!~VU&gKgc^c6?u9uAbAG>o0!%e{vvZZZ?Mi+3)w;6{NJhD9-d^)|
ztpdGvtGtQHuXC*i{Ekx#_@qI<^bU;ko;Ox-u)*T5J#0-UrrwgqW@qDbv(jWjntLNI
zox7Nrm`uDbjh#I^eK9d7ogGU^<8kTYY<xmGH$5ZGUL2o2J2QD<ZgM*DqI7=xQrv4c
zE1jE}KJRsoz0J*x`Ffk1_G;I@WIPUC$KAfiK~#0b2}{Tq2<%F!4o4bn8>1{O$OK%B
zjf@_uEWsw10y^w!GSM|Xo5wX^1*u8;?42jW2pI$|S|My*7c}>Pr=coI&+9H&iU&Nb
zY?G}*H*^vREQ<)Yt9^YGwm@G*4{t;d-<~T+`zz6YwyR_SdU->9`N70r4n0i$>4iVP
z@OklXm#>y&wR~BtT-M5>UJ><@pl{Cx@dS#Y>Jk*5Yyp|x$ri_L!wGDK8ld4*&tMJ^
zX5tg^_<1n*4<@Ik(DoOm#?HcHV}LZoKtm&Y?{Pp-kBzZ&bMYAo-+rE<s|o?D*|8`~
zd%)MBM<A~vc@2o;{Hpf#d%QMmtY<x|c6nCy3w{h;(W5|^N!vRbnQo<&yiyjgR>Z3%
z;pz?+n}Keg-eUek=~<4PvS-U2Vmk$g2uC=WqT8$CHIUx51A(oJF<|(0Az&i}f6cj^
z%lZk{#;sA+^9^l?L-#xWKp%|!cIEdgWpS(`j+KNld*ZdO3LOlCD!R`no4DUitp)th
zeUf7}e-F5$FP`*3R(o7FJhDjPxJ)O?f-X5KlTZs@ZTsW|X9UNkOA9j~b76KGm<(p*
z4Ji54NnQa?vD3p7hA7uJ;fW$W4g}C7a1NSkBguN`OL6Z<Be$A99=*+f{OWBurWz=V
zgB5YGBn)oXFlra=zV+RsDT5CLOa>p82iTs|Jr=56M^@AIWrZwI-+XQFn>T10eQVvs
zUG~p$;{E_SydlCKxGbKkh^I=zDK@#U)}wHahO=@n)IP(|2o#<KL;k~9XL*qG(AqbX
zR>((}<mGfuGnW0+vA?9)$CSkmzZq>V#&g;Qq`D?>GG%e3B94@Vk;Zmnvv^87xp@ye
zN_Cg{Vw#!;Ss}Q`s?Bx?Mu?gn9s;qh&8OJJZ<d!f#Fy?*l*Q8(@pMTzy?rid5r#SZ
z2nS!-Ab_NK$jX8VD;$Ruj1+^3*w|fH-SAPt{se}Z=QO?#72#!`T`YrxF9k+U$-wYZ
zru=TfFqNX@(>#7lsH=g7-r5ZWtkB+dtFt5?EC~ng@p`Efh#xav@<WgjOk~|`kqr)O
zyV)Wen-k<&;s7~>Y7nh%Yz=Ds3j4l-q#KCu3)eRehse;R){a&u>ZqE&xTAQ^r=e}~
z-}uI01;?hQd?(c3I1p#OSRoU(Fbzz{KuC1(2pW|g5Z1x1PWn6FkhZP!2B@l9$<5a;
zV;`8W*(1Uj17LFYG2N&spFLpTxs=wIi_iO%)u_rJeS@>3Do@@7ZXZunyzRp;SUDxD
z%d!=b<t%*J&0u+#4473iwuGQ#Acv9QsUI0aGK>V*K6x3*IFdLLOcq(dAQ!NN=jLqL
zlDDz+4w88!DI|+X5U~tZZ0ANWwPU0W3Umg5f7AQ783=_h^P5}^Z4<)LP0l0x!uaTs
z_I=^*P0l03o%raHp&oqn$S5EF-X`Y}p*fs_cWt8`;jj$+8rsf>$AMErg>X2ARU85p
zPNUo*0v|q(kF^ANXOLG*fF~i(A>ZneHLGjkb!Dp?HQg7nnq?Wj^n=w~0a1g_r&`hi
zLYs5W{scgFc^v0cEWuBlRx5mH)!@_|{%-(f-+gTh`mOr4FlvMA74j}LLT^TY24pkH
y^ZaHY%!fc*K-xI|xf1tm?cXE+BZwMt4wX3H-)2)fz=Pfz(|<AkzaJxI+W8M}F_TLG

delta 950
zcmb7?OKVd>6vyxB<L1#k+M8!@lJ*u+xV160jZ|YXCV>)?*cOAeri&t(5`<doG^yB?
zlrFmV2qLa@BUwstmxUX@gLEPI1w>In+~_$sZE?{C9Js$Za~}UWGjpHieqQjral4%g
zjrr|HZQb?OV*+gBWjJ@sFVsD#*o19Qsn~^`=nxK~Q#gqOA|PB8cL~36)9e-=@_K}q
z=oN#+K@k)hMTUfrR+{K9D`u$m0cKTvp$4$6r=DtCV7BVoC%_e_1DE|-h__z)cOf)M
z4atiHvsY?tk1?h&8N32BxDk8}CJu#S8mBb>O_|2)p*W;l8=)Y?#<_@7WQwrWOE3&W
z2HBIqS79A;*bXCUEe;DP;=AD;)#P9rFX<&%z+JsT!C$(eoo9g_OQ2Jq$MMJ*l(7_<
zP5}7_==-h`o-0BrE0T4ZN9`XtH{}D-sMc5S37Nrmq?o_W`8L86<)hcPUzcIBtE_Z1
zPE(Zy%4qg<?j?hFqJ`87dE^bo|Eb6Y{2ZNASFLi4$MlJ=n;t&KL0|px<{F*jQ7orc
zJGJj)fywT*eVvAjoIl0LpkrkIOwFoiaO>8!nILmy(^TfkhdU$5>;y-Xj2XsNMuL%L
z%rWwe5@V5Zld;5DW)$$xNEFUubTp0oqqyY%szCoC?8lbn>%KfG<yZ<I8daSisB;|t
i)qdM&@6+S2uU(UO@rzMQR{&_=lljf^|2QRTiT(xTT)b-l

diff --git a/libraries/wrappers/earn_binance.py b/libraries/wrappers/earn_binance.py
index b5856dd..9e5f316 100644
--- a/libraries/wrappers/earn_binance.py
+++ b/libraries/wrappers/earn_binance.py
@@ -60,7 +60,7 @@ class binance_earn:
             return None
 
 
-    def get_position(self, **kwargs):
+    def get_position(self, coin=None, **kwargs):
         '''
         asset (str, optional)
         productId (str, optional)
@@ -70,7 +70,7 @@ class binance_earn:
         '''
 
         try:
-            response = self.client.get_flexible_product_position(**kwargs)
+            response = self.client.get_flexible_product_position(asset=coin, **kwargs)
             return response
         except ClientError as error:
             print("Found error. status: {}, error code: {}, error message: {}".format(error.status_code, error.error_code, error.error_message))
diff --git a/libraries/wrappers/earn_gateio.py b/libraries/wrappers/earn_gateio.py
index 3ee8e5a..2bdcb39 100644
--- a/libraries/wrappers/earn_gateio.py
+++ b/libraries/wrappers/earn_gateio.py
@@ -2,68 +2,51 @@
 https://www.gate.io/docs/developers/apiv4/#earnuni
 '''
 
-from gate_api import ApiClient, Configuration, EarnApi, EarnUniApi
+# Implement from scratch, gateio python connector is AWFUL.
+
 from credentials import get_api_key
 
 class gateio_earn:
     def __init__(self):
         api_key, api_secret = get_api_key("gateio")
-        config = Configuration(key=api_key, secret=api_secret)
-        self.earn_api = EarnUniApi(ApiClient(config))
     
     
     def get_trading_balance(self, coin):
         '''
         Returns the free available balance of a coin in the trading account (or the equivalent account in the exchange)
         '''
-        return 0.0       
+        return {"Error": "To be implemented"}
     
-    def get_available_products(self, coin):
-        currency_list = self.earn_api.list_uni_currencies()
-        return_list = []
-        for item in currency_list:
-            if item.to_dict()["currency"] == coin:
-                return_list.append(item.to_dict())
-        return return_list
+    
+    def get_available_products(self,coin):
+        return {"Error": "To be implemented"}
+    
+    def get_product_detail(self,coin):
+        return {"Error": "To be implemented"}  
   
-  
-    def subscribe_product(self, product_id, amount, auto_subscribe=True, source_account="SPOT"):
-        return None
-
+    def subscribe_product(self, coin, amount, rate):
+        return {"Error": "To be implemented"}
 
     def redeem_product(self, product_id, redeem_all=True, amount=0, destination_account="SPOT"):
-        return None
-
+        return {"Error": "To be implemented"}
 
     def get_position(self, **kwargs):
-        return None
-
+        return {"Error": "To be implemented"}
 
     def get_account(self, coin, recv_window=5000):
-        return_list = []
-        earn_list = self.earn_api.list_user_uni_lends()
-        for item in earn_list:
-            if item.to_dict["currency"]==coin:
-                return_list.append(item.to_dict())
-        return return_list
-
+        return {"Error": "To be implemented"}
 
     def get_personal_left_quota(self, product_id, **kwargs):
-        return None
-
+        return {"Error": "To be implemented"}
 
     def get_subscription_record(self, **kwargs):
-        return None  
-        
-
+        return {"Error": "To be implemented"}
+    
     def get_redemption_record(self, **kwargs):
-        return None  
-
+        return {"Error": "To be implemented"}
 
     def get_rewards_history(self, type="ALL", **kwargs):
-        return None
-
+        return {"Error": "To be implemented"}
 
     def get_subscription_preview(self, product_id, amount, **kwargs):
-        return None  
-        
\ No newline at end of file
+        return {"Error": "To be implemented"}        
\ No newline at end of file
diff --git a/libraries/wrappers/earn_okx.py b/libraries/wrappers/earn_okx.py
index 2c16d6d..a2502fb 100644
--- a/libraries/wrappers/earn_okx.py
+++ b/libraries/wrappers/earn_okx.py
@@ -164,20 +164,20 @@ class okx_earn:
 
 
     def get_personal_left_quota(self, product_id, **kwargs):
-        return None
+        return {"Error": "N/A"}
 
 
     def get_subscription_record(self, **kwargs):
-        return None  
+        return {"Error": "N/A"}
         
 
     def get_redemption_record(self, **kwargs):
-        return None  
+        return {"Error": "N/A"}
 
 
     def get_rewards_history(self, type="ALL", **kwargs):
-        return None
+        return {"Error": "N/A"}
 
 
     def get_subscription_preview(self, product_id, amount, **kwargs):
-        return None  
\ No newline at end of file
+        return {"Error": "N/A"}
\ No newline at end of file
diff --git a/main.py b/main.py
index 14d1613..3db1a07 100644
--- a/main.py
+++ b/main.py
@@ -12,6 +12,6 @@ gateio = earn_gateio.gateio_earn()
 
 if __name__=="__main__":
     #Available products
-    print(okx.get_funding_balance("USDT"))
+    print(gateio.get_product_detail("USDT"))