diff --git a/Makefile b/Makefile index e926463..42b7a6d 100644 --- a/Makefile +++ b/Makefile @@ -40,8 +40,8 @@ test: .PHONY: test-integration test-integration: - MODE=online go test -v -tags=integration -count=1 ./testing - MODE=offline go test -v -tags=integration -count=1 ./testing + MODE=online go test -v -tags=integration -count=1 ./testing + MODE=offline go test -v -tags=integration ./testing .PHONY: cover cover: diff --git a/go.mod b/go.mod index 2b28d24..60582c0 100644 --- a/go.mod +++ b/go.mod @@ -210,8 +210,6 @@ require ( replace ( // Use the cosmos keyring code github.com/99designs/keyring => github.com/cosmos/keyring v1.2.0 - - //github.com/coinbase/rosetta-sdk-go => /Users/yevheniishcherbina/go/src/github.com/coinbase/rosetta-sdk-go // Use cometbft fork of tendermint github.com/cometbft/cometbft => github.com/kava-labs/cometbft v0.37.4-kava.1 github.com/cometbft/cometbft-db => github.com/kava-labs/cometbft-db v0.9.1-kava.1 diff --git a/server/router.go b/server/router.go index 91cff67..2818d6a 100644 --- a/server/router.go +++ b/server/router.go @@ -74,7 +74,6 @@ func NewRouter(config *configuration.Configuration) (http.Handler, error) { router := services.NewBlockchainRouter(config, client, asserter) loggedRouter := sdkserver.LoggerMiddleware(router) - //loggedRouter := router corsRouter := sdkserver.CorsMiddleware(loggedRouter) return corsRouter, nil diff --git a/services/network_service.go b/services/network_service.go index 1e56cd3..e0c87d0 100644 --- a/services/network_service.go +++ b/services/network_service.go @@ -19,8 +19,6 @@ package services import ( "context" - "fmt" - "github.com/kava-labs/rosetta-kava/configuration" "github.com/kava-labs/rosetta-kava/kava" @@ -84,8 +82,6 @@ func (s *NetworkAPIService) NetworkStatus( ctx context.Context, request *types.NetworkRequest, ) (*types.NetworkStatusResponse, *types.Error) { - fmt.Printf("rosetta-kava NetworkStatus is called\n") - if s.config.Mode != configuration.Online { return nil, ErrUnavailableOffline } @@ -97,7 +93,6 @@ func (s *NetworkAPIService) NetworkStatus( peers, err := s.client.Status(ctx) if err != nil { - fmt.Printf("debug(NetworkStatus), err: %v\n", err) return nil, wrapErr(ErrKava, err) } diff --git a/testing/retry_test.go b/testing/retry_test.go index dc3fd50..b155bc8 100644 --- a/testing/retry_test.go +++ b/testing/retry_test.go @@ -19,9 +19,7 @@ package testing import ( "context" - "fmt" "math/rand" - "os/exec" "regexp" "sync/atomic" "testing" @@ -47,11 +45,6 @@ func TestBlockRetry(t *testing.T) { } errChan := make(chan serviceError, numJobs) - cmd := exec.Command("bash", "-c", "lsof | wc -l") - initialLSOFOutput, err := cmd.Output() - _ = initialLSOFOutput - _ = err - var globalReq atomic.Uint64 for i := 0; i < numJobs; i++ { go func() { @@ -75,20 +68,6 @@ func TestBlockRetry(t *testing.T) { NetworkIdentifier: config.NetworkIdentifier, }, ) - fmt.Printf("###################### BEGIN ##########################\n") - fmt.Printf("err : %v\n", err) - fmt.Printf("rosettaErr : %v\n", rosettaErr) - fmt.Printf("networkStatus: %v\n", networkStatus) - fmt.Printf("req : %v\n", req) - fmt.Printf("globalReq : %v\n", globalReq.Load()) - //cmd := exec.Command("bash", "-c", "lsof | wc -l") - //output, err := cmd.Output() - //if err != nil { - // fmt.Printf("lsof err: %v\n", err) - //} - //fmt.Printf("initial LSOF output: %s\n", initialLSOFOutput) - //fmt.Printf(" lsof output: %s\n", output) - fmt.Printf("####################### END #########################\n") currentBlock := networkStatus.CurrentBlockIdentifier request := &types.BlockRequest{ @@ -101,7 +80,6 @@ func TestBlockRetry(t *testing.T) { _, rosettaErr, err = client.BlockAPI.Block(ctx, request) if err != nil { - // TODO(yevhenii): skip other errors as well if lessOrEqualCurrentHeight.MatchString(err.Error()) { continue }