DNM: app wiring POC

core/abci/app_base.go

@@ -0,0 +1,67 @@
+package abci
+
+import (
+	"context"
+
+	"github.com/tendermint/tendermint/abci/types"
+)
+
+type AppBase struct {
+	handler    Handler
+	checkCtx   context.Context
+	deliverCtx context.Context
+}
+
+var _ types.Application = AppBase{}
+
+func (a AppBase) Info(info types.RequestInfo) types.ResponseInfo {
+	return a.handler.Info(a.checkCtx, info)
+}
+
+func (a AppBase) SetOption(option types.RequestSetOption) types.ResponseSetOption {
+	return a.handler.SetOption(a.checkCtx, option)
+}
+
+func (a AppBase) Query(query types.RequestQuery) types.ResponseQuery {
+	return a.handler.Query(a.checkCtx, query)
+}
+
+func (a AppBase) CheckTx(tx types.RequestCheckTx) types.ResponseCheckTx {
+	return a.handler.CheckTx(a.checkCtx, tx)
+}
+
+func (a AppBase) InitChain(chain types.RequestInitChain) types.ResponseInitChain {
+	return a.handler.InitChain(a.deliverCtx, chain)
+}
+
+func (a AppBase) BeginBlock(block types.RequestBeginBlock) types.ResponseBeginBlock {
+	return a.handler.BeginBlock(a.deliverCtx, block)
+}
+
+func (a AppBase) DeliverTx(tx types.RequestDeliverTx) types.ResponseDeliverTx {
+	return a.handler.DeliverTx(a.deliverCtx, tx)
+}
+
+func (a AppBase) EndBlock(block types.RequestEndBlock) types.ResponseEndBlock {
+	return a.handler.EndBlock(a.deliverCtx, block)
+}
+
+func (a AppBase) Commit() types.ResponseCommit {
+	return a.handler.Commit(a.deliverCtx)
+}
+
+func (a AppBase) ListSnapshots(snapshots types.RequestListSnapshots) types.ResponseListSnapshots {
+	return a.handler.ListSnapshots(a.checkCtx, snapshots)
+}
+
+func (a AppBase) OfferSnapshot(snapshot types.RequestOfferSnapshot) types.ResponseOfferSnapshot {
+	return a.handler.OfferSnapshot(a.checkCtx, snapshot)
+}
+
+func (a AppBase) LoadSnapshotChunk(chunk types.RequestLoadSnapshotChunk) types.ResponseLoadSnapshotChunk {
+	return a.handler.LoadSnapshotChunk(a.checkCtx, chunk)
+}
+
+func (a AppBase) ApplySnapshotChunk(chunk types.RequestApplySnapshotChunk) types.ResponseApplySnapshotChunk {
+	return a.handler.ApplySnapshotChunk(a.checkCtx, chunk)
+}

core/abci/config/config.go

@@ -0,0 +1,5 @@
+package config
+
+type Config struct {
+	Middleware []interface{}
+}

core/abci/handler.go

@@ -0,0 +1,30 @@
+package abci
+
+import (
+	"context"
+
+	types "github.com/tendermint/tendermint/abci/types"
+)
+
+type Handler interface {
+	// Info/Query Connection
+	Info(ctx context.Context, req types.RequestInfo) types.ResponseInfo                // Return application info
+	SetOption(ctx context.Context, req types.RequestSetOption) types.ResponseSetOption // Set application option
+	Query(ctx context.Context, req types.RequestQuery) types.ResponseQuery             // Query for state
+
+	// Mempool Connection
+	CheckTx(ctx context.Context, req types.RequestCheckTx) types.ResponseCheckTx // Validate a tx for the mempool
+
+	// Consensus Connection
+	InitChain(ctx context.Context, req types.RequestInitChain) types.ResponseInitChain    // Initialize blockchain w validators/other info from TendermintCore
+	BeginBlock(ctx context.Context, req types.RequestBeginBlock) types.ResponseBeginBlock // Signals the beginning of a block
+	DeliverTx(ctx context.Context, req types.RequestDeliverTx) types.ResponseDeliverTx    // Deliver a tx for full processing
+	EndBlock(ctx context.Context, req types.RequestEndBlock) types.ResponseEndBlock       // Signals the end of a block, returns changes to the validator set
+	Commit(context.Context) types.ResponseCommit                                          // Commit the state and return the application Merkle root hash
+
+	// State Sync Connection
+	ListSnapshots(ctx context.Context, req types.RequestListSnapshots) types.ResponseListSnapshots                // List available snapshots
+	OfferSnapshot(ctx context.Context, req types.RequestOfferSnapshot) types.ResponseOfferSnapshot                // Offer a snapshot to the application
+	LoadSnapshotChunk(ctx context.Context, req types.RequestLoadSnapshotChunk) types.ResponseLoadSnapshotChunk    // Load a snapshot chunk
+	ApplySnapshotChunk(ctx context.Context, req types.RequestApplySnapshotChunk) types.ResponseApplySnapshotChunk // Apply a shapshot chunk
+}

core/abci/handler_base.go

