Mohamed Sohail
2793d92343
* breaking: use event router, adsd telegram notifier, update indexer schema * fix: early ack on handler not found * fix: jetstream switch to new API, discard buffer on close * remove telegram dependency, rely on log alters instead, which indirectly connect to telegram via uptrace * feat (breaking): switch to self contained auto bootstrapper
35 lines
682 B
Go
35 lines
682 B
Go
package handler
|
|
|
|
import (
|
|
"log/slog"
|
|
|
|
"github.com/grassrootseconomics/eth-indexer/internal/cache"
|
|
"github.com/grassrootseconomics/eth-indexer/internal/store"
|
|
"github.com/grassrootseconomics/ethutils"
|
|
)
|
|
|
|
type (
|
|
HandlerOpts struct {
|
|
Store store.Store
|
|
Cache *cache.Cache
|
|
ChainProvider *ethutils.Provider
|
|
Logg *slog.Logger
|
|
}
|
|
|
|
Handler struct {
|
|
store store.Store
|
|
cache *cache.Cache
|
|
chainProvider *ethutils.Provider
|
|
logg *slog.Logger
|
|
}
|
|
)
|
|
|
|
func NewHandler(o HandlerOpts) *Handler {
|
|
return &Handler{
|
|
store: o.Store,
|
|
cache: o.Cache,
|
|
chainProvider: o.ChainProvider,
|
|
logg: o.Logg,
|
|
}
|
|
}
|