feat: implement nv22

app/node/builder.go

@@ -15,6 +15,7 @@ import (
 	"github.com/libp2p/go-libp2p"
 	"github.com/pkg/errors"
 
+	"github.com/filecoin-project/venus/app/submodule/actorevent"
 	"github.com/filecoin-project/venus/app/submodule/blockstore"
 	"github.com/filecoin-project/venus/app/submodule/chain"
 	"github.com/filecoin-project/venus/app/submodule/common"
@@ -171,6 +172,10 @@ func (b *Builder) build(ctx context.Context) (*Node, error) {
 		return nil, err
 	}
 
+	if nd.actorEvent, err = actorevent.NewActorEventSubModule(ctx, b.repo.Config(), nd.chain, nd.eth); err != nil {
+		return nil, err
+	}
+
 	apiBuilder := NewBuilder()
 	apiBuilder.NameSpace("Filecoin")
 
@@ -188,6 +193,7 @@ func (b *Builder) build(ctx context.Context) (*Node, error) {
 		nd.market,
 		nd.common,
 		nd.eth,
+		nd.actorEvent,
 	)
 
 	if err != nil {

app/node/node.go

@@ -11,6 +11,7 @@ import (
 	"github.com/awnumar/memguard"
 	"github.com/etherlabsio/healthcheck/v2"
 	"github.com/filecoin-project/go-jsonrpc"
+	"github.com/filecoin-project/venus/app/submodule/actorevent"
 	"github.com/filecoin-project/venus/app/submodule/blockstore"
 	chain2 "github.com/filecoin-project/venus/app/submodule/chain"
 	"github.com/filecoin-project/venus/app/submodule/common"
@@ -100,7 +101,8 @@ type Node struct {
 
 	common *common.CommonModule
 
-	eth *eth.EthSubModule
+	eth        *eth.EthSubModule
+	actorEvent *actorevent.ActorEventSubModule
 
 	//
 	// Jsonrpc

app/node/rpc.go

@@ -5,6 +5,7 @@ import (
 	"reflect"
 
 	"github.com/filecoin-project/go-jsonrpc"
+	"github.com/filecoin-project/venus/app/submodule/actorevent"
 	"github.com/filecoin-project/venus/app/submodule/eth"
 	v0api "github.com/filecoin-project/venus/venus-shared/api/chain/v0"
 	v1api "github.com/filecoin-project/venus/venus-shared/api/chain/v1"
@@ -40,14 +41,15 @@ func (builder *RPCBuilder) AddServices(services ...RPCService) error {
 }
 
 var ethSubModuleTyp = reflect.TypeOf(&eth.EthSubModule{}).Elem()
+var actorEventSubModuleTyp = reflect.TypeOf(&actorevent.ActorEventSubModule{}).Elem()
 
 func skipV0API(in interface{}) bool {
 	inT := reflect.TypeOf(in)
 	if inT.Kind() == reflect.Pointer {
 		inT = inT.Elem()
 	}
 
-	return inT.AssignableTo(ethSubModuleTyp)
+	return inT.AssignableTo(ethSubModuleTyp) || inT.AssignableTo(actorEventSubModuleTyp)
 }
 
 func (builder *RPCBuilder) AddV0API(service RPCService) error {