yumoqing/kivyblocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2021-07-14 19:22:22 +08:00
parent f31ab177e6
commit db2cf3f860
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
kivyblocks/udp_widget.py
View File

@ -55,7 +55,8 @@ class UdpWidget(EventDispatcher):
'pubkey':self.dataencoder.my_text_publickey() 'pubkey':self.dataencoder.my_text_publickey()
} }
} }
self.udp_transport.broadcast(d) bd = self.dataencoder.pack('none', d, uncrypt=True)
self.udp_transport.broadcast(bd)
if peer_id is None: if peer_id is None:
print('get_peer_pubkey():return') print('get_peer_pubkey():return')
return return
@ -110,15 +111,15 @@ class UdpWidget(EventDispatcher):
'pubkey':self.dataencoder.my_text_publickey() 'pubkey':self.dataencoder.my_text_publickey()
} }
} }
self.send(addr[0], data) self.send(addr[0], data, uncrypt=True)
def broadcast(self, data): def broadcast(self, data):
for peer in self.dataencoder.public_keys.keys(): for peer in self.dataencoder.public_keys.keys():
self.send(peer, data) self.send(peer, data)
def send(self, peer_id, data): def send(self, peer_id, data, uncrypt=False):
print('send():', peer_id, data) print('send():', peer_id, data)
d = self.dataencoder.pack(peer_id, data) d = self.dataencoder.pack(peer_id, data, uncrypt=uncrypt)
addr = (peer_id, self.udp_port) addr = (peer_id, self.udp_port)
self.udp_transport.send(d, addr) self.udp_transport.send(d, addr)