@@ -29,10 +29,9 @@ import (
2929 "github.com/cosmos/cosmos-sdk/x/bank"
3030 "github.com/cosmos/cosmos-sdk/x/gov"
3131 "github.com/cosmos/ibc-go/v8/modules/apps/transfer"
32+ libshare "github.com/celestiaorg/go-square/v3/share"
3233 "github.com/evstack/ev-node/pkg/da/jsonrpc"
3334 datypes "github.com/evstack/ev-node/pkg/da/types"
34- seqcommon "github.com/evstack/ev-node/sequencers/common"
35- "github.com/rs/zerolog"
3635 "github.com/stretchr/testify/require"
3736)
3837
@@ -241,7 +240,7 @@ func TestEvNode_PostsToDA(t *testing.T) {
241240
242241 // 6) Assert data landed on DA via celestia-node blob RPC (namespace ev-data)
243242 daRPCAddr := fmt .Sprintf ("http://%s" , bridgeNetInfo .Internal .RPCAddress ())
244- daClient , err := jsonrpc .NewClient (ctx , zerolog . Nop (), daRPCAddr , authToken , seqcommon . AbsoluteMaxBlobSize )
243+ daClient , err := jsonrpc .NewClient (ctx , daRPCAddr , authToken , "" )
245244 require .NoError (t , err , "new da client" )
246245 defer daClient .Close ()
247246
@@ -275,17 +274,20 @@ func TestEvNode_PostsToDA(t *testing.T) {
275274 return false , nil
276275 })
277276
277+ ns , err := libshare .NewNamespaceFromBytes (dataNamespace .Bytes ())
278+ require .NoError (t , err , "create libshare namespace" )
279+
278280 wait .ForCondition (ctx , time .Minute , 5 * time .Second , func () (bool , error ) {
279281 if pfbHeight == 0 {
280282 return false , nil
281283 }
282284 for h := pfbHeight ; h <= pfbHeight + 10 ; h ++ {
283- ids , err := daClient .DA . GetIDs (ctx , uint64 (h ), dataNamespace . Bytes () )
285+ blobs , err := daClient .Blob . GetAll (ctx , uint64 (h ), []libshare. Namespace { ns } )
284286 if err != nil {
285- t .Logf ("GetIDs data height=%d err=%v" , h , err )
287+ t .Logf ("GetAll data height=%d err=%v" , h , err )
286288 continue
287289 }
288- if ids != nil && len (ids . IDs ) > 0 {
290+ if len (blobs ) > 0 {
289291 return true , nil
290292 }
291293 }
0 commit comments