Implemented inactivity claim submitter

pkg/tbtc/inactivity.go

@@ -30,7 +30,7 @@ type inactivityClaimExecutor struct {
 	broadcastChannel    net.BroadcastChannel
 	membershipValidator *group.MembershipValidator
 	groupParameters     *GroupParameters
-	protocolLatch 		*generator.ProtocolLatch
+	protocolLatch       *generator.ProtocolLatch
 
 	waitForBlockFn waitForBlockFn
 }
@@ -159,7 +159,11 @@ func (ice *inactivityClaimExecutor) publish(
 		dishonestThreshold,
 		membershipValidator,
 		newInactivityClaimSigner(ice.chain),
-		newInactivityClaimSubmitter(),
+		newInactivityClaimSubmitter(
+			inactivityLogger,
+			ice.chain,
+			ice.groupParameters,
+		),
 		inactivityClaim,
 	)
 }

pkg/tbtc/inactivity_submit.go

@@ -4,6 +4,8 @@ import (
 	"context"
 	"fmt"
 
+	"github.com/ipfs/go-log/v2"
+	"github.com/keep-network/keep-core/pkg/bitcoin"
 	"github.com/keep-network/keep-core/pkg/protocol/group"
 	"github.com/keep-network/keep-core/pkg/tecdsa/inactivity"
 )
@@ -71,12 +73,22 @@ func (ics *inactivityClaimSigner) VerifySignature(
 }
 
 type inactivityClaimSubmitter struct {
-	// TODO: Implement
+	inactivityLogger log.StandardLogger
+
+	chain           Chain
+	groupParameters *GroupParameters
 }
 
-func newInactivityClaimSubmitter() *inactivityClaimSubmitter {
-	// TODO: Implement
-	return &inactivityClaimSubmitter{}
+func newInactivityClaimSubmitter(
+	inactivityLogger log.StandardLogger,
+	chain Chain,
+	groupParameters *GroupParameters,
+) *inactivityClaimSubmitter {
+	return &inactivityClaimSubmitter{
+		inactivityLogger: inactivityLogger,
+		chain:            chain,
+		groupParameters:  groupParameters,
+	}
 }
 
 func (ics *inactivityClaimSubmitter) SubmitClaim(
@@ -85,6 +97,39 @@ func (ics *inactivityClaimSubmitter) SubmitClaim(
 	claim *inactivity.Claim,
 	signatures map[group.MemberIndex][]byte,
 ) error {
-	// TODO: Implement
+	if len(signatures) < ics.groupParameters.HonestThreshold {
+		return fmt.Errorf(
+			"could not submit inactivity claim with [%v] signatures for "+
+				"group honest threshold [%v]",
+			len(signatures),
+			ics.groupParameters.HonestThreshold,
+		)
+	}
+
+	walletPublicKeyHash := bitcoin.PublicKeyHash(claim.WalletPublicKey)
+
+	walletRegistryData, err := ics.chain.GetWallet(walletPublicKeyHash)
+	if err != nil {
+		return fmt.Errorf("could not get registry data on wallet: [%v]", err)
+	}
+
+	currentNonce, err := ics.chain.GetInactivityClaimNonce(
+		walletRegistryData.EcdsaWalletID,
+	)
+	if err != nil {
+		return fmt.Errorf("could not get nonce for wallet: [%v]", err)
+	}
+
+	if currentNonce.Cmp(claim.Nonce) > 0 {
+		// Someone who was ahead of us in the queue submitted the claim. Giving up.
+		ics.inactivityLogger.Infof(
+			"[member:%v] inactivity claim already submitted; "+
+				"aborting inactivity claim on-chain submission",
+			memberIndex,
+		)
+		return nil
+	}
+
+	// TODO: Continue with the implementation
 	return nil
 }