import {useCallback, useMemo, useState} from 'react'; import styled from '@emotion/styled'; import debounce from 'lodash/debounce'; import {addErrorMessage, addSuccessMessage} from 'sentry/actionCreators/indicator'; import {addRepository, migrateRepository} from 'sentry/actionCreators/integrations'; import DropdownAutoComplete from 'sentry/components/dropdownAutoComplete'; import DropdownButton from 'sentry/components/dropdownButton'; import {t} from 'sentry/locale'; import RepositoryStore from 'sentry/stores/repositoryStore'; import type { Integration, IntegrationRepository, Repository, } from 'sentry/types/integrations'; import useApi from 'sentry/utils/useApi'; import useOrganization from 'sentry/utils/useOrganization'; interface IntegrationReposAddRepositoryProps { currentRepositories: Repository[]; integration: Integration; onAddRepository: (repo: Repository) => void; onSearchError: (errorStatus: number | null | undefined) => void; } interface IntegrationRepoSearchResult { repos: IntegrationRepository[]; } export function IntegrationReposAddRepository({ integration, currentRepositories, onSearchError, onAddRepository, }: IntegrationReposAddRepositoryProps) { const api = useApi({persistInFlight: true}); const organization = useOrganization(); const [dropdownBusy, setDropdownBusy] = useState(false); const [adding, setAdding] = useState(false); const [searchResult, setSearchResult] = useState({ repos: [], }); const searchRepositoriesRequest = useCallback( async (searchQuery?: string) => { try { const data: IntegrationRepoSearchResult = await api.requestPromise( `/organizations/${organization.slug}/integrations/${integration.id}/repos/`, {method: 'GET', query: {search: searchQuery}} ); setSearchResult(data); } catch (error) { onSearchError(error?.status); } setDropdownBusy(false); }, [api, integration, organization, onSearchError] ); const debouncedSearchRepositoriesRequest = useMemo( () => debounce(query => searchRepositoriesRequest(query), 200), [searchRepositoriesRequest] ); const handleSearchRepositories = useCallback( (e?: React.ChangeEvent) => { if (e?.target.value) { setDropdownBusy(true); onSearchError(null); debouncedSearchRepositoriesRequest(e?.target.value); } else { setDropdownBusy(false); onSearchError(null); setSearchResult({repos: []}); } }, [debouncedSearchRepositoriesRequest, onSearchError] ); const addRepo = async (selection: {value: string}) => { setAdding(true); const migratableRepo = currentRepositories.find(item => { if (!(selection.value && item.externalSlug)) { return false; } return selection.value === item.externalSlug; }); let promise: Promise; if (migratableRepo) { promise = migrateRepository(api, organization.slug, migratableRepo.id, integration); } else { promise = addRepository(api, organization.slug, selection.value, integration); } try { const repo = await promise; onAddRepository(repo); addSuccessMessage(t('Repository added')); RepositoryStore.resetRepositories(); } catch (error) { addErrorMessage(t('Unable to add repository.')); } finally { setAdding(false); } }; const dropdownItems = useMemo(() => { const repositories = new Set( currentRepositories.filter(item => item.integrationId).map(i => i.externalSlug) ); const repositoryOptions = searchResult.repos.filter( repo => !repositories.has(repo.identifier) ); return repositoryOptions.map(repo => ({ searchKey: repo.name, value: repo.identifier, label: {repo.name}, })); }, [currentRepositories, searchResult]); if ( !['github', 'gitlab'].includes(integration.provider.key) && !organization.access.includes('org:integrations') ) { return ( {t('Add Repository')} ); } return ( {({isOpen}) => ( {t('Add Repository')} )} ); } const DropdownWrapper = styled('div')` text-transform: none; `; const RepoName = styled('div')` font-weight: ${p => p.theme.fontWeightNormal}; `;