Skip to content

Commit b35bb06

Browse files
committed
adding back get tx result
1 parent 2140924 commit b35bb06

File tree

3 files changed

+36
-0
lines changed

3 files changed

+36
-0
lines changed

pkg/loop/internal/relayer/evm_test.go

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,17 @@ func Test_EVMDomainRoundTripThroughGRPC(t *testing.T) {
145145
require.NoError(t, err)
146146
require.Equal(t, txFee, fee.TransactionFee)
147147
})
148+
149+
t.Run("GetTransactionStatus", func(t *testing.T) {
150+
evmService.staticGetTransactionStatus = func(ctx context.Context, transactionID types.IdempotencyKey) (types.TransactionStatus, error) {
151+
require.Equal(t, txId, transactionID)
152+
return types.Finalized, nil
153+
}
154+
155+
got, err := client.GetTransactionStatus(ctx, txId)
156+
require.NoError(t, err)
157+
require.Equal(t, got, types.Finalized)
158+
})
148159

149160
t.Run("FilterLogs", func(t *testing.T) {
150161
expFQ := evm.FilterQuery{

pkg/loop/internal/relayerset/evm.go

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -367,6 +367,21 @@ func (s *Server) UnregisterLogTracking(ctx context.Context, request *relayerset.
367367
return &emptypb.Empty{}, nil
368368
}
369369

370+
func (s *Server) GetTransactionStatus(ctx context.Context, request *relayerset.GetTransactionStatusRequest) (*evmpb.GetTransactionStatusReply, error) {
371+
evmService, err := s.getEVMService(ctx, request.GetRelayerId())
372+
if err != nil {
373+
return nil, err
374+
}
375+
376+
txStatus, err := evmService.GetTransactionStatus(ctx, request.Request.TransactionId)
377+
if err != nil {
378+
return nil, err
379+
}
380+
381+
//nolint: gosec // G115
382+
return &evmpb.GetTransactionStatusReply{TransactionStatus: evmpb.TransactionStatus(txStatus)}, nil
383+
}
384+
370385
func (s *Server) SubmitTransaction(ctx context.Context, request *relayerset.SubmitTransactionRequest) (*evmpb.SubmitTransactionReply, error) {
371386
evmService, err := s.getEVMService(ctx, request.GetRelayerId())
372387
if err != nil {

pkg/loop/internal/relayerset/relayerset_test.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -403,6 +403,16 @@ func Test_RelayerSet_EVMService(t *testing.T) {
403403
require.Equal(t, fee, out)
404404
},
405405
},
406+
{
407+
name: "GetTransactionStatus",
408+
run: func(t *testing.T, evm types.EVMService, mockEVM *mocks2.EVMService) {
409+
id := types.IdempotencyKey("status-tx")
410+
mockEVM.EXPECT().GetTransactionStatus(mock.Anything, id).Return(types.Unconfirmed, nil)
411+
out, err := evm.GetTransactionStatus(ctx, id)
412+
require.NoError(t, err)
413+
require.Equal(t, types.Unconfirmed, out)
414+
},
415+
},
406416
{
407417
name: "QueryTrackedLogs",
408418
run: func(t *testing.T, evm types.EVMService, mockEVM *mocks2.EVMService) {

0 commit comments

Comments
 (0)