Remove ILogPoller interface, add LogPoller interface to chain.go

Also: add GetBlockWithOpts to MultiClient
smartcontractkit · Jan 15, 2025 · 7c4058b · 7c4058b
1 parent 1395dd3
commit 7c4058b
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 12 deletions.
diff --git a/pkg/solana/chain.go b/pkg/solana/chain.go
@@ -34,12 +34,19 @@ import (
 	txmutils "github.com/smartcontractkit/chainlink-solana/pkg/solana/txm/utils"
 )
 
+type LogPoller interface {
+	Start(context.Context) error
+	Close() error
+	RegisterFilter(ctx context.Context, filter logpoller.Filter) error
+	UnregisterFilter(ctx context.Context, name string) error
+}
+
 type Chain interface {
 	types.ChainService
 
 	ID() string
 	Config() config.Config
-	LogPoller() logpoller.ILogPoller
+	LogPoller() LogPoller
 	TxManager() TxManager
 	// Reader returns a new Reader from the available list of nodes (if there are multiple, it will randomly select one)
 	Reader() (client.Reader, error)
@@ -92,7 +99,7 @@ type chain struct {
 	services.StateMachine
 	id             string
 	cfg            *config.TOMLConfig
-	lp             logpoller.ILogPoller
+	lp             logpoller.LogPoller
 	txm            *txm.Txm
 	balanceMonitor services.Service
 	lggr           logger.Logger
@@ -407,7 +414,7 @@ func (c *chain) Config() config.Config {
 	return c.cfg
 }
 
-func (c *chain) LogPoller() logpoller.ILogPoller {
+func (c *chain) LogPoller() LogPoller {
 	return c.lp
 }
 

diff --git a/pkg/solana/client/multi_client.go b/pkg/solana/client/multi_client.go
@@ -166,3 +166,12 @@ func (m *MultiClient) GetSignaturesForAddressWithOpts(ctx context.Context, addr
 
 	return r.GetSignaturesForAddressWithOpts(ctx, addr, opts)
 }
+
+func (m *MultiClient) GetBlockWithOpts(ctx context.Context, slot uint64, opts *rpc.GetBlockOpts) (*rpc.GetBlockResult, error) {
+	r, err := m.getClient()
+	if err != nil {
+		return nil, err
+	}
+
+	return r.GetBlockWithOpts(ctx, slot, opts)
+}
diff --git a/pkg/solana/logpoller/log_poller.go b/pkg/solana/logpoller/log_poller.go
@@ -32,14 +32,6 @@ type ORM interface {
 	SelectSeqNums(ctx context.Context) (map[int64]int64, error)
 }
 
-type ILogPoller interface {
-	Start(context.Context) error
-	Close() error
-	RegisterFilter(ctx context.Context, filter Filter) error
-	UnregisterFilter(ctx context.Context, name string) error
-	Process(programEvent ProgramEvent) error
-}
-
 type LogPoller struct {
 	services.Service
 	eng *services.Engine
@@ -53,7 +45,7 @@ type LogPoller struct {
 	filters *filters
 }
 
-func New(lggr logger.SugaredLogger, orm ORM, cl internal.Loader[client.Reader]) ILogPoller {
+func New(lggr logger.SugaredLogger, orm ORM, cl internal.Loader[client.Reader]) *LogPoller {
 	lggr = logger.Sugared(logger.Named(lggr, "LogPoller"))
 	lp := &LogPoller{
 		orm:     orm,