txsource: Add consensus GetEvents workload

go/consensus/api/api.go

@@ -78,6 +78,9 @@ type ClientBackend interface {
 	// NOTE: Any of these transactions could be invalid.
 	GetTransactions(ctx context.Context, height int64) ([][]byte, error)
 
+	// GetEvents returns the consensus protocol events at specified block height.
+	GetEvents(ctx context.Context, height int64) ([]roothash.Event, error)
+
 	// WatchBlocks returns a channel that produces a stream of consensus
 	// blocks as they are being finalized.
 	WatchBlocks(ctx context.Context) (<-chan *Block, pubsub.ClosableSubscription, error)

go/consensus/api/grpc.go

@@ -10,6 +10,7 @@ import (
 	"github.com/oasislabs/oasis-core/go/consensus/api/transaction"
 	epochtime "github.com/oasislabs/oasis-core/go/epochtime/api"
 	genesis "github.com/oasislabs/oasis-core/go/genesis/api"
+	roothash "github.com/oasislabs/oasis-core/go/roothash/api"
 )
 
 var (
@@ -32,6 +33,8 @@ var (
 	methodGetBlock = serviceName.NewMethod("GetBlock", int64(0))
 	// methodGetTransactions is the GetTransactions method.
 	methodGetTransactions = serviceName.NewMethod("GetTransactions", int64(0))
+	// methodGetEvents is the GetEvents method.
+	methodGetEvents = serviceName.NewMethod("GetEvents", int64(0))
 
 	// methodWatchBlocks is the WatchBlocks method.
 	methodWatchBlocks = serviceName.NewMethod("WatchBlocks", nil)
@@ -73,6 +76,10 @@ var (
 				MethodName: methodGetTransactions.ShortName(),
 				Handler:    handlerGetTransactions,
 			},
+			{
+				MethodName: methodGetEvents.ShortName(),
+				Handler:    handlerGetEvents,
+			},
 		},
 		Streams: []grpc.StreamDesc{
 			{
@@ -268,6 +275,29 @@ func handlerGetTransactions( // nolint: golint
 	return interceptor(ctx, height, info, handler)
 }
 
+func handlerGetEvents( // nolint: golint
+	srv interface{},
+	ctx context.Context,
+	dec func(interface{}) error,
+	interceptor grpc.UnaryServerInterceptor,
+) (interface{}, error) {
+	var height int64
+	if err := dec(&height); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(Backend).GetEvents(ctx, height)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: methodGetEvents.FullName(),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(Backend).GetEvents(ctx, req.(int64))
+	}
+	return interceptor(ctx, height, info, handler)
+}
+
 func handlerWatchBlocks(srv interface{}, stream grpc.ServerStream) error {
 	if err := stream.RecvMsg(nil); err != nil {
 		return err
@@ -362,6 +392,14 @@ func (c *consensusClient) GetTransactions(ctx context.Context, height int64) ([]
 	return rsp, nil
 }
 
+func (c *consensusClient) GetEvents(ctx context.Context, height int64) ([]roothash.Event, error) {
+	var rsp []roothash.Event
+	if err := c.conn.Invoke(ctx, methodGetEvents.FullName(), height, &rsp); err != nil {
+		return nil, err
+	}
+	return rsp, nil
+}
+
 func (c *consensusClient) WatchBlocks(ctx context.Context) (<-chan *Block, pubsub.ClosableSubscription, error) {
 	ctx, sub := pubsub.NewContextSubscription(ctx)
 

go/consensus/tendermint/tendermint.go

@@ -861,6 +861,10 @@ func (t *tendermintService) GetBlockResults(height int64) (*tmrpctypes.ResultBlo
 	return result, nil
 }
 
+func (t *tendermintService) GetEvents(ctx context.Context, height int64) ([]roothashAPI.Event, error) {
+	return t.roothash.GetEvents(ctx, height)
+}
+
 func (t *tendermintService) WatchTendermintBlocks() (<-chan *tmtypes.Block, *pubsub.Subscription) {
 	typedCh := make(chan *tmtypes.Block)
 	sub := t.blockNotifier.Subscribe()

go/oasis-node/cmd/debug/txsource/workload/queries.go

@@ -102,6 +102,12 @@ func (q *queries) doConsensusQueries(ctx context.Context, rng *rand.Rand, height
 		return fmt.Errorf("GetTransactions at height %d: %w", height, err)
 	}
 
+	// Events.
+	_, err = q.consensus.GetEvents(ctx, height)
+	if err != nil {
+		return fmt.Errorf("GetEvents error at height %d: %w", height, err)
+	}
+
 	q.logger.Debug("Consensus queries done",
 		"height", height,
 		"epoch", epoch,

go/roothash/api/api.go

@@ -151,8 +151,8 @@ type MergeDiscrepancyDetectedEvent struct {
 
 // Event is a protocol event.
 type Event struct {
-	ExecutionDiscrepancyDetected *ExecutionDiscrepancyDetectedEvent
-	MergeDiscrepancyDetected     *MergeDiscrepancyDetectedEvent
+	ExecutionDiscrepancyDetected *ExecutionDiscrepancyDetectedEvent `json:"execution_discrepancy,omitempty"`
+	MergeDiscrepancyDetected     *MergeDiscrepancyDetectedEvent     `json:"merge_discrepancy,omitempty"`
 }
 
 // MetricsMonitorable is the interface exposed by backends capable of