Function getRepos

packages/backend/src/azuredevops.ts:285–338

(
    repoList: string[],
    baseUrl: string,
    token: string,
    useTfsPath: boolean
)

}

async function getRepos(
    repoList: string[],
    baseUrl: string,
    token: string,
    useTfsPath: boolean
) {
    const results = await Promise.allSettled(repoList.map(async (repo) => {
        try {
            const [org, projectName, repoName] = repo.split('/');
            logger.debug(`Fetching repository info for ${repo}...`);

            const { durationMs, data: result } = await measure(async () => {
                const fetchFn = async () => {
                    const orgUrl = buildOrgUrl(baseUrl, org, useTfsPath);
                    const connection = createAzureDevOpsConnection(orgUrl, token);
                    const gitApi = await connection.getGitApi();

                    const repo = await gitApi.getRepository(repoName, projectName);
                    return repo;
                };

                return fetchWithRetry(fetchFn, repo, logger);
            });

            logger.debug(`Found info for repository ${repo} in ${durationMs}ms`);
            return {
                type: 'valid' as const,
                data: [result]
            };

        } catch (error) {
            Sentry.captureException(error);
            logger.error(`Failed to fetch repository ${repo}.`, error);

            if (error && typeof error === 'object' && 'statusCode' in error && error.statusCode === 404) {
                const warning = `Repository ${repo} not found or no access`;
                logger.warn(warning);
                return {
                    type: 'warning' as const,
                    warning
                };
            }
            throw error;
        }
    }));

    throwIfAnyFailed(results);
    const { validItems: repos, warnings } = processPromiseResults<GitRepository>(results);

    return {
        repos,
        warnings,
    };
}