package modules import ( "context" "path/filepath" "go.uber.org/fx" "github.com/filecoin-project/lotus/chain/ethhashlookup" "github.com/filecoin-project/lotus/chain/events" "github.com/filecoin-project/lotus/chain/messagepool" "github.com/filecoin-project/lotus/chain/stmgr" "github.com/filecoin-project/lotus/chain/store" "github.com/filecoin-project/lotus/node/config" "github.com/filecoin-project/lotus/node/impl/full" "github.com/filecoin-project/lotus/node/modules/helpers" "github.com/filecoin-project/lotus/node/repo" ) func EthModuleAPI(cfg config.FevmConfig) func(helpers.MetricsCtx, repo.LockedRepo, fx.Lifecycle, *store.ChainStore, *stmgr.StateManager, EventAPI, *messagepool.MessagePool, full.StateAPI, full.ChainAPI, full.MpoolAPI) (*full.EthModule, error) { return func(mctx helpers.MetricsCtx, r repo.LockedRepo, lc fx.Lifecycle, cs *store.ChainStore, sm *stmgr.StateManager, evapi EventAPI, mp *messagepool.MessagePool, stateapi full.StateAPI, chainapi full.ChainAPI, mpoolapi full.MpoolAPI) (*full.EthModule, error) { em := &full.EthModule{ Chain: cs, Mpool: mp, StateManager: sm, ChainAPI: chainapi, MpoolAPI: mpoolapi, StateAPI: stateapi, } dbPath, err := r.SqlitePath() if err != nil { return nil, err } transactionHashLookup, err := ethhashlookup.NewTransactionHashLookup(filepath.Join(dbPath, "txhash.db")) if err != nil { return nil, err } lc.Append(fx.Hook{ OnStop: func(ctx context.Context) error { return transactionHashLookup.Close() }, }) ethTxHashManager := full.EthTxHashManager{ StateAPI: stateapi, TransactionHashLookup: transactionHashLookup, } em.EthTxHashManager = ðTxHashManager const ChainHeadConfidence = 1 ctx := helpers.LifecycleCtx(mctx, lc) lc.Append(fx.Hook{ OnStart: func(context.Context) error { ev, err := events.NewEventsWithConfidence(ctx, &evapi, ChainHeadConfidence) if err != nil { return err } // Tipset listener _ = ev.Observe(ðTxHashManager) ch, err := mp.Updates(ctx) if err != nil { return err } go full.WaitForMpoolUpdates(ctx, ch, ðTxHashManager) go full.EthTxHashGC(ctx, cfg.EthTxHashMappingLifetimeDays, ðTxHashManager) return nil }, }) return em, nil } }