From a639bde5beed2198fe5665b955969aa2d70c2c6b Mon Sep 17 00:00:00 2001
From: Mars-Ares <56955817+Mars-Ares@users.noreply.github.com>
Date: Thu, 24 Oct 2019 10:33:26 +0200
Subject: [PATCH] Added BLE terminal

Use  sudo ./gattctl.py --connect address to open an terminal.
'ESC' + your text + ENTER to send a message
---
 examples/read_firmware_version.py |   1 +
 gatt/__init__.pyc                 | Bin 0 -> 288 bytes
 gatt/errors.pyc                   | Bin 0 -> 1762 bytes
 gatt/gatt.pyc                     | Bin 0 -> 409 bytes
 gatt/gatt_linux.py                |   5 +-
 gatt/gatt_linux.pyc               | Bin 0 -> 29337 bytes
 gattctl.py                        | 107 ++++++++++++++++++++++++++++--
 7 files changed, 108 insertions(+), 5 deletions(-)
 create mode 100644 gatt/__init__.pyc
 create mode 100644 gatt/errors.pyc
 create mode 100644 gatt/gatt.pyc
 create mode 100644 gatt/gatt_linux.pyc

diff --git a/examples/read_firmware_version.py b/examples/read_firmware_version.py
index 3e5f031..8bb929f 100644
--- a/examples/read_firmware_version.py
+++ b/examples/read_firmware_version.py
@@ -29,4 +29,5 @@ def characteristic_value_updated(self, characteristic, value):
 device = AnyDevice(manager=manager, mac_address=args.mac_address)
 device.connect()
 
+
 manager.run()
