mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-09-14 13:30:11 +00:00
1222a555f2
* Split deletePastBlocks into sub-routines * Remove SelectedParentIterator, and refactor SelectedChildIterator to support First and Error * Implement PruneAllBlocks * Prune all blocks in the store * Prune only blocks that are below the pruning point * Defer call onEnd of LogAndMeasureExecutionTime * Handle a forgotten error * Minor style fixes
54 lines
2.0 KiB
Go
54 lines
2.0 KiB
Go
package blockprocessor
|
|
|
|
import (
|
|
"github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
|
|
"github.com/kaspanet/kaspad/domain/consensus/ruleerrors"
|
|
"github.com/kaspanet/kaspad/domain/consensus/utils/consensushashing"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
func (bp *blockProcessor) validateAndInsertImportedPruningPoint(newPruningPoint *externalapi.DomainBlock) error {
|
|
log.Info("Checking that the given pruning point is the expected pruning point")
|
|
|
|
newPruningPointHash := consensushashing.BlockHash(newPruningPoint)
|
|
isValidPruningPoint, err := bp.pruningManager.IsValidPruningPoint(newPruningPointHash)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if !isValidPruningPoint {
|
|
return errors.Wrapf(ruleerrors.ErrUnexpectedPruningPoint, "%s is not a valid pruning point",
|
|
newPruningPointHash)
|
|
}
|
|
|
|
// We have to validate the pruning point block before we set the new pruning point in consensusStateManager.
|
|
log.Infof("Validating the new pruning point %s", newPruningPointHash)
|
|
err = bp.validateBlockAndDiscardChanges(newPruningPoint, true)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
log.Info("Deleting block data for all blocks in blockStore")
|
|
err = bp.pruningManager.PruneAllBlocksBelow(newPruningPointHash)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
log.Infof("Updating consensus state manager according to the new pruning point %s", newPruningPointHash)
|
|
err = bp.consensusStateManager.ImportPruningPoint(newPruningPoint)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
log.Infof("Inserting the new pruning point %s", newPruningPointHash)
|
|
_, err = bp.validateAndInsertBlock(newPruningPoint, true)
|
|
if err != nil && errors.As(err, &ruleerrors.RuleError{}) {
|
|
// This should never happen because we already validated the block with bp.validateBlockAndDiscardChanges.
|
|
// We use Errorf so it won't be identified later on to be a rule error and will eventually cause
|
|
// the program to panic.
|
|
return errors.Errorf("validateAndInsertBlock returned unexpected rule error while processing "+
|
|
"the pruning point: %+v", err)
|
|
}
|
|
return err
|
|
}
|