File tree Expand file tree Collapse file tree 4 files changed +18
-4
lines changed
Expand file tree Collapse file tree 4 files changed +18
-4
lines changed Original file line number Diff line number Diff line change 99 "go.opentelemetry.io/otel/codes"
1010 "go.opentelemetry.io/otel/trace"
1111
12+ blobrpc "github.com/evstack/ev-node/pkg/da/jsonrpc"
1213 datypes "github.com/evstack/ev-node/pkg/da/types"
1314)
1415
@@ -132,6 +133,14 @@ func (t *tracedClient) HasForcedInclusionNamespace() bool {
132133 return t .inner .HasForcedInclusionNamespace ()
133134}
134135
136+ func (t * tracedClient ) Subscribe (ctx context.Context , namespace []byte ) (<- chan * blobrpc.SubscriptionResponse , error ) {
137+ return t .inner .Subscribe (ctx , namespace )
138+ }
139+
140+ func (t * tracedClient ) LocalHead (ctx context.Context ) (uint64 , error ) {
141+ return t .inner .LocalHead (ctx )
142+ }
143+
135144type submitError struct { msg string }
136145
137146func (e * submitError ) Error () string { return e .msg }
Original file line number Diff line number Diff line change @@ -12,6 +12,7 @@ import (
1212 sdktrace "go.opentelemetry.io/otel/sdk/trace"
1313 "go.opentelemetry.io/otel/sdk/trace/tracetest"
1414
15+ blobrpc "github.com/evstack/ev-node/pkg/da/jsonrpc"
1516 datypes "github.com/evstack/ev-node/pkg/da/types"
1617)
1718
@@ -58,6 +59,10 @@ func (m *mockFullClient) GetHeaderNamespace() []byte { return []byte{0x
5859func (m * mockFullClient ) GetDataNamespace () []byte { return []byte {0x02 } }
5960func (m * mockFullClient ) GetForcedInclusionNamespace () []byte { return []byte {0x03 } }
6061func (m * mockFullClient ) HasForcedInclusionNamespace () bool { return true }
62+ func (m * mockFullClient ) Subscribe (ctx context.Context , namespace []byte ) (<- chan * blobrpc.SubscriptionResponse , error ) {
63+ return nil , nil
64+ }
65+ func (m * mockFullClient ) LocalHead (ctx context.Context ) (uint64 , error ) { return 0 , nil }
6166
6267// setup a tracer provider + span recorder
6368func setupDATrace (t * testing.T , inner FullClient ) (FullClient , * tracetest.SpanRecorder ) {
Original file line number Diff line number Diff line change @@ -84,8 +84,8 @@ github.com/ferranbt/fastssz v0.1.4 h1:OCDB+dYDEQDvAgtAGnTSidK1Pe2tW3nFV40XyMkTeD
8484github.com/ferranbt/fastssz v0.1.4 /go.mod h1:Ea3+oeoRGGLGm5shYAeDgu6PGUlcvQhE2fILyD9+tGg =
8585github.com/filecoin-project/go-clock v0.1.0 h1:SFbYIM75M8NnFm1yMHhN9Ahy3W5bEZV9gd6MPfXbKVU =
8686github.com/filecoin-project/go-clock v0.1.0 /go.mod h1:4uB/O4PvOjlx1VCMdZ9MyDZXRm//gkj1ELEbxfI1AZs =
87- github.com/filecoin-project/go-jsonrpc v0.9 .0 h1:G47qEF52w7GholpI21vPSTVBFvsrip6geIoqNiqyZtQ =
88- github.com/filecoin-project/go-jsonrpc v0.9 .0 /go.mod h1:OG7kVBVh/AbDFHIwx7Kw0l9ARmKOS6gGOr0LbdBpbLc =
87+ github.com/filecoin-project/go-jsonrpc v0.10 .0 h1:gZc1thGVD5Khg5Gp1UJibRWZrnNBEP1iFrGOTn0w5TE =
88+ github.com/filecoin-project/go-jsonrpc v0.10 .0 /go.mod h1:OG7kVBVh/AbDFHIwx7Kw0l9ARmKOS6gGOr0LbdBpbLc =
8989github.com/flynn/noise v1.1.0 h1:KjPQoQCEFdZDiP03phOvGi11+SVVhBG2wOWAorLsstg =
9090github.com/flynn/noise v1.1.0 /go.mod h1:xbMo+0i6+IGbYdJhF31t2eR1BIU0CYc12+BNAKwUTag =
9191github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8 =
Original file line number Diff line number Diff line change @@ -208,8 +208,8 @@ github.com/ferranbt/fastssz v0.1.4 h1:OCDB+dYDEQDvAgtAGnTSidK1Pe2tW3nFV40XyMkTeD
208208github.com/ferranbt/fastssz v0.1.4 /go.mod h1:Ea3+oeoRGGLGm5shYAeDgu6PGUlcvQhE2fILyD9+tGg =
209209github.com/filecoin-project/go-clock v0.1.0 h1:SFbYIM75M8NnFm1yMHhN9Ahy3W5bEZV9gd6MPfXbKVU =
210210github.com/filecoin-project/go-clock v0.1.0 /go.mod h1:4uB/O4PvOjlx1VCMdZ9MyDZXRm//gkj1ELEbxfI1AZs =
211- github.com/filecoin-project/go-jsonrpc v0.9 .0 h1:G47qEF52w7GholpI21vPSTVBFvsrip6geIoqNiqyZtQ =
212- github.com/filecoin-project/go-jsonrpc v0.9 .0 /go.mod h1:OG7kVBVh/AbDFHIwx7Kw0l9ARmKOS6gGOr0LbdBpbLc =
211+ github.com/filecoin-project/go-jsonrpc v0.10 .0 h1:gZc1thGVD5Khg5Gp1UJibRWZrnNBEP1iFrGOTn0w5TE =
212+ github.com/filecoin-project/go-jsonrpc v0.10 .0 /go.mod h1:OG7kVBVh/AbDFHIwx7Kw0l9ARmKOS6gGOr0LbdBpbLc =
213213github.com/flynn/noise v1.1.0 h1:KjPQoQCEFdZDiP03phOvGi11+SVVhBG2wOWAorLsstg =
214214github.com/flynn/noise v1.1.0 /go.mod h1:xbMo+0i6+IGbYdJhF31t2eR1BIU0CYc12+BNAKwUTag =
215215github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw =
You can’t perform that action at this time.
0 commit comments