rbxii3/firmware
1
0
Fork 0
mirror of https://github.com/meshtastic/firmware.git synced 2026-01-01 07:30:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

rebroadcast

Browse Source
This commit is contained in:
Jonathan Bennett
2025-12-15 12:15:46 -06:00
parent e44ab7f7b8
commit 6f10f6939a
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/modules/Native/StoreForwardPlusPlus.cpp
View File

@@ -41,6 +41,7 @@
#include "RTC.h"
#include "SHA256.h"
#include "meshUtils.h"
#include "modules/RoutingModule.h"
StoreForwardPlusPlusModule::StoreForwardPlusPlusModule()
: ProtobufModule("StoreForwardpp", meshtastic_PortNum_STORE_FORWARD_PLUSPLUS_APP, &meshtastic_StoreForwardPlusPlus_msg),
@@ -256,6 +257,9 @@ bool StoreForwardPlusPlusModule::handleReceivedProtobuf(const meshtastic_MeshPac
addToChain(t->encapsulated_to, t->encapsulated_from, t->encapsulated_id, false, _channel_hash, t->message.bytes,
t->message.size, t->message_hash.bytes, t->chain_hash.bytes, t->root_hash.bytes, t->encapsulated_rxtime,
"", 0);
// auto pAck = routingModule->allocAckNak(meshtastic_Routing_Error_NONE, getFrom(e.packet), e.packet->id, ch.index);
// pAck->transport_mechanism = meshtastic_MeshPacket_TransportMechanism_TRANSPORT_MQTT;
// router->sendLocal(pAck);
} else {
addToChain(t->encapsulated_to, t->encapsulated_from, t->encapsulated_id, false, _channel_hash, t->message.bytes,
t->message.size, t->message_hash.bytes, t->chain_hash.bytes, t->root_hash.bytes, t->encapsulated_rxtime,
@@ -267,6 +271,17 @@ bool StoreForwardPlusPlusModule::handleReceivedProtobuf(const meshtastic_MeshPac
updatePayload(t->message_hash.bytes, payloadFromScratch.c_str(), payloadFromScratch.size());
}
removeFromScratch(t->message_hash.bytes);
} else {
// if this packet is new to us, we rebroadcast it
meshtastic_MeshPacket *p = router->allocForSending();
p->to = t->encapsulated_to;
p->from = t->encapsulated_from;
p->id = t->encapsulated_id;
p->which_payload_variant = meshtastic_MeshPacket_encrypted_tag;
p->encrypted.size = t->message.size;
memcpy(p->encrypted.bytes, t->message.bytes, t->message.size);
p->transport_mechanism = meshtastic_MeshPacket_TransportMechanism_TRANSPORT_LORA; // only a tiny white lie
router->sendLocal(p);
}
requestNextMessage(t->root_hash.bytes, t->chain_hash.bytes);