(ctx context.Context, cfg *Config)
| 293 | } |
| 294 | |
| 295 | func (n *EsNode) initMiner(ctx context.Context, cfg *Config) error { |
| 296 | if cfg.Mining == nil { |
| 297 | // not enabled |
| 298 | return nil |
| 299 | } |
| 300 | l1api := miner.NewL1MiningAPI(n.l1Source, n.randaoSource, n.lg) |
| 301 | if err := l1api.CheckMinerRole(ctx, cfg.Storage.L1Contract, cfg.Storage.Miner); err != nil { |
| 302 | n.lg.Crit("Check miner role", "err", err) |
| 303 | } |
| 304 | pvr := prover.NewKZGPoseidonProver( |
| 305 | cfg.Mining.ZKWorkingDir, |
| 306 | cfg.Mining.ZKeyFile, |
| 307 | cfg.Mining.ZKProverMode, |
| 308 | cfg.Mining.ZKProverImpl, |
| 309 | n.lg, |
| 310 | ) |
| 311 | br := blobs.NewBlobReader(n.blobCache, n.storageManager, n.lg) |
| 312 | n.miner = miner.New(cfg.Mining, n.db, n.storageManager, l1api, br, &pvr, n.feed, n.lg) |
| 313 | n.lg.Info("Initialized miner") |
| 314 | return nil |
| 315 | } |
| 316 | |
| 317 | func (n *EsNode) initArchiver(ctx context.Context, cfg *Config) error { |
| 318 | if cfg.Archiver == nil { |
no test coverage detected