mirror of
https://github.com/DJ2LS/FreeDATA
synced 2024-05-14 08:04:33 +00:00
Use arq_data_type_handler when sending P2P messages
This commit is contained in:
parent
b62d3e3dc9
commit
1f28074566
1 changed files with 5 additions and 2 deletions
|
@ -4,6 +4,7 @@ import base64
|
|||
from queue import Queue
|
||||
from arq_session_iss import ARQSessionISS
|
||||
from message_p2p import MessageP2P
|
||||
from arq_data_type_handler import ARQDataTypeHandler
|
||||
|
||||
class SendMessageCommand(TxCommand):
|
||||
"""Command to send a P2P message using an ARQ transfer session
|
||||
|
@ -14,10 +15,12 @@ class SendMessageCommand(TxCommand):
|
|||
self.message = MessageP2P.from_api_params(origin, apiParams)
|
||||
|
||||
def transmit(self, modem):
|
||||
data, data_type = self.arq_data_type_handler.prepare(self.message.to_payload, 'p2pmsg_lzma')
|
||||
iss = ARQSessionISS(self.config, modem,
|
||||
self.message.destination,
|
||||
self.message.to_payload(),
|
||||
self.state_manager)
|
||||
data,
|
||||
self.state_manager,
|
||||
data_type)
|
||||
|
||||
self.state_manager.register_arq_iss_session(iss)
|
||||
iss.start()
|
||||
|
|
Loading…
Reference in a new issue