Function TestActionRolloutCommand

backend/tests/action_test.go:656–1070

(t *testing.T)

}

func TestActionRolloutCommand(t *testing.T) {
	t.Parallel()

	t.Run("BasicRollout", func(t *testing.T) {
		t.Parallel()
		a := require.New(t)
		ctx := context.Background()
		ctl := &controller{}

		ctx, err := ctl.StartServerWithExternalPg(ctx)
		a.NoError(err)
		defer ctl.Close(ctx)

		// Create test database
		database := ctl.createTestDatabase(ctx, t)

		// Create test data directory and migration file
		testDataDir := t.TempDir()
		migrationContent := `CREATE TABLE users (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    username TEXT NOT NULL UNIQUE,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);`
		migrationFile := filepath.Join(testDataDir, "00001_create_users.sql")
		err = os.WriteFile(migrationFile, []byte(migrationContent), 0644)
		a.NoError(err)

		// Create output file
		outputFile := filepath.Join(t.TempDir(), "rollout-output.json")

		// Execute rollout
		result, err := executeActionCommand(ctx,
			"rollout",
			"--url", ctl.rootURL,
			"--service-account", "demo@example.com",
			"--service-account-secret", "1024bytebase",
			"--project", ctl.project.Name,
			"--targets", database.Name,
			"--file-pattern", migrationFile,
			"--target-stage", "environments/prod",
			"--output", outputFile,
		)

		a.NoError(err, "Rollout command should succeed")

		// E2E Verification: Check server state for complete rollout lifecycle

		// 1. Verify plan was created
		plans, err := ctl.planServiceClient.ListPlans(ctx, connect.NewRequest(&v1pb.ListPlansRequest{
			Parent: ctl.project.Name,
		}))
		a.NoError(err)
		a.NotEmpty(plans.Msg.Plans, "Expected plan to be created")
		plan := plans.Msg.Plans[0]

		// 2. Verify release was created with correct title
		releases, err := ctl.releaseServiceClient.ListReleases(ctx, connect.NewRequest(&v1pb.ListReleasesRequest{
			Parent: ctl.project.Name,