Function TestPlanSpecRemove_EmitsIssueComment

backend/tests/plan_update_test.go:212–261

(t *testing.T)

}

func TestPlanSpecRemove_EmitsIssueComment(t *testing.T) {
	t.Parallel()
	a := require.New(t)
	f := setupPlanUpdateFixture(t, true)

	originalSpec := f.plan.Specs[0]
	secondSpecID := uuid.NewString()
	// Seed: add a second spec we can later remove.
	_, err := f.ctl.planServiceClient.UpdatePlan(f.ctx, connect.NewRequest(&v1pb.UpdatePlanRequest{
		Plan: &v1pb.Plan{
			Name: f.plan.Name,
			Specs: []*v1pb.Plan_Spec{
				originalSpec,
				{
					Id: secondSpecID,
					Config: &v1pb.Plan_Spec_ChangeDatabaseConfig{
						ChangeDatabaseConfig: &v1pb.Plan_ChangeDatabaseConfig{
							Targets: []string{f.database.Name},
							Sheet:   f.sheet2.Name,
						},
					},
				},
			},
		},
		UpdateMask: &fieldmaskpb.FieldMask{Paths: []string{"specs"}},
	}))
	a.NoError(err)

	// Now remove the second spec.
	_, err = f.ctl.planServiceClient.UpdatePlan(f.ctx, connect.NewRequest(&v1pb.UpdatePlanRequest{
		Plan: &v1pb.Plan{
			Name:  f.plan.Name,
			Specs: []*v1pb.Plan_Spec{originalSpec},
		},
		UpdateMask: &fieldmaskpb.FieldMask{Paths: []string{"specs"}},
	}))
	a.NoError(err)

	events := listPlanUpdateEvents(t, f)
	a.Len(events, 2, "expected two PlanUpdate rows: seed add + removal")
	removal := events[1]
	a.Len(removal.FromSpecs, 2)
	a.Len(removal.ToSpecs, 1)
	a.Equal(originalSpec.Id, removal.ToSpecs[0].Id)
	idsBefore := map[string]bool{}
	for _, s := range removal.FromSpecs {
		idsBefore[s.Id] = true
	}
	a.True(idsBefore[secondSpecID])
}

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