From 21c7f719717e4e517163cbf8e30af559f5dd1b4b Mon Sep 17 00:00:00 2001
From: randogoth <kflux@posteo.de>
Date: Fri, 19 May 2023 02:18:16 +0300
Subject: [PATCH] init

---
 __pycache__/bot.cpython-310.pyc | Bin 0 -> 4120 bytes
 bot.py                          | 101 ++++++++++++++++++++++++++++++++
 randobot.py                     |  10 ++++
 3 files changed, 111 insertions(+)
 create mode 100644 __pycache__/bot.cpython-310.pyc
 create mode 100644 bot.py
 create mode 100644 randobot.py

diff --git a/__pycache__/bot.cpython-310.pyc b/__pycache__/bot.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..e99f5341a7e9473b8899eabc6ef7a2a0c575c52a
GIT binary patch
literal 4120
zcmd1j<>g{vU|{H2pO%s!z`*br#6iZ)3=9ko3=9m#aSRL$DGVu$ISf${nlXwI%x8*X
zN?}N0%3;oBiDJoRjbdd4$usA$<+4YygV`)O9J!oPoM1L<4p%OB6gMM-J3|Uv3VRDf
z3VSnC6i*6cFoPz?OOVZenoPGieIk5=@=Hrni@?m(;^M^gR87WP?2ZKmE}2EenvAzt
z14~m&L1O&DnYjfyseXyMsl^3}$*IX8Ly$4t3jqua45<ttXGbxmGej|`vZOGkF!eG<
zv8D*6FsHDzFh;SZu%@uJFhsGZu%~deFhp^raHepzFhp^t2&eF*@U}2Uaixf)@TUm0
zFh+5w2nI7~ir!-PiSTuE$}f4z%D}(?a%65|MR8_TYBCd&D?oDW3=9m;ps;+#z`#($
zSi=y{P{IguLNik>QwdWR^8%I{rYzPJ=7mhP%t(Beg-kUJ@oZob_8R7ejK%sT91A#8
zSW7svxE3-oGL&#E;9kg3%TmL#fCnTG63OCTzzbs6FvRnLRkI;fXYrSCWC^6O_cAgv
zlnB-^WbuLR<>&?3BUHnXC6px$7G+G~1dEA)#1@FwFl31>1nB|U&b2_igkyn34MUbl
zmgGXlg^V!sYZw+tEo1=2b})k`w_g#++qXE267y2>)ALI*ZgFI$q~?`mmQ>#2NX*O2
zFU?C%t<v|)R|qJ|%uOt+RPcmKE2L%Sq$;H4m*%DDC?pr9CYEI8r7Ps6mh0*1RZ05f
zC#IyPD8S58NGr<E1?$jcyv31|pPrLimYSo<RK(4|z;KJZxFo+QF+H^)u_Qy2@fJ@?
zW^qAIVr6_@Vs2`cGARBOAjwUkC^a#qQlTVYp(r&uHM1;LAwSPbp}JO6`W6dFaS;p1
zIHvsKTPz^6Zn0$LXXf4FEiFzhicd)_NsLd)EV{)D^Hw}q4O?b0$S1d$gZzSTG3Vr`
z-{SD`caQh<bMwE&0rTuF_LBT~urf}NPasUD%#>T4L8&E~$)!1^xwp7M+QM9eocx1b
zi$IC%7F!V{lSmb%re_wHfE<yUlUbHpR2dHom|Ltl`N@enx3DNlPRz+kN=(kaB^aLz
z$zt(PU#Hw+OUp0HO)R;^Q&5yzQc{_bT2Yi*aEm1)u{h%vXFSY<nyj~2ic@paiUdHx
z!jh6%RD6pqGX>=BB3T9ohLsFOIt&a9zm)Ye@^e%5({f5H^aG0Wvr>~wiuH3Ua?^B^
z@=NrS@=NpzDsOSb$7kkcmc++{3@cV(U|?Wl=3*3J6k_CI<YVMu<YMFlL1rOF5k@{n
zIYu7FDgjW`Ipvq=!L%kbqUAXbSe|>tz`#(#kj1!wsfHnoc_CwwN(l>ymBQG})X!JT
zSi)MvxPWaTLo;J7Q#eBk0}BHSLo+iYLmr1AL$O>rBO?O{Mlvum<Z+g;FW^XFDq+v!
z1m(UI=31s2rV`c?t_55m{n;!<c3>4Oa1{)}3{cxxo0<B>Ync(MQ`p2oIhT0>cL`4o
zOEV)Ve__}khirchLl*A>K2Qz=+rnPLp2ZJ#2Lq@K^}EGbR3)93n3<EB0!qjE1*v%o
zu=oN+%u7%ZRS5^BCa30=z-4k%^Ga?pmS=LXGcZ(XI70I!NK~OXHLpZRA+@5QNTE2j
zM8VL)z(AomH90>orC3v-NRWYnp-2csh=B-Ea6$lCdW$(TujCd7C`09B=A{;igQO)u
z(wv}l?BePa>VAu*Br`Yl7HfG?W=ZNT=Hil~A|;SA9uOf3Do$C8G(lPz(~3Z1x0n*s
zZt>=&R+PY#AUJ_R2wjja4F(1VHBccd$H2e<PB4rz|Ct*2m|4I{iH}KuQGikA9~ZL_
zW0fF0`M?4QrOXCpF;L|JF0(<2vW6jxVF6<eIF4!<gBeybf+{Pa6j+{vWvJp?Y>5R0
zsd*`yOc3XDq?P6+mt^MWK^zLo6Gb4`f`SKJ%%qrsoD3>lco<ob(lsnUqPUBVfq?;3
zsDj*990g6+HH=wIpt_`&sgtptp`9^}30$Rd)G~E2WHGxi#7fjM*D%&FbuiX2X0a?_
zO<`Tgn8G%PrIw|HErmUkp@wA%V;^HJYYlS^YcnGwL!nR#Bt5x-sx*)nb2Cd&vKJ^F
zfm|#Maylq@Iv5r(bTHO1z!GDT4JZZ~K}AGfiYDVN=G@}+mCz7jD^ATzNiBke2RJBL
zi&6`6DnVL`K>;toSfv4v9`xc#&jwtm72D~7HC3^emZa%gXtLa50Tn7mZlHwV3Q9NZ
z$@zIDsd*(}do<a>iSQO1v^3)`&Mz%WPK^f@YDKmnJsu!EY$>V9`6;PIpkUTygG3-Z
z)CFLpZ*jmP`WAD3QdSWteSj?}ase3v@=cKn0|SE<C}2RjLV%Hvk&B6miHVVkk&BV-
z4<8#BBg>B}Nu2(>#To<(jAT&o!U{A_1_lODTMcAe@jC_vhAQ?FXlkrw31`TYVqqv@
zs#IiTsAXkjsNySOUci#VSi+pe3W|<!hDe4KhFaD-R#2=$Smli63?*!!GN*(&i#>}Y
zg-MDbo2l3Ytdkk0Gmou=Ig4`vR}ITT##*)-wiJeJrlJtA8WxzE66P%K1w0@Xj0|8I
z))M9{UXZ;Y+e(-h@YR4!;mhJLVb0>q5&*UQ7P8i|mk8FdgIX3fOf}3Uf?2{T9KEcy
z94VYN9PywQhv)*a8V*o-2r@;J%dbkpGp{T$Co@GMCAGLDGcOU8qZB}~_YzdhSIOg&
zR>(=sOE1Z&+UcBMnv<fCmtO*^-V<|j6cY20nj85=3MCn-3Pq`frK!awsVNGHDJey%
z#l?CGk@=+x8Hr`73I#>^Nr_20l?r*OWvN9VQ$US`6p%TvA_USB$t=-R2q~(B83t;(
zBr1T4Ux+lwp1jnO^8BJ~g|y6~;u1Xt&pd^+#N-kkg`Ct9^<ssTe1(#X%wmPS{Bi{=
z&8lL5Zyg1w3FV2!FmqE=^b|bPz|Mvlmz|eiUJO;LqfnV&s!*PplLK=qic8BgOESQE
zVXY7aP#Z>}I3vHPB&SlZ$Q_g&I6!$H)TGd4y2V<OS(1}_i!UX$II}1<B|bN`BqKj1
zL{t10Yf@!NYVj?0P~#;dwc-}1YejNu0VsmNd9Dai@Vf>D`3K!%&PmNH0u|A>L_&f>
z{hS>`TwUTl9D_Z4T>acbJc^`1R<jkQf^ym|&XA(SyyAlVqLN!Y(AWVtt%^WZ#4T<Y
zL~6Lj>>nC(i!IpG&)vth2vk6VE0kMoE}lWI&LOwNONuJv3ySg!64Sw{Cq6$f9#mJ}
zVl4!9CvGtpl$L06Lh?K}QYtI*0p;u<5TOoo8DlEAeRE3yRNllRDZIs;Q;`cP4B(}F
zkrM+01E^>z29*j-phgTBb2Kph6JZfx<YD4q;$!4t6k?QO5@Tdz6kx34ffWs)V)7*@
z+oRL~EDQ_`pdJOdEC>PD01FsX7;6}^m}WDiFwJEy0kv_M7#TPr?GDx~)@DW*hFIQO
zQ0s>k)Xu48u3^YxU%&zCBQP=)g4+9>j0`1Q3%DWmTOqF|vtJb#$Q=q!`6UVoRk{fZ
zMX8`j043(M{33;v(vnJr#Jm)R#PY;UaN`_WN*3$s>1pyHA|Bj4ghUogPG)gQQ4%N&
znbT8Cia^c0Tl^V`c_}%m@%g1CNucI_5vUR`0#%8(Sc`K~Qwua%AW_1alA4oPd5bZ#
zC><0P;1C8ApfdLsb5Us?sGC|0s*EHUnHUAYZALamE=H!`Roo!2fZB>hrFnjujNopG
zCS#F5xQ;5y08u=kHYli>A0K~<D?UCqKczG$H9r0pPkek~X<`mU22xXiLLcmnB0Z2x
zzzzoWlfeZ)IKqqaK@wosAqbE=!8U`sCB>j-69)qe6Bi>F6Neaw00#>fAD<XlUXvHn
zvH}GHI3RDafZPvm_Jh;)E%wBM0#Jh++$DiH1>~q(tR<BNsm0*h3v3cnVg$Pb<b+!s
bHW1I*fhzH0J_ZH`0R|360Y)A$6k-JcO;|Js

