Fix closed connection (#1322)

* Fix closed connection

* Throw error

* Update relayer/relays/parachain/scanner.go

Co-authored-by: Vincent Geddes <[email protected]>

---------

Co-authored-by: Vincent Geddes <[email protected]>

Author: yrong

relayer/relays/parachain/main.go

@@ -86,7 +86,7 @@ func (relay *Relay) Start(ctx context.Context, eg *errgroup.Group) error {
 		return fmt.Errorf("unable to connect to ethereum: beefy: %w", err)
 	}
 
-	err = relay.relaychainConn.Connect(ctx)
+	err = relay.relaychainConn.ConnectWithHeartBeat(ctx, 30*time.Second)
 	if err != nil {
 		return err
 	}

relayer/relays/parachain/scanner.go

@@ -5,10 +5,11 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"github.com/ethereum/go-ethereum/accounts/abi"
 	"reflect"
 	"strings"
 
+	"github.com/ethereum/go-ethereum/accounts/abi"
+
 	"github.com/snowfork/go-substrate-rpc-client/v4/scale"
 
 	"github.com/ethereum/go-ethereum/accounts/abi/bind"
@@ -122,7 +123,10 @@ func (s *Scanner) findTasks(
 		return nil, err
 	}
 
-	s.gatherProofInputs(tasks)
+	err = s.gatherProofInputs(tasks)
+	if err != nil {
+		return nil, fmt.Errorf("gather proof input: %w", err)
+	}
 
 	return tasks, nil
 }