Add total difficulty

DylanTinianov · DylanTinianov · commit c278fa876fc6 · 2025-01-14T12:50:44.000-05:00
diff --git a/multinode/adaptor.go b/multinode/adaptor.go
@@ -189,12 +189,14 @@ func (m *Adapter[RPC, HEAD]) OnNewHead(ctx context.Context, requestCh <-chan str
 	defer m.chainInfoLock.Unlock()
 	if !CtxIsHeathCheckRequest(ctx) {
 		m.highestUserObservations.BlockNumber = max(m.highestUserObservations.BlockNumber, head.BlockNumber())
+		m.highestUserObservations.TotalDifficulty = MaxTotalDifficulty(m.highestUserObservations.TotalDifficulty, head.BlockDifficulty())
 	}
 	select {
 	case <-requestCh: // no need to update latestChainInfo, as rpcMultiNodeAdapter already started new life cycle
 		return
 	default:
 		m.latestChainInfo.BlockNumber = head.BlockNumber()
+		m.latestChainInfo.TotalDifficulty = head.BlockDifficulty()
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -189,12 +189,14 @@ func (m *Adapter[RPC, HEAD]) OnNewHead(ctx context.Context, requestCh <-chan str`
`189`	`189`	`defer m.chainInfoLock.Unlock()`
`190`	`190`	`if !CtxIsHeathCheckRequest(ctx) {`
`191`	`191`	`m.highestUserObservations.BlockNumber = max(m.highestUserObservations.BlockNumber, head.BlockNumber())`
	`192`	`+ m.highestUserObservations.TotalDifficulty = MaxTotalDifficulty(m.highestUserObservations.TotalDifficulty, head.BlockDifficulty())`
`192`	`193`	`}`
`193`	`194`	`select {`
`194`	`195`	`case <-requestCh: // no need to update latestChainInfo, as rpcMultiNodeAdapter already started new life cycle`
`195`	`196`	`return`
`196`	`197`	`default:`
`197`	`198`	`m.latestChainInfo.BlockNumber = head.BlockNumber()`
	`199`	`+ m.latestChainInfo.TotalDifficulty = head.BlockDifficulty()`
`198`	`200`	`}`
`199`	`201`	`}`
`200`	`202`