Add DBSync Module

abci/client/grpc_client.go

@@ -181,3 +181,7 @@ func (cli *grpcClient) VerifyVoteExtension(ctx context.Context, params *types.Re
 func (cli *grpcClient) FinalizeBlock(ctx context.Context, params *types.RequestFinalizeBlock) (*types.ResponseFinalizeBlock, error) {
 	return cli.client.FinalizeBlock(ctx, types.ToRequestFinalizeBlock(params).GetFinalizeBlock(), grpc.WaitForReady(true))
 }
+
+func (cli *grpcClient) LoadLatest(ctx context.Context, params *types.RequestLoadLatest) (*types.ResponseLoadLatest, error) {
+	return cli.client.LoadLatest(ctx, types.ToRequestLoadLatest(params).GetLoadLatest(), grpc.WaitForReady(true))
+}

abci/client/socket_client.go

@@ -361,6 +361,14 @@ func (cli *socketClient) FinalizeBlock(ctx context.Context, req *types.RequestFi
 	return res.GetFinalizeBlock(), nil
 }
 
+func (cli *socketClient) LoadLatest(ctx context.Context, req *types.RequestLoadLatest) (*types.ResponseLoadLatest, error) {
+	res, err := cli.doRequest(ctx, types.ToRequestLoadLatest(req))
+	if err != nil {
+		return nil, err
+	}
+	return res.GetLoadLatest(), nil
+}
+
 //----------------------------------------
 
 func resMatchesReq(req *types.Request, res *types.Response) (ok bool) {

abci/types/application.go

@@ -2,9 +2,10 @@ package types
 
 import "context"
 
-//go:generate ../../scripts/mockery_generate.sh Application
 // Application is an interface that enables any finite, deterministic state machine
 // to be driven by a blockchain-based replication engine via the ABCI.
+//
+//go:generate ../../scripts/mockery_generate.sh Application
 type Application interface {
 	// Info/Query Connection
 	Info(context.Context, *RequestInfo) (*ResponseInfo, error)    // Return application info
@@ -31,6 +32,8 @@ type Application interface {
 	OfferSnapshot(context.Context, *RequestOfferSnapshot) (*ResponseOfferSnapshot, error)                // Offer a snapshot to the application
 	LoadSnapshotChunk(context.Context, *RequestLoadSnapshotChunk) (*ResponseLoadSnapshotChunk, error)    // Load a snapshot chunk
 	ApplySnapshotChunk(context.Context, *RequestApplySnapshotChunk) (*ResponseApplySnapshotChunk, error) // Apply a shapshot chunk
+	// Notify application to load latest application state (e.g. after DBSync finishes)
+	LoadLatest(context.Context, *RequestLoadLatest) (*ResponseLoadLatest, error)
 }
 
 //-------------------------------------------------------
@@ -119,3 +122,7 @@ func (BaseApplication) FinalizeBlock(_ context.Context, req *RequestFinalizeBloc
 		TxResults: txs,
 	}, nil
 }
+
+func (BaseApplication) LoadLatest(_ context.Context, _ *RequestLoadLatest) (*ResponseLoadLatest, error) {
+	return &ResponseLoadLatest{}, nil
+}

abci/types/messages.go

@@ -123,6 +123,12 @@ func ToRequestFinalizeBlock(req *RequestFinalizeBlock) *Request {
 	}
 }
 
+func ToRequestLoadLatest(req *RequestLoadLatest) *Request {
+	return &Request{
+		Value: &Request_LoadLatest{req},
+	}
+}
+
 //----------------------------------------
 
 func ToResponseException(errStr string) *Response {
@@ -226,3 +232,9 @@ func ToResponseFinalizeBlock(res *ResponseFinalizeBlock) *Response {
 		Value: &Response_FinalizeBlock{res},
 	}
 }
+
+func ToResponseLoadLatest(res *ResponseLoadLatest) *Response {
+	return &Response{
+		Value: &Response_LoadLatest{res},
+	}
+}