[server] add searchString to getRepositoriesForAutomatedPrebuilds

Author: AlexTugarev

components/server/src/bitbucket-server/bitbucket-server-api.ts

@@ -280,34 +280,43 @@ export class BitbucketServerApi {
     }
 
     /**
+     * If `searchString` is provided, this tries to match projects and repositorys by name,
+     *  otherwise it returns the first n repositories.
+     *
+     * Based on:
      * https://developer.atlassian.com/server/bitbucket/rest/v811/api-group-repository/#api-api-latest-repos-get
      */
     async getRepos(
         userOrToken: User | string,
         query: {
             permission?: "REPO_READ" | "REPO_WRITE" | "REPO_ADMIN";
+            searchString?: string;
         },
     ) {
-        const result: BitbucketServer.Repository[] = [];
         const permission = query.permission ? `permission=${query.permission}&` : "";
-        let isLastPage = false;
-        let start = 0;
-        while (!isLastPage) {
-            const pageResult = await this.runQuery<BitbucketServer.Paginated<BitbucketServer.Repository>>(
+        const runQuery = async (params: string) =>
+            this.runQuery<BitbucketServer.Paginated<BitbucketServer.Repository>>(
                 userOrToken,
-                `/repos?${permission}start=${start}`,
+                `/repos?${permission}${params}`,
             );
-            if (pageResult.values) {
-                result.push(...pageResult.values);
-            }
-            isLastPage =
-                typeof pageResult.isLastPage === "undefined" || // a fuse to prevent infinite loop
-                !!pageResult.isLastPage;
-            if (pageResult.nextPageStart) {
-                start = pageResult.nextPageStart;
+
+        if (query.searchString?.trim()) {
+            const result: BitbucketServer.Repository[] = [];
+            const ids = new Set<number>(); // used to deduplicate
+            for (const param of ["name", "projectname", "projectkey"]) {
+                const pageResult = await runQuery(`limit=1000&${param}=${query.searchString}`);
+                for (const repo of pageResult.values || []) {
+                    if (!ids.has(repo.id)) {
+                        ids.add(repo.id);
+                        result.push(repo);
+                    }
+                }
             }
+            return result;
+        } else {
+            const pageResult = await runQuery(`limit=1000`);
+            return pageResult.values || [];
         }
-        return result;
     }
 
     async getPullRequest(

components/server/src/prebuilds/bitbucket-server-service.ts

@@ -24,8 +24,8 @@ export class BitbucketServerService extends RepositoryService {
     @inject(TokenService) protected tokenService: TokenService;
     @inject(BitbucketServerContextParser) protected contextParser: BitbucketServerContextParser;
 
-    async getRepositoriesForAutomatedPrebuilds(user: User): Promise<ProviderRepository[]> {
-        const repos = await this.api.getRepos(user, { permission: "REPO_ADMIN" });
+    async getRepositoriesForAutomatedPrebuilds(user: User, searchString?: string): Promise<ProviderRepository[]> {
+        const repos = await this.api.getRepos(user, { permission: "REPO_ADMIN", searchString });
         return repos.map((r) => {
             const cloneUrl = r.links.clone.find((u) => u.name === "http")?.href!;
             // const webUrl = r.links?.self[0]?.href?.replace("/browse", "");

components/server/src/repohost/repo-service.ts

@@ -9,7 +9,7 @@ import { injectable } from "inversify";
 
 @injectable()
 export class RepositoryService {
-    async getRepositoriesForAutomatedPrebuilds(user: User): Promise<ProviderRepository[]> {
+    async getRepositoriesForAutomatedPrebuilds(user: User, searchString?: string): Promise<ProviderRepository[]> {
         return [];
     }
 

components/server/src/workspace/gitpod-server-impl.ts

@@ -1464,7 +1464,7 @@ export class GitpodServerImpl implements GitpodServerWithTracing, Disposable {
     // Projects
     async getProviderRepositoriesForUser(
         ctx: TraceContext,
-        params: { provider: string; hints?: object },
+        params: { provider: string; hints?: object; searchString?: string },
     ): Promise<ProviderRepository[]> {
         traceAPIParams(ctx, { params });
 
@@ -1489,7 +1489,10 @@ export class GitpodServerImpl implements GitpodServerWithTracing, Disposable {
             const hostContext = this.hostContextProvider.get(providerHost);
             if (hostContext?.services) {
                 repositories.push(
-                    ...(await hostContext.services.repositoryService.getRepositoriesForAutomatedPrebuilds(user)),
+                    ...(await hostContext.services.repositoryService.getRepositoriesForAutomatedPrebuilds(
+                        user,
+                        params.searchString,
+                    )),
                 );
             }
         } else if (provider?.authProviderType === "GitLab") {