fix format

client/rpc.go

@@ -282,13 +282,14 @@ func (c RPC) GetSignature(signingID uint64) (*SigningResult, error) {
 				)
 				failCh <- struct{}{}
 				return
-			}
-			if res.CurrentGroupSigningResult == nil {
+			} else if res.CurrentGroupSigningResult == nil {
 				c.logger.Warning(
 					"GetSignature",
 					"Failed to get signature from %s, signing ID: %d, no signing result from current group",
 					node.Remote(), signingID,
 				)
+				failCh <- struct{}{}
+				return
 			}
 
 			signingResult := SigningResult{
@@ -299,8 +300,6 @@ func (c RPC) GetSignature(signingID uint64) (*SigningResult, error) {
 		}(node)
 	}
 
-	// Return the first result that we found;
-	// If unable to get result from all nodes, return error.
 	for range c.nodes {
 		select {
 		case res := <-resultCh:

client/types.go

@@ -4,7 +4,6 @@ import (
 	bandtsstypes "github.com/bandprotocol/chain/v2/x/bandtss/types"
 	oracletypes "github.com/bandprotocol/chain/v2/x/oracle/types"
 	tsstypes "github.com/bandprotocol/chain/v2/x/tss/types"
-	tmbytes "github.com/cometbft/cometbft/libs/bytes"
 )
 
 // OracleResult stores the necessary information for an oracle query result.
@@ -26,20 +25,3 @@ type SigningInfo struct {
 	PubKey       []byte
 	PubNonce     []byte
 }
-
-// SingleProof represents a single proof in a response.
-type SingleProof struct {
-	BlockHeight string `json:"block_height"`
-}
-
-// SingleProofResponse represents the response containing a SingleProof and the EVM proof bytes.
-type SingleProofResponse struct {
-	Proof         SingleProof      `json:"proof"`
-	EVMProofBytes tmbytes.HexBytes `json:"evm_proof_bytes"`
-}
-
-// Proof represents a full proof in a response, containing a height and a SingleProofResponse.
-type Proof struct {
-	Height string              `json:"height"`
-	Result SingleProofResponse `json:"result"`
-}

requester/middleware/parser/parser.go

@@ -4,7 +4,6 @@ import (
 	"github.com/bandprotocol/go-band-sdk/client"
 	"github.com/bandprotocol/go-band-sdk/requester/sender"
 	"github.com/bandprotocol/go-band-sdk/requester/watcher/request"
-	"github.com/bandprotocol/go-band-sdk/requester/watcher/signing"
 )
 
 func IntoRequestWatcherTaskHandler(ctx sender.SuccessResponse) (request.Task, error) {
@@ -20,10 +19,6 @@ func IntoSenderTaskHandler(ctx sender.FailResponse) (sender.Task, error) {
 	return ctx.Task, nil
 }
 
-func IntoSigningWatcherTaskHandler(ctx signing.FailResponse) (signing.Task, error) {
-	return ctx.Task, nil
-}
-
 func IntoSenderTaskHandlerFromRequest(ctx request.FailResponse) (sender.Task, error) {
 	return sender.NewTask(ctx.ID(), ctx.Msg), nil
 }

requester/sender/sender.go

@@ -101,11 +101,14 @@ func (s *Sender) request(task Task, key keyring.Record) {
 	if err != nil {
 		s.logger.Error("Sender", "failed to broadcast task ID(%d) with error: %s", task.ID(), err.Error())
 		if strings.Contains(err.Error(), "out-of-gas while executing the wasm script: bad wasm execution") {
-			s.failedRequestsCh <- FailResponse{task, sdk.TxResponse{}, types.ErrOutOfPrepareGas.Wrapf(err.Error())}
-			return
+			s.failedRequestsCh <- FailResponse{
+				task, sdk.TxResponse{}, types.ErrOutOfPrepareGas.Wrapf(err.Error()),
+			}
+		} else {
+			s.failedRequestsCh <- FailResponse{
+				task, sdk.TxResponse{}, types.ErrBroadcastFailed.Wrapf(err.Error()),
+			}
 		}
-
-		s.failedRequestsCh <- FailResponse{task, sdk.TxResponse{}, types.ErrBroadcastFailed.Wrapf(err.Error())}
 		return
 	} else if resp != nil && resp.Code != 0 {
 		s.logger.Error("Sender", "failed to broadcast task ID(%d) with code %d", task.ID(), resp.Code)

requester/watcher/signing/watcher.go

@@ -58,7 +58,11 @@ func (w *Watcher) Start() {
 
 func (w *Watcher) watch(task Task) {
 	if task.SigningID == 0 {
-		w.failedRequestsCh <- FailResponse{task, client.SigningResult{}, types.ErrUnknown.Wrapf("signing ID %d is invalid", task.SigningID)}
+		w.failedRequestsCh <- FailResponse{
+			task,
+			client.SigningResult{},
+			types.ErrUnknown.Wrapf("signing ID %d is invalid", task.SigningID),
+		}
 		return
 	}