use crate::sign_in::CopilotCodeVerification; use anyhow::Result; use copilot::{Copilot, SignOut, Status}; use editor::{scroll::autoscroll::Autoscroll, Editor}; use fs::Fs; use gpui::{ div, Action, AnchorCorner, AppContext, AsyncWindowContext, Entity, IntoElement, ParentElement, Render, Subscription, View, ViewContext, WeakView, WindowContext, }; use language::{ language_settings::{self, all_language_settings, AllLanguageSettings}, File, Language, }; use settings::{update_settings_file, Settings, SettingsStore}; use std::{path::Path, sync::Arc}; use util::{paths, ResultExt}; use workspace::{ create_and_open_local_file, item::ItemHandle, ui::{popover_menu, ButtonCommon, Clickable, ContextMenu, Icon, IconButton, IconSize, Tooltip}, StatusItemView, Toast, Workspace, }; use zed_actions::OpenBrowser; const COPILOT_SETTINGS_URL: &str = "https://github.com/settings/copilot"; const COPILOT_STARTING_TOAST_ID: usize = 1337; const COPILOT_ERROR_TOAST_ID: usize = 1338; pub struct CopilotButton { editor_subscription: Option<(Subscription, usize)>, editor_enabled: Option, language: Option>, file: Option>, fs: Arc, } impl Render for CopilotButton { fn render(&mut self, cx: &mut ViewContext) -> impl IntoElement { let all_language_settings = all_language_settings(None, cx); if !all_language_settings.copilot.feature_enabled { return div(); } let Some(copilot) = Copilot::global(cx) else { return div(); }; let status = copilot.read(cx).status(); let enabled = self .editor_enabled .unwrap_or_else(|| all_language_settings.copilot_enabled(None, None)); let icon = match status { Status::Error(_) => Icon::CopilotError, Status::Authorized => { if enabled { Icon::Copilot } else { Icon::CopilotDisabled } } _ => Icon::CopilotInit, }; if let Status::Error(e) = status { return div().child( IconButton::new("copilot-error", icon) .icon_size(IconSize::Small) .on_click(cx.listener(move |_, _, cx| { if let Some(workspace) = cx.window_handle().downcast::() { workspace .update(cx, |workspace, cx| { workspace.show_toast( Toast::new( COPILOT_ERROR_TOAST_ID, format!("Copilot can't be started: {}", e), ) .on_click( "Reinstall Copilot", |cx| { if let Some(copilot) = Copilot::global(cx) { copilot .update(cx, |copilot, cx| { copilot.reinstall(cx) }) .detach(); } }, ), cx, ); }) .ok(); } })) .tooltip(|cx| Tooltip::text("GitHub Copilot", cx)), ); } let this = cx.view().clone(); div().child( popover_menu("copilot") .menu(move |cx| match status { Status::Authorized => { Some(this.update(cx, |this, cx| this.build_copilot_menu(cx))) } _ => Some(this.update(cx, |this, cx| this.build_copilot_start_menu(cx))), }) .anchor(AnchorCorner::BottomRight) .trigger( IconButton::new("copilot-icon", icon) .tooltip(|cx| Tooltip::text("GitHub Copilot", cx)), ), ) } } impl CopilotButton { pub fn new(fs: Arc, cx: &mut ViewContext) -> Self { Copilot::global(cx).map(|copilot| cx.observe(&copilot, |_, _, cx| cx.notify()).detach()); cx.observe_global::(move |_, cx| cx.notify()) .detach(); Self { editor_subscription: None, editor_enabled: None, language: None, file: None, fs, } } pub fn build_copilot_start_menu(&mut self, cx: &mut ViewContext) -> View { let fs = self.fs.clone(); ContextMenu::build(cx, |menu, _| { menu.entry("Sign In", None, initiate_sign_in).entry( "Disable Copilot", None, move |cx| hide_copilot(fs.clone(), cx), ) }) } pub fn build_copilot_menu(&mut self, cx: &mut ViewContext) -> View { let fs = self.fs.clone(); return ContextMenu::build(cx, move |mut menu, cx| { if let Some(language) = self.language.clone() { let fs = fs.clone(); let language_enabled = language_settings::language_settings(Some(&language), None, cx) .show_copilot_suggestions; menu = menu.entry( format!( "{} Suggestions for {}", if language_enabled { "Hide" } else { "Show" }, language.name() ), None, move |cx| toggle_copilot_for_language(language.clone(), fs.clone(), cx), ); } let settings = AllLanguageSettings::get_global(cx); if let Some(file) = &self.file { let path = file.path().clone(); let path_enabled = settings.copilot_enabled_for_path(&path); menu = menu.entry( format!( "{} Suggestions for This Path", if path_enabled { "Hide" } else { "Show" } ), None, move |cx| { if let Some(workspace) = cx.window_handle().downcast::() { if let Ok(workspace) = workspace.root_view(cx) { let workspace = workspace.downgrade(); cx.spawn(|cx| { configure_disabled_globs( workspace, path_enabled.then_some(path.clone()), cx, ) }) .detach_and_log_err(cx); } } }, ); } let globally_enabled = settings.copilot_enabled(None, None); menu.entry( if globally_enabled { "Hide Suggestions for All Files" } else { "Show Suggestions for All Files" }, None, move |cx| toggle_copilot_globally(fs.clone(), cx), ) .separator() .link( "Copilot Settings", OpenBrowser { url: COPILOT_SETTINGS_URL.to_string(), } .boxed_clone(), ) .action("Sign Out", SignOut.boxed_clone()) }); } pub fn update_enabled(&mut self, editor: View, cx: &mut ViewContext) { let editor = editor.read(cx); let snapshot = editor.buffer().read(cx).snapshot(cx); let suggestion_anchor = editor.selections.newest_anchor().start; let language = snapshot.language_at(suggestion_anchor); let file = snapshot.file_at(suggestion_anchor).cloned(); self.editor_enabled = Some( all_language_settings(self.file.as_ref(), cx) .copilot_enabled(language, file.as_ref().map(|file| file.path().as_ref())), ); self.language = language.cloned(); self.file = file; cx.notify() } } impl StatusItemView for CopilotButton { fn set_active_pane_item(&mut self, item: Option<&dyn ItemHandle>, cx: &mut ViewContext) { if let Some(editor) = item.map(|item| item.act_as::(cx)).flatten() { self.editor_subscription = Some(( cx.observe(&editor, Self::update_enabled), editor.entity_id().as_u64() as usize, )); self.update_enabled(editor, cx); } else { self.language = None; self.editor_subscription = None; self.editor_enabled = None; } cx.notify(); } } async fn configure_disabled_globs( workspace: WeakView, path_to_disable: Option>, mut cx: AsyncWindowContext, ) -> Result<()> { let settings_editor = workspace .update(&mut cx, |_, cx| { create_and_open_local_file(&paths::SETTINGS, cx, || { settings::initial_user_settings_content().as_ref().into() }) })? .await? .downcast::() .unwrap(); settings_editor.downgrade().update(&mut cx, |item, cx| { let text = item.buffer().read(cx).snapshot(cx).text(); let settings = cx.global::(); let edits = settings.edits_for_update::(&text, |file| { let copilot = file.copilot.get_or_insert_with(Default::default); let globs = copilot.disabled_globs.get_or_insert_with(|| { settings .get::(None) .copilot .disabled_globs .iter() .map(|glob| glob.glob().to_string()) .collect() }); if let Some(path_to_disable) = &path_to_disable { globs.push(path_to_disable.to_string_lossy().into_owned()); } else { globs.clear(); } }); if !edits.is_empty() { item.change_selections(Some(Autoscroll::newest()), cx, |selections| { selections.select_ranges(edits.iter().map(|e| e.0.clone())); }); // When *enabling* a path, don't actually perform an edit, just select the range. if path_to_disable.is_some() { item.edit(edits.iter().cloned(), cx); } } })?; anyhow::Ok(()) } fn toggle_copilot_globally(fs: Arc, cx: &mut AppContext) { let show_copilot_suggestions = all_language_settings(None, cx).copilot_enabled(None, None); update_settings_file::(fs, cx, move |file| { file.defaults.show_copilot_suggestions = Some((!show_copilot_suggestions).into()) }); } fn toggle_copilot_for_language(language: Arc, fs: Arc, cx: &mut AppContext) { let show_copilot_suggestions = all_language_settings(None, cx).copilot_enabled(Some(&language), None); update_settings_file::(fs, cx, move |file| { file.languages .entry(language.name()) .or_default() .show_copilot_suggestions = Some(!show_copilot_suggestions); }); } fn hide_copilot(fs: Arc, cx: &mut AppContext) { update_settings_file::(fs, cx, move |file| { file.features.get_or_insert(Default::default()).copilot = Some(false); }); } fn initiate_sign_in(cx: &mut WindowContext) { let Some(copilot) = Copilot::global(cx) else { return; }; let status = copilot.read(cx).status(); let Some(workspace) = cx.window_handle().downcast::() else { return; }; match status { Status::Starting { task } => { let Some(workspace) = cx.window_handle().downcast::() else { return; }; let Ok(workspace) = workspace.update(cx, |workspace, cx| { workspace.show_toast( Toast::new(COPILOT_STARTING_TOAST_ID, "Copilot is starting..."), cx, ); workspace.weak_handle() }) else { return; }; cx.spawn(|mut cx| async move { task.await; if let Some(copilot) = cx.update(|_, cx| Copilot::global(cx)).ok().flatten() { workspace .update(&mut cx, |workspace, cx| match copilot.read(cx).status() { Status::Authorized => workspace.show_toast( Toast::new(COPILOT_STARTING_TOAST_ID, "Copilot has started!"), cx, ), _ => { workspace.dismiss_toast(COPILOT_STARTING_TOAST_ID, cx); copilot .update(cx, |copilot, cx| copilot.sign_in(cx)) .detach_and_log_err(cx); } }) .log_err(); } }) .detach(); } _ => { copilot.update(cx, |this, cx| this.sign_in(cx)).detach(); workspace .update(cx, |this, cx| { this.toggle_modal(cx, |cx| CopilotCodeVerification::new(&copilot, cx)); }) .ok(); } } }