literal 0
HcmV?d00001

diff --git a/bot.py b/bot.py
new file mode 100644
index 0000000..6b8ace0
--- /dev/null
+++ b/bot.py
@@ -0,0 +1,101 @@
+import os, time
+import RNS
+from   LXMF    import LXMRouter, LXMessage
+from   appdirs import AppDirs
+from   queue   import Queue
+from   types   import SimpleNamespace
+
+# Core class influenced by https://github.com/chengtripp/lxmf_messageboard
+# Bot syntax inspired by Discord.py and Telethon
+
+class LXMFBot:
+
+    delivery_callbacks = []
+    queue = Queue(maxsize = 5)
+
+    def __init__(self, name='LXMFBot'):
+
+        # initialize identiy
+        self.name = name
+        dirs = AppDirs("LXMFBot", "randogoth")
+        idpath = os.path.join(dirs.user_data_dir, "identity")
+        self.announce_path = os.path.join(dirs.user_data_dir, "announce")
+        if not os.path.isfile(idpath):
+            RNS.log('No Primary Identity file found, creating new...', RNS.LOG_INFO)
+            id = RNS.Identity()
+            id.to_file(idpath)
+        self.id = RNS.Identity.from_file(idpath)
+        RNS.log('Loaded identity from file', RNS.LOG_INFO)
+
+        # start RNS and LXMFRouter
+        RNS.Reticulum(loglevel=RNS.LOG_VERBOSE)
+        self.router = LXMRouter(identity = self.id, storagepath = dirs.user_data_dir)
+        self.local = self.router.register_delivery_identity(self.id, display_name=name)
+        self.router.register_delivery_callback(self._message_received)
+        RNS.log('LXMF Router ready to receive on: {}'.format(RNS.prettyhexrep(self.local.hash)), RNS.LOG_INFO)
+        self._announce()
+
+    def _announce(self):
+        if os.path.isfile(self.announce_path):
+            with open(self.announce_path, "r") as f:
+                announce = int(f.readline())
+        else:
+            RNS.log('failed to open announcepath', RNS.LOG_DEBUG)
+            announce = 1
+        if announce > int(time.time()):
+            RNS.log('Recent announcement', RNS.LOG_DEBUG)
+        else:
+            with open(self.announce_path, "w") as af:
+                next_announce = int(time.time()) + 1800
+                af.write(str(next_announce))
+            self.local.announce()
+            RNS.log('Announcement sent, expr set 1800 seconds', RNS.LOG_INFO)
+    
+    def received(self, function):
+        self.delivery_callbacks.append(function)
+        return function
+    
+    def _message_received(self, message):
+        sender = RNS.hexrep(message.source_hash, delimit=False)
+        def reply(msg):
+            self.send(sender, msg)
+        for callback in self.delivery_callbacks:
+            obj = {
+                'lxmf' : message,
+                'reply' : reply,
+                'sender' : sender,
+                'content' : message.content.decode('utf-8')
+            }
+            msg = SimpleNamespace(**obj)
+            callback(msg)
+
+    def send(self, destination, message, title='Reply'):
+        try:
+            hash = bytes.fromhex(destination)
+        except Exception as e:
+            RNS.log("Invalid destination hash", RNS.LOG_ERROR)
+            return
+
+        if not len(hash) == RNS.Reticulum.TRUNCATED_HASHLENGTH//8:
+            RNS.log("Invalid destination hash length", RNS.LOG_ERROR)
+        else:
+            id = RNS.Identity.recall(hash)
+
+        if id == None:
+            RNS.log("Could not recall an Identity for the requested address. You have probably never received an announce from it. Try requesting a path from the network first. In fact, let's do this now :)", RNS.LOG_ERROR)
+            RNS.Transport.request_path(hash)
+            RNS.log("OK, a path was requested. If the network knows a path, you will receive an announce with the Identity data shortly.", RNS.LOG_INFO)
+        else:
+            lxmf_destination = RNS.Destination(id, RNS.Destination.OUT, RNS.Destination.SINGLE, "lxmf", "delivery")
+            lxm = LXMessage(lxmf_destination, self.local, message, title=title, desired_method=LXMessage.DIRECT)
+            lxm.try_propagation_on_fail = True
+            self.queue.put(lxm)
+    
+    def run(self, delay=10):
+        RNS.log(f'LXMF Bot `{self.name}` reporting for duty and awaiting messages...', RNS.LOG_INFO)
+        while True:
+            for i in list(self.queue.queue):
+                lxm = self.queue.get()
+                self.router.handle_outbound(lxm)
+            self._announce
+            time.sleep(delay)
\ No newline at end of file
diff --git a/randobot.py b/randobot.py
new file mode 100644
index 0000000..e1a2baa
--- /dev/null
+++ b/randobot.py
@@ -0,0 +1,10 @@
+from bot import LXMFBot
+from pprint import pprint
+
+bot = LXMFBot("Randobot")
+
+@bot.received
+def echo_msg(msg):
+    msg.reply(msg.content)
+
+bot.run()
\ No newline at end of file