diff --git a/relayer/pkg/chainlink/ocr2/contract_reader.go b/relayer/pkg/chainlink/ocr2/contract_reader.go index 2ce41622..91d09486 100644 --- 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 index 851de28b..7928738c 100644 --- 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 {