overflow 163 inject logging fields (#165)

* Inject log fields in ctx for grpc logs

* Remove TODO item

* Add more grpc logging fields to ctxs

* Depend on grpc logging

Author: gabrielseibel1

go.mod

@@ -9,6 +9,7 @@ require (
 	github.com/bjartek/underflow v1.5.0
 	github.com/enescakir/emoji v1.0.0
 	github.com/fatih/color v1.16.0
+	github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.1.0
 	github.com/hashicorp/go-multierror v1.1.1
 	github.com/hexops/autogold v1.3.1
 	github.com/onflow/cadence v1.0.0-preview.34
@@ -95,7 +96,6 @@ require (
 	github.com/googleapis/gax-go/v2 v2.12.0 // indirect
 	github.com/gorilla/websocket v1.5.0 // indirect
 	github.com/gosuri/uilive v0.0.4 // indirect
-	github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.1.0 // indirect
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.0 // indirect
 	github.com/hashicorp/errwrap v1.1.0 // indirect
 	github.com/hashicorp/golang-lru v1.0.2 // indirect

state.go

@@ -14,6 +14,7 @@ import (
 
 	"github.com/bjartek/underflow"
 	"github.com/enescakir/emoji"
+	"github.com/grpc-ecosystem/go-grpc-middleware/v2/interceptors/logging"
 	"github.com/hashicorp/go-multierror"
 	"github.com/onflow/cadence"
 	"github.com/onflow/cadence/runtime"
@@ -497,6 +498,7 @@ func (o *OverflowState) GetAccount(ctx context.Context, key string) (*flow.Accou
 		return nil, err
 	}
 	rawAddress := account.Address
+	ctx = logging.InjectFields(ctx, logging.Fields{"account_name", key, "account_address", rawAddress.String()})
 	return o.Flowkit.GetAccount(ctx, rawAddress)
 }
 
@@ -611,12 +613,14 @@ func (o *OverflowState) GetLatestBlock(ctx context.Context) (*flow.Block, error)
 
 // get block at a given height
 func (o *OverflowState) GetBlockAtHeight(ctx context.Context, height uint64) (*flow.Block, error) {
+	ctx = logging.InjectLogField(ctx, "block_height", height)
 	bc := flowkit.BlockQuery{Height: height}
 	return o.Flowkit.GetBlock(ctx, bc)
 }
 
 // blockId should be a hexadecimal string
 func (o *OverflowState) GetBlockById(ctx context.Context, blockId string) (*flow.Block, error) {
+	ctx = logging.InjectLogField(ctx, "block_id", blockId)
 	bid := flow.HexToID(blockId)
 	bc := flowkit.BlockQuery{ID: &bid}
 	return o.Flowkit.GetBlock(ctx, bc)

transaction.go

@@ -7,6 +7,7 @@ import (
 	"strings"
 
 	"github.com/bjartek/underflow"
+	"github.com/grpc-ecosystem/go-grpc-middleware/v2/interceptors/logging"
 	"github.com/onflow/cadence/runtime/common"
 	"github.com/onflow/cadence/runtime/parser"
 	"github.com/onflow/flow-go-sdk"
@@ -144,6 +145,7 @@ func (o *OverflowState) CreateOverflowTransaction(blockId string, transactionRes
 }
 
 func (o *OverflowState) GetOverflowTransactionById(ctx context.Context, id flow.Identifier) (*OverflowTransaction, error) {
+	ctx = logging.InjectLogField(ctx, "transaction_id", id)
 	tx, txr, err := o.Flowkit.GetTransactionByID(ctx, id, false)
 	if err != nil {
 		return nil, err
@@ -156,6 +158,7 @@ func (o *OverflowState) GetOverflowTransactionById(ctx context.Context, id flow.
 }
 
 func (o *OverflowState) GetTransactionById(ctx context.Context, id flow.Identifier) (*flow.Transaction, error) {
+	ctx = logging.InjectLogField(ctx, "transaction_id", id)
 	tx, _, err := o.Flowkit.GetTransactionByID(ctx, id, false)
 	if err != nil {
 		return nil, err
@@ -164,6 +167,7 @@ func (o *OverflowState) GetTransactionById(ctx context.Context, id flow.Identifi
 }
 
 func (o *OverflowState) GetTransactionsByBlockId(ctx context.Context, id flow.Identifier) ([]*flow.Transaction, []*flow.TransactionResult, error) {
+	ctx = logging.InjectLogField(ctx, "block_id", id)
 	tx, txr, err := o.Flowkit.GetTransactionsByBlockID(ctx, id)
 	if err != nil {
 		return nil, nil, err