From 472c65178aca9e5862983b41761e834ddd432431 Mon Sep 17 00:00:00 2001 From: Jonathan Bennett Date: Mon, 15 Dec 2025 22:46:26 -0600 Subject: [PATCH] cleanups --- src/modules/Native/StoreForwardPlusPlus.cpp | 21 +++------------------ src/modules/Native/StoreForwardPlusPlus.h | 2 -- 2 files changed, 3 insertions(+), 20 deletions(-) diff --git a/src/modules/Native/StoreForwardPlusPlus.cpp b/src/modules/Native/StoreForwardPlusPlus.cpp index 54f0f9cbd..30fb8010c 100644 --- a/src/modules/Native/StoreForwardPlusPlus.cpp +++ b/src/modules/Native/StoreForwardPlusPlus.cpp @@ -158,8 +158,6 @@ StoreForwardPlusPlusModule::StoreForwardPlusPlusModule() sqlite3_prepare_v2(ppDb, "UPDATE channel_messages SET payload=? WHERE message_hash=?", -1, &updatePayloadStmt, NULL); - sqlite3_prepare_v2(ppDb, "SELECT payload from local_messages WHERE message_hash=?", -1, &getPayloadFromScratchStmt, NULL); - encryptedOk = true; // wait about 15 seconds after boot for the first runOnce() @@ -363,9 +361,9 @@ bool StoreForwardPlusPlusModule::handleReceivedProtobuf(const meshtastic_MeshPac "", 0); if (isInScratch(t->message_hash.bytes)) { // TODO: Copy payload from scratch into chain - std::string payloadFromScratch = getPayloadFromScratch(t->message_hash.bytes); - if (payloadFromScratch != "") { - updatePayload(t->message_hash.bytes, payloadFromScratch.c_str(), payloadFromScratch.size()); + link_object scratch_object = getFromScratch(t->message_hash.bytes, 32); + if (scratch_object.payload != "") { + updatePayload(t->message_hash.bytes, scratch_object.payload.c_str(), scratch_object.payload.size()); } removeFromScratch(t->message_hash.bytes); } else { @@ -931,19 +929,6 @@ void StoreForwardPlusPlusModule::updatePayload(uint8_t *message_hash_bytes, cons sqlite3_reset(updatePayloadStmt); } -std::string StoreForwardPlusPlusModule::getPayloadFromScratch(uint8_t *message_hash_bytes) -{ - LOG_WARN("getPayloadFromScratch"); - sqlite3_bind_blob(getPayloadFromScratchStmt, 1, message_hash_bytes, 32, NULL); - auto res = sqlite3_step(getPayloadFromScratchStmt); - const char *_error_mesg = sqlite3_errmsg(ppDb); - LOG_WARN("step %u, %s", res, _error_mesg); - const char *tmp_text = (char *)sqlite3_column_text(getPayloadFromScratchStmt, 0); - size_t payload_len = sqlite3_column_bytes(getPayloadFromScratchStmt, 0); - std::string tmp_string(tmp_text, payload_len); - return tmp_string; -} - StoreForwardPlusPlusModule::link_object StoreForwardPlusPlusModule::getFromScratch(uint8_t *message_hash_bytes, size_t hash_len) { diff --git a/src/modules/Native/StoreForwardPlusPlus.h b/src/modules/Native/StoreForwardPlusPlus.h index d7af28a72..3054f8e10 100644 --- a/src/modules/Native/StoreForwardPlusPlus.h +++ b/src/modules/Native/StoreForwardPlusPlus.h @@ -105,8 +105,6 @@ class StoreForwardPlusPlusModule : public ProtobufModule