connect log poller

pkg/solana/chainreader/chain_reader.go

@@ -36,7 +36,7 @@ type ContractReaderService struct {
 	// provided dependencies
 	lggr   logger.Logger
 	client MultipleAccountGetter
-	events EventsReader
+	reader EventsReader
 
 	// internal values
 	bindings namespaceBindings
@@ -60,7 +60,7 @@ func NewContractReaderService(
 	lggr logger.Logger,
 	dataReader MultipleAccountGetter,
 	cfg config.ContractReader,
-	events EventsReader,
+	reader EventsReader,
 ) (*ContractReaderService, error) {
 	svc := &ContractReaderService{
 		lggr:     logger.Named(lggr, ServiceName),
@@ -69,6 +69,7 @@ func NewContractReaderService(
 		lookup:   newLookup(),
 		parsed:   &codec.ParsedTypes{EncoderDefs: map[string]codec.Entry{}, DecoderDefs: map[string]codec.Entry{}},
 		filters:  []logpoller.Filter{},
+		reader:   reader,
 	}
 
 	if err := svc.init(cfg.Namespaces); err != nil {
@@ -100,7 +101,7 @@ func (s *ContractReaderService) Start(ctx context.Context) error {
 	return s.StartOnce(ServiceName, func() error {
 		// registering filters needs a context so we should be able to use the start function context.
 		for _, filter := range s.filters {
-			if err := s.events.RegisterFilter(ctx, filter); err != nil {
+			if err := s.reader.RegisterFilter(ctx, filter); err != nil {
 				return err
 			}
 		}
@@ -342,7 +343,7 @@ func (s *ContractReaderService) init(namespaces map[string]config.ChainContractR
 					nameSpaceDef.ContractAddress,
 					nameSpaceDef.IDL, eventIDlDef,
 					read,
-					s.events,
+					s.reader,
 				); err != nil {
 					return err
 				}