diff --git a/integration/common/utils.go b/integration/common/utils.go index 4d5ca021af..9b2a5d9ba3 100644 --- a/integration/common/utils.go +++ b/integration/common/utils.go @@ -38,7 +38,7 @@ func RndBtwTime(min time.Duration, max time.Duration) time.Duration { return time.Duration(RndBtw(uint64(min.Nanoseconds()), uint64(max.Nanoseconds()))) * time.Nanosecond } -func AwaitReceiptEth(ctx context.Context, client ethadapter.EthClient, txHash gethcommon.Hash, timeout time.Duration) error { +func AwaitReceiptEth(client ethadapter.EthClient, txHash gethcommon.Hash, timeout time.Duration) error { var receipt *types.Receipt var err error err = retry.Do(func() error { diff --git a/integration/simulation/simulation.go b/integration/simulation/simulation.go index 04ece6fc6c..545739ca94 100644 --- a/integration/simulation/simulation.go +++ b/integration/simulation/simulation.go @@ -161,7 +161,7 @@ func (s *Simulation) bridgeFundingToObscuro() { transactions = append(transactions, tx) } - //time.Sleep(3 * time.Second) + // time.Sleep(3 * time.Second) // todo - fix the wait group, for whatever reason it does not find a receipt... wg := sync.WaitGroup{} for _, tx := range transactions { @@ -169,7 +169,7 @@ func (s *Simulation) bridgeFundingToObscuro() { transaction := tx go func() { defer wg.Done() - err := testcommon.AwaitReceiptEth(s.ctx, s.RPCHandles.RndEthClient(), transaction.Hash(), 2*time.Minute) + err := testcommon.AwaitReceiptEth(s.RPCHandles.RndEthClient(), transaction.Hash(), 2*time.Minute) if err != nil { panic(err) }