chore: FinalizeSnapshot implemented, not tested

abci/client/grpc_client.go

@@ -255,6 +255,10 @@ func (cli *grpcClient) ApplySnapshotChunk(ctx context.Context, params *types.Req
 	return cli.client.ApplySnapshotChunk(ctx, types.ToRequestApplySnapshotChunk(params).GetApplySnapshotChunk(), grpc.WaitForReady(true))
 }
 
+func (cli *grpcClient) FinalizeSnapshot(ctx context.Context, params *types.RequestFinalizeSnapshot) (*types.ResponseFinalizeSnapshot, error) {
+	return cli.client.FinalizeSnapshot(ctx, types.ToRequestFinalizeSnapshot(params).GetFinalizeSnapshot(), grpc.WaitForReady(true))
+}
+
 func (cli *grpcClient) PrepareProposal(ctx context.Context, params *types.RequestPrepareProposal) (*types.ResponsePrepareProposal, error) {
 	return cli.client.PrepareProposal(ctx, types.ToRequestPrepareProposal(params).GetPrepareProposal(), grpc.WaitForReady(true))
 }

abci/client/routed_client.go

@@ -351,6 +351,11 @@ func (cli *routedClient) ApplySnapshotChunk(ctx context.Context, req *types.Requ
 	return result.(*types.ResponseApplySnapshotChunk), err
 }
 
+func (cli *routedClient) FinalizeSnapshot(ctx context.Context, req *types.RequestFinalizeSnapshot) (*types.ResponseFinalizeSnapshot, error) {
+	result, err := cli.delegate(ctx, req)
+	return result.(*types.ResponseFinalizeSnapshot), err
+}
+
 func (cli *routedClient) PrepareProposal(ctx context.Context, req *types.RequestPrepareProposal) (*types.ResponsePrepareProposal, error) {
 	result, err := cli.delegate(ctx, req)
 	return result.(*types.ResponsePrepareProposal), err

abci/client/socket_client.go

@@ -357,6 +357,14 @@ func (cli *socketClient) ApplySnapshotChunk(ctx context.Context, req *types.Requ
 	return res.GetApplySnapshotChunk(), nil
 }
 
+func (cli *socketClient) FinalizeSnapshot(ctx context.Context, req *types.RequestFinalizeSnapshot) (*types.ResponseFinalizeSnapshot, error) {
+	res, err := cli.doRequest(ctx, types.ToRequestFinalizeSnapshot(req))
+	if err != nil {
+		return nil, err
+	}
+	return res.GetFinalizeSnapshot(), nil
+}
+
 func (cli *socketClient) PrepareProposal(ctx context.Context, req *types.RequestPrepareProposal) (*types.ResponsePrepareProposal, error) {
 	res, err := cli.doRequest(ctx, types.ToRequestPrepareProposal(req))
 	if err != nil {

abci/types/application.go

@@ -16,6 +16,8 @@ type StateSyncer interface {
 	LoadSnapshotChunk(context.Context, *RequestLoadSnapshotChunk) (*ResponseLoadSnapshotChunk, error)
 	// ApplySnapshotChunk applies a chunk of snapshot
 	ApplySnapshotChunk(context.Context, *RequestApplySnapshotChunk) (*ResponseApplySnapshotChunk, error)
+	// FinalizeSnapshot sends light block to ABCI app after successful state sync
+	FinalizeSnapshot(context.Context, *RequestFinalizeSnapshot) (*ResponseFinalizeSnapshot, error)
 }
 
 // Application is an interface that enables any finite, deterministic state machine
@@ -97,6 +99,10 @@ func (BaseApplication) ApplySnapshotChunk(_ context.Context, _req *RequestApplyS
 	return &ResponseApplySnapshotChunk{}, nil
 }
 
+func (BaseApplication) FinalizeSnapshot(_ context.Context, _req *RequestFinalizeSnapshot) (*ResponseFinalizeSnapshot, error) {
+	return &ResponseFinalizeSnapshot{}, nil
+}
+
 func (BaseApplication) PrepareProposal(_ context.Context, req *RequestPrepareProposal) (*ResponsePrepareProposal, error) {
 	trs := make([]*TxRecord, 0, len(req.Txs))
 	var totalBytes int64

abci/types/messages.go

@@ -87,6 +87,12 @@ func ToRequestApplySnapshotChunk(req *RequestApplySnapshotChunk) *Request {
 	}
 }
 
+func ToRequestFinalizeSnapshot(req *RequestFinalizeSnapshot) *Request {
+	return &Request{
+		Value: &Request_FinalizeSnapshot{req},
+	}
+}
+
 func ToRequestExtendVote(req *RequestExtendVote) *Request {
 	return &Request{
 		Value: &Request_ExtendVote{req},