Function TestGitOpsCheckReleaseVCSUserTracking

backend/tests/gitops_test.go:200–299

(t *testing.T)

}

func TestGitOpsCheckReleaseVCSUserTracking(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)

	project := createGitOpsVCSUserTestProject(ctx, t, ctl)
	stores := getStore(t, ctl.server)
	workspaceID, err := stores.GetWorkspaceID(ctx)
	a.NoError(err)

	targets := []string{"instances/missing/databases/missing"}
	_, err = ctl.releaseServiceClient.CheckRelease(ctx, connect.NewRequest(&v1pb.CheckReleaseRequest{
		Parent:  project.Name,
		Release: gitOpsVCSUserTestRelease(),
		Targets: targets,
	}))
	a.Error(err)
	a.Equal(connect.CodeNotFound, connect.CodeOf(err))

	count, err := stores.CountActiveVCSProviderUsers(ctx, workspaceID, 90*24*time.Hour)
	a.NoError(err)
	a.Zero(count)

	_, err = ctl.releaseServiceClient.CheckRelease(ctx, connect.NewRequest(&v1pb.CheckReleaseRequest{
		Parent:  project.Name,
		Release: gitOpsVCSUserTestRelease(),
		Targets: []string{"malformed-target"},
		VcsUser: &v1pb.VCSUser{
			VcsType:  v1pb.VCSType_GITHUB,
			UserId:   "malformed-target-user",
			UserName: "malformed-target-user",
		},
	}))
	a.Error(err)
	a.Equal(connect.CodeInvalidArgument, connect.CodeOf(err))

	count, err = stores.CountActiveVCSProviderUsers(ctx, workspaceID, 90*24*time.Hour)
	a.NoError(err)
	a.Zero(count)

	_, err = ctl.releaseServiceClient.CheckRelease(ctx, connect.NewRequest(&v1pb.CheckReleaseRequest{
		Parent:  project.Name,
		Release: gitOpsVCSUserTestRelease(),
		Targets: targets,
		VcsUser: &v1pb.VCSUser{
			VcsType:     v1pb.VCSType_GITHUB,
			UserId:      "1001",
			UserName:    "alice",
			DisplayName: "Alice",
		},
	}))
	a.Error(err)
	a.Equal(connect.CodeNotFound, connect.CodeOf(err))