rbxii3/firmware
1
0
Fork 0
mirror of https://github.com/meshtastic/firmware.git synced 2025-12-23 19:20:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

more

Browse Source
This commit is contained in:
Jonathan Bennett
2025-12-14 17:31:40 -06:00
parent 471da2e632
commit 4dd43c7753
2 changed files with 32 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -206,12 +206,17 @@ bool StoreForwardPlusPlusModule::handleReceivedProtobuf(const meshtastic_MeshPac
LOG_WARN("End of chain matches!"); LOG_WARN("End of chain matches!");
} else } else
("End of chain does not match!"); ("End of chain does not match!");
} else {
LOG_WARN("No Messages on this chain, request!");
requestNextMessage(last_message_chain_hash, last_message_chain_hash);
} }
// compare to chain tip in incoming message // compare to chain tip in incoming message
// if not found, request the next message // if not found, request the next message
} }
} else if (t->sfpp_message_type == meshtastic_StoreForwardPlusPlus_SFPP_message_type_LINK_REQUEST) {
LOG_WARN("Received link request");
} }
return true; return true;
@@ -427,6 +432,31 @@ bool StoreForwardPlusPlusModule::getChainEnd(ChannelHash _ch_hash, uint8_t *_cha
return true; return true;
} }
void StoreForwardPlusPlusModule::requestNextMessage(uint8_t *_root_hash, uint8_t *_chain_hash)
{
meshtastic_StoreForwardPlusPlus storeforward = meshtastic_StoreForwardPlusPlus_init_zero;
storeforward.sfpp_message_type = meshtastic_StoreForwardPlusPlus_SFPP_message_type_LINK_REQUEST;
// set root hash
// set chain hash
storeforward.chain_hash.size = 32;
memcpy(storeforward.chain_hash.bytes, _chain_hash, 32);
// set root hash
storeforward.root_hash.size = 32;
memcpy(storeforward.root_hash.bytes, _root_hash, 32);
// storeforward.
meshtastic_MeshPacket *p = allocDataProtobuf(storeforward);
p->to = NODENUM_BROADCAST;
p->decoded.want_response = false;
p->priority = meshtastic_MeshPacket_Priority_BACKGROUND;
p->channel = 0;
LOG_INFO("Send packet to mesh");
service->sendToMesh(p, RX_SRC_LOCAL, true);
}
// announce latest hash // announce latest hash
// chain_end_announce // chain_end_announce

2
src/modules/Native/StoreForwardPlusPlus.h
View File

@@ -57,6 +57,8 @@ class StoreForwardPlusPlusModule : public ProtobufModule<meshtastic_StoreForward
// return indicates message found // return indicates message found
bool getChainEnd(ChannelHash, uint8_t *, uint8_t *); bool getChainEnd(ChannelHash, uint8_t *, uint8_t *);
void requestNextMessage(uint8_t *, uint8_t *);
enum chain_types { enum chain_types {
channel_chain = 0, channel_chain = 0,
}; };