Skip to content

Commit 28b689a

Browse files
authored
Revert "Use RepoNames instead of Repos in search code (#16590)" (#16649)
This reverts commit e4b838e.
1 parent 2e9b67b commit 28b689a

30 files changed

Lines changed: 206 additions & 266 deletions

cmd/frontend/backend/repos.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ func (s *repos) List(ctx context.Context, opt db.ReposListOptions) (repos []*typ
153153
}
154154

155155
// ListDefault calls db.DefaultRepos.List, with tracing.
156-
func (s *repos) ListDefault(ctx context.Context) (repos []*types.RepoName, err error) {
156+
func (s *repos) ListDefault(ctx context.Context) (repos []*types.Repo, err error) {
157157
ctx, done := trace(ctx, "Repos", "ListDefault", nil, &err)
158158
defer func() {
159159
if err == nil {

cmd/frontend/graphqlbackend/repositories.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -317,20 +317,20 @@ func repoNamesToStrings(repoNames []api.RepoName) []string {
317317
return strings
318318
}
319319

320-
func toRepositoryResolvers(repos []*types.RepoName) []*RepositoryResolver {
320+
func toRepositoryResolvers(repos []*types.Repo) []*RepositoryResolver {
321321
if len(repos) == 0 {
322322
return []*RepositoryResolver{}
323323
}
324324

325325
resolvers := make([]*RepositoryResolver, len(repos))
326326
for i := range repos {
327-
resolvers[i] = &RepositoryResolver{repo: repos[i].ToRepo()}
327+
resolvers[i] = &RepositoryResolver{repo: repos[i]}
328328
}
329329

330330
return resolvers
331331
}
332332

333-
func toRepoNames(repos []*types.RepoName) []api.RepoName {
333+
func toRepoNames(repos []*types.Repo) []api.RepoName {
334334
names := make([]api.RepoName, len(repos))
335335
for i, repo := range repos {
336336
names[i] = repo.Name

cmd/frontend/graphqlbackend/search.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -907,7 +907,7 @@ func resolveRepositories(ctx context.Context, op resolveRepoOp) (resolvedReposit
907907
}
908908
}
909909

910-
var defaultRepos []*types.RepoName
910+
var defaultRepos []*types.Repo
911911
if envvar.SourcegraphDotComMode() && len(includePatterns) == 0 {
912912
start := time.Now()
913913
defaultRepos, err = defaultRepositories(ctx, db.DefaultRepos.List, search.Indexed(), excludePatterns)
@@ -922,7 +922,7 @@ func resolveRepositories(ctx context.Context, op resolveRepoOp) (resolvedReposit
922922
}
923923
}
924924

925-
var repos []*types.RepoName
925+
var repos []*types.Repo
926926
var excluded excludedRepos
927927
if len(defaultRepos) > 0 {
928928
repos = defaultRepos
@@ -952,7 +952,7 @@ func resolveRepositories(ctx context.Context, op resolveRepoOp) (resolvedReposit
952952
excludedC <- computeExcludedRepositories(ctx, op.query, options)
953953
}()
954954

955-
repos, err = db.Repos.ListRepoNames(ctx, options)
955+
repos, err = db.Repos.List(ctx, options)
956956
tr.LazyPrintf("Repos.List - done")
957957

958958
excluded = <-excludedC
@@ -1065,9 +1065,9 @@ func resolveRepositories(ctx context.Context, op resolveRepoOp) (resolvedReposit
10651065
}, err
10661066
}
10671067

1068-
type defaultReposFunc func(ctx context.Context) ([]*types.RepoName, error)
1068+
type defaultReposFunc func(ctx context.Context) ([]*types.Repo, error)
10691069

1070-
func defaultRepositories(ctx context.Context, getRawDefaultRepos defaultReposFunc, z *searchbackend.Zoekt, excludePatterns []string) ([]*types.RepoName, error) {
1070+
func defaultRepositories(ctx context.Context, getRawDefaultRepos defaultReposFunc, z *searchbackend.Zoekt, excludePatterns []string) ([]*types.Repo, error) {
10711071
// Get the list of default repos from the db.
10721072
defaultRepos, err := getRawDefaultRepos(ctx)
10731073
if err != nil {

cmd/frontend/graphqlbackend/search_alert_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ func TestAlertForOverRepoLimit(t *testing.T) {
206206
j := 0
207207
for i := range repoRevs {
208208
repoRevs[i] = &search.RepositoryRevisions{
209-
Repo: &types.RepoName{
209+
Repo: &types.Repo{
210210
ID: api.RepoID(i),
211211
Name: api.RepoName(chars[j] + "/repoName" + strconv.Itoa(i)),
212212
},

cmd/frontend/graphqlbackend/search_commits.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -307,7 +307,7 @@ func doSearchCommitsInRepoStream(ctx context.Context, op search.CommitParameters
307307
}
308308
}()
309309

310-
repoResolver := &RepositoryResolver{repo: op.RepoRevs.Repo.ToRepo()}
310+
repoResolver := &RepositoryResolver{repo: op.RepoRevs.Repo}
311311
for event := range events {
312312
// if the result is incomplete, git log timed out and the client
313313
// should be notified of that.
@@ -570,7 +570,7 @@ func searchCommitsInRepos(ctx context.Context, args *search.TextParametersForCom
570570
unflattened [][]*CommitSearchResultResolver
571571
common = &searchResultsCommon{}
572572
)
573-
common.repos = make([]*types.RepoName, len(args.Repos))
573+
common.repos = make([]*types.Repo, len(args.Repos))
574574
for i, repo := range args.Repos {
575575
common.repos[i] = repo.Repo
576576
}

cmd/frontend/graphqlbackend/search_commits_test.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ import (
1414
"github.com/sourcegraph/sourcegraph/internal/db"
1515
"github.com/sourcegraph/sourcegraph/internal/search"
1616
"github.com/sourcegraph/sourcegraph/internal/search/query"
17+
// "github.com/google/go-cmp/cmp"
1718
"github.com/sourcegraph/sourcegraph/internal/types"
1819
"github.com/sourcegraph/sourcegraph/internal/vcs/git"
1920
)
@@ -51,7 +52,7 @@ func TestSearchCommitsInRepo(t *testing.T) {
5152
t.Fatal(err)
5253
}
5354
repoRevs := &search.RepositoryRevisions{
54-
Repo: &types.RepoName{ID: 1, Name: "repo"},
55+
Repo: &types.Repo{ID: 1, Name: "repo"},
5556
Revs: []search.RevisionSpecifier{{RevSpec: "rev"}},
5657
}
5758
results, limitHit, timedOut, err := searchCommitsInRepo(ctx, search.CommitParameters{

cmd/frontend/graphqlbackend/search_pagination.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ func (r *searchResolver) paginatedResults(ctx context.Context) (result *SearchRe
221221

222222
// repoIsLess sorts repositories first by name then by ID, suitable for use
223223
// with sort.Slice.
224-
func repoIsLess(i, j *types.RepoName) bool {
224+
func repoIsLess(i, j *types.Repo) bool {
225225
if i.Name != j.Name {
226226
return i.Name < j.Name
227227
}
@@ -391,7 +391,7 @@ func (p *repoPaginationPlan) execute(ctx context.Context, exec executor) (c *sea
391391
if len(sliced.results) > 0 {
392392
// First, identify what repository corresponds to the last result.
393393
lastRepoConsumedName, _ := sliced.results[len(sliced.results)-1].searchResultURIs()
394-
var lastRepoConsumed *types.RepoName
394+
var lastRepoConsumed *types.Repo
395395
for _, repo := range p.repositories {
396396
if string(repo.Repo.Name) == lastRepoConsumedName {
397397
lastRepoConsumed = repo.Repo
@@ -404,7 +404,7 @@ func (p *repoPaginationPlan) execute(ctx context.Context, exec executor) (c *sea
404404
// that out now. For example, a cloning repository could be last or
405405
// first in the results and we need to know the position for the cursor
406406
// RepositoryOffset.
407-
potentialLastRepos := []*types.RepoName{lastRepoConsumed}
407+
potentialLastRepos := []*types.Repo{lastRepoConsumed}
408408
potentialLastRepos = append(potentialLastRepos, sliced.common.cloning...)
409409
potentialLastRepos = append(potentialLastRepos, sliced.common.missing...)
410410
sort.Slice(potentialLastRepos, func(i, j int) bool {
@@ -475,11 +475,11 @@ func sliceSearchResults(results []SearchResultResolver, common *searchResultsCom
475475

476476
// Break results into repositories because for each result we need to add
477477
// the respective repository to the new common structure.
478-
reposByName := map[string]*types.RepoName{}
478+
reposByName := map[string]*types.Repo{}
479479
for _, r := range common.repos {
480480
reposByName[string(r.Name)] = r
481481
}
482-
resultsByRepo := map[*types.RepoName][]SearchResultResolver{}
482+
resultsByRepo := map[*types.Repo][]SearchResultResolver{}
483483
for _, r := range results[:limit] {
484484
repoName, _ := r.searchResultURIs()
485485
repo := reposByName[repoName]
@@ -549,7 +549,7 @@ func sliceSearchResultsCommon(common *searchResultsCommon, firstResultRepo, last
549549
resultCount: common.resultCount,
550550
}
551551

552-
doAppend := func(dst, src []*types.RepoName) []*types.RepoName {
552+
doAppend := func(dst, src []*types.Repo) []*types.Repo {
553553
sort.Slice(src, func(i, j int) bool {
554554
return repoIsLess(src[i], src[j])
555555
})

0 commit comments

Comments
 (0)