Method fix_payment_queue_after_undo_redo

src/Core/WalletState.cpp:278–325

}

void WalletState::fix_payment_queue_after_undo_redo() {
	auto &by_hash_index = payment_queue.get<by_hash>();
	//    std::cout << "by_hash_index.size=" << by_hash_index.size() << std::endl;
	std::vector<Hash> added_to_bc;
	std::vector<Hash> removed_from_bc;
	bool pq_modified = false;
	for (auto git = by_hash_index.begin(); git != by_hash_index.end(); ++git) {
		if (git->in_blockchain() && !api_has_transaction(git->hash, false))
			removed_from_bc.push_back(git->hash);
		if (!git->in_blockchain() && api_has_transaction(git->hash, false))
			added_to_bc.push_back(git->hash);
	}
	for (auto tid : removed_from_bc) {
		auto git = by_hash_index.find(tid);
		if (git == by_hash_index.end())
			continue;
		QueueEntry entry = *git;
		by_hash_index.erase(git);
		entry.remove_height = 0;
		payment_queue.insert(entry);
		pq_modified = true;
		add_transaction_to_mempool(tid, entry.pwtx, true);
	}
	for (auto tid : added_to_bc) {
		auto git = by_hash_index.find(tid);
		if (git == by_hash_index.end())
			continue;
		api::Transaction ptx;
		if (!api_get_transaction(tid, false, nullptr, &ptx))
			continue;
		QueueEntry entry = *git;
		by_hash_index.erase(git);
		entry.remove_height = ptx.block_height + m_config.payment_queue_confirmations;
		payment_queue.insert(entry);
		pq_modified = true;
		remove_transaction_from_mempool(tid, true);
	}
	auto &by_remove_height_index = payment_queue.get<by_remove_height>();
	//    std::cout << "by_remove_height_index.size=" << by_remove_height_index.size() << std::endl;
	auto git = by_remove_height_index.lower_bound(1);
	while (git != by_remove_height_index.end() && get_tip_height() >= git->remove_height) {
		m_wallet.payment_queue_remove(git->hash);
		git         = by_remove_height_index.erase(git);
		pq_modified = true;
	}
	if (pq_modified)
		m_tx_pool_version += 1;
}

void WalletState::add_transaction_to_mempool(Hash tid, const PreparedWalletTransaction &pwtx, bool from_pq) {
	const auto now = platform::now_unix_timestamp();