tutti/services/tuttid/service/tuttimodeexecution/conformance/catalog.go

package conformance

import (
	"context"
	"fmt"
)

type Scenario struct {
	Name string
	run  func(context.Context, Driver) error
}

func Catalog() []Scenario {
	scenarios := MaterializationCatalog()
	scenarios = append(scenarios, ScheduleCatalog()...)
	scenarios = append(scenarios, MutationCatalog()...)
	scenarios = append(scenarios, SettlementCatalog()...)
	scenarios = append(scenarios, WakeCatalog()...)
	scenarios = append(scenarios, WatchdogCatalog()...)
	scenarios = append(scenarios, ReviewCatalog()...)
	scenarios = append(scenarios, ArchiveCatalog()...)
	return append(scenarios, DeletionCatalog()...)
}

func MutationCatalog() []Scenario {
	return []Scenario{
		{
			Name: "MutationFencesReplayAndSchedulesReturnedRevision",
			run:  runMutationFencesReplayAndSchedulesReturnedRevision,
		},
		{
			Name: "MutationOperationsCommitAllOrNone",
			run:  runMutationOperationsCommitAllOrNone,
		},
		{
			Name: "FailedTaskReworkInheritsLaunchAndRebindsDependents",
			run:  runFailedTaskReworkInheritsLaunchAndRebindsDependents,
		},
		{
			Name: "CanceledTaskReworkInheritsLaunchAndSchedulesReplacement",
			run:  runCanceledTaskReworkInheritsLaunchAndSchedulesReplacement,
		},
		{
			Name: "LogicalSupersessionPreservesHistoryAndRequiresSettlement",
			run:  runLogicalSupersessionPreservesHistoryAndRequiresSettlement,
		},
		{
			Name: "MutationSupersedesStaleGoalReview",
			run:  runMutationSupersedesStaleGoalReview,
		},
	}
}

func SettlementCatalog() []Scenario {
	return []Scenario{
		{
			Name: "TerminalSettlementCreatesCheckpointWithoutSuccessor",
			run:  runTerminalSettlementCreatesCheckpointWithoutSuccessor,
		},
		{
			Name: "ParallelSettlementsQueueOrderedCheckpointBacklog",
			run:  runParallelSettlementsQueueOrderedCheckpointBacklog,
		},
		{
			Name: "SettlementReviewCanScheduleDependentNextStep",
			run:  runSettlementReviewCanScheduleDependentNextStep,
		},
		{
			Name: "ScheduleReviewPromotesExistingSettlementBacklog",
			run:  runScheduleReviewPromotesExistingSettlementBacklog,
		},
		{
			Name: "GraphMutationRebindsPromotedSettlementBacklog",
			run:  runGraphMutationRebindsPromotedSettlementBacklog,
		},
		{
			Name: "ReworkRearmsSupersededTerminalCheckpoint",
			run:  runReworkRearmsSupersededTerminalCheckpoint,
		},
		{
			Name: "TimedOutRunCreatesFailedCheckpoint",
			run:  runTimedOutRunCreatesFailedCheckpoint,
		},
		{
			Name: "AuthoritativeLaunchFailureSettlesRun",
			run:  runAuthoritativeLaunchFailureSettlesRun,
		},
		{
			Name: "ExpiredLaunchOwnerCannotSettleReclaimedRun",
			run:  runExpiredLaunchOwnerCannotSettleReclaimedRun,
		},
		{
			Name: "TerminalPreparedLaunchCannotRecover",
			run:  runTerminalPreparedLaunchCannotRecover,
		},
		{
			Name: "TerminalInFlightLaunchIsCanceledAfterDelivery",
			run:  runTerminalInFlightLaunchIsCanceledAfterDelivery,
		},
		{
			Name: "TerminalAmbiguousLaunchIsCanceledAfterDelivery",
			run:  runTerminalAmbiguousLaunchIsCanceledAfterDelivery,
		},
		{
			Name: "FailedLateLaunchCancellationIsDurablyRetried",
			run:  runFailedLateLaunchCancellationIsDurablyRetried,
		},
		{
			Name: "UnsupportedCancellationResultIsDurablyRetried",
			run:  runUnsupportedCancellationResultIsDurablyRetried,
		},
		{
			Name: "CanceledDeliveryContextStillCompensatesLateLaunch",
			run:  runCanceledDeliveryContextStillCompensatesLateLaunch,
		},
		{
			Name: "ReclaimedRunningLaunchIsNotCanceledOnAmbiguousError",
			run:  runReclaimedRunningLaunchIsNotCanceledOnAmbiguousError,
		},
		{
			Name: "ReclaimedRunningLaunchIsNotCanceledOnSuccess",
			run:  runReclaimedRunningLaunchIsNotCanceledOnSuccess,
		},
		{
			Name: "TimedOutDispatchedLaunchRequestsExactCancellation",
			run:  runTimedOutDispatchedLaunchRequestsExactCancellation,
		},
		{
			Name: "TimedOutInFlightLaunchCancelsAfterDelivery",
			run:  runTimedOutInFlightLaunchCancelsAfterDelivery,
		},
		{
			Name: "RepairRestoresMissingSettlementCheckpoint",
			run:  runRepairRestoresMissingSettlementCheckpoint,
		},
		{
			Name: "AcknowledgeFencesAndDrainsBacklogIntoGoalReview",
			run:  runAcknowledgeFencesAndDrainsBacklogIntoGoalReview,
		},
		{
			Name: "AcknowledgeEligibilityUsesActiveWorkOrBacklog",
			run:  runAcknowledgeEligibilityUsesActiveWorkOrBacklog,
		},
		{
			Name: "MixedTerminalOutcomesReachGoalReview",
			run:  runMixedTerminalOutcomesReachGoalReview,
		},
	}
}

func MaterializationCatalog() []Scenario {
	return []Scenario{
		{
			Name: "MaterializedPlanRequiresInitialSchedule",
			run:  runMaterializedPlanRequiresInitialSchedule,
		},
	}
}

func ScheduleCatalog() []Scenario {
	return []Scenario{
		{
			Name: "SourceSchedulesExactSet",
			run:  runSourceSchedulesExactSet,
		},
		{
			Name: "ScheduleRejectsInvalidSetAtomically",
			run:  runScheduleRejectsInvalidSetAtomically,
		},
		{
			Name: "ScheduleRequestIdentityIsIdempotent",
			run:  runScheduleRequestIdentityIsIdempotent,
		},
		{
			Name: "PreparedLaunchIntentIsRecoverable",
			run:  runPreparedLaunchIntentIsRecoverable,
		},
		{
			Name: "ActiveRunBudgetReservationRejectsWholeSet",
			run:  runActiveRunBudgetReservationRejectsWholeSet,
		},
		{
			Name: "ConcurrentReplayClaimsOneDelivery",
			run:  runConcurrentReplayClaimsOneDelivery,
		},
		{
			Name: "ExpiredLaunchLeaseIsRecoveredOnce",
			run:  runExpiredLaunchLeaseIsRecoveredOnce,
		},
		{
			Name: "IdleRecoveryQueueObservesScheduleAdmission",
			run:  runIdleRecoveryQueueObservesScheduleAdmission,
		},
	}
}

func Run(ctx context.Context, driver Driver, scenario Scenario) error {
	if driver == nil {
		return fmt.Errorf("tutti mode execution conformance driver is required")
	}
	if scenario.run == nil {
		return fmt.Errorf("tutti mode execution conformance scenario %q has no runner", scenario.Name)
	}
	return scenario.run(ctx, driver)
}