mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-09-13 04:50:11 +00:00
765dd170e4
* Modify DefaultTimeout to 120 seconds A temporary workaround for nodes having trouble to sync (currently the download of pruning point related data during IBD takes more than 30 seconds) * Cache existence in reachability store * Cache block level in the header * Fix IBD indication on submit block * Add hardForkOmitGenesisFromParentsDAAScore logic * Fix NumThreads bug in the wallet * Get rid of ParentsAtLevel header method * Fix a bug in BuildPruningPointProof * Increase race detector timeout * Add cache to BuildPruningPointProof * Add comments and temp comment out go vet * Fix ParentsAtLevel * Dont fill empty parents * Change HardForkOmitGenesisFromParentsDAAScore in fast netsync test * Add --allow-submit-block-when-not-synced in stability tests * Fix TestPruning * Return fast tests * Fix off by one error on kaspawallet * Fetch only one block with trusted data at a time * Update fork DAA score * Don't ban for unexpected message type * Fix tests Co-authored-by: Michael Sutton <mikisiton2@gmail.com> Co-authored-by: Ori Newman <>
55 lines
1.9 KiB
Go
55 lines
1.9 KiB
Go
package rpchandlers
|
|
|
|
import (
|
|
"github.com/kaspanet/kaspad/app/appmessage"
|
|
"github.com/kaspanet/kaspad/app/protocol/protocolerrors"
|
|
"github.com/kaspanet/kaspad/app/rpc/rpccontext"
|
|
"github.com/kaspanet/kaspad/domain/consensus/ruleerrors"
|
|
"github.com/kaspanet/kaspad/domain/consensus/utils/consensushashing"
|
|
"github.com/kaspanet/kaspad/infrastructure/network/netadapter/router"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
// HandleSubmitBlock handles the respectively named RPC command
|
|
func HandleSubmitBlock(context *rpccontext.Context, _ *router.Router, request appmessage.Message) (appmessage.Message, error) {
|
|
submitBlockRequest := request.(*appmessage.SubmitBlockRequestMessage)
|
|
|
|
isSynced, err := context.ProtocolManager.ShouldMine()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
if !context.Config.AllowSubmitBlockWhenNotSynced && !isSynced {
|
|
return &appmessage.SubmitBlockResponseMessage{
|
|
Error: appmessage.RPCErrorf("Block not submitted - node is not synced"),
|
|
RejectReason: appmessage.RejectReasonIsInIBD,
|
|
}, nil
|
|
}
|
|
|
|
domainBlock, err := appmessage.RPCBlockToDomainBlock(submitBlockRequest.Block)
|
|
if err != nil {
|
|
return &appmessage.SubmitBlockResponseMessage{
|
|
Error: appmessage.RPCErrorf("Could not parse block: %s", err),
|
|
RejectReason: appmessage.RejectReasonBlockInvalid,
|
|
}, nil
|
|
}
|
|
|
|
err = context.ProtocolManager.AddBlock(domainBlock)
|
|
if err != nil {
|
|
isProtocolOrRuleError := errors.As(err, &ruleerrors.RuleError{}) || errors.As(err, &protocolerrors.ProtocolError{})
|
|
if !isProtocolOrRuleError {
|
|
return nil, err
|
|
}
|
|
|
|
return &appmessage.SubmitBlockResponseMessage{
|
|
Error: appmessage.RPCErrorf("Block rejected. Reason: %s", err),
|
|
RejectReason: appmessage.RejectReasonBlockInvalid,
|
|
}, nil
|
|
}
|
|
|
|
log.Infof("Accepted block %s via submitBlock", consensushashing.BlockHash(domainBlock))
|
|
|
|
response := appmessage.NewSubmitBlockResponseMessage()
|
|
return response, nil
|
|
}
|