Reticulum/LXMF-Tools
1
0
Fork 0
mirror of https://github.com/SebastianObi/LXMF-Tools.git synced 2025-12-22 08:27:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed identity not known bug

Browse Source
This commit is contained in:
SebastianObi
2025-03-19 20:04:05 +01:00
parent 1be6b9e0ac
commit 6ec952832a
10 changed files with 90 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
lxmf_bridge_matrix/lxmf_bridge_matrix.py
View File

@@ -388,6 +388,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_bridge_mqtt/lxmf_bridge_mqtt.py
View File

@@ -382,6 +382,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_chatbot/lxmf_chatbot.py
View File

@@ -380,6 +380,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_cmd/lxmf_cmd.py
View File

@@ -378,6 +378,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_distribution_group_extended/lxmf_distribution_group_extended.py
View File

@@ -389,6 +389,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_distribution_group_minimal/lxmf_distribution_group_minimal.py
View File

@@ -376,6 +376,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_echo/lxmf_echo.py
View File

@@ -375,6 +375,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_terminal/lxmf_terminal.py
View File

@@ -385,6 +385,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_test/lxmf_test.py
View File

@@ -319,6 +319,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)

9
lxmf_welcome/lxmf_welcome.py
View File

@@ -375,6 +375,15 @@ class LXMFPeer:
method = self.method method = self.method
destination_identity = RNS.Identity.recall(destination) destination_identity = RNS.Identity.recall(destination)
if not destination_identity:
log("LXMF - No keys known for destination. Requesting path", LOG_DEBUG)
RNS.Transport.request_path(destination)
pr_time = time.time()+RNS.Transport.first_hop_timeout(destination)
while not RNS.Transport.has_path(destination):
if time.time() > pr_time+30:
log("LXMF - Path request timeout", LOG_DEBUG)
return None
destination_identity = RNS.Identity.recall(destination)
destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type) destination = RNS.Destination(destination_identity, RNS.Destination.OUT, RNS.Destination.SINGLE, destination_name, destination_type)
return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method) return self.send_message(destination, self.destination, content, title, fields, timestamp, app_data, method)