Compatibility with chainlink

smartcontractkit · Dec 18, 2024 · c4e2208 · c4e2208
1 parent 4b15bd3
commit c4e2208
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 12 deletions.
diff --git a/commit/factory.go b/commit/factory.go
@@ -162,8 +162,8 @@ func (p *PluginFactory) NewReportingPlugin(ctx context.Context, config ocr3types
 		if err1 != nil {
 			return nil, ocr3types.ReportingPluginInfo{}, fmt.Errorf("failed to get chain id from selector: %w", err1)
 		}
-		readers[chain] = contractreader.NewObserverReader(
-			contractreader.NewExtendedContractReader(cr), lggr, chainID)
+		readers[chain] = contractreader.NewExtendedContractReader(
+			contractreader.NewObserverReader(cr, lggr, chainID))
 	}
 
 	// Bind the RMNHome contract

diff --git a/execute/factory.go b/execute/factory.go
@@ -156,8 +156,8 @@ func (p PluginFactory) NewReportingPlugin(
 		if err1 != nil {
 			return nil, ocr3types.ReportingPluginInfo{}, fmt.Errorf("failed to get chain id from selector: %w", err1)
 		}
-		readers[chain] = contractreader.NewObserverReader(
-			contractreader.NewExtendedContractReader(cr), lggr, chainID)
+		readers[chain] = contractreader.NewExtendedContractReader(
+			contractreader.NewObserverReader(cr, lggr, chainID))
 	}
 
 	ccipReader := readerpkg.NewCCIPChainReader(

diff --git a/internal/reader/home_chain.go b/internal/reader/home_chain.go
@@ -55,7 +55,7 @@ type homeChainPoller struct {
 	wg                      sync.WaitGroup
 	stopCh                  services.StopChan
 	sync                    services.StateMachine
-	homeChainReader         contractreader.Extended
+	homeChainReader         contractreader.ContractReaderFacade
 	lggr                    logger.Logger
 	mutex                   *sync.RWMutex
 	state                   state
@@ -68,7 +68,7 @@ type homeChainPoller struct {
 const MaxFailedPolls = 10
 
 func NewHomeChainConfigPoller(
-	homeChainReader contractreader.Extended,
+	homeChainReader contractreader.ContractReaderFacade,
 	lggr logger.Logger,
 	pollingInterval time.Duration,
 	ccipConfigBoundContract types.BoundContract,

diff --git a/pkg/contractreader/observed.go b/pkg/contractreader/observed.go
@@ -63,7 +63,7 @@ var (
 )
 
 type Observed struct {
-	Extended
+	ContractReaderFacade
 	lggr    logger.Logger
 	chainID string
 
@@ -75,12 +75,12 @@ type Observed struct {
 }
 
 func NewObserverReader(
-	cr Extended,
+	cr ContractReaderFacade,
 	lggr logger.Logger,
 	chainID string,
 ) *Observed {
 	return &Observed{
-		Extended:                cr,
+		ContractReaderFacade:    cr,
 		lggr:                    lggr,
 		chainID:                 chainID,
 		directRequestsDurations: CrDirectRequestsDurations,
@@ -97,7 +97,7 @@ func (o *Observed) GetLatestValue(
 	params, returnVal any,
 ) error {
 	start := time.Now()
-	err := o.Extended.GetLatestValue(ctx, readIdentifier, confidenceLevel, params, returnVal)
+	err := o.ContractReaderFacade.GetLatestValue(ctx, readIdentifier, confidenceLevel, params, returnVal)
 	duration := time.Since(start)
 
 	contract, function := unpackReadIdentifier(readIdentifier)
@@ -121,7 +121,7 @@ func (o *Observed) BatchGetLatestValues(
 	request types.BatchGetLatestValuesRequest,
 ) (types.BatchGetLatestValuesResult, error) {
 	start := time.Now()
-	result, err := o.Extended.BatchGetLatestValues(ctx, request)
+	result, err := o.ContractReaderFacade.BatchGetLatestValues(ctx, request)
 	duration := time.Since(start)
 
 	o.batchRequestsDurations.

diff --git a/pkg/reader/home_chain.go b/pkg/reader/home_chain.go
@@ -25,7 +25,7 @@ type OCR3Config = reader_internal.OCR3Config
 type OCR3Node = reader_internal.OCR3Node
 
 func NewObservedHomeChainReader(
-	homeChainReader contractreader.Extended,
+	homeChainReader contractreader.ContractReaderFacade,
 	lggr logger.Logger,
 	pollingInterval time.Duration,
 	ccipConfigBoundContract types.BoundContract,