Function cloudGetReposForProjects

packages/backend/src/bitbucket.ts:262–321

(client: BitbucketClient, projects: string[])

}

async function cloudGetReposForProjects(client: BitbucketClient, projects: string[]): Promise<{repos: CloudRepository[], warnings: string[]}> {
    const results = await Promise.allSettled(projects.map(async (project) => {
        const [workspace, project_name] = project.split('/');
        if (!workspace || !project_name) {
            const warning = `Invalid project ${project}`;
            logger.warn(warning);
            return {
                type: 'warning' as const,
                warning
            }
        }

        logger.debug(`Fetching all repos for project ${project} for workspace ${workspace}...`);
        try {
            const { durationMs, data: repos } = await measure(async () => {
                const fetchFn = () => getPaginatedCloud<CloudRepository>(`/repositories/${workspace}` as CloudGetRequestPath, async (path, query) => {
                    const { data } = await client.apiClient.GET(path, {
                        params: {
                            path: {
                                workspace,
                            },
                            query: {
                                ...query,
                                q: `project.key="${project_name}"`
                            }
                        }
                    });
                    return data;
                });
                return fetchWithRetry(fetchFn, `project ${project_name} in workspace ${workspace}`, logger);
            });

            logger.debug(`Found ${repos.length} repos for project ${project_name} for workspace ${workspace} in ${durationMs}ms.`);
            return {
                type: 'valid' as const,
                data: repos
            }
        } catch (e: any) {
            Sentry.captureException(e);
            logger.error(`Failed to fetch repos for project ${project_name}: ${e}`);

            if (e?.status === 404) {
                const warning = `Project ${project_name} not found in ${workspace} or invalid access`;
                logger.warn(warning);
                return {
                    type: 'warning' as const,
                    warning
                }
            }
            throw e;
        }
    }));

    throwIfAnyFailed(results);
    const { validItems: repos, warnings } = processPromiseResults(results);
    return {
        repos,
        warnings