crowetic/qortal
1
0
Fork 0
forked from Qortal/qortal
Code Pull Requests Activity

Fix synchronizer so incoming block's transactions have approval status set

Browse Source
This commit is contained in:
catbref 2019-06-03 08:07:33 +01:00
parent 4667b768df
commit ab9fd681f3
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/org/qora/controller/Synchronizer.java
View File

@ -13,6 +13,7 @@ import org.qora.block.BlockChain;
import org.qora.block.GenesisBlock; import org.qora.block.GenesisBlock;
import org.qora.data.block.BlockData; import org.qora.data.block.BlockData;
import org.qora.data.network.BlockSummaryData; import org.qora.data.network.BlockSummaryData;
import org.qora.data.transaction.TransactionData;
import org.qora.network.Peer; import org.qora.network.Peer;
import org.qora.network.message.BlockMessage; import org.qora.network.message.BlockMessage;
import org.qora.network.message.BlockSummariesMessage; import org.qora.network.message.BlockSummariesMessage;
@ -27,6 +28,7 @@ import org.qora.repository.DataException;
import org.qora.repository.Repository; import org.qora.repository.Repository;
import org.qora.repository.RepositoryManager; import org.qora.repository.RepositoryManager;
import org.qora.transaction.Transaction; import org.qora.transaction.Transaction;
import org.qora.transaction.Transaction.ApprovalStatus;
import org.qora.utils.NTP; import org.qora.utils.NTP;
public class Synchronizer { public class Synchronizer {
@ -243,8 +245,18 @@ public class Synchronizer {
} }
// Save transactions attached to this block // Save transactions attached to this block
for (Transaction transaction : newBlock.getTransactions()) for (Transaction transaction : newBlock.getTransactions()) {
repository.getTransactionRepository().save(transaction.getTransactionData()); TransactionData transactionData = transaction.getTransactionData();
// Fix up approval status
if (transaction.needsGroupApproval()) {
transactionData.setApprovalStatus(ApprovalStatus.PENDING);
} else {
transactionData.setApprovalStatus(ApprovalStatus.NOT_REQUIRED);
}
repository.getTransactionRepository().save(transactionData);
}
newBlock.process(); newBlock.process();