Improved inactivity claim submission process

pkg/tbtc/heartbeat.go

@@ -138,7 +138,7 @@ func (ha *heartbeatAction) execute() error {
 	)
 	defer cancelHeartbeatCtx()
 
-	signature, activeOperatorsCount, _, err := ha.signingExecutor.sign(
+	signature, activeOperatorsCount, signingEndBlock, err := ha.signingExecutor.sign(
 		heartbeatCtx,
 		messageToSign,
 		ha.startBlock,
@@ -189,12 +189,14 @@ func (ha *heartbeatAction) execute() error {
 	// The value of consecutive heartbeat failures exceeds the threshold.
 	// Proceed with operator inactivity notification.
 	err = ha.inactivityClaimExecutor.publishClaim(
-		// Leave the list empty. Some operators were inactive during the
-		// heartbeat because they were simply unstaking and therefore should not
-		// be punished.
+		// Leave the list of inactive operators empty even if some operators
+		// were inactive during signing heartbeat. The inactive operators could
+		// simply be in the process of unstaking and therefore should not be
+		// punished.
 		[]group.MemberIndex{},
 		true,
 		messageToSign,
+		signingEndBlock,
 	)
 	if err != nil {
 		return fmt.Errorf(

pkg/tbtc/inactivity.go

@@ -24,6 +24,9 @@ const (
 	// by the given member to avoid all members submitting the same inactivity claim
 	// at the same time.
 	inactivityClaimSubmissionDelayStepBlocks = 3
+	// inactivityClaimMaximumSubmissionBlocks determines the maximum block
+	// duration of inactivity claim submission procedure.
+	inactivityClaimMaximumSubmissionBlocks = 60
 )
 
 // errInactivityClaimExecutorBusy is an error returned when the inactivity claim
@@ -70,6 +73,7 @@ func (ice *inactivityClaimExecutor) publishClaim(
 	inactiveMembersIndexes []group.MemberIndex,
 	heartbeatFailed bool,
 	message *big.Int,
+	startBlock uint64,
 ) error {
 	if lockAcquired := ice.lock.TryAcquire(1); !lockAcquired {
 		return errInactivityClaimExecutorBusy
@@ -121,7 +125,7 @@ func (ice *inactivityClaimExecutor) publishClaim(
 
 		defer wg.Done()
 
-		inactivityClaimTimeoutBlock := uint64(0) // TODO: Set the value of timeout block
+		inactivityClaimTimeoutBlock := startBlock + inactivityClaimMaximumSubmissionBlocks
 
 		go func(signer *signer) {
 			ctx, cancelCtx := withCancelOnBlock(