diff --git a/pkg/solana/logpoller/log_poller.go b/pkg/solana/logpoller/log_poller.go index 6efc91910..37f897aa2 100644 --- a/pkg/solana/logpoller/log_poller.go +++ b/pkg/solana/logpoller/log_poller.go @@ -57,9 +57,9 @@ func NewLogPoller(lggr logger.SugaredLogger, orm ORM, cl internal.Loader[client. return &lp } -func (lp LogPoller) Process(event ProgramEvent) error { +func (lp *LogPoller) Process(event ProgramEvent) error { // process stream of events coming from event loader - + lp.events = append(lp.events, event) return nil } @@ -114,9 +114,8 @@ func (lp *LogPoller) loadFilters(ctx context.Context) error { if err != nil { lp.lggr.Errorw("Failed loading filters in init logpoller loop, retrying later", "err", err) } - - return nil } + // unreachable } func (lp *LogPoller) run() {