diff --git a/gatt/__init__.pyc b/gatt/__init__.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..67f78de1fb76b125d5caa69b5a8fc18683d1d15e
GIT binary patch
literal 288
zcmYjL!Ait15S_GD7h(Mj>17RjUqslw>Y?kY2qmOLn<Yu5nHBsUZ~GnlNq&I7h=?KY
z&E(DSUdqqq_1F62#nSI7P#=JF3+izdd7_}GRTK(p3koH*C54LGid0|FzAmxq6sWF1
zvIOn;%~^gl(F{Dx<)0!~X!ktlsobF7j%GGicy>vgeX1{@Nwyh`NP|jEc5d>&njBOE
z|0wP7)Z-LbAB^`LBkSk$$)8Ua&I1RIl5{p(y}rvh#Z@o~aX*soIv1UE-5q8N7;VDT
LA3fja$OO<gFoHmv

literal 0
HcmV?d00001

diff --git a/gatt/errors.pyc b/gatt/errors.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..4d37f762fcf335d498a1065cab292ca9dd93f66e
GIT binary patch
literal 1762
zcmd6n&uiN-6vv+v=jWQPEv&G^?zv=U_c4~y4hE$Zr4&{QL0GSehb<dP8B4G2U$R^8
z`w#jj^$%#@b0#;?OD+N1=t=t6lD>L+dd<f{|LN1;s~G-2O{%|AvH!>@00g)WKm~9I
za0~GBk~$4fn-y(<3O#LAv<a&1X{VwgsII5Iinc)YJ$+NrHmDs>2Nmsr+V%8pMZ2K(
zU^3h%;ckb_IF8ZUBh(41YJUNJ_(sKc$<XF#KVmYZHVhkN9OLO!%M7Pe*DpI+t`;eE
zSAP+LvSoRiXr5;n{gP>lT4QwnaGyTh$8%|Bn4xwynn~wI#nR1lJ<6nYXi5~JF}blH
zi>2TRS(WAW+ktCS^<5_E=As1;7d(7R5;-VZRJ=s?%MX2K@|htIZ|d8v%M3|YZ%yVw
zDf72X6Llfe1)iXuxp{5mvPTDNa=Cq)yYYg8#UwX1I)4sHzE=MH`I3-Qfl@7N<IWC=
zdbcK$QviuPLz5-W)ySLdz4xz$P8LOxn>q>QyY%5j=;@GwV{`l`#=<4JF0+^5{2=)D
k365#O;Uf4r1aDRFfbArvGFyLM<>xPD4&9}-4#V~L8AK&~00000

literal 0
HcmV?d00001

diff --git a/gatt/gatt.pyc b/gatt/gatt.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..0e9dec2da98826706af6f5034887da02d9839ce5
GIT binary patch
literal 409
zcmYjM!AiqG5S`sLQ9^R*)gLHAjow9yc(5Q9+61KtAvSB1xVx#@iP&@h#9P0kpX3MB
z*`U>7_RYLEFmK2C3jO`X=hFgy!l62%XB0tB$v^_k4?Tl91Hqu;upyDdD~Bcp0Z=(m
z^&od3@4<#!w4*8HF616a7vi__mv|6s{~sZj+2DvA%RR*eU25-2-F{%-cH>F%m_Cf-
z+xsL=Z?2OWGLp|rivtTCKkYUkCte#orm~V5zSNCEkBC_t6bh}2(C=kaYqZBM1)^_j
zhM3CE^FR%@&t^bF_yaQ{8Wpt?QI$z4v=&jk+sfT`QDn_hD523rcH3~Z#-i3km637N
eNgbS#Zhv>F>b#ZW${t_>f`A3Q&rVp#L+2Z*vs?WD

literal 0
HcmV?d00001

diff --git a/gatt/gatt_linux.py b/gatt/gatt_linux.py
index 5fdb9d7..44b31f5 100644
--- a/gatt/gatt_linux.py
+++ b/gatt/gatt_linux.py
@@ -63,6 +63,7 @@ def run(self):
         This call blocks until you call `stop()` to stop the main loop.
         """
 
+
         if self._main_loop:
             return
 
@@ -86,7 +87,7 @@ def disconnect_signals():
             self._properties_changed_signal.remove()
             self._interface_added_signal.remove()
 
-        self._main_loop = GObject.MainLoop()
+        self._main_loop = GObject.MainLoop.new(None, False)  # modification to launch run in a thread
         try:
             self._main_loop.run()
             disconnect_signals()
@@ -605,6 +606,7 @@ def write_value(self, value, offset=0):
         :param value: array of bytes to be written
         :param offset: offset from where to start writing the bytes (defaults to 0)
         """
+        print("Sent : ", value)
         bytes = [dbus.Byte(b) for b in value]
 
         try:
@@ -640,6 +642,7 @@ def enable_notifications(self, enabled=True):
         Each time when the device notifies a new value, `characteristic_value_updated()` of the related
         device will be called.
         """
+        print("enable_notifications called")
         try:
             if enabled:
                 self._object.StartNotify(
diff --git a/gatt/gatt_linux.pyc b/gatt/gatt_linux.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..56c1faf6adc6d084647026986e108f9ebb9638f1
GIT binary patch
literal 29337
zcmd6QTaX;rdES}JUS_dN+z1dPL9+>w=F$chgsng^NK3?xG+5#i)eCAZ*wF0kOz-Xh
zvonkCUH~f+<&a=WO5~gDI8Gv`in>^i6f4eyZN-(i%4MZ|i=9d;dB{tiT;-%v@k1(4
zd5QCV-`}^HodpSHhYEl`IDPu`>2vwd|9}5~{&S}Czh<WX=G0ezy6KWXWBC6iT+!i@
zb6ZDU%ehv`b)373h{a2cFLr;-RfDp-G3CNVS1Of~hZT3V;#y_*%1^W^45|o%io0HQ
ztuc46<VxL=`^hBln7cZrLdRWa+^tWzs}rt-Y^@2`nRM$lceUn9fpgcV-1R-~`m}3J
zx?slL!{_qUhj5R#YOeLLYfZU#9q&JVb+2pfajiqHHJv5xbFCTII_z2xWl8&83mG4A
zt$kV20oOw65!X79B^`9FgS@$lFO=NE?4#(P_TS*oeDnySuk~7+oxppxwY(WU>vemv
zx6<3}wxSbwcDWNYqQDC`yJx&;v(@t&8}W(NAokkbC~kB*-o{qE*6aT03BDX%#v2Pk
z;59l??~Jz=#~aa^lP6c(@!IC{T(h@+5^qL9x7|Fs+KA&5_U=cLqT1cn6H1O+H%_ed
z!sKxq<LG7?#1jZ!d42hM(2Ol%90@@f_QEKB2+=5r>y4=13RW7Moj9IB(uLqwyBWOJ
z=r&e^Fe8#Oo}A+g{|*6$;%bS*c(u&#VLw$|fblM?13@igE*Nvy#~mnw!=sc|RXHa}
z7JOyWwZ;{}Ku#z!#o^|oJ#H0*S99;;MbLo8_$o$nkDfl13^7N1MkyF)jqp{CE=$0e
zYJjg|B=;*1MpEN@6%>Lvh8KlD;{1i#Lu}U<5lngbbFmwTTi!;m-Q}o;-a2~%J?)+Q
z<VEk5vsbQoE%i_|H>Lbn*4mNR>@=dtLj-RH-B!@@;-0r0fB=^D$P!c(#@dTEf@XWA
z-Sp7^UT<ZfSk|J+4(H6|bskrA00Y``?k(r)CHEHoAyRg+CK~9Uw_|SW2}Z74-(!f%
z%=yT@vb$Tx{C&n%nSa7vpVTZ4T<LDbmExLvtHMEgr{p+S`%1tAyj|6YrrcW?@G4XI
zxjktjzKEHJ$!_V>X*wukJWZT&Ah_!ou?bZP1N{iT$YS=nwpD+B8o}UM3I@+27%+<*
zQu_`Y2f);st)Xw`BZj?jb#A${8GJU{gS(TsJ*nH1F{i@G=s+>g+}Rf9We}c<o=lQg
z!XRh`(T%vbF?ZqIW;Ay>>}>>L+zz7X*iLzDY9*5;nnt$I6h0gsLBdIp%j|6Zr_P?Z
z`uvF>yY}Xf+<orN(|4bHdX|hNt|FN4b%S^kkxn}T_28Q<s9_bXcN^=0vXNh4sL<#w
zWLrlSm0V}?6q3Oy>OD<$-3E7>!A9Kff$L~mBmc!TDL#z+b@74vO4wVkvuwN97cPN{
z!<9zUs#Q;_5+CGSX}vbG?uqv@-9BA68V_UAZy1OHfsJjnJ3-6=0IMN;sc$smwR#w=
z26xo*BssEAwAxX#cPj{kR+i4rs&jIwTBro(SUqa5b{n1eF+R(yQ*W*{x~utP_6@4l
z?$$fK-iFxT=0>X#2WjE6oMY<CDCn&C<eAEqwlwKfQc)0-S@btGY56Q3I0ezmh@D*P
ztp_KsgW(6=ZgBF-cfZ;B?l)1ha5Y#Dx^YzG=O@-17|~Ek3hJG9ck|91xIM|Dj)u46
zdi@E+qo)zLQms@g?=4kIPm~Uo_Tf5II)dvlrrY0glhx%_!6gPl8OEuNf8Y#a4w$gu
z&^OAMM<T=>=7>h|a_=@r#Doh+*WZr-`~(svFzMnS#m#8?fwa?(a^kbf{3uc**2R^Z
z{Et`0FgdXY+6$_@ULpSh>$z7!t6BT`9a`-_g@@{wyrm04>~l!eBj<WO$olTAI)hDD
z>V{QqB;DYD1Yh|WuC&n{V1Ax7&bCDV8o?Jd$RXq<pbKwG?s{3N!f6<B@Ni+XGM?6}
zdX(h>7=u_Dr<h<i$Z$j;t0ASQ&~H_~GU-0=+zLo&kNcc+cS{aj1CZ^WzFh~3Jd#ub
zasi1Y_Bj4q>^=?&G%eZl9U{mi{T(N{!|KkG^+msjK*E)xa3OAlapc8o0c3Hz>v0z2
zt^q_9dEKB1{@j4XhQJMR)4mmW=O6{*UN2trf?J$x9(kM!$e$#WI}zgijtO!iwB=5(
zc_Z>RyK%eYZS^+2CR3Lph=$qcmiQ$``)f3p)puUZLmV|@SRYV=#FSjd)r{|xvu4aV
zI!mq>bK2#y>AW#Ju`e)}=OaGOMB$vFxl@uT;<-11t=qk@rTk22BD?qm$%qU-I)~uS
zQ|SO|<Sty>=kD5UDr+Qf?sJQztQ38ecmvb{Y=F`rs}}?}=VysGeM%cplykQl7#WjR
z?JjQGWWzoglOBh`I@rEXshOiy6BxSB`O9vySh5yL9PsI8oCuX@0jbd>0#`a*dZ;v0
znxz!=DQkSrHc2Xop(H<KnP@N6@Z^$;EDM9CHkokSE~t#7>_efK{nsyF^sijHxKO|J
z^4aqj)ipjII0=H+K>nYk467go3Wj8LCe(92<o^hs&+@gr+jg<X{J)KoU%(aV8xyrs
zwM?-yUYf3&_!(!symy=;YNoUY*F-53NF=oLeESCx7=sRv<(ygsWXKR~LHg%{nijo?
z{Mjs9zziH@3ec~@7*P8*)F)0?++n_Eugr_xYY0XDH#gg{PjQj=l64xA+%EQ)K?~Hk
z!E!kd9QtXdB$36T<fR_r)UzG|&jxb@+lHh9b|>z3?ncdpbBrhR484O)_JZYpu`u=6
zGMjoVALvlrWxdfPNrvE>YP)|D53OU4@`Y0f1n7c0K%>xm5|lKWo}mt!K*r=d&;`<Y
zcc?VYUZRX6>?J}`Fa0JWSufoK;}K7S6oS%-Zn$vmare{Gc%a-cA42uxXUgv8QR*_x
zS4F-f?(Ud-O9lyc?FGh}>4LjEu1w=9%rdd0F?VCah3zz7+ufaTcOG|dO(5SvcXv{s
z8+UI_a@a~YzvLDR<3U{Mli7$x05h4|(0W~%J&HMAZ2<d7%o@EiFi_&66cFo;8!2{`
z`XjceF*ESpN)Tz}(;gx1r!K_5(Tk$?awjO34R*{9UYC+k_$JaRNxH%9{@nhLBXuOi
z;6IL%d$^=WIpEpZ(lfXc5@0QPi3F$)7ztqfON`lMNd-@I8X2;Q?+5W_*o|Oh>3BD~
zz1!UaLNM_HWu6d#e{3$WE}A_49Acwp5G0MHB6kptNb0USWgLPx8L0gRZUDgzzMm#%
zD7nxR8xWR%5j<h*seF1E<*SF%i2@k*88ZY_MbR+leZ>p`umZqlgB}I&gHjOQC8C9`
zKv+@M0rYy7XIy!H$=&=a;a{Hx0g!QFb`n*M-b0W8xQ3VNbz3s5(4LYs+Bo(quv-@<
zk&qgq_r@ESE~GXVj?0;iM%Y+SAJ;cG+pXw~_j0=f&B+8o6g0x-8sS;5+t~sd<fsq(
zL{c<M<sa#)&`-%^u7r(lw9yM=O-E&v7M~-ki?p82&G%wIXtcJXb-c6<Rmvn7^7)(x
zmBCxuuDS?DE?o&XgC!4ECP;Jd*`T@B^NvY@KogF6Z<zs+Rt&+}X54vpE+PaOtj?t_
z5aBAB`ur@>iBB{kg&Uv0kf_sJ)>(q58k6jS5QtCc?GxpQ7tov_5K9Au&zUC-k~Z8Y
z>o)D^X!=SrbT&3ItB{R&eMJN1{{Y{@Wx;L=Swdxr{Cf7$pJ5Wa%Z<+fk<64UP?q<D
zu^bRSIZ&>cnoLBJ%`k9mx3xc?L1ZwC-A`i1NO^?lr2)K-83PtisSCRo8d}n9xXhWD
z%pq9HF^4X@n@gNVNQX>FENm_6o}Aaw1q2!E$uUjV1ZW!DFiqaT9NR>c4ue$jasy_U
zR`f6)&G!nkFDY|gQ`AU>!_Lp|L=rv?)f&=_F4n1dtp-L2>_W+*5sok^j*3^_{$FJZ
z$<|dX8rY{x7}5&v)9XBQumen5U=+v^%Y8bEXq$pLfgoA=L8}0aBuhEBa;0u0gzSG5
z-}o9X)A379QYJ4pNzKWHA5aWhv<lMN-Xi}ekzb}Q!w2MUS=D8!NbF>Sg}FM`5^5Mt
z)BYCfKna$bFW4kDEmH}u;|5a+V?>|@vp%RY8#zK@V7ZEmp35Fc?3?V_ctwM(9L$Qo
zf&Icz^NJn;>_I{0iWI&=sKD>e57(GYb3KO)1_NGXjNLEPENo=Lt4J+ui_HR3i~nf`
z#7jceqv=wP^0#nBWVa58xmwx_?p7^5g?MHZ%YYN-5LuMg%!-P-CIQL2(SqeQZbu;g
zd{R>@7)|}Jq2%Ajl~OyuNwVO@?v6fzz(~M!A`Yz-qDV`X3!oJsd=L#DAbgVRj)Fp%
z6ULhp<EAW^{zVig#Cyg@nD$)B`t?TKT(iODFs_EZ%?(YHFxcqO6wcHRje9v$(9}uD
zfW{Pm33*1-Po%`};7V)~lwj3-d|5a37A-ij%^_KM(R24)*$kc0|Hi{i*t`ZU0+6`d
zN`MmL-qHnG=a+1)vI`U@RXSO&f@b~N+4EkaJr*oyuY+R3b}N8I3??}&SFH840G1%I
zMq#}xSr5xUfYq<`t2qWY!0s(^WdxO3k*O`Oh4r`>tr5_3^;Iiv8-#7B<1%c4*_vFT
zOin}%XtG2hP%pcawYos=qtkIXNWYKE$bDk_1g+vB$T%^1T*6&8VrN?|4pP#3jf_F&
z!l-D#dYf@B?eiX(H_FUs^~jp31t`!-B2fP*Yw+0nHJDY(8tls+IM`+yg15Chd*?%J
zBr%hjER%Nr#Xvi$)^R*FGyf0~<74;0r(uEs7rXO0B}s@O^}@AHSuQFPUQp~_rN9Dr
z!!s~#!pT?NO^;SFrb~STt$^K;*GY4OtpebZ-vQ(tb1P+c7`6=FPrB>S(vXR;71^<v
zi-K{30vGQbq0E(;*WQK<uDBn+`JP+M>nxGU_RRaR@jJ0nVXMND=Q9!4JL}Ixv$Rx5
zr8oI`7Pn%du=+M4lZwk}+U5pUTD9<IXjGbr2H&QpW@!VNx~*B6QI7IWN~`Ebd!w!*
zrR~7F9o6GreVGOlsB|!wSC9+I62bOa%I1+UX;mSi2(YGvDx&|ydLBXGN>k<W(ow9{
zjh7xT9i%c+o+&+4o}cB@WUY_tR=uvq)$8kWG{G%fU9Y!#&3fJU(#(k|c}vSe>Ld6Q
zKpmEW)~AKmr}VT@c$Kj$3>F!DlmYRWaH4;WG0GUjI3Q2wuQ8xx@i!3UJ*L<$s%}1q
zi294{$>U?=<=WxB)dSVq57s7Y<F#6CV){sJx>l)GYf}i7Qk(Es@J17t{*bA$`qBSE
z5WoSX<lw3VihUPe9)bt&B2mzQ5zP`tu)OskZYlIh!CRy7NilyT_$ocDPryUzkRtF)
zI;_Z}bX(%rAEUDpBage*qly3tJ*LPL^k<>%s#!(AvCELbpW}w=59kOHASgu4WQvFY
z6%D0`BLsT@dPW=_CNvHpMbwDi%AnN*xf1yc^O@xnrXj2n>P@g4@Fe<;$dijmyyzcd
ziQr1;$%2arokLKXd5Ivhk6bAH6IDnmIr$aAduCq(Pb|ud4VXZ*;@22-*D1i2_w(54
zG~vvXE+eG!_C)5h(_Y``Xbrz1?}|+FXh|{*RytTk5@0bw{cL3JJ(#SpfdqwmBo?iL
z(e+FbV9_y1K*q|+zH=tQFK1HVWOn2b79}o<8Y;3p_j|u}#=ErQy$r{*;JB*Wgu#mV
z$vy`lk%KEMErC`+nj@)4Rxz`tF}w_$MZ3A#X@s!Dp&8OUVNsUd4?a=mF9rCSqra>X
zw_yXj-RQ<ciiKsb1;;4>&0g1QLQCOta8liTSuMefM1e3TTC2Q9=883>T)EQ`?W)Jo
zhbbbZWe)f<hfq6;yMjcdqMcb{hAWpJ#OY{$mL>_4SYT)-9uf;%q$Nl#CYaP*W>zS5
z&ejgBPvm6dOAb%+IW1%+ND_}0J}NlQnDQe-NZy;NlMVTEz1g!hQULpKs}6_6V0|N&
zjL8iRg&I?6C8Q&hVp1*pdM;0PQ<Ql4<bT6uX1~2!jx0}?rYp1ZkU2u{7|7rz)!p<u
z&-~<<IqrTFcNw9ahb$*MAUQSgFIAA~$K!1@nm1qt^VS*>)DYxI7J^&3(}6X6&hrDT
zID$c?B%2%g=)17l&B-hQv8<rX38U$&&!G4kzG1pZb$Fk|w3DzR^QJFRo``9TdQF7r
z8fJ6&h|wz!o=1DLs^-p3tXMvLc~y}-@<kiYskC+n?^ie3Tp;U)+gzxzn+>VY|6s)3
zt7YFuvRda8f<Q_=`V=A*{-_=B0;(@h5UnI>y|n}=kk}R8K-PS=7>~e`OiyAZrT%k8
zryA;T2{VC*BKUm-{@kQ1&&p;ep9gIe48p4*^f@JEfX=v(Im$$ao0HN;+-+i?$)_G;
z?~SvDSk1>;9d7#_(4I#MI<AU=M@N3FjDFnuXwsFoX06_=xashmlI1;<#I>qGth3nt
zE37@pA1iU&{ozu!_D~}T!$43qG+lDa!6-#oCFPEI>E>}QQ&?78*!#B79R2DE%lPuQ
z9kYo@0myEEvj19nif>tpy)~h?kb+mtAHVN2@GnN8hg2eJw3lU}E@^e}(m-mmM<DU%
zm8nkJ00rqb&s<xAd!wth++_Lu40`{9tXE#E2OdkakX#s!d(E|=c>`=)4!<7tE1A6t
zR+G8=EuTDrl3#~@D!7L=WUcD~(s&S(T5@ZXCq^EEh2BbhyAgu68=FLs1rl#8!#cII
z8(6xk=)>5!HA`Er2;RSgn27GYO)LKv6COqY-k72RFv+Obxs~{aZA%?k-Ls_}GNq(?
z^%boX*%}`S+SZNyPa*1qMBInA#G|hr<GgwrpLMWg(|_nN)MT#NJ&Nl9QugZqnbLvE
z;an1sN1VqMQSD6#8H)d;3s2}4Dvi`YKFU1U<zU1Vn{6!$5Hi4d|A!Eof%vnCnHIc-
zm<<1EzroOuxF8cW6);n}vO={!XIHkcojRC}m{a-h;M-?17KKjxft*EUO#T=$(SZeB
zK=Tv4{J`;{=ozoSIo0RD!nZ_!Dmyoqiaryn8x2zVS$z2uYztAEgWW{T774jWNI!o2
zhj^4pq(y2nFcH&>GsSUB$r#d~lhADiF4oanVaj5|N525;FD|h<Cq*U}Y7=#mW+|IU
zJ`=QZq4uGGyFNOVXvOA+)_L|JhtUl&#16oe%m)2(u`i2QctD6Zdz+nBYL17p*I34W
z26Sn$<s35qZ3G4CA@{`kK`$H)?R){nznZms2+F0KlTCnx>~l5XMLf#JT}$J_Xa$F2
z8}j4SIfo9l=8Ty56w1nr81d|v`B3_WDtviJ`&lzF%zQZ+yq<<>bOtO#c`uwR_QJ5q
zL_$btpK~eyZvWt`FF5#OBBSmB%E-JX^=uA&ihUtILI*3{WZuu}jnhalYJfDLSKw?)
z90}^R{>dZ<U=~V1-c(Cs(S9y8p2uxWi(DVZ|8PYC`}`W4O_haGb%txhY&wS|BZOnP
z`5uG;OV6jX|8u;>Wx;Oh_P>lmS?ldmpn@kFJ-U)-a~TwDOC!L-fTM}W&FjdL&1qX`
zjJ(7VtDlc^U!S3_pmp5Cc7h<hjdgKvN&4?n&ew(;dE`%aJ}p3y*1Cx}!e?iXdJ1qE
z1u!vd1RO=SDf_$Db<p69s<B=N1gxp2JzU>Q*AW0OB*pm&xcxr#p#M44V|}34IA18U
zL~x%*Wb2V3G`FzWePO_7?8>0en8-4`NR#;jK$Pi7sf!rWWK@f|QnQU<bCwJHvev)6
zS!y=Vy)RX=>SwtI_dxnp;wzSs?l7IgP%>defgOy@;m@aWAmZ4N%;^C32tE6%)w0$;
z$c8h{#^o$<1FUP@7<b|GjNtas@FU5<-2+#=iDbZFL%z_v!8(%sP314UM~#nQQ#3P{
zp|)GhL;zpO#;lLY6fsjH6_km#uqE`F=nFJAuR?DvIAi6*>HmE+!v6;dG!f>__wwhN
z_)83^82X<_P;knmGKck$7EI;TP?FCSOuljpFMO`>Xf!<hi>L-D+(jf4SDl98WTre*
zKAIX(IBY~pnq1#P#JD*J2wpqrblyvm<M!di=O0O03r8+n1;23ZNjVAO4NNNxHU<yb
z!_&N>hyQ7Mk`d}up!J+$URaSZyeOUPSM~->BaDq>;3sfRq6}Bz+sn*X$7(vhr(JJ6
zj9@{Iw^6?>te|lqnv6YWY|bj-e}iEO8%@|ax#6N2i3C!OJ|BM_Ja963@u#qrxUt;C
zzWr-&e)R6svXj{gHy5|H;e-y-W=A=Uq-;TA?iHBr6V`f48R_IaZ_D+Rus#ivKGBnZ
zn*j;Oe~H0a21^K}@Fis!-BCd+&>aUiZKCb+6)ceXE?E%Bj2EM!GfsqG%;{{Zd>AzL
zWT{g5c<vvH$3|x)x*YDZnHj(BpS%4d<!L)xaRTR~l_+@?lx6Oh?2`W1<qe@CM$!fG
z(QRL>>uYt}{oMKryN4_i${_2>Ylkkmghvn3B{Y!%JFR1^u?`~Z(#~DuzlYNOUqCRL
ze(+Fof6s#?8?B@>taksj&=>3yUOV)~Yk2e^eQ`U)rk<=bGBspdfAEv$JNh1Cqv?vL
zQSv}nsCr3XWR?4^LU+6mX}pRezxVF=e$&QN_wNv^-tQKA<9&$ZQy;iDU_jytAm&5h
z1zlK6{(qqoijV;+vHI2fDxIs;zhCH}_aT>s-RYq3H{JZu2kauN=fC;j{X>7P9i|fw
zCuxT5jhMTI9)!P|Ehu|=gq)TVC$HspF8gouewd|R;NN5rA`lSaW+>ld5?7}EpJDKK
z7@TDAE`xgv-eEw*;S2qKfw3<!5DtEuF#(xhVT>A_R0W^VQvlijDq~+`@O1{i&fpsi
zeuKd`5#;PwvE8&{tf2V+ic4D*u}%6ZIJ8yqw*qIkBegNaCXh0&u&UVJ+C#PdxX=Fj
z{{-(hap?~_)m+~$AQHeW3}z36QgP5}b~qO!@WHA$M&SKsPH*t%va^_Q#Dks1G)V`t
z2^6Fi7*QgYq<}^fuPPmYlt4QZVVSnYnSY*dq7Kw$iIIh{8IkhE2oO9_xsWzJ%@9vL
z&F~cISc;*hhPb?1`HJnuMMU0V^elsLMibNh8#R0{!?(60_7sx*FC!4hGDjGy6^3T%
z_hKt+dlBnrby3Vkn}M`!fi1_lIoj5Da)Q}STJcbo|IA54dx+B}`x;Dl)9@ax<+e)_
zfI6NSlRY=w(cnouO>IFuBd4Hqe3)xef64YxjJjPhLH;HR8d#4Kpd8JB{BwNmuh@X9
z8Zc}j>i&ap4DS^!!QY>8cpJ6&?;{uomRqp>yvJKy7VPH4_$?Ir*W1Q{rY+8LO@?nF
zl23+F8V}&)S~MPj&C*t+&1Mg1JlI*!g7F~Xy09Mf6U~kW1M2W6nRlqQfOdLq^%MUx
zO95RSGEOQ>!TCNuamxQS<VcJK9D{<f;Ggk!n6ZEpqQ4klla_NScN^5fS_2I;(}A!7
zpTu0LO3eoYS+%9BIT~X7Ha`15No;Hhw&fRW2_|ha7~@CCU=T(ig-z6Qr?1XpL3tGw
z+s#QqRPZ0udX87%M!!c+^KhIO2E34Az$S9)5BcypT+v4m?1UYN8sJ4=B{U%4i`ocw
zfCl+D;4j(6Zu}-ZCb0k^S6%E3gBMQRpq&$GEA7?I#H)rr!Z@d?e^7VA7cb-UL-0jv
z9yDim0tcZC;0QpB1XI9ND-$A)O571ZjH7t7Nf1Dor>%%PgAD}~@E)^JVHz<Cn8Zj$
z<ZU|p4G5rC;wU)nry}2Dt;P4=L}UwwPT>HUvoW)?W6#hFToJ?3trd3~7!XVfH@2M;
z3l<-@1q<0yxyk*O9SZ^HGutY}Eww0CXF_l@5zsy!aZ7E<4tdSo^8Wyp$kZ4g+KQdf
zU<NaJSz~c6R}~6Q@r(4bl_5gDfaaQR@5v(_ejK)~a9~X?FKoNsK_?G=l<#)v<et?n
zS++)PU<L2pC@xsbW%*VkY{MD7-oZ&?9WhDmv+1p@V5^P)ESec{&9R?p=9A!*w5{Y!
z2Dt$ctg=Hs#iOvailPGFz$ss+PUlB3$mL2#Qv;gc#A`XT^uL2!?QBBNXvh5swK`H=
zZZO+RLKGaGsDKEM;+n*|%XG<VH;fhjE7l!XA=pi}_d6)L!dh_(i0w`I{{qqNOpdGa
zJ2AO;cUF+78iD`m;99H%Fb;WdC)HxVi){&-askdj#Ywez3hzrhsTN1@=`iA}50Q7y
z;PcTBBiMm=?#TVvFzRHQ-+zh75bkGe?R(O$V9tk9#hI=BJqd?I%LJf!%<HtfKBEj!
zDl0m;H918I?|@s#0TgGu-lGrM3p!K@so1<DMN=y;U#90AK9MBxzcGNMWNqbMMXNGj
zW{$c}f3@Rd1`l?n3d5<k%_H=3b{MJc&>%M$hI$O<+<(UY8a^_65P?lU2?6ncPJ{sk
z(w0G~MfzGAB_}rL4;7$Ql$V%xmcbGOl54VWJhkUU=4p78kAIFqCQ$4Ul}v6I01;c5
zPpaLVPabOU4CfOS;eMqP+a~~iD)7XlABHUC75p!{q{@xqyAGl7!Tc_B0c_rudEY6f
z{``9=REC=oyGlrd{1_Wu#TV%!lQj^D*1+S4<PE&PXOP;)E=ru&`~87N-I%xW;TKYl
zX#PI3(y(7MoN$570XEXo7ZykR&dYd7EtStK!IPK^W<IPb68D(t<?Ij*_Sn4aEGE<5
z!@d6%1V+^_@>U}%(k7Y60H-&Wx8fkm<(gn>?nmqYBWC``3{)N>yRS-q5rw`~=q#*B
z=g5j}%X(}RH(TZ<06PC5$Z80t+5o1)VJ*Z|L}EJ81f>mND&W*@nCida^BHd02~!Qq
zknDwRxN50CYyaBdcEptWEu<jKJYSDz<rmze1`5uxL*i)8!iNDa|98<sacJQiLs##w
zlKukTDj+QXU*g{Q^6xP=&48kJ5K?^&X$2%tNHt<8<r4}01Zhp0WCEb}2tH{EmZV02
zD27V9U&S2diH3(rC$Xr`pg7$SCOBueF6L7ebCYNv+02Jw0PT}`N$xTNQICJv#0z%5
z*gX#9k3>-+k^irNO2_PAJrF8b1n_}$1;hE7x5HWRxQqnO+I~Ro{IONfMzTbncvANh
zMgjCM*xn!Ng<LV&g#TDdXSU=7$7~$yL7G$POG8&Jb&y)$BU^r10_x}P-5BS~b+!th
zO*Y_4yEp@{wXmVxs$xp?{)Vo>58+Jqtc}SlhX2n%tDqiWTm7&<5cS4uI$ld}@@E6+
zsbwY3CO@;FCOrRKR^|ZROYh*JGh20>?c3_Wd57dH7wI(R!RCf^j!BduQ_4B;T(f=?
z&@6I!+88&di=7NVw0rIN+TtVY-h74?U<~=SX(^x(x9tA`??>hfCOlQB*&^rI!}z4D
z9Rq#WuxW&fN)1QR9?B(q23;OQM$QTRlMw-GGH&nTglb5>WRKg&ktZ9mqE`sVSDyxz
z-Q?-UatO(m((`qG*%T5ykc+~vquf#Bfj`1GI_wf$Fks1Mz{XQ5i`5X?VE%*EP$Eg%
zTTf(rW(WZwuORjT0}?aP3wY}Ry2Pkupg$7*m~wWIKmR(?3P&xGSo5DL7@fZB|1mxk
zvbR_%x~OISmFZxg$Ahg!_E&f+ryL_2*qaP5vG4GYoBApx{PspdVVNyzXuienb6~~#
z{SI(rvf_6PFz{`Z1^~ukNbD`+7z$P@qSVZW;-Z`hu(>{@7cLzOqJ$5F0pphuxJM)R
zJt*+Q2WG?l484ATFM*}3f~eTi(7f-%uP-)uyk{Hx_p}!~_km4XgmyM?BK&P@?Q!n`
zAx>7mbRSROzM%r){vo>D|1N`P+4&z7qL2d{<E15Wfd@Ozb0oH6EzJ$>k&KVXoojdx
zTdxT_^9V;PbHG8jFp)?w_N~?kIWoELuoi7`W=XT0s_+y}vE?aj(f@yA&*$*DZ2XGs
zxk&5gW<#OOZ7NyU7Do0x6tj&*e*=l5X3>9+Z+wYegKH>@UO_VW4P?|kX>8nIdqyep
zSO&{M3VaHf$5PC@{0uqJ0xZCN%pL3OvhtFjpg2=T$lU3{EROOCeD47}bdbT{Z&U4l
z6n{3^N~<B-!m!Acijzt$0SjI@t{S_;)8k6bC{MU=K;trEwn>$6x?n8*4Q8n@?I?pk
zW1!a%*?k4_FHq>Oa_FdOxGMLk9w=975tUu&CKBc2GPpSOHXl&?lv?2bDPxq>5<vd9
z82k4ONE$vrlAC)J+fADf?WG>uz?mr<>H#>SjMXNm_f8+8GYU>%8qZ836pZI_>32HX
z6RBbX2}RjN3;|Ji8h`>4i*hSVEnBKBBV?&qi(p=nVxG5ZsZu}k)G<pnPmrvHaZ80&
z777i%KIu-|`h>Y>v-HfTMD>G>GyUnPe(z}8hyAi0oJ(AoTlVcye$sNbnVaV`e|9c?
z3~i!q*8NWg-PL$)Ks;DB@aVIfI3_V{e-;Pyl1c}^gB+KGaGl!6ju{qkZko<K)Wq@e
zizgoTsjs&+Z6e`OoHx>nD5Zv)O|3F#n>={o0)Ax<XMR#NX(zb<cNwEYqa;h-ZfzyF
zWIx{_#lhMsC8e)jI*X>*jx-^ww-Sn<_g~~kIkAo5j!a_^*!(&vo=esa3c}&S--D%r
zxmLJ6#2QW_P(Kin&hcky_^UK?tDW|;bdgKz92j-4mT4mVWEW=*P9%u6X0F~^ZO=i^
z>qTw&^lkZg%$byQzfQGC3)Z_ToSGnio$QtLw?M=w)Q|BREiI9LEJ{bJ`IH&*6_e3f
ziy~@wp*8&8E;16;`b9gn?&H+_^dlb?FvES?bU0Sx-~Hw3^1kxE%Hh(!%EA9|@P8b9
K{@@b_-~GRS&SFCV

literal 0
HcmV?d00001

diff --git a/gattctl.py b/gattctl.py
index 9f57947..2acf672 100755
--- a/gattctl.py
+++ b/gattctl.py
@@ -1,7 +1,12 @@
 #!/usr/bin/env python3
 
 from argparse import ArgumentParser
+from threading import Thread
+import keyboard
+from termios import tcflush, TCIFLUSH
 import gatt
+import time
+import sys
 
 device_manager = None
 
@@ -11,13 +16,28 @@ class AnyDeviceManager(gatt.DeviceManager):
     An implementation of ``gatt.DeviceManager`` that discovers any GATT device
     and prints all discovered devices.
     """
+    def __init__(self, adapter_name):
+        super().__init__(adapter_name)
+        self.nb_device_connected = 0
+        self.discover_filter = 'True'
 
     def device_discovered(self, device):
-        print("[%s] Discovered, alias = %s" % (device.mac_address, device.alias()))
+        if self.discover_filter == 'True':
+            print("[%s] Discovered, alias = %s" % (device.mac_address, device.alias()))
+        elif self.discover_filter in device.alias() or self.discover_filter in device.mac_address:
+            print("[%s] Discovered, alias = %s" % (device.mac_address, device.alias()))
 
     def make_device(self, mac_address):
         return AnyDevice(mac_address=mac_address, manager=self)
 
+    def run(self):
+        print("Running Manager")
+        super().run()
+
+    def quit(self):
+        print("Stopping Manager")
+        super().stop()
+
 
 class AnyDevice(gatt.Device):
     """
@@ -28,6 +48,9 @@ class AnyDevice(gatt.Device):
     def __init__(self, mac_address, manager, auto_reconnect=False):
         super().__init__(mac_address=mac_address, manager=manager)
         self.auto_reconnect = auto_reconnect
+        self.message = ''
+        self.transmition = ""
+        self.reception = ""
 
     def connect(self):
         print("Connecting...")
@@ -35,6 +58,7 @@ def connect(self):
 
     def connect_succeeded(self):
         super().connect_succeeded()
+        device_manager.nb_device_connected += 1
         print("[%s] Connected" % (self.mac_address))
 
     def connect_failed(self, error):
@@ -42,6 +66,8 @@ def connect_failed(self, error):
         print("[%s] Connection failed: %s" % (self.mac_address, str(error)))
 
     def disconnect_succeeded(self):
+        if device_manager.nb_device_connected:
+            device_manager.nb_device_connected -= 1
         super().disconnect_succeeded()
 
         print("[%s] Disconnected" % (self.mac_address))
@@ -55,7 +81,48 @@ def services_resolved(self):
         for service in self.services:
             print("[%s]  Service [%s]" % (self.mac_address, service.uuid))
             for characteristic in service.characteristics:
+                if characteristic.uuid == '6e400003-b5a3-f393-e0a9-e50e24dcca9e':
+                    characteristic.enable_notifications()
+
                 print("[%s]    Characteristic [%s]" % (self.mac_address, characteristic.uuid))
+        print("[%s] Resolved services" % (self.mac_address))
+
+        device_service = next(
+            s for s in self.services
+            if s.uuid == '6e400001-b5a3-f393-e0a9-e50e24dcca9e')
+
+        self.reception = next(
+            c for c in device_service.characteristics
+            if c.uuid == '6e400003-b5a3-f393-e0a9-e50e24dcca9e')
+
+        self.transmition = next(
+            c for c in device_service.characteristics
+            if c.uuid == '6e400002-b5a3-f393-e0a9-e50e24dcca9e')
+
+        if self.message:
+            bar = bytearray(self.message.encode())
+            self.transmition.write_value(bar)
+
+        time.sleep(2)
+        self.reception.read_value()
+
+    def characteristic_value_updated(self, characteristic, value):
+        print("RX:", (value.decode("utf-8")).replace('\n', ''))
+
+    def characteristic_read_value_failed(self, characteristic, error):
+        print("RX fail : ", error)
+
+    def characteristic_enable_notifications_succeeded(self, characteristic):
+        print("enable notification succeeded for characteristic ", characteristic.uuid)
+
+    def characteristic_enable_notifications_failed(self, characteristic, error):
+        print("enable notification succeeded for characteristic ", characteristic.uuid, ", error, ", error)
+
+    def characteristic_write_value_succeeded(self, characteristic):
+        print("write value succeeded for characteristic ", characteristic.uuid)
+
+    def characteristic_write_value_failed(self, characteristic, error):
+        print("write value fail for characteristic ", characteristic.uuid, ", error, ", error)
 
 
 def main():
@@ -64,6 +131,11 @@ def main():
         '--adapter',
         default='hci0',
         help="Name of Bluetooth adapter, defaults to 'hci0'")
+    arg_parser.add_argument(
+        '--message',
+        metavar='string',
+        type=str,
+        help="String send by ble, usable with --connect only. All 'n' of the message will be remplace by '\ n' ")
     arg_commands_group = arg_parser.add_mutually_exclusive_group(required=True)
     arg_commands_group.add_argument(
         '--power-on',
@@ -81,6 +153,11 @@ def main():
         '--discover',
         action='store_true',
         help="Lists all nearby GATT devices")
+    arg_commands_group.add_argument(
+        '--discover-filter',
+        metavar='filter',
+        type=str,
+        help="Lists all nearby GATT devices containing filter in their MAC address or alias")
     arg_commands_group.add_argument(
         '--connect',
         metavar='address',
@@ -114,8 +191,14 @@ def main():
         return
     if args.discover:
         device_manager.start_discovery()
+    if args.discover_filter:
+        print("discover filter : ", args.discover_filter)
+        device_manager.discover_filter = args.discover_filter
+        device_manager.start_discovery()
     elif args.connect:
         device = AnyDevice(mac_address=args.connect, manager=device_manager)
+        if args.message:
+            device.message = (args.message.replace('%n','\n'))
         device.connect()
     elif args.auto:
         device = AnyDevice(mac_address=args.auto, manager=device_manager, auto_reconnect=True)
@@ -125,12 +208,28 @@ def main():
         device.disconnect()
         return
 
+    thread = Thread(target=device_manager.run)
+    thread.start()
+
     print("Terminate with Ctrl+C")
+    print("Started Thread.")
+
     try:
-        device_manager.run()
+        while True:
+            if device_manager.nb_device_connected:
+                # If ESCAPE key is pressed you can start to write the message, ENTER to send it to the device
+                if keyboard.is_pressed(chr(27)):
+                    tcflush(sys.stdin, TCIFLUSH)
+                    message = bytearray(input(">> ").replace('%n','\n').encode())
+                    device.transmition.write_value(message)
+
+            pass
     except KeyboardInterrupt:
-        pass
-
+        print('KeyboardInterrupt!')
+        if device_manager.nb_device_connected:
+            device.disconnect()
+        device_manager.quit()
+    thread.join()
 
 if __name__ == '__main__':
     main()