Skip to content

Commit

Permalink
fixed and debug messages removed
Browse files Browse the repository at this point in the history
  • Loading branch information
unicorny committed Aug 29, 2024
1 parent 985490a commit 0dfafa7
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 16 deletions.
1 change: 0 additions & 1 deletion src/blockchain/Abstract.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ namespace gradido {
return nullptr;
}
if (results.size() > 1) {
printf("filter pagination size: %d\n", filter.pagination.size);
throw TransactionResultCountException("to many transactions found with blockchain::Abstract::findOne", 1, results.size());
}
return results.front();
Expand Down
27 changes: 12 additions & 15 deletions src/blockchain/InMemory.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -127,10 +127,8 @@ namespace gradido {
if (FilterCriteria::NONE == startSetType) {
return {};
}
printf("[InMemory::findAll] pagination size: %d\n", filter.pagination.size);
auto processEntry = [&](auto& start, auto& end, FilterCriteria toFilter, const Filter& filter) -> TransactionEntries
{
printf("[InMemory::findAll::processEntry] pagination size: %d\n", filter.pagination.size);
end--;
TransactionEntries transactionEntries;
bool revert = SearchDirection::DESC == filter.searchDirection;
Expand All @@ -142,9 +140,6 @@ namespace gradido {
if (paginationCursor >= filter.pagination.skipEntriesCount()) {
transactionEntries.push_back(it->second);
if (filter.pagination.size && transactionEntries.size() >= filter.pagination.size) {
if(transactionEntries.size() > 1) {
printf("transaction size: %d, pagination size: %d\n", transactionEntries.size(), filter.pagination.size);
}
return transactionEntries;
}
}
Expand Down Expand Up @@ -339,17 +334,19 @@ namespace gradido {
);
if (lastFromSameSender) {
auto lastFromSameSenderBody = lastFromSameSender->getTransactionBody();
auto lastFromSameSenderRecipient = lastFromSameSenderBody->getDeferredTransfer()->getTransfer().getRecipient();

auto pubkey = body->getTransfer()->getSender().getPubkey();
if (lastFromSameSenderBody->isDeferredTransfer() &&
lastFromSameSenderRecipient->isTheSame(pubkey)) {
auto lastFromSameSenderTimeout = lastFromSameSenderBody->getDeferredTransfer()->getTimeout();
// seems we found a matching deferred transfer transaction
auto byTimeoutDeferredRedeemedPairsIt = mTimeoutDeferredRedeemedTransferPairs.equal_range(lastFromSameSenderTimeout.getAsTimepoint());
for (auto it = byTimeoutDeferredRedeemedPairsIt.first; it != byTimeoutDeferredRedeemedPairsIt.second; ++it) {
if (lastFromSameSender->getSerializedTransaction()->isTheSame(it->second.first->getSerializedTransaction())) {
it->second.second = transactionEntry;
break;
if (lastFromSameSenderBody->isDeferredTransfer()) {
auto lastFromSameSenderRecipient = lastFromSameSenderBody->getDeferredTransfer()->getTransfer().getRecipient();
if (lastFromSameSenderRecipient->isTheSame(pubkey)) {
auto lastFromSameSenderTimeout = lastFromSameSenderBody->getDeferredTransfer()->getTimeout();
// seems we found a matching deferred transfer transaction
auto byTimeoutDeferredRedeemedPairsIt = mTimeoutDeferredRedeemedTransferPairs.equal_range(lastFromSameSenderTimeout.getAsTimepoint());
for (auto it = byTimeoutDeferredRedeemedPairsIt.first; it != byTimeoutDeferredRedeemedPairsIt.second; ++it) {
if (lastFromSameSender->getSerializedTransaction()->isTheSame(it->second.first->getSerializedTransaction())) {
it->second.second = transactionEntry;
break;
}
}
}
}
Expand Down

0 comments on commit 0dfafa7

Please sign in to comment.