feat(MSFDG): add common datatypes

op-challenger2/cmd/main_test.go

@@ -52,12 +52,12 @@ func TestLogLevel(t *testing.T) {
 
 func TestDefaultCLIOptionsMatchDefaultConfig(t *testing.T) {
 	cfg := configForArgs(t, addRequiredArgs(config.TraceTypeAlphabet))
-	defaultCfg := config.NewConfig(common.HexToAddress(gameFactoryAddressValue), l1EthRpc, l1Beacon, rollupRpc, l2EthRpc, datadir, config.TraceTypeAlphabet)
+	defaultCfg := config.NewConfig(common.HexToAddress(gameFactoryAddressValue), l1EthRpc, l1Beacon, rollupRpc, l2EthRpc, datadir, config.DACalldata, config.TraceTypeAlphabet)
 	require.Equal(t, defaultCfg, cfg)
 }
 
 func TestDefaultConfigIsValid(t *testing.T) {
-	cfg := config.NewConfig(common.HexToAddress(gameFactoryAddressValue), l1EthRpc, l1Beacon, rollupRpc, l2EthRpc, datadir, config.TraceTypeAlphabet)
+	cfg := config.NewConfig(common.HexToAddress(gameFactoryAddressValue), l1EthRpc, l1Beacon, rollupRpc, l2EthRpc, datadir, config.DACalldata, config.TraceTypeAlphabet)
 	require.NoError(t, cfg.Check())
 }
 

op-challenger2/config/config.go

@@ -59,6 +59,11 @@ const (
 	TraceTypePermissioned TraceType = "permissioned"
 )
 
+const (
+	DACalldata int64 = 0
+	DABlob     int64 = 1
+)
+
 var TraceTypes = []TraceType{TraceTypeAlphabet, TraceTypeCannon, TraceTypePermissioned, TraceTypeAsterisc}
 
 func (t TraceType) String() string {
@@ -154,6 +159,8 @@ type Config struct {
 	TxMgrConfig   txmgr.CLIConfig
 	MetricsConfig opmetrics.CLIConfig
 	PprofConfig   oppprof.CLIConfig
+
+	DAType int64
 }
 
 func NewConfig(
@@ -163,6 +170,7 @@ func NewConfig(
 	l2RollupRpc string,
 	l2EthRpc string,
 	datadir string,
+	datype int64,
 	supportedTraceTypes ...TraceType,
 ) Config {
 	return Config{
@@ -189,6 +197,8 @@ func NewConfig(
 		AsteriscSnapshotFreq: DefaultAsteriscSnapshotFreq,
 		AsteriscInfoFreq:     DefaultAsteriscInfoFreq,
 		GameWindow:           DefaultGameWindow,
+
+		DAType: datype,
 	}
 }
 

op-challenger2/config/config_test.go

@@ -50,7 +50,7 @@ func applyValidConfigForAsterisc(cfg *Config) {
 }
 
 func validConfig(traceType TraceType) Config {
-	cfg := NewConfig(validGameFactoryAddress, validL1EthRpc, validL1BeaconUrl, validRollupRpc, validL2Rpc, validDatadir, traceType)
+	cfg := NewConfig(validGameFactoryAddress, validL1EthRpc, validL1BeaconUrl, validRollupRpc, validL2Rpc, validDatadir, 0, traceType)
 	if traceType == TraceTypeCannon || traceType == TraceTypePermissioned {
 		applyValidConfigForCannon(&cfg)
 	}

op-challenger2/game/fault/agent.go

@@ -31,6 +31,10 @@ type Responder interface {
 type ClaimLoader interface {
 	GetAllClaims(ctx context.Context, block rpcblock.Block) ([]types.Claim, error)
 	IsL2BlockNumberChallenged(ctx context.Context, block rpcblock.Block) (bool, error)
+	GetMaxGameDepth(ctx context.Context) (types.Depth, error)
+	GetSplitDepth(ctx context.Context) (types.Depth, error)
+	GetNBits(ctx context.Context) (uint64, error)
+	GetMaxAttackBranch(ctx context.Context) (uint64, error)
 }
 
 type Agent struct {
@@ -59,12 +63,13 @@ func NewAgent(
 	log log.Logger,
 	selective bool,
 	claimants []common.Address,
+	daType types.DAType,
 ) *Agent {
 	return &Agent{
 		metrics:          m,
 		systemClock:      systemClock,
 		l1Clock:          l1Clock,
-		solver:           solver.NewGameSolver(maxDepth, trace),
+		solver:           solver.NewGameSolver(maxDepth, trace, daType),
 		loader:           loader,
 		responder:        responder,
 		selective:        selective,
@@ -239,6 +244,18 @@ func (a *Agent) newGameFromContracts(ctx context.Context) (types.Game, error) {
 	if len(claims) == 0 {
 		return nil, errors.New("no claims")
 	}
-	game := types.NewGameState(claims, a.maxDepth)
+	maxDepth, err := a.loader.GetMaxGameDepth(ctx)
+	if err != nil {
+		return nil, fmt.Errorf("failed to retrieve max game depth: %w", err)
+	}
+	splitDepth, err := a.loader.GetSplitDepth(ctx)
+	if err != nil {
+		return nil, fmt.Errorf("failed to retrieve split depth: %w", err)
+	}
+	nbits, err := a.loader.GetNBits(ctx)
+	if err != nil {
+		return nil, fmt.Errorf("failed to retrieve nbits: %w", err)
+	}
+	game := types.NewGameState2(claims, maxDepth, nbits, splitDepth)
 	return game, nil
 }

op-challenger2/game/fault/agent_test.go

@@ -195,7 +195,7 @@ func setupTestAgent(t *testing.T) (*Agent, *stubClaimLoader, *stubResponder) {
 	responder := &stubResponder{}
 	systemClock := clock.NewDeterministicClock(time.UnixMilli(120200))
 	l1Clock := clock.NewDeterministicClock(l1Time)
-	agent := NewAgent(metrics.NoopMetrics, systemClock, l1Clock, claimLoader, depth, gameDuration, trace.NewSimpleTraceAccessor(provider), responder, logger, false, []common.Address{})
+	agent := NewAgent(metrics.NoopMetrics, systemClock, l1Clock, claimLoader, depth, gameDuration, trace.NewSimpleTraceAccessor(provider), responder, logger, false, []common.Address{}, types.CallDataType)
 	return agent, claimLoader, responder
 }
 
@@ -204,6 +204,9 @@ type stubClaimLoader struct {
 	maxLoads           int
 	claims             []types.Claim
 	blockNumChallenged bool
+	maxDepth           types.Depth
+	splitDepth         types.Depth
+	nbits              uint64
 }
 
 func (s *stubClaimLoader) IsL2BlockNumberChallenged(_ context.Context, _ rpcblock.Block) (bool, error) {
@@ -218,6 +221,22 @@ func (s *stubClaimLoader) GetAllClaims(_ context.Context, _ rpcblock.Block) ([]t
 	return s.claims, nil
 }
 
+func (s *stubClaimLoader) GetMaxGameDepth(_ context.Context) (types.Depth, error) {
+	return s.maxDepth, nil
+}
+
+func (s *stubClaimLoader) GetSplitDepth(_ context.Context) (types.Depth, error) {
+	return s.splitDepth, nil
+}
+
+func (s *stubClaimLoader) GetNBits(_ context.Context) (uint64, error) {
+	return s.nbits, nil
+}
+
+func (s *stubClaimLoader) GetMaxAttackBranch(_ context.Context) (uint64, error) {
+	return 1<<s.nbits - 1, nil
+}
+
 type stubResponder struct {
 	l                 sync.Mutex
 	callResolveCount  int

op-challenger2/game/fault/player.go

@@ -82,6 +82,7 @@ func NewGamePlayer(
 	l1HeaderSource L1HeaderSource,
 	selective bool,
 	claimants []common.Address,
+	daType types.DAType,
 ) (*GamePlayer, error) {
 	logger = logger.New("game", addr)
 
@@ -146,7 +147,7 @@ func NewGamePlayer(
 		return nil, fmt.Errorf("failed to create the responder: %w", err)
 	}
 
-	agent := NewAgent(m, systemClock, l1Clock, loader, gameDepth, maxClockDuration, accessor, responder, logger, selective, claimants)
+	agent := NewAgent(m, systemClock, l1Clock, loader, gameDepth, maxClockDuration, accessor, responder, logger, selective, claimants, daType)
 	return &GamePlayer{
 		act:                agent.Act,
 		loader:             loader,

op-challenger2/game/fault/register.go

@@ -73,23 +73,25 @@ func RegisterGameTypes(
 	}
 	syncValidator := newSyncStatusValidator(rollupClient)
 
+	datype := faultTypes.NewDaType(cfg.DAType)
+
 	if cfg.TraceTypeEnabled(config.TraceTypeCannon) {
-		if err := registerCannon(faultTypes.CannonGameType, registry, oracles, ctx, systemClock, l1Clock, logger, m, cfg, syncValidator, rollupClient, txSender, gameFactory, caller, l2Client, l1HeaderSource, selective, claimants); err != nil {
+		if err := registerCannon(faultTypes.CannonGameType, registry, oracles, ctx, systemClock, l1Clock, logger, m, cfg, syncValidator, rollupClient, txSender, gameFactory, caller, l2Client, l1HeaderSource, selective, claimants, datype); err != nil {
 			return nil, fmt.Errorf("failed to register cannon game type: %w", err)
 		}
 	}
 	if cfg.TraceTypeEnabled(config.TraceTypePermissioned) {
-		if err := registerCannon(faultTypes.PermissionedGameType, registry, oracles, ctx, systemClock, l1Clock, logger, m, cfg, syncValidator, rollupClient, txSender, gameFactory, caller, l2Client, l1HeaderSource, selective, claimants); err != nil {
+		if err := registerCannon(faultTypes.PermissionedGameType, registry, oracles, ctx, systemClock, l1Clock, logger, m, cfg, syncValidator, rollupClient, txSender, gameFactory, caller, l2Client, l1HeaderSource, selective, claimants, datype); err != nil {
 			return nil, fmt.Errorf("failed to register permissioned cannon game type: %w", err)
 		}
 	}
 	if cfg.TraceTypeEnabled(config.TraceTypeAsterisc) {
-		if err := registerAsterisc(faultTypes.AsteriscGameType, registry, oracles, ctx, systemClock, l1Clock, logger, m, cfg, syncValidator, rollupClient, txSender, gameFactory, caller, l2Client, l1HeaderSource, selective, claimants); err != nil {
+		if err := registerAsterisc(faultTypes.AsteriscGameType, registry, oracles, ctx, systemClock, l1Clock, logger, m, cfg, syncValidator, rollupClient, txSender, gameFactory, caller, l2Client, l1HeaderSource, selective, claimants, datype); err != nil {
 			return nil, fmt.Errorf("failed to register asterisc game type: %w", err)
 		}
 	}
 	if cfg.TraceTypeEnabled(config.TraceTypeAlphabet) {
-		if err := registerAlphabet(registry, oracles, ctx, systemClock, l1Clock, logger, m, syncValidator, rollupClient, l2Client, txSender, gameFactory, caller, l1HeaderSource, selective, claimants); err != nil {
+		if err := registerAlphabet(registry, oracles, ctx, systemClock, l1Clock, logger, m, syncValidator, rollupClient, l2Client, txSender, gameFactory, caller, l1HeaderSource, selective, claimants, datype); err != nil {
 			return nil, fmt.Errorf("failed to register alphabet game type: %w", err)
 		}
 	}
@@ -113,6 +115,7 @@ func registerAlphabet(
 	l1HeaderSource L1HeaderSource,
 	selective bool,
 	claimants []common.Address,
+	daType faultTypes.DAType,
 ) error {
 	playerCreator := func(game types.GameMetadata, dir string) (scheduler.GamePlayer, error) {
 		contract, err := contracts.NewFaultDisputeGameContract(ctx, m, game.Proxy, caller)
@@ -146,7 +149,7 @@ func registerAlphabet(
 		}
 		prestateValidator := NewPrestateValidator("alphabet", contract.GetAbsolutePrestateHash, alphabet.PrestateProvider)
 		startingValidator := NewPrestateValidator("output root", contract.GetStartingRootHash, prestateProvider)
-		return NewGamePlayer(ctx, systemClock, l1Clock, logger, m, dir, game.Proxy, txSender, contract, syncValidator, []Validator{prestateValidator, startingValidator}, creator, l1HeaderSource, selective, claimants)
+		return NewGamePlayer(ctx, systemClock, l1Clock, logger, m, dir, game.Proxy, txSender, contract, syncValidator, []Validator{prestateValidator, startingValidator}, creator, l1HeaderSource, selective, claimants, daType)
 	}
 	err := registerOracle(ctx, m, oracles, gameFactory, caller, faultTypes.AlphabetGameType)
 	if err != nil {
@@ -197,6 +200,7 @@ func registerAsterisc(
 	l1HeaderSource L1HeaderSource,
 	selective bool,
 	claimants []common.Address,
+	daType faultTypes.DAType,
 ) error {
 	var prestateSource PrestateSource
 	if cfg.AsteriscAbsolutePreStateBaseURL != nil {
@@ -256,7 +260,7 @@ func registerAsterisc(
 		}
 		prestateValidator := NewPrestateValidator("asterisc", contract.GetAbsolutePrestateHash, asteriscPrestateProvider)
 		genesisValidator := NewPrestateValidator("output root", contract.GetStartingRootHash, prestateProvider)
-		return NewGamePlayer(ctx, systemClock, l1Clock, logger, m, dir, game.Proxy, txSender, contract, syncValidator, []Validator{prestateValidator, genesisValidator}, creator, l1HeaderSource, selective, claimants)
+		return NewGamePlayer(ctx, systemClock, l1Clock, logger, m, dir, game.Proxy, txSender, contract, syncValidator, []Validator{prestateValidator, genesisValidator}, creator, l1HeaderSource, selective, claimants, daType)
 	}
 	err := registerOracle(ctx, m, oracles, gameFactory, caller, gameType)
 	if err != nil {
@@ -290,6 +294,7 @@ func registerCannon(
 	l1HeaderSource L1HeaderSource,
 	selective bool,
 	claimants []common.Address,
+	daType faultTypes.DAType,
 ) error {
 	var prestateSource PrestateSource
 	if cfg.CannonAbsolutePreStateBaseURL != nil {
@@ -351,7 +356,7 @@ func registerCannon(
 		}
 		prestateValidator := NewPrestateValidator("cannon", contract.GetAbsolutePrestateHash, cannonPrestateProvider)
 		startingValidator := NewPrestateValidator("output root", contract.GetStartingRootHash, prestateProvider)
-		return NewGamePlayer(ctx, systemClock, l1Clock, logger, m, dir, game.Proxy, txSender, contract, syncValidator, []Validator{prestateValidator, startingValidator}, creator, l1HeaderSource, selective, claimants)
+		return NewGamePlayer(ctx, systemClock, l1Clock, logger, m, dir, game.Proxy, txSender, contract, syncValidator, []Validator{prestateValidator, startingValidator}, creator, l1HeaderSource, selective, claimants, daType)
 	}
 	err := registerOracle(ctx, m, oracles, gameFactory, caller, gameType)
 	if err != nil {

op-challenger2/game/fault/solver/game_solver.go

@@ -13,9 +13,9 @@ type GameSolver struct {
 	claimSolver *claimSolver
 }
 
-func NewGameSolver(gameDepth types.Depth, trace types.TraceAccessor) *GameSolver {
+func NewGameSolver(gameDepth types.Depth, trace types.TraceAccessor, daType types.DAType) *GameSolver {
 	return &GameSolver{
-		claimSolver: newClaimSolver(gameDepth, trace),
+		claimSolver: newClaimSolver(gameDepth, trace, daType),
 	}
 }
 

op-challenger2/game/fault/solver/game_solver_test.go

@@ -23,7 +23,7 @@ func TestCalculateNextActions_ChallengeL2BlockNumber(t *testing.T) {
 	}
 	claimBuilder := faulttest.NewAlphabetClaimBuilder(t, startingBlock, maxDepth)
 	traceProvider := faulttest.NewAlphabetWithProofProvider(t, startingBlock, maxDepth, nil)
-	solver := NewGameSolver(maxDepth, trace.NewSimpleTraceAccessor(traceProvider))
+	solver := NewGameSolver(maxDepth, trace.NewSimpleTraceAccessor(traceProvider), types.CallDataType)
 
 	// Do not challenge when provider returns error indicating l2 block is valid
 	actions, err := solver.CalculateNextActions(context.Background(), claimBuilder.GameBuilder().Game)
@@ -205,7 +205,7 @@ func TestCalculateNextActions(t *testing.T) {
 			test.setupGame(builder)
 			game := builder.Game
 
-			solver := NewGameSolver(maxDepth, trace.NewSimpleTraceAccessor(claimBuilder.CorrectTraceProvider()))
+			solver := NewGameSolver(maxDepth, trace.NewSimpleTraceAccessor(claimBuilder.CorrectTraceProvider()), types.CallDataType)
 			postState, actions := runStep(t, solver, game, claimBuilder.CorrectTraceProvider())
 			for i, action := range builder.ExpectedActions {
 				t.Logf("Expect %v: Type: %v, ParentIdx: %v, Attack: %v, Value: %v, PreState: %v, ProofData: %v",
@@ -311,7 +311,7 @@ func TestMultipleRounds(t *testing.T) {
 				game := builder.Game
 
 				correctTrace := claimBuilder.CorrectTraceProvider()
-				solver := NewGameSolver(maxDepth, trace.NewSimpleTraceAccessor(correctTrace))
+				solver := NewGameSolver(maxDepth, trace.NewSimpleTraceAccessor(correctTrace), types.CallDataType)
 
 				roundNum := 0
 				done := false
@@ -356,5 +356,5 @@ func applyActions(game types.Game, claimant common.Address, actions []types.Acti
 			panic(fmt.Errorf("unknown move type: %v", action.Type))
 		}
 	}
-	return types.NewGameState(claims, game.MaxDepth())
+	return types.NewGameState2(claims, game.MaxDepth(), game.NBits(), game.SplitDepth())
 }

op-challenger2/game/fault/solver/solver.go

@@ -17,13 +17,15 @@ var (
 type claimSolver struct {
 	trace     types.TraceAccessor
 	gameDepth types.Depth
+	daType    types.DAType
 }
 
 // newClaimSolver creates a new [claimSolver] using the provided [TraceProvider].
-func newClaimSolver(gameDepth types.Depth, trace types.TraceAccessor) *claimSolver {
+func newClaimSolver(gameDepth types.Depth, trace types.TraceAccessor, daType types.DAType) *claimSolver {
 	return &claimSolver{
 		trace,
 		gameDepth,
+		daType,
 	}
 }
 

op-challenger2/game/fault/solver/solver_test.go

@@ -164,7 +164,7 @@ func TestAttemptStep(t *testing.T) {
 		t.Run(tableTest.name, func(t *testing.T) {
 			builder := claimBuilder.GameBuilder(faulttest.WithInvalidValue(tableTest.agreeWithOutputRoot))
 			tableTest.setupGame(builder)
-			alphabetSolver := newClaimSolver(maxDepth, trace.NewSimpleTraceAccessor(claimBuilder.CorrectTraceProvider()))
+			alphabetSolver := newClaimSolver(maxDepth, trace.NewSimpleTraceAccessor(claimBuilder.CorrectTraceProvider()), types.CallDataType)
 			game := builder.Game
 			claims := game.Claims()
 			lastClaim := claims[len(claims)-1]

op-challenger2/game/fault/trace/asterisc/executor_test.go

@@ -20,7 +20,8 @@ func TestGenerateProof(t *testing.T) {
 	input := "starting.json"
 	tempDir := t.TempDir()
 	dir := filepath.Join(tempDir, "gameDir")
-	cfg := config.NewConfig(common.Address{0xbb}, "http://localhost:8888", "http://localhost:9000", "http://localhost:9096", "http://localhost:9095", tempDir, config.TraceTypeAsterisc)
+	datype := int64(0)
+	cfg := config.NewConfig(common.Address{0xbb}, "http://localhost:8888", "http://localhost:9000", "http://localhost:9096", "http://localhost:9095", tempDir, datype, config.TraceTypeAsterisc)
 	cfg.L2Rpc = "http://localhost:9999"
 	prestate := "pre.json"
 	cfg.AsteriscBin = "./bin/asterisc"

op-challenger2/game/fault/trace/cannon/executor_test.go

@@ -25,7 +25,8 @@ func TestGenerateProof(t *testing.T) {
 	input := "starting.json"
 	tempDir := t.TempDir()
 	dir := filepath.Join(tempDir, "gameDir")
-	cfg := config.NewConfig(common.Address{0xbb}, "http://localhost:8888", "http://localhost:9000", "http://localhost:9096", "http://localhost:9095", tempDir, config.TraceTypeCannon)
+	datype := int64(0)
+	cfg := config.NewConfig(common.Address{0xbb}, "http://localhost:8888", "http://localhost:9000", "http://localhost:9096", "http://localhost:9095", tempDir, datype, config.TraceTypeCannon)
 	cfg.L2Rpc = "http://localhost:9999"
 	prestate := "pre.json"
 	cfg.CannonBin = "./bin/cannon"