@@ -0,0 +1,63 @@
+package abci
+
+import (
+	"context"
+
+	"github.com/tendermint/tendermint/abci/types"
+)
+
+type HandlerBase struct{}
+
+func (h HandlerBase) Info(context.Context, types.RequestInfo) types.ResponseInfo {
+	return types.ResponseInfo{}
+}
+
+func (h HandlerBase) SetOption(context.Context, types.RequestSetOption) types.ResponseSetOption {
+	return types.ResponseSetOption{}
+}
+
+func (h HandlerBase) Query(context.Context, types.RequestQuery) types.ResponseQuery {
+	return types.ResponseQuery{}
+}
+
+func (h HandlerBase) CheckTx(context.Context, types.RequestCheckTx) types.ResponseCheckTx {
+	return types.ResponseCheckTx{}
+}
+
+func (h HandlerBase) InitChain(context.Context, types.RequestInitChain) types.ResponseInitChain {
+	return types.ResponseInitChain{}
+}
+
+func (h HandlerBase) BeginBlock(context.Context, types.RequestBeginBlock) types.ResponseBeginBlock {
+	return types.ResponseBeginBlock{}
+}
+
+func (h HandlerBase) DeliverTx(context.Context, types.RequestDeliverTx) types.ResponseDeliverTx {
+	return types.ResponseDeliverTx{}
+}
+
+func (h HandlerBase) EndBlock(context.Context, types.RequestEndBlock) types.ResponseEndBlock {
+	return types.ResponseEndBlock{}
+}
+
+func (h HandlerBase) Commit(context.Context) types.ResponseCommit {
+	return types.ResponseCommit{}
+}
+
+func (h HandlerBase) ListSnapshots(context.Context, types.RequestListSnapshots) types.ResponseListSnapshots {
+	return types.ResponseListSnapshots{}
+}
+
+func (h HandlerBase) OfferSnapshot(context.Context, types.RequestOfferSnapshot) types.ResponseOfferSnapshot {
+	return types.ResponseOfferSnapshot{}
+}
+
+func (h HandlerBase) LoadSnapshotChunk(context.Context, types.RequestLoadSnapshotChunk) types.ResponseLoadSnapshotChunk {
+	return types.ResponseLoadSnapshotChunk{}
+}
+
+func (h HandlerBase) ApplySnapshotChunk(context.Context, types.RequestApplySnapshotChunk) types.ResponseApplySnapshotChunk {
+	return types.ResponseApplySnapshotChunk{}
+}
+
+var _ Handler = HandlerBase{}

core/abci/header/header.go

@@ -0,0 +1,88 @@
+package header
+
+import (
+	"context"
+	"fmt"
+
+	tmproto "github.com/tendermint/tendermint/proto/tendermint/types"
+
+	sdk "github.com/cosmos/cosmos-sdk/types"
+
+	"github.com/tendermint/tendermint/abci/types"
+
+	"github.com/cosmos/cosmos-sdk/core/abci"
+)
+
+var Middleware abci.Middleware = func(handler abci.Handler) abci.Handler {
+	return &middleware{
+		Handler: handler,
+	}
+}
+
+type middleware struct {
+	abci.Handler
+	initialHeight   int64
+	lastBlockHeight int64
+}
+
+func (m *middleware) InitChain(ctx context.Context, req types.RequestInitChain) types.ResponseInitChain {
+	// On a new chain, we consider the init chain block height as 0, even though
+	// req.InitialHeight is 1 by default.
+	initHeader := tmproto.Header{ChainID: req.ChainId, Time: req.Time}
+
+	// If req.InitialHeight is > 1, then we set the initial version in the
+	// stores.
+	if req.InitialHeight > 1 {
+		m.initialHeight = req.InitialHeight
+		initHeader = tmproto.Header{ChainID: req.ChainId, Height: req.InitialHeight, Time: req.Time}
+	}
+
+	sdkCtx := sdk.UnwrapSDKContext(ctx)
+	sdkCtx = sdkCtx.WithBlockHeader(initHeader)
+	ctx = context.WithValue(ctx, sdk.SdkContextKey, sdkCtx)
+
+	return m.Handler.InitChain(ctx, req)
+}
+
+func (m *middleware) BeginBlock(ctx context.Context, req types.RequestBeginBlock) types.ResponseBeginBlock {
+	if err := m.validateHeight(req); err != nil {
+		panic(err)
+	}
+
+	m.lastBlockHeight = req.Header.Height
+
+	sdkCtx := sdk.UnwrapSDKContext(ctx)
+	sdkCtx = sdkCtx.
+		WithBlockHeader(req.Header).
+		WithBlockHeight(req.Header.Height)
+	ctx = context.WithValue(ctx, sdk.SdkContextKey, sdkCtx)
+
+	return m.Handler.BeginBlock(ctx, req)
+}
+
+func (m middleware) validateHeight(req types.RequestBeginBlock) error {
+	if req.Header.Height < 1 {
+		return fmt.Errorf("invalid height: %d", req.Header.Height)
+	}
+
+	// expectedHeight holds the expected height to validate.
+	var expectedHeight int64
+	if m.lastBlockHeight == 0 && m.initialHeight > 1 {
+		// In this case, we're validating the first block of the chain (no
+		// previous commit). The height we're expecting is the initial height.
+		expectedHeight = m.initialHeight
+	} else {
+		// This case can means two things:
+		// - either there was already a previous commit in the store, in which
+		// case we increment the version from there,
+		// - or there was no previous commit, and initial version was not set,
+		// in which case we start at version 1.
+		expectedHeight = m.lastBlockHeight + 1
+	}
+
+	if req.Header.Height != expectedHeight {
+		return fmt.Errorf("invalid height: %d; expected: %d", req.Header.Height, expectedHeight)
+	}
+
+	return nil
+}

core/abci/middleware.go

@@ -0,0 +1,3 @@
+package abci
+
+type Middleware func(Handler) Handler