Load IPC-actors bundle and spawn IPC gateway actor in genesis

.circleci/config.yml

@@ -617,4 +617,4 @@ workflows:
           name: mir-consensus-tests
           suite: consensus
           go-test-flags: "-tags=spacenet -timeout 60m -run TestMirConsensus"
-          target: "./itests/mir_test.go"
+          target: "./itests/mir_test.go"

api/api_full.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"time"
 
+	"github.com/consensus-shipyard/go-ipc-types/subnetactor"
 	"github.com/google/uuid"
 	"github.com/ipfs/go-cid"
 	blocks "github.com/ipfs/go-libipfs/blocks"
@@ -858,6 +859,9 @@ type FullNode interface {
 
 	RaftState(ctx context.Context) (*RaftStateData, error) //perm:read
 	RaftLeader(ctx context.Context) (peer.ID, error)       //perm:read
+
+	// IPC-specific methods
+	IpcAddSubnetActor(ctx context.Context, wallet address.Address, params subnetactor.ConstructParams) (address.Address, error) //perm:write
 }
 
 // reverse interface to the client, called after EthSubscribe

api/docgen/docgen.go

@@ -13,6 +13,7 @@ import (
 	"time"
 	"unicode"
 
+	"github.com/consensus-shipyard/go-ipc-types/subnetactor"
 	"github.com/google/uuid"
 	"github.com/ipfs/go-cid"
 	"github.com/ipfs/go-graphsync"
@@ -401,6 +402,8 @@ func init() {
 		FromBlock: pstring("2301220"),
 		Address:   []ethtypes.EthAddress{ethaddr},
 	})
+
+	addExample(subnetactor.ConsensusType(0))
 }
 
 func GetAPIType(name, pkg string) (i interface{}, t reflect.Type, permStruct []reflect.Type) {

build/builtin_actors.go

@@ -28,6 +28,11 @@ import (
 //go:embed actors/*.tar.zst
 var embeddedBuiltinActorReleases embed.FS
 
+const IPCCarPath = "actors/ipc-actors.car"
+
+//go:embed actors/ipc-actors.car
+var ipcActorsFs embed.FS
+
 func init() {
 	if BundleOverrides == nil {
 		BundleOverrides = make(map[actorstypes.Version]string)
@@ -61,9 +66,30 @@ func loadManifests(netw string) error {
 	var newMetadata []*BuiltinActorsMetadata
 	// First, prefer overrides.
 	for av, path := range BundleOverrides {
-		root, actorCids, err := readBundleManifestFromFile(path)
-		if err != nil {
-			return err
+		var (
+			root      cid.Cid
+			actorCids map[string]cid.Cid
+			err       error
+		)
+		// if the version bundle is to be overridden by the ipc-actors bundle
+		if IsIPCActorOverride(path) {
+			fi, err := ipcActorsFs.Open(IPCCarPath)
+			if err != nil {
+				return xerrors.Errorf("couldn't open ipc-actors.car: %w", err)
+			}
+
+			root, actorCids, err = readBundleManifest(fi)
+			if err != nil {
+				return err
+			}
+			fi.Close() //nolint
+
+		} else {
+			// else we use a path override
+			root, actorCids, err = readBundleManifestFromFile(path)
+			if err != nil {
+				return err
+			}
 		}
 		newMetadata = append(newMetadata, &BuiltinActorsMetadata{
 			Network:     netw,
@@ -264,3 +290,28 @@ func GetEmbeddedBuiltinActorsBundle(version actorstypes.Version) ([]byte, bool)
 		return car, true
 	}
 }
+
+// GetIPCActorsBundle gets the specific bundle including ipc actors from the embedded car file.
+func GetIPCActorsBundle(ctx context.Context, bs blockstore.Blockstore) (cid.Cid, error) {
+	f, err := ipcActorsFs.Open(IPCCarPath)
+	if err != nil {
+		return cid.Undef, xerrors.Errorf("error opening ipc-actors bundle: %w", err)
+	}
+	defer f.Close() //nolint
+
+	hdr, err := car.LoadCar(ctx, bs, f)
+	if err != nil {
+		return cid.Undef, xerrors.Errorf("error loading builtin actors bundle: %w", err)
+	}
+
+	if len(hdr.Roots) != 1 {
+		return cid.Undef, xerrors.Errorf("expected one root when loading actors bundle, got %d", len(hdr.Roots))
+	}
+	return hdr.Roots[0], nil
+}
+
+// IsIPCActorOverride checks if the override should point to the ipc-actors or
+// some other generic path.
+func IsIPCActorOverride(path string) bool {
+	return path == "ipc-actors"
+}

build/params_spacenet.go

@@ -18,7 +18,9 @@ import (
 )
 
 var NetworkBundle = "devnet"
-var BundleOverrides map[actorstypes.Version]string
+var BundleOverrides = map[actorstypes.Version]string{
+	actorstypes.Version10: "ipc-actors",
+}
 var ActorDebugging = false
 
 // FIXME: The following will be used to address this issue:

chain/gen/genesis/f02_reward.go

@@ -3,9 +3,11 @@ package genesis
 import (
 	"context"
 
+	ipctypes "github.com/consensus-shipyard/go-ipc-types/sdk"
 	cbor "github.com/ipfs/go-ipld-cbor"
 	"golang.org/x/xerrors"
 
+	"github.com/filecoin-project/go-state-types/abi"
 	actorstypes "github.com/filecoin-project/go-state-types/actors"
 	"github.com/filecoin-project/go-state-types/big"
 	"github.com/filecoin-project/go-state-types/manifest"
@@ -18,7 +20,7 @@ import (
 	"github.com/filecoin-project/lotus/chain/types"
 )
 
-func SetupRewardActor(ctx context.Context, bs bstore.Blockstore, qaPower big.Int, av actorstypes.Version) (*types.Actor, error) {
+func SetupRewardActor(ctx context.Context, bs bstore.Blockstore, qaPower big.Int, av actorstypes.Version, networkName string) (*types.Actor, error) {
 	cst := cbor.NewCborStore(bs)
 	rst, err := reward.MakeState(adt.WrapStore(ctx, cst), av, qaPower)
 	if err != nil {
@@ -35,9 +37,17 @@ func SetupRewardActor(ctx context.Context, bs bstore.Blockstore, qaPower big.Int
 		return nil, xerrors.Errorf("failed to get reward actor code ID for actors version %d", av)
 	}
 
+	// For IPC and spacenet, rewards are handled by the IPC gateway in subnets,
+	// let's not allocate any initial balance into the reward actor if this is not
+	// the rootnet.
+	balance := abi.NewTokenAmount(0)
+	if networkName == ipctypes.RootSubnet.String() {
+		balance = types.BigInt{Int: build.InitialRewardBalance}
+	}
+
 	act := &types.Actor{
 		Code:    actcid,
-		Balance: types.BigInt{Int: build.InitialRewardBalance},
+		Balance: balance,
 		Head:    statecid,
 	}