Update Substreams dependency and refactor gRPC client connection

streamingfast · Feb 17, 2025 · 4ef5892 · 4ef5892
1 parent 523e525
commit 4ef5892
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 6 deletions.
diff --git a/cmd/apps/substreams_tier1.go b/cmd/apps/substreams_tier1.go
@@ -164,7 +164,7 @@ func RegisterSubstreamsTier1App[B firecore.Block](chain *firecore.Chain[B], root
 			workerPoolFactory := work.NewSimpleWorkerPoolFactory(clientFactory).WorkerPool
 
 			if substreamsGlobalWorkerPoolAddress != "" {
-				grpcClientConnection, err := dgrpc.NewInternalClientConn(substreamsGlobalWorkerPoolAddress)
+				grpcClientConnection, err := dgrpc.NewInternalNoWaitClientConn(substreamsGlobalWorkerPoolAddress)
 				if err != nil {
 					return nil, fmt.Errorf("unable to create grpc client connection to global worker pool: %w", err)
 				}

diff --git a/go.mod b/go.mod
@@ -2,8 +2,6 @@ module github.com/streamingfast/firehose-core
 
 go 1.23.4
 
-//replace github.com/streamingfast/substreams => ../substreams
-
 require (
 	buf.build/gen/go/bufbuild/reflect/connectrpc/go v1.16.1-20240117202343-bf8f65e8876c.1
 	buf.build/gen/go/bufbuild/reflect/protocolbuffers/go v1.33.0-20240117202343-bf8f65e8876c.1
@@ -33,7 +31,7 @@ require (
 	github.com/streamingfast/payment-gateway v0.0.0-20240426151444-581e930c76e2
 	github.com/streamingfast/pbgo v0.0.6-0.20250114182320-0b43084f4000
 	github.com/streamingfast/snapshotter v0.0.0-20230316190750-5bcadfde44d0
-	github.com/streamingfast/substreams v1.12.3-0.20250212174204-147cdb27c693
+	github.com/streamingfast/substreams v1.12.3-0.20250217154006-513918760221
 	github.com/streamingfast/worker-pool-protocol v0.0.0-20250211140743-fb8ffbc05fbc
 	github.com/stretchr/testify v1.9.0
 	github.com/test-go/testify v1.1.4

diff --git a/go.sum b/go.sum
@@ -2186,8 +2186,8 @@ github.com/streamingfast/shutter v1.5.0 h1:NpzDYzj0HVpSiDJVO/FFSL6QIK/YKOxY0gJAt
 github.com/streamingfast/shutter v1.5.0/go.mod h1:B/T6efqdeMGbGwjzPS1ToXzYZI4kDzI5/u4I+7qbjY8=
 github.com/streamingfast/snapshotter v0.0.0-20230316190750-5bcadfde44d0 h1:Y15G1Z4fpEdm2b+/70owI7TLuXadlqBtGM7rk4Hxrzk=
 github.com/streamingfast/snapshotter v0.0.0-20230316190750-5bcadfde44d0/go.mod h1:/Rnz2TJvaShjUct0scZ9kKV2Jr9/+KBAoWy4UMYxgv4=
-github.com/streamingfast/substreams v1.12.3-0.20250212174204-147cdb27c693 h1:Laq33zSVG4D3tDVmVC9oTBC6JGcaWOMfQMI3Mu/lNzY=
-github.com/streamingfast/substreams v1.12.3-0.20250212174204-147cdb27c693/go.mod h1:l0QpHJpUYVNfxnbTQDkJCdfE4qpKLb693MFYj7YXWAA=
+github.com/streamingfast/substreams v1.12.3-0.20250217154006-513918760221 h1:vRjtJqv6J+CXU5KLTPo5TrLgJmw/N3PR4JhJemwPDzY=
+github.com/streamingfast/substreams v1.12.3-0.20250217154006-513918760221/go.mod h1:l0QpHJpUYVNfxnbTQDkJCdfE4qpKLb693MFYj7YXWAA=
 github.com/streamingfast/wazero v0.0.0-20241202185309-91287c3640ed h1:LU6/c376zP1cMAo9L6rFLyjo0W7RU+hIh7BegH8Zo5M=
 github.com/streamingfast/wazero v0.0.0-20241202185309-91287c3640ed/go.mod h1:yAI0XTsMBhREkM/YDAK/zNou3GoiAce1P6+rp/wQhjs=
 github.com/streamingfast/worker-pool-protocol v0.0.0-20250211140743-fb8ffbc05fbc h1:WrgK+ECYQpYd5n+IG7rDR88lkaXw3wef1UKlEBvZ6Bs=