From aa9545ec1f36b12dc362b64d3893d2e0c6b906b8 Mon Sep 17 00:00:00 2001 From: Alberto Benegiamo Date: Thu, 26 Oct 2023 16:13:46 +0200 Subject: [PATCH] rpcchainvm backfilling scaffolding --- vms/rpcchainvm/vm_server.go | 26 ++++++++++++++++++++++---- 1 file changed, 22 insertions(+), 4 deletions(-) diff --git a/vms/rpcchainvm/vm_server.go b/vms/rpcchainvm/vm_server.go index 21b21ccfbbb0..257df29ef633 100644 --- a/vms/rpcchainvm/vm_server.go +++ b/vms/rpcchainvm/vm_server.go @@ -823,12 +823,30 @@ func (vm *VMServer) GetStateSummary( var errNotYetImplemented = errors.New("backfilling not yet implemented") -func (*VMServer) BackfillBlocksEnabled(context.Context, *emptypb.Empty) (*vmpb.BackfillBlocksEnabledResponse, error) { - return &vmpb.BackfillBlocksEnabledResponse{}, errNotYetImplemented +func (vm *VMServer) BackfillBlocksEnabled(ctx context.Context, _ *emptypb.Empty) (*vmpb.BackfillBlocksEnabledResponse, error) { + var ( + blkID = ids.Empty + err error + ) + if vm.ssVM != nil { + blkID, err = vm.ssVM.BackfillBlocksEnabled(ctx) + } + + return &vmpb.BackfillBlocksEnabledResponse{ + Id: blkID[:], + Err: errorToErrEnum[err], + }, errorToRPCError(err) } -func (*VMServer) BackfillBlocks(context.Context, *vmpb.BackfillBlocksRequest) (*vmpb.BackfillBlocksResponse, error) { - return &vmpb.BackfillBlocksResponse{}, errNotYetImplemented +func (vm *VMServer) BackfillBlocks(ctx context.Context, req *vmpb.BackfillBlocksRequest) (*vmpb.BackfillBlocksResponse, error) { + var err error + if vm.ssVM != nil { + err = vm.ssVM.BackfillBlocks(ctx, req.BlksBytes) + } + + return &vmpb.BackfillBlocksResponse{ + Err: errorToErrEnum[err], + }, errorToRPCError(err) } func (vm *VMServer) BlockVerify(ctx context.Context, req *vmpb.BlockVerifyRequest) (*vmpb.BlockVerifyResponse, error) {