update the cache used for LatestRoundRequested (#503) (#504)

smartcontractkit · Aug 5, 2024 · 837a7dc · 837a7dc
1 parent ea0176c
commit 837a7dc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 14 deletions.
diff --git a/relayer/pkg/chainlink/ocr2/contract_reader.go b/relayer/pkg/chainlink/ocr2/contract_reader.go
@@ -101,6 +101,7 @@ func (c *contractReader) LatestTransmissionDetails(
 	return
 }
 
+// round will never be requested on Starknet so we return 0 values
 func (c *contractReader) LatestRoundRequested(
 	ctx context.Context,
 	lookback time.Duration,
@@ -110,15 +111,9 @@ func (c *contractReader) LatestRoundRequested(
 	round uint8,
 	err error,
 ) {
-	transmissionDetails, err := c.reader.LatestTransmissionDetails(ctx, c.address)
-	if err != nil {
-		err = fmt.Errorf("couldn't get transmission details: %w", err)
-	}
-
-	configDigest = transmissionDetails.Digest
+	configDigest = types.ConfigDigest{}
 	epoch = 0
 	round = 0
-
 	return
 }
 

diff --git a/relayer/pkg/chainlink/ocr2/transmissions_cache.go b/relayer/pkg/chainlink/ocr2/transmissions_cache.go
@@ -130,13 +130,7 @@ func (c *transmissionsCache) LatestRoundRequested(
 	round uint8,
 	err error,
 ) {
-	c.tdLock.RLock()
-	defer c.tdLock.RUnlock()
-	configDigest = c.transmissionDetails.Digest
-	epoch = c.transmissionDetails.Epoch
-	round = c.transmissionDetails.Round
-	err = c.assertTransmissionsNotStale()
-	return
+	return c.reader.LatestRoundRequested(ctx, lookback)
 }
 
 func (c *transmissionsCache) assertTransmissionsNotStale() error {