diff --git a/cmd/access/node_builder/access_node_builder.go b/cmd/access/node_builder/access_node_builder.go index 9f5a980f249..b79ee6b4d9d 100644 --- a/cmd/access/node_builder/access_node_builder.go +++ b/cmd/access/node_builder/access_node_builder.go @@ -670,10 +670,6 @@ func (builder *FlowAccessNodeBuilder) BuildExecutionSyncComponents() *FlowAccess indexedBlockHeight = bstorage.NewConsumerProgress(builder.DB, module.ConsumeProgressExecutionDataIndexerBlockHeight) return nil }). - Module("events storage", func(node *cmd.NodeConfig) error { - builder.Storage.Events = bstorage.NewEvents(node.Metrics.Cache, node.DB) - return nil - }). Module("transaction results storage", func(node *cmd.NodeConfig) error { builder.Storage.LightTransactionResults = bstorage.NewLightTransactionResults(node.Metrics.Cache, node.DB, bstorage.DefaultCacheSize) return nil @@ -1267,6 +1263,10 @@ func (builder *FlowAccessNodeBuilder) Build() (cmd.Node, error) { builder.RegistersAsyncStore = execution.NewRegistersAsyncStore() return nil }). + Module("events storage", func(node *cmd.NodeConfig) error { + builder.Storage.Events = bstorage.NewEvents(node.Metrics.Cache, node.DB) + return nil + }). Component("RPC engine", func(node *cmd.NodeConfig) (module.ReadyDoneAware, error) { config := builder.rpcConf backendConfig := config.BackendConfig @@ -1310,6 +1310,7 @@ func (builder *FlowAccessNodeBuilder) Build() (cmd.Node, error) { HistoricalAccessNodes: builder.HistoricalAccessRPCs, Blocks: node.Storage.Blocks, Headers: node.Storage.Headers, + Events: node.Storage.Events, Collections: node.Storage.Collections, Transactions: node.Storage.Transactions, ExecutionReceipts: node.Storage.Receipts,