Compatibility with chainlink

pkg/contractreader/extended.go

@@ -24,6 +24,11 @@ var (
 
 // Extended version of a ContractReader.
 type Extended interface {
+	// Unbind is included for compatibility with ContractReader
+	Unbind(ctx context.Context, bindings []types.BoundContract) error
+	// HealthReport is included for compatibility with ContractReader
+	HealthReport() map[string]error
+
 	Bind(ctx context.Context, bindings []types.BoundContract) error
 
 	GetBindings(contractName string) []ExtendedBoundContract
@@ -278,19 +283,19 @@ func (e *extendedContractReader) bindingExists(b types.BoundContract) bool {
 }
 
 func (e *extendedContractReader) hasFinalityViolation() bool {
-	if e.reader == nil {
-		return false
-	}
-
-	if _, ok := e.reader.(Extended); ok {
-		panic("bad news")
-	}
-
 	report := e.reader.HealthReport()
 	return services.ContainsError(
 		report,
 		clcommontypes.ErrFinalityViolated)
 }
 
+func (e *extendedContractReader) Unbind(ctx context.Context, bindings []types.BoundContract) error {
+	return e.reader.Unbind(ctx, bindings)
+}
+
+func (e *extendedContractReader) HealthReport() map[string]error {
+	return e.reader.HealthReport()
+}
+
 // Interface compliance check
 var _ Extended = (*extendedContractReader)(nil)

pkg/reader/rmn_home.go

@@ -61,7 +61,7 @@ type rmnHomePoller struct {
 	stopCh               services.StopChan
 	sync                 services.StateMachine
 	mutex                *sync.RWMutex
-	contractReader       contractreader.Extended
+	contractReader       contractreader.ContractReaderFacade
 	rmnHomeBoundContract types.BoundContract
 	lggr                 logger.Logger
 	rmnHomeState         rmnHomeState
@@ -70,7 +70,7 @@ type rmnHomePoller struct {
 }
 
 func NewRMNHomePoller(
-	contractReader contractreader.Extended,
+	contractReader contractreader.ContractReaderFacade,
 	rmnHomeBoundContract types.BoundContract,
 	lggr logger.Logger,
 	pollingInterval time.Duration,