315 lines · 10.5 KB · Rust
RawDownload
use crate::git_status_icon;use git::status::{FileStatus, StatusCode, TrackedStatus, UnmergedStatus, UnmergedStatusCode};use gpui::{App, DismissEvent, Entity, EventEmitter, FocusHandle, Focusable, Task, WeakEntity};use itertools::Itertools;use picker::{Picker, PickerDelegate, PickerEditorPosition};use project::{Project, git_store::Repository};use std::sync::Arc;use ui::{ListItem, ListItemSpacing, prelude::*};use workspace::{ModalView, Workspace}; pub fn register(workspace: &mut Workspace) {    workspace.register_action(open);} pub fn open(    workspace: &mut Workspace,    _: &zed_actions::git::SelectRepo,    window: &mut Window,    cx: &mut Context<Workspace>,) {    let project = workspace.project().clone();    workspace.toggle_modal(window, cx, |window, cx| {        RepositorySelector::new(project, rems(34.), window, cx)    })} pub struct RepositorySelector {    width: Rems,    picker: Entity<Picker<RepositorySelectorDelegate>>,} impl RepositorySelector {    pub fn new(        project_handle: Entity<Project>,        width: Rems,        window: &mut Window,        cx: &mut Context<Self>,    ) -> Self {        let git_store = project_handle.read(cx).git_store().clone();        let repository_entries = git_store.update(cx, |git_store, _cx| {            let mut repos: Vec<_> = git_store.repositories().values().cloned().collect();             repos.sort_by(|a, b| {                a.read(_cx)                    .display_name()                    .to_lowercase()                    .cmp(&b.read(_cx).display_name().to_lowercase())            });             repos        });        let filtered_repositories = repository_entries.clone();         let widest_item_ix = repository_entries.iter().position_max_by(|a, b| {            a.read(cx)                .display_name()                .len()                .cmp(&b.read(cx).display_name().len())        });         let active_repository = git_store.read(cx).active_repository();        let selected_index = active_repository            .as_ref()            .and_then(|active| filtered_repositories.iter().position(|repo| repo == active))            .unwrap_or(0);        let delegate = RepositorySelectorDelegate {            repository_selector: cx.entity().downgrade(),            repository_entries,            filtered_repositories,            active_repository,            selected_index,        };         let picker = cx.new(|cx| {            Picker::uniform_list(delegate, window, cx)                .widest_item(widest_item_ix)                .max_height(Some(rems(20.).into()))                .show_scrollbar(true)        });         RepositorySelector { picker, width }    }} //pub(crate) fn filtered_repository_entries(//    git_store: &GitStore,//    cx: &App,//) -> Vec<Entity<Repository>> {//    let repositories = git_store//        .repositories()//        .values()//        .sorted_by_key(|repo| {//            let repo = repo.read(cx);//            (//                repo.dot_git_abs_path.clone(),//                repo.worktree_abs_path.clone(),//            )//        })//        .collect::<Vec<&Entity<Repository>>>();////    repositories//        .chunk_by(|a, b| a.read(cx).dot_git_abs_path == b.read(cx).dot_git_abs_path)//        .flat_map(|chunk| {//            let has_non_single_file_worktree = chunk//                .iter()//                .any(|repo| !repo.read(cx).is_from_single_file_worktree);//            chunk.iter().filter(move |repo| {//                // Remove any entry that comes from a single file worktree and represents a repository that is also represented by a non-single-file worktree.//                !repo.read(cx).is_from_single_file_worktree || !has_non_single_file_worktree//            })//        })//        .map(|&repo| repo.clone())//        .collect()//} impl EventEmitter<DismissEvent> for RepositorySelector {} impl Focusable for RepositorySelector {    fn focus_handle(&self, cx: &App) -> FocusHandle {        self.picker.focus_handle(cx)    }} impl Render for RepositorySelector {    fn render(&mut self, _window: &mut Window, _cx: &mut Context<Self>) -> impl IntoElement {        div()            .key_context("GitRepositorySelector")            .w(self.width)            .child(self.picker.clone())    }} impl ModalView for RepositorySelector {} pub struct RepositorySelectorDelegate {    repository_selector: WeakEntity<RepositorySelector>,    repository_entries: Vec<Entity<Repository>>,    filtered_repositories: Vec<Entity<Repository>>,    active_repository: Option<Entity<Repository>>,    selected_index: usize,} impl RepositorySelectorDelegate {    pub fn update_repository_entries(&mut self, all_repositories: Vec<Entity<Repository>>) {        self.repository_entries = all_repositories.clone();        self.filtered_repositories = all_repositories;        self.selected_index = self            .active_repository            .as_ref()            .and_then(|active| {                self.filtered_repositories                    .iter()                    .position(|repo| repo == active)            })            .unwrap_or(0);    }} impl PickerDelegate for RepositorySelectorDelegate {    type ListItem = ListItem;     fn match_count(&self) -> usize {        self.filtered_repositories.len()    }     fn selected_index(&self) -> usize {        self.selected_index    }     fn set_selected_index(        &mut self,        ix: usize,        _window: &mut Window,        cx: &mut Context<Picker<Self>>,    ) {        self.selected_index = ix.min(self.filtered_repositories.len().saturating_sub(1));        cx.notify();    }     fn placeholder_text(&self, _window: &mut Window, _cx: &mut App) -> Arc<str> {        "Select a repository...".into()    }     fn editor_position(&self) -> PickerEditorPosition {        PickerEditorPosition::End    }     fn update_matches(        &mut self,        query: String,        window: &mut Window,        cx: &mut Context<Picker<Self>>,    ) -> Task<()> {        let all_repositories = self.repository_entries.clone();         let repo_names: Vec<(Entity<Repository>, String)> = all_repositories            .iter()            .map(|repo| (repo.clone(), repo.read(cx).display_name().to_lowercase()))            .collect();         cx.spawn_in(window, async move |this, cx| {            let filtered_repositories = cx                .background_spawn(async move {                    if query.is_empty() {                        all_repositories                    } else {                        let query_lower = query.to_lowercase();                        repo_names                            .into_iter()                            .filter(|(_, display_name)| display_name.contains(&query_lower))                            .map(|(repo, _)| repo)                            .collect()                    }                })                .await;             this.update_in(cx, |this, window, cx| {                let mut sorted_repositories = filtered_repositories;                sorted_repositories.sort_by(|a, b| {                    a.read(cx)                        .display_name()                        .to_lowercase()                        .cmp(&b.read(cx).display_name().to_lowercase())                });                let selected_index = this                    .delegate                    .active_repository                    .as_ref()                    .and_then(|active| sorted_repositories.iter().position(|repo| repo == active))                    .unwrap_or(0);                this.delegate.filtered_repositories = sorted_repositories;                this.delegate.set_selected_index(selected_index, window, cx);                cx.notify();            })            .ok();        })    }     fn confirm(&mut self, _secondary: bool, window: &mut Window, cx: &mut Context<Picker<Self>>) {        let Some(selected_repo) = self.filtered_repositories.get(self.selected_index) else {            return;        };        selected_repo.update(cx, |selected_repo, cx| {            selected_repo.set_as_active_repository(cx)        });        self.dismissed(window, cx);    }     fn dismissed(&mut self, _window: &mut Window, cx: &mut Context<Picker<Self>>) {        self.repository_selector            .update(cx, |_this, cx| cx.emit(DismissEvent))            .ok();    }     fn render_match(        &self,        ix: usize,        selected: bool,        _window: &mut Window,        cx: &mut Context<Picker<Self>>,    ) -> Option<Self::ListItem> {        let repo_info = self.filtered_repositories.get(ix)?;        let repo = repo_info.read(cx);        let display_name = repo.display_name();        let summary = repo.status_summary();        let is_active = self            .active_repository            .as_ref()            .is_some_and(|active| active == repo_info);         let mut item = ListItem::new(ix)            .inset(true)            .spacing(ListItemSpacing::Sparse)            .toggle_state(selected)            .child(                h_flex()                    .gap_1()                    .child(Label::new(display_name))                    .when(is_active, |this| {                        this.child(                            Icon::new(IconName::Check)                                .size(IconSize::Small)                                .color(Color::Accent),                        )                    }),            );         if summary.count > 0 {            let status = if summary.conflict > 0 {                FileStatus::Unmerged(UnmergedStatus {                    first_head: UnmergedStatusCode::Updated,                    second_head: UnmergedStatusCode::Updated,                })            } else if summary.worktree.deleted > 0 || summary.index.deleted > 0 {                FileStatus::Tracked(TrackedStatus {                    index_status: StatusCode::Deleted,                    worktree_status: StatusCode::Unmodified,                })            } else if summary.worktree.modified > 0 || summary.index.modified > 0 {                FileStatus::Tracked(TrackedStatus {                    index_status: StatusCode::Modified,                    worktree_status: StatusCode::Unmodified,                })            } else {                FileStatus::Tracked(TrackedStatus {                    index_status: StatusCode::Added,                    worktree_status: StatusCode::Unmodified,                })            };            item = item.end_slot(div().pr_2().child(git_status_icon(status)));        }         Some(item)    }}