Add missing changes to last commit

BeanLeader · Jul 22, 2022 · 7e5a6af · 7e5a6af
1 parent 3bacb2f
commit 7e5a6af
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/packages/arb-util/broadcastclient/broadcastclient.go b/packages/arb-util/broadcastclient/broadcastclient.go
@@ -63,21 +63,21 @@ var logger = arblog.Logger.With().Str("component", "broadcaster").Logger()
 func NewBroadcastClient(
 	websocketUrl string,
 	chainId uint64,
-	lastInboxSeqNum *big.Int,
+	requestedInboxSeqNum *big.Int,
 	idleTimeout time.Duration,
 	broadcastClientErrChan chan error,
 ) *BroadcastClient {
-	var seqNum *big.Int
-	if lastInboxSeqNum == nil {
-		seqNum = big.NewInt(0)
+	var lastSeqNum *big.Int
+	if requestedInboxSeqNum == nil || requestedInboxSeqNum.Cmp(big.NewInt(0)) <= 0 {
+		lastSeqNum = big.NewInt(0)
 	} else {
-		seqNum = lastInboxSeqNum
+		lastSeqNum = new(big.Int).Sub(requestedInboxSeqNum, big.NewInt(1))
 	}
 
 	return &BroadcastClient{
 		websocketUrl:    websocketUrl,
 		chainId:         chainId,
-		lastInboxSeqNum: seqNum,
+		lastInboxSeqNum: lastSeqNum,
 		connMutex:       &sync.Mutex{},
 		errChan:         broadcastClientErrChan,
 		retryMutex:      &sync.Mutex{},