1use crate::{
2 assistant_settings::{AssistantDockPosition, AssistantSettings, ZedDotDevModel},
3 codegen::{self, Codegen, CodegenKind},
4 embedded_scope::EmbeddedScope,
5 prompts::generate_content_prompt,
6 Assist, CompletionProvider, CycleMessageRole, InlineAssist, LanguageModel,
7 LanguageModelRequest, LanguageModelRequestMessage, MessageId, MessageMetadata, MessageStatus,
8 NewConversation, QuoteSelection, ResetKey, Role, SavedConversation, SavedConversationMetadata,
9 SavedMessage, Split, ToggleFocus, ToggleIncludeConversation,
10};
11use anyhow::{anyhow, Result};
12use chrono::{DateTime, Local};
13use collections::{hash_map, HashMap, HashSet, VecDeque};
14use editor::{
15 actions::{MoveDown, MoveUp},
16 display_map::{
17 BlockContext, BlockDisposition, BlockId, BlockProperties, BlockStyle, ToDisplayPoint,
18 },
19 scroll::{Autoscroll, AutoscrollStrategy},
20 Anchor, Editor, EditorElement, EditorEvent, EditorStyle, MultiBuffer, MultiBufferSnapshot,
21 ToOffset as _, ToPoint,
22};
23use file_icons::FileIcons;
24use fs::Fs;
25use futures::StreamExt;
26use gpui::{
27 canvas, div, point, relative, rems, uniform_list, Action, AnyElement, AnyView, AppContext,
28 AsyncAppContext, AsyncWindowContext, AvailableSpace, ClipboardItem, Context, EventEmitter,
29 FocusHandle, FocusableView, FontStyle, FontWeight, HighlightStyle, InteractiveElement,
30 IntoElement, Model, ModelContext, ParentElement, Pixels, Render, SharedString,
31 StatefulInteractiveElement, Styled, Subscription, Task, TextStyle, UniformListScrollHandle,
32 View, ViewContext, VisualContext, WeakModel, WeakView, WhiteSpace, WindowContext,
33};
34use language::{language_settings::SoftWrap, Buffer, BufferId, LanguageRegistry, ToOffset as _};
35use parking_lot::Mutex;
36use project::Project;
37use search::{buffer_search::DivRegistrar, BufferSearchBar};
38use settings::Settings;
39use std::{cmp, fmt::Write, iter, ops::Range, path::PathBuf, sync::Arc, time::Duration};
40use telemetry_events::AssistantKind;
41use theme::ThemeSettings;
42use ui::{
43 prelude::*,
44 utils::{DateTimeType, FormatDistance},
45 ButtonLike, Tab, TabBar, Tooltip,
46};
47use util::{paths::CONVERSATIONS_DIR, post_inc, ResultExt, TryFutureExt};
48use uuid::Uuid;
49use workspace::{
50 dock::{DockPosition, Panel, PanelEvent},
51 searchable::Direction,
52 Event as WorkspaceEvent, Save, Toast, ToggleZoom, Toolbar, Workspace,
53};
54
55pub fn init(cx: &mut AppContext) {
56 cx.observe_new_views(
57 |workspace: &mut Workspace, _cx: &mut ViewContext<Workspace>| {
58 workspace
59 .register_action(|workspace, _: &ToggleFocus, cx| {
60 let settings = AssistantSettings::get_global(cx);
61 if !settings.enabled {
62 return;
63 }
64
65 workspace.toggle_panel_focus::<AssistantPanel>(cx);
66 })
67 .register_action(AssistantPanel::inline_assist)
68 .register_action(AssistantPanel::cancel_last_inline_assist)
69 .register_action(ConversationEditor::quote_selection);
70 },
71 )
72 .detach();
73}
74
75pub struct AssistantPanel {
76 workspace: WeakView<Workspace>,
77 width: Option<Pixels>,
78 height: Option<Pixels>,
79 active_conversation_editor: Option<ActiveConversationEditor>,
80 show_saved_conversations: bool,
81 saved_conversations: Vec<SavedConversationMetadata>,
82 saved_conversations_scroll_handle: UniformListScrollHandle,
83 zoomed: bool,
84 focus_handle: FocusHandle,
85 toolbar: View<Toolbar>,
86 languages: Arc<LanguageRegistry>,
87 fs: Arc<dyn Fs>,
88 _subscriptions: Vec<Subscription>,
89 next_inline_assist_id: usize,
90 pending_inline_assists: HashMap<usize, PendingInlineAssist>,
91 pending_inline_assist_ids_by_editor: HashMap<WeakView<Editor>, Vec<usize>>,
92 include_conversation_in_next_inline_assist: bool,
93 inline_prompt_history: VecDeque<String>,
94 _watch_saved_conversations: Task<Result<()>>,
95 model: LanguageModel,
96 authentication_prompt: Option<AnyView>,
97}
98
99struct ActiveConversationEditor {
100 editor: View<ConversationEditor>,
101 _subscriptions: Vec<Subscription>,
102}
103
104impl AssistantPanel {
105 const INLINE_PROMPT_HISTORY_MAX_LEN: usize = 20;
106
107 pub fn load(
108 workspace: WeakView<Workspace>,
109 cx: AsyncWindowContext,
110 ) -> Task<Result<View<Self>>> {
111 cx.spawn(|mut cx| async move {
112 let fs = workspace.update(&mut cx, |workspace, _| workspace.app_state().fs.clone())?;
113 let saved_conversations = SavedConversationMetadata::list(fs.clone())
114 .await
115 .log_err()
116 .unwrap_or_default();
117
118 // TODO: deserialize state.
119 let workspace_handle = workspace.clone();
120 workspace.update(&mut cx, |workspace, cx| {
121 cx.new_view::<Self>(|cx| {
122 const CONVERSATION_WATCH_DURATION: Duration = Duration::from_millis(100);
123 let _watch_saved_conversations = cx.spawn(move |this, mut cx| async move {
124 let mut events = fs
125 .watch(&CONVERSATIONS_DIR, CONVERSATION_WATCH_DURATION)
126 .await;
127 while events.next().await.is_some() {
128 let saved_conversations = SavedConversationMetadata::list(fs.clone())
129 .await
130 .log_err()
131 .unwrap_or_default();
132 this.update(&mut cx, |this, cx| {
133 this.saved_conversations = saved_conversations;
134 cx.notify();
135 })
136 .ok();
137 }
138
139 anyhow::Ok(())
140 });
141
142 let toolbar = cx.new_view(|cx| {
143 let mut toolbar = Toolbar::new();
144 toolbar.set_can_navigate(false, cx);
145 toolbar.add_item(cx.new_view(BufferSearchBar::new), cx);
146 toolbar
147 });
148
149 let focus_handle = cx.focus_handle();
150 let subscriptions = vec![
151 cx.on_focus_in(&focus_handle, Self::focus_in),
152 cx.on_focus_out(&focus_handle, Self::focus_out),
153 cx.observe_global::<CompletionProvider>({
154 let mut prev_settings_version =
155 CompletionProvider::global(cx).settings_version();
156 move |this, cx| {
157 this.completion_provider_changed(prev_settings_version, cx);
158 prev_settings_version =
159 CompletionProvider::global(cx).settings_version();
160 }
161 }),
162 ];
163 let model = CompletionProvider::global(cx).default_model();
164
165 cx.observe_global::<FileIcons>(|_, cx| {
166 cx.notify();
167 })
168 .detach();
169
170 Self {
171 workspace: workspace_handle,
172 active_conversation_editor: None,
173 show_saved_conversations: false,
174 saved_conversations,
175 saved_conversations_scroll_handle: Default::default(),
176 zoomed: false,
177 focus_handle,
178 toolbar,
179 languages: workspace.app_state().languages.clone(),
180 fs: workspace.app_state().fs.clone(),
181 width: None,
182 height: None,
183 _subscriptions: subscriptions,
184 next_inline_assist_id: 0,
185 pending_inline_assists: Default::default(),
186 pending_inline_assist_ids_by_editor: Default::default(),
187 include_conversation_in_next_inline_assist: false,
188 inline_prompt_history: Default::default(),
189 _watch_saved_conversations,
190 model,
191 authentication_prompt: None,
192 }
193 })
194 })
195 })
196 }
197
198 fn focus_in(&mut self, cx: &mut ViewContext<Self>) {
199 self.toolbar
200 .update(cx, |toolbar, cx| toolbar.focus_changed(true, cx));
201 cx.notify();
202 if self.focus_handle.is_focused(cx) {
203 if let Some(editor) = self.active_conversation_editor() {
204 cx.focus_view(editor);
205 }
206 }
207 }
208
209 fn focus_out(&mut self, cx: &mut ViewContext<Self>) {
210 self.toolbar
211 .update(cx, |toolbar, cx| toolbar.focus_changed(false, cx));
212 cx.notify();
213 }
214
215 fn completion_provider_changed(
216 &mut self,
217 prev_settings_version: usize,
218 cx: &mut ViewContext<Self>,
219 ) {
220 if self.is_authenticated(cx) {
221 self.authentication_prompt = None;
222
223 let model = CompletionProvider::global(cx).default_model();
224 self.set_model(model, cx);
225
226 if self.active_conversation_editor().is_none() {
227 self.new_conversation(cx);
228 }
229 } else if self.authentication_prompt.is_none()
230 || prev_settings_version != CompletionProvider::global(cx).settings_version()
231 {
232 self.authentication_prompt =
233 Some(cx.update_global::<CompletionProvider, _>(|provider, cx| {
234 provider.authentication_prompt(cx)
235 }));
236 }
237 }
238
239 pub fn inline_assist(
240 workspace: &mut Workspace,
241 _: &InlineAssist,
242 cx: &mut ViewContext<Workspace>,
243 ) {
244 let settings = AssistantSettings::get_global(cx);
245 if !settings.enabled {
246 return;
247 }
248
249 let Some(assistant) = workspace.panel::<AssistantPanel>(cx) else {
250 return;
251 };
252 let active_editor = if let Some(active_editor) = workspace
253 .active_item(cx)
254 .and_then(|item| item.act_as::<Editor>(cx))
255 {
256 active_editor
257 } else {
258 return;
259 };
260 let project = workspace.project().clone();
261
262 if assistant.update(cx, |assistant, cx| assistant.is_authenticated(cx)) {
263 assistant.update(cx, |assistant, cx| {
264 assistant.new_inline_assist(&active_editor, cx, &project)
265 });
266 } else {
267 let assistant = assistant.downgrade();
268 cx.spawn(|workspace, mut cx| async move {
269 assistant
270 .update(&mut cx, |assistant, cx| assistant.authenticate(cx))?
271 .await?;
272 if assistant.update(&mut cx, |assistant, cx| assistant.is_authenticated(cx))? {
273 assistant.update(&mut cx, |assistant, cx| {
274 assistant.new_inline_assist(&active_editor, cx, &project)
275 })?;
276 } else {
277 workspace.update(&mut cx, |workspace, cx| {
278 workspace.focus_panel::<AssistantPanel>(cx)
279 })?;
280 }
281
282 anyhow::Ok(())
283 })
284 .detach_and_log_err(cx)
285 }
286 }
287
288 fn new_inline_assist(
289 &mut self,
290 editor: &View<Editor>,
291 cx: &mut ViewContext<Self>,
292 project: &Model<Project>,
293 ) {
294 let selection = editor.read(cx).selections.newest_anchor().clone();
295 if selection.start.excerpt_id != selection.end.excerpt_id {
296 return;
297 }
298 let snapshot = editor.read(cx).buffer().read(cx).snapshot(cx);
299
300 // Extend the selection to the start and the end of the line.
301 let mut point_selection = selection.map(|selection| selection.to_point(&snapshot));
302 if point_selection.end > point_selection.start {
303 point_selection.start.column = 0;
304 // If the selection ends at the start of the line, we don't want to include it.
305 if point_selection.end.column == 0 {
306 point_selection.end.row -= 1;
307 }
308 point_selection.end.column = snapshot.line_len(point_selection.end.row);
309 }
310
311 let codegen_kind = if point_selection.start == point_selection.end {
312 CodegenKind::Generate {
313 position: snapshot.anchor_after(point_selection.start),
314 }
315 } else {
316 CodegenKind::Transform {
317 range: snapshot.anchor_before(point_selection.start)
318 ..snapshot.anchor_after(point_selection.end),
319 }
320 };
321
322 let inline_assist_id = post_inc(&mut self.next_inline_assist_id);
323
324 let codegen =
325 cx.new_model(|cx| Codegen::new(editor.read(cx).buffer().clone(), codegen_kind, cx));
326
327 let measurements = Arc::new(Mutex::new(BlockMeasurements::default()));
328 let inline_assistant = cx.new_view(|cx| {
329 InlineAssistant::new(
330 inline_assist_id,
331 measurements.clone(),
332 self.include_conversation_in_next_inline_assist,
333 self.inline_prompt_history.clone(),
334 codegen.clone(),
335 self.workspace.clone(),
336 cx,
337 )
338 });
339 let block_id = editor.update(cx, |editor, cx| {
340 editor.change_selections(None, cx, |selections| {
341 selections.select_anchor_ranges([selection.head()..selection.head()])
342 });
343 editor.insert_blocks(
344 [BlockProperties {
345 style: BlockStyle::Flex,
346 position: snapshot.anchor_before(point_selection.head()),
347 height: 2,
348 render: Box::new({
349 let inline_assistant = inline_assistant.clone();
350 move |cx: &mut BlockContext| {
351 *measurements.lock() = BlockMeasurements {
352 anchor_x: cx.anchor_x,
353 gutter_width: cx.gutter_dimensions.width,
354 };
355 inline_assistant.clone().into_any_element()
356 }
357 }),
358 disposition: if selection.reversed {
359 BlockDisposition::Above
360 } else {
361 BlockDisposition::Below
362 },
363 }],
364 Some(Autoscroll::Strategy(AutoscrollStrategy::Newest)),
365 cx,
366 )[0]
367 });
368
369 self.pending_inline_assists.insert(
370 inline_assist_id,
371 PendingInlineAssist {
372 editor: editor.downgrade(),
373 inline_assistant: Some((block_id, inline_assistant.clone())),
374 codegen: codegen.clone(),
375 project: project.downgrade(),
376 _subscriptions: vec![
377 cx.subscribe(&inline_assistant, Self::handle_inline_assistant_event),
378 cx.subscribe(editor, {
379 let inline_assistant = inline_assistant.downgrade();
380 move |_, editor, event, cx| {
381 if let Some(inline_assistant) = inline_assistant.upgrade() {
382 if let EditorEvent::SelectionsChanged { local } = event {
383 if *local
384 && inline_assistant.focus_handle(cx).contains_focused(cx)
385 {
386 cx.focus_view(&editor);
387 }
388 }
389 }
390 }
391 }),
392 cx.observe(&codegen, {
393 let editor = editor.downgrade();
394 move |this, _, cx| {
395 if let Some(editor) = editor.upgrade() {
396 this.update_highlights_for_editor(&editor, cx);
397 }
398 }
399 }),
400 cx.subscribe(&codegen, move |this, codegen, event, cx| match event {
401 codegen::Event::Undone => {
402 this.finish_inline_assist(inline_assist_id, false, cx)
403 }
404 codegen::Event::Finished => {
405 let pending_assist = if let Some(pending_assist) =
406 this.pending_inline_assists.get(&inline_assist_id)
407 {
408 pending_assist
409 } else {
410 return;
411 };
412
413 let error = codegen
414 .read(cx)
415 .error()
416 .map(|error| format!("Inline assistant error: {}", error));
417 if let Some(error) = error {
418 if pending_assist.inline_assistant.is_none() {
419 if let Some(workspace) = this.workspace.upgrade() {
420 workspace.update(cx, |workspace, cx| {
421 workspace.show_toast(
422 Toast::new(inline_assist_id, error),
423 cx,
424 );
425 })
426 }
427
428 this.finish_inline_assist(inline_assist_id, false, cx);
429 }
430 } else {
431 this.finish_inline_assist(inline_assist_id, false, cx);
432 }
433 }
434 }),
435 ],
436 },
437 );
438 self.pending_inline_assist_ids_by_editor
439 .entry(editor.downgrade())
440 .or_default()
441 .push(inline_assist_id);
442 self.update_highlights_for_editor(editor, cx);
443 }
444
445 fn handle_inline_assistant_event(
446 &mut self,
447 inline_assistant: View<InlineAssistant>,
448 event: &InlineAssistantEvent,
449 cx: &mut ViewContext<Self>,
450 ) {
451 let assist_id = inline_assistant.read(cx).id;
452 match event {
453 InlineAssistantEvent::Confirmed {
454 prompt,
455 include_conversation,
456 } => {
457 self.confirm_inline_assist(assist_id, prompt, *include_conversation, cx);
458 }
459 InlineAssistantEvent::Canceled => {
460 self.finish_inline_assist(assist_id, true, cx);
461 }
462 InlineAssistantEvent::Dismissed => {
463 self.hide_inline_assist(assist_id, cx);
464 }
465 InlineAssistantEvent::IncludeConversationToggled {
466 include_conversation,
467 } => {
468 self.include_conversation_in_next_inline_assist = *include_conversation;
469 }
470 }
471 }
472
473 fn cancel_last_inline_assist(
474 workspace: &mut Workspace,
475 _: &editor::actions::Cancel,
476 cx: &mut ViewContext<Workspace>,
477 ) {
478 if let Some(panel) = workspace.panel::<AssistantPanel>(cx) {
479 if let Some(editor) = workspace
480 .active_item(cx)
481 .and_then(|item| item.downcast::<Editor>())
482 {
483 let handled = panel.update(cx, |panel, cx| {
484 if let Some(assist_id) = panel
485 .pending_inline_assist_ids_by_editor
486 .get(&editor.downgrade())
487 .and_then(|assist_ids| assist_ids.last().copied())
488 {
489 panel.finish_inline_assist(assist_id, true, cx);
490 true
491 } else {
492 false
493 }
494 });
495 if handled {
496 return;
497 }
498 }
499 }
500
501 cx.propagate();
502 }
503
504 fn finish_inline_assist(&mut self, assist_id: usize, undo: bool, cx: &mut ViewContext<Self>) {
505 self.hide_inline_assist(assist_id, cx);
506
507 if let Some(pending_assist) = self.pending_inline_assists.remove(&assist_id) {
508 if let hash_map::Entry::Occupied(mut entry) = self
509 .pending_inline_assist_ids_by_editor
510 .entry(pending_assist.editor.clone())
511 {
512 entry.get_mut().retain(|id| *id != assist_id);
513 if entry.get().is_empty() {
514 entry.remove();
515 }
516 }
517
518 if let Some(editor) = pending_assist.editor.upgrade() {
519 self.update_highlights_for_editor(&editor, cx);
520
521 if undo {
522 pending_assist
523 .codegen
524 .update(cx, |codegen, cx| codegen.undo(cx));
525 }
526 }
527 }
528 }
529
530 fn hide_inline_assist(&mut self, assist_id: usize, cx: &mut ViewContext<Self>) {
531 if let Some(pending_assist) = self.pending_inline_assists.get_mut(&assist_id) {
532 if let Some(editor) = pending_assist.editor.upgrade() {
533 if let Some((block_id, inline_assistant)) = pending_assist.inline_assistant.take() {
534 editor.update(cx, |editor, cx| {
535 editor.remove_blocks(HashSet::from_iter([block_id]), None, cx);
536 if inline_assistant.focus_handle(cx).contains_focused(cx) {
537 editor.focus(cx);
538 }
539 });
540 }
541 }
542 }
543 }
544
545 fn confirm_inline_assist(
546 &mut self,
547 inline_assist_id: usize,
548 user_prompt: &str,
549 include_conversation: bool,
550 cx: &mut ViewContext<Self>,
551 ) {
552 let conversation = if include_conversation {
553 self.active_conversation_editor()
554 .map(|editor| editor.read(cx).conversation.clone())
555 } else {
556 None
557 };
558
559 let pending_assist =
560 if let Some(pending_assist) = self.pending_inline_assists.get_mut(&inline_assist_id) {
561 pending_assist
562 } else {
563 return;
564 };
565
566 let editor = if let Some(editor) = pending_assist.editor.upgrade() {
567 editor
568 } else {
569 return;
570 };
571
572 let project = pending_assist.project.clone();
573
574 let project_name = project.upgrade().map(|project| {
575 project
576 .read(cx)
577 .worktree_root_names(cx)
578 .collect::<Vec<&str>>()
579 .join("/")
580 });
581
582 self.inline_prompt_history
583 .retain(|prompt| prompt != user_prompt);
584 self.inline_prompt_history.push_back(user_prompt.into());
585 if self.inline_prompt_history.len() > Self::INLINE_PROMPT_HISTORY_MAX_LEN {
586 self.inline_prompt_history.pop_front();
587 }
588
589 let codegen = pending_assist.codegen.clone();
590 let snapshot = editor.read(cx).buffer().read(cx).snapshot(cx);
591 let range = codegen.read(cx).range();
592 let start = snapshot.point_to_buffer_offset(range.start);
593 let end = snapshot.point_to_buffer_offset(range.end);
594 let (buffer, range) = if let Some((start, end)) = start.zip(end) {
595 let (start_buffer, start_buffer_offset) = start;
596 let (end_buffer, end_buffer_offset) = end;
597 if start_buffer.remote_id() == end_buffer.remote_id() {
598 (start_buffer.clone(), start_buffer_offset..end_buffer_offset)
599 } else {
600 self.finish_inline_assist(inline_assist_id, false, cx);
601 return;
602 }
603 } else {
604 self.finish_inline_assist(inline_assist_id, false, cx);
605 return;
606 };
607
608 let language = buffer.language_at(range.start);
609 let language_name = if let Some(language) = language.as_ref() {
610 if Arc::ptr_eq(language, &language::PLAIN_TEXT) {
611 None
612 } else {
613 Some(language.name())
614 }
615 } else {
616 None
617 };
618
619 // Higher Temperature increases the randomness of model outputs.
620 // If Markdown or No Language is Known, increase the randomness for more creative output
621 // If Code, decrease temperature to get more deterministic outputs
622 let temperature = if let Some(language) = language_name.clone() {
623 if language.as_ref() != "Markdown" {
624 0.5
625 } else {
626 1.0
627 }
628 } else {
629 1.0
630 };
631
632 let user_prompt = user_prompt.to_string();
633
634 let prompt = cx.background_executor().spawn(async move {
635 let language_name = language_name.as_deref();
636 generate_content_prompt(user_prompt, language_name, buffer, range, project_name)
637 });
638
639 let mut messages = Vec::new();
640 if let Some(conversation) = conversation {
641 let conversation = conversation.read(cx);
642 let buffer = conversation.buffer.read(cx);
643 messages.extend(
644 conversation
645 .messages(cx)
646 .map(|message| message.to_open_ai_message(buffer)),
647 );
648 }
649 let model = self.model.clone();
650
651 cx.spawn(|_, mut cx| async move {
652 // I Don't know if we want to return a ? here.
653 let prompt = prompt.await?;
654
655 messages.push(LanguageModelRequestMessage {
656 role: Role::User,
657 content: prompt,
658 });
659
660 let request = LanguageModelRequest {
661 model,
662 messages,
663 stop: vec!["|END|>".to_string()],
664 temperature,
665 };
666
667 codegen.update(&mut cx, |codegen, cx| codegen.start(request, cx))?;
668 anyhow::Ok(())
669 })
670 .detach();
671 }
672
673 fn update_highlights_for_editor(&self, editor: &View<Editor>, cx: &mut ViewContext<Self>) {
674 let mut background_ranges = Vec::new();
675 let mut foreground_ranges = Vec::new();
676 let empty_inline_assist_ids = Vec::new();
677 let inline_assist_ids = self
678 .pending_inline_assist_ids_by_editor
679 .get(&editor.downgrade())
680 .unwrap_or(&empty_inline_assist_ids);
681
682 for inline_assist_id in inline_assist_ids {
683 if let Some(pending_assist) = self.pending_inline_assists.get(inline_assist_id) {
684 let codegen = pending_assist.codegen.read(cx);
685 background_ranges.push(codegen.range());
686 foreground_ranges.extend(codegen.last_equal_ranges().iter().cloned());
687 }
688 }
689
690 let snapshot = editor.read(cx).buffer().read(cx).snapshot(cx);
691 merge_ranges(&mut background_ranges, &snapshot);
692 merge_ranges(&mut foreground_ranges, &snapshot);
693 editor.update(cx, |editor, cx| {
694 if background_ranges.is_empty() {
695 editor.clear_background_highlights::<PendingInlineAssist>(cx);
696 } else {
697 editor.highlight_background::<PendingInlineAssist>(
698 &background_ranges,
699 |theme| theme.editor_active_line_background, // todo!("use the appropriate color")
700 cx,
701 );
702 }
703
704 if foreground_ranges.is_empty() {
705 editor.clear_highlights::<PendingInlineAssist>(cx);
706 } else {
707 editor.highlight_text::<PendingInlineAssist>(
708 foreground_ranges,
709 HighlightStyle {
710 fade_out: Some(0.6),
711 ..Default::default()
712 },
713 cx,
714 );
715 }
716 });
717 }
718
719 fn new_conversation(&mut self, cx: &mut ViewContext<Self>) -> Option<View<ConversationEditor>> {
720 let workspace = self.workspace.upgrade()?;
721
722 let editor = cx.new_view(|cx| {
723 ConversationEditor::new(
724 self.model.clone(),
725 self.languages.clone(),
726 self.fs.clone(),
727 workspace,
728 cx,
729 )
730 });
731 self.show_conversation(editor.clone(), cx);
732 Some(editor)
733 }
734
735 fn show_conversation(
736 &mut self,
737 conversation_editor: View<ConversationEditor>,
738 cx: &mut ViewContext<Self>,
739 ) {
740 let mut subscriptions = Vec::new();
741 subscriptions
742 .push(cx.subscribe(&conversation_editor, Self::handle_conversation_editor_event));
743
744 let conversation = conversation_editor.read(cx).conversation.clone();
745 subscriptions.push(cx.observe(&conversation, |_, _, cx| cx.notify()));
746
747 let editor = conversation_editor.read(cx).editor.clone();
748 self.toolbar.update(cx, |toolbar, cx| {
749 toolbar.set_active_item(Some(&editor), cx);
750 });
751 if self.focus_handle.contains_focused(cx) {
752 cx.focus_view(&editor);
753 }
754 self.active_conversation_editor = Some(ActiveConversationEditor {
755 editor: conversation_editor,
756 _subscriptions: subscriptions,
757 });
758 self.show_saved_conversations = false;
759
760 cx.notify();
761 }
762
763 fn cycle_model(&mut self, cx: &mut ViewContext<Self>) {
764 let next_model = match &self.model {
765 LanguageModel::OpenAi(model) => LanguageModel::OpenAi(match &model {
766 open_ai::Model::ThreePointFiveTurbo => open_ai::Model::Four,
767 open_ai::Model::Four => open_ai::Model::FourTurbo,
768 open_ai::Model::FourTurbo => open_ai::Model::ThreePointFiveTurbo,
769 }),
770 LanguageModel::ZedDotDev(model) => LanguageModel::ZedDotDev(match &model {
771 ZedDotDevModel::Gpt3Point5Turbo => ZedDotDevModel::Gpt4,
772 ZedDotDevModel::Gpt4 => ZedDotDevModel::Gpt4Turbo,
773 ZedDotDevModel::Gpt4Turbo => ZedDotDevModel::Claude3Opus,
774 ZedDotDevModel::Claude3Opus => ZedDotDevModel::Claude3Sonnet,
775 ZedDotDevModel::Claude3Sonnet => ZedDotDevModel::Claude3Haiku,
776 ZedDotDevModel::Claude3Haiku => {
777 match CompletionProvider::global(cx).default_model() {
778 LanguageModel::ZedDotDev(custom) => custom,
779 _ => ZedDotDevModel::Gpt3Point5Turbo,
780 }
781 }
782 ZedDotDevModel::Custom(_) => ZedDotDevModel::Gpt3Point5Turbo,
783 }),
784 };
785
786 self.set_model(next_model, cx);
787 }
788
789 fn set_model(&mut self, model: LanguageModel, cx: &mut ViewContext<Self>) {
790 self.model = model.clone();
791 if let Some(editor) = self.active_conversation_editor() {
792 editor.update(cx, |active_conversation, cx| {
793 active_conversation
794 .conversation
795 .update(cx, |conversation, cx| {
796 conversation.set_model(model, cx);
797 })
798 })
799 }
800 cx.notify();
801 }
802
803 fn handle_conversation_editor_event(
804 &mut self,
805 _: View<ConversationEditor>,
806 event: &ConversationEditorEvent,
807 cx: &mut ViewContext<Self>,
808 ) {
809 match event {
810 ConversationEditorEvent::TabContentChanged => cx.notify(),
811 }
812 }
813
814 fn toggle_zoom(&mut self, _: &workspace::ToggleZoom, cx: &mut ViewContext<Self>) {
815 if self.zoomed {
816 cx.emit(PanelEvent::ZoomOut)
817 } else {
818 cx.emit(PanelEvent::ZoomIn)
819 }
820 }
821
822 fn deploy(&mut self, action: &search::buffer_search::Deploy, cx: &mut ViewContext<Self>) {
823 let mut propagate = true;
824 if let Some(search_bar) = self.toolbar.read(cx).item_of_type::<BufferSearchBar>() {
825 search_bar.update(cx, |search_bar, cx| {
826 if search_bar.show(cx) {
827 search_bar.search_suggested(cx);
828 if action.focus {
829 let focus_handle = search_bar.focus_handle(cx);
830 search_bar.select_query(cx);
831 cx.focus(&focus_handle);
832 }
833 propagate = false
834 }
835 });
836 }
837 if propagate {
838 cx.propagate();
839 }
840 }
841
842 fn handle_editor_cancel(&mut self, _: &editor::actions::Cancel, cx: &mut ViewContext<Self>) {
843 if let Some(search_bar) = self.toolbar.read(cx).item_of_type::<BufferSearchBar>() {
844 if !search_bar.read(cx).is_dismissed() {
845 search_bar.update(cx, |search_bar, cx| {
846 search_bar.dismiss(&Default::default(), cx)
847 });
848 return;
849 }
850 }
851 cx.propagate();
852 }
853
854 fn select_next_match(&mut self, _: &search::SelectNextMatch, cx: &mut ViewContext<Self>) {
855 if let Some(search_bar) = self.toolbar.read(cx).item_of_type::<BufferSearchBar>() {
856 search_bar.update(cx, |bar, cx| bar.select_match(Direction::Next, 1, cx));
857 }
858 }
859
860 fn select_prev_match(&mut self, _: &search::SelectPrevMatch, cx: &mut ViewContext<Self>) {
861 if let Some(search_bar) = self.toolbar.read(cx).item_of_type::<BufferSearchBar>() {
862 search_bar.update(cx, |bar, cx| bar.select_match(Direction::Prev, 1, cx));
863 }
864 }
865
866 fn reset_credentials(&mut self, _: &ResetKey, cx: &mut ViewContext<Self>) {
867 CompletionProvider::global(cx)
868 .reset_credentials(cx)
869 .detach_and_log_err(cx);
870 }
871
872 fn active_conversation_editor(&self) -> Option<&View<ConversationEditor>> {
873 Some(&self.active_conversation_editor.as_ref()?.editor)
874 }
875
876 fn render_hamburger_button(cx: &mut ViewContext<Self>) -> impl IntoElement {
877 IconButton::new("hamburger_button", IconName::Menu)
878 .on_click(cx.listener(|this, _event, cx| {
879 this.show_saved_conversations = !this.show_saved_conversations;
880 cx.notify();
881 }))
882 .tooltip(|cx| Tooltip::text("Conversation History", cx))
883 }
884
885 fn render_editor_tools(&self, cx: &mut ViewContext<Self>) -> Vec<AnyElement> {
886 if self.active_conversation_editor().is_some() {
887 vec![
888 Self::render_split_button(cx).into_any_element(),
889 Self::render_quote_button(cx).into_any_element(),
890 Self::render_assist_button(cx).into_any_element(),
891 ]
892 } else {
893 Default::default()
894 }
895 }
896
897 fn render_split_button(cx: &mut ViewContext<Self>) -> impl IntoElement {
898 IconButton::new("split_button", IconName::Snip)
899 .on_click(cx.listener(|this, _event, cx| {
900 if let Some(active_editor) = this.active_conversation_editor() {
901 active_editor.update(cx, |editor, cx| editor.split(&Default::default(), cx));
902 }
903 }))
904 .icon_size(IconSize::Small)
905 .tooltip(|cx| Tooltip::for_action("Split Message", &Split, cx))
906 }
907
908 fn render_assist_button(cx: &mut ViewContext<Self>) -> impl IntoElement {
909 IconButton::new("assist_button", IconName::MagicWand)
910 .on_click(cx.listener(|this, _event, cx| {
911 if let Some(active_editor) = this.active_conversation_editor() {
912 active_editor.update(cx, |editor, cx| editor.assist(&Default::default(), cx));
913 }
914 }))
915 .icon_size(IconSize::Small)
916 .tooltip(|cx| Tooltip::for_action("Assist", &Assist, cx))
917 }
918
919 fn render_quote_button(cx: &mut ViewContext<Self>) -> impl IntoElement {
920 IconButton::new("quote_button", IconName::Quote)
921 .on_click(cx.listener(|this, _event, cx| {
922 if let Some(workspace) = this.workspace.upgrade() {
923 cx.window_context().defer(move |cx| {
924 workspace.update(cx, |workspace, cx| {
925 ConversationEditor::quote_selection(workspace, &Default::default(), cx)
926 });
927 });
928 }
929 }))
930 .icon_size(IconSize::Small)
931 .tooltip(|cx| Tooltip::for_action("Quote Selection", &QuoteSelection, cx))
932 }
933
934 fn render_plus_button(cx: &mut ViewContext<Self>) -> impl IntoElement {
935 IconButton::new("plus_button", IconName::Plus)
936 .on_click(cx.listener(|this, _event, cx| {
937 this.new_conversation(cx);
938 }))
939 .icon_size(IconSize::Small)
940 .tooltip(|cx| Tooltip::for_action("New Conversation", &NewConversation, cx))
941 }
942
943 fn render_zoom_button(&self, cx: &mut ViewContext<Self>) -> impl IntoElement {
944 let zoomed = self.zoomed;
945 IconButton::new("zoom_button", IconName::Maximize)
946 .on_click(cx.listener(|this, _event, cx| {
947 this.toggle_zoom(&ToggleZoom, cx);
948 }))
949 .selected(zoomed)
950 .selected_icon(IconName::Minimize)
951 .icon_size(IconSize::Small)
952 .tooltip(move |cx| {
953 Tooltip::for_action(if zoomed { "Zoom Out" } else { "Zoom In" }, &ToggleZoom, cx)
954 })
955 }
956
957 fn render_saved_conversation(
958 &mut self,
959 index: usize,
960 cx: &mut ViewContext<Self>,
961 ) -> impl IntoElement {
962 let conversation = &self.saved_conversations[index];
963 let path = conversation.path.clone();
964
965 ButtonLike::new(index)
966 .on_click(cx.listener(move |this, _, cx| {
967 this.open_conversation(path.clone(), cx)
968 .detach_and_log_err(cx)
969 }))
970 .full_width()
971 .child(
972 div()
973 .flex()
974 .w_full()
975 .gap_2()
976 .child(
977 Label::new(conversation.mtime.format("%F %I:%M%p").to_string())
978 .color(Color::Muted)
979 .size(LabelSize::Small),
980 )
981 .child(Label::new(conversation.title.clone()).size(LabelSize::Small)),
982 )
983 }
984
985 fn open_conversation(&mut self, path: PathBuf, cx: &mut ViewContext<Self>) -> Task<Result<()>> {
986 cx.focus(&self.focus_handle);
987
988 let fs = self.fs.clone();
989 let workspace = self.workspace.clone();
990 let languages = self.languages.clone();
991 cx.spawn(|this, mut cx| async move {
992 let saved_conversation = SavedConversation::load(&path, fs.as_ref()).await?;
993 let model = this.update(&mut cx, |this, _| this.model.clone())?;
994 let conversation = Conversation::deserialize(
995 saved_conversation,
996 model,
997 path.clone(),
998 languages,
999 &mut cx,
1000 )
1001 .await?;
1002
1003 this.update(&mut cx, |this, cx| {
1004 let workspace = workspace
1005 .upgrade()
1006 .ok_or_else(|| anyhow!("workspace dropped"))?;
1007 let editor = cx.new_view(|cx| {
1008 ConversationEditor::for_conversation(conversation, fs, workspace, cx)
1009 });
1010 this.show_conversation(editor, cx);
1011 anyhow::Ok(())
1012 })??;
1013 Ok(())
1014 })
1015 }
1016
1017 fn is_authenticated(&mut self, cx: &mut ViewContext<Self>) -> bool {
1018 CompletionProvider::global(cx).is_authenticated()
1019 }
1020
1021 fn authenticate(&mut self, cx: &mut ViewContext<Self>) -> Task<Result<()>> {
1022 cx.update_global::<CompletionProvider, _>(|provider, cx| provider.authenticate(cx))
1023 }
1024
1025 fn render_signed_in(&mut self, cx: &mut ViewContext<Self>) -> impl IntoElement {
1026 let header = TabBar::new("assistant_header")
1027 .start_child(
1028 h_flex().gap_1().child(Self::render_hamburger_button(cx)), // .children(title),
1029 )
1030 .children(self.active_conversation_editor().map(|editor| {
1031 h_flex()
1032 .h(rems(Tab::CONTAINER_HEIGHT_IN_REMS))
1033 .flex_1()
1034 .px_2()
1035 .child(Label::new(editor.read(cx).title(cx)).into_element())
1036 }))
1037 .when(self.focus_handle.contains_focused(cx), |this| {
1038 this.end_child(
1039 h_flex()
1040 .gap_2()
1041 .when(self.active_conversation_editor().is_some(), |this| {
1042 this.child(h_flex().gap_1().children(self.render_editor_tools(cx)))
1043 .child(
1044 ui::Divider::vertical()
1045 .inset()
1046 .color(ui::DividerColor::Border),
1047 )
1048 })
1049 .child(
1050 h_flex()
1051 .gap_1()
1052 .child(Self::render_plus_button(cx))
1053 .child(self.render_zoom_button(cx)),
1054 ),
1055 )
1056 });
1057
1058 let contents = if self.active_conversation_editor().is_some() {
1059 let mut registrar = DivRegistrar::new(
1060 |panel, cx| panel.toolbar.read(cx).item_of_type::<BufferSearchBar>(),
1061 cx,
1062 );
1063 BufferSearchBar::register(&mut registrar);
1064 registrar.into_div()
1065 } else {
1066 div()
1067 };
1068 v_flex()
1069 .key_context("AssistantPanel")
1070 .size_full()
1071 .on_action(cx.listener(|this, _: &workspace::NewFile, cx| {
1072 this.new_conversation(cx);
1073 }))
1074 .on_action(cx.listener(AssistantPanel::toggle_zoom))
1075 .on_action(cx.listener(AssistantPanel::deploy))
1076 .on_action(cx.listener(AssistantPanel::select_next_match))
1077 .on_action(cx.listener(AssistantPanel::select_prev_match))
1078 .on_action(cx.listener(AssistantPanel::handle_editor_cancel))
1079 .on_action(cx.listener(AssistantPanel::reset_credentials))
1080 .track_focus(&self.focus_handle)
1081 .child(header)
1082 .children(if self.toolbar.read(cx).hidden() {
1083 None
1084 } else {
1085 Some(self.toolbar.clone())
1086 })
1087 .child(contents.flex_1().child(
1088 if self.show_saved_conversations || self.active_conversation_editor().is_none() {
1089 let view = cx.view().clone();
1090 let scroll_handle = self.saved_conversations_scroll_handle.clone();
1091 let conversation_count = self.saved_conversations.len();
1092 canvas(
1093 move |bounds, cx| {
1094 let mut saved_conversations = uniform_list(
1095 view,
1096 "saved_conversations",
1097 conversation_count,
1098 |this, range, cx| {
1099 range
1100 .map(|ix| this.render_saved_conversation(ix, cx))
1101 .collect()
1102 },
1103 )
1104 .track_scroll(scroll_handle)
1105 .into_any_element();
1106 saved_conversations.layout(
1107 bounds.origin,
1108 bounds.size.map(AvailableSpace::Definite),
1109 cx,
1110 );
1111 saved_conversations
1112 },
1113 |_bounds, mut saved_conversations, cx| saved_conversations.paint(cx),
1114 )
1115 .size_full()
1116 .into_any_element()
1117 } else {
1118 let editor = self.active_conversation_editor().unwrap();
1119 let conversation = editor.read(cx).conversation.clone();
1120 div()
1121 .size_full()
1122 .child(editor.clone())
1123 .child(
1124 h_flex()
1125 .absolute()
1126 .gap_1()
1127 .top_3()
1128 .right_5()
1129 .child(self.render_model(&conversation, cx))
1130 .children(self.render_remaining_tokens(&conversation, cx)),
1131 )
1132 .into_any_element()
1133 },
1134 ))
1135 }
1136
1137 fn render_model(
1138 &self,
1139 conversation: &Model<Conversation>,
1140 cx: &mut ViewContext<Self>,
1141 ) -> impl IntoElement {
1142 Button::new("current_model", conversation.read(cx).model.display_name())
1143 .style(ButtonStyle::Filled)
1144 .tooltip(move |cx| Tooltip::text("Change Model", cx))
1145 .on_click(cx.listener(|this, _, cx| this.cycle_model(cx)))
1146 }
1147
1148 fn render_remaining_tokens(
1149 &self,
1150 conversation: &Model<Conversation>,
1151 cx: &mut ViewContext<Self>,
1152 ) -> Option<impl IntoElement> {
1153 let remaining_tokens = conversation.read(cx).remaining_tokens()?;
1154 let remaining_tokens_color = if remaining_tokens <= 0 {
1155 Color::Error
1156 } else if remaining_tokens <= 500 {
1157 Color::Warning
1158 } else {
1159 Color::Default
1160 };
1161 Some(Label::new(remaining_tokens.to_string()).color(remaining_tokens_color))
1162 }
1163}
1164
1165impl Render for AssistantPanel {
1166 fn render(&mut self, cx: &mut ViewContext<Self>) -> impl IntoElement {
1167 if let Some(authentication_prompt) = self.authentication_prompt.as_ref() {
1168 authentication_prompt.clone().into_any()
1169 } else {
1170 self.render_signed_in(cx).into_any_element()
1171 }
1172 }
1173}
1174
1175impl Panel for AssistantPanel {
1176 fn persistent_name() -> &'static str {
1177 "AssistantPanel"
1178 }
1179
1180 fn position(&self, cx: &WindowContext) -> DockPosition {
1181 match AssistantSettings::get_global(cx).dock {
1182 AssistantDockPosition::Left => DockPosition::Left,
1183 AssistantDockPosition::Bottom => DockPosition::Bottom,
1184 AssistantDockPosition::Right => DockPosition::Right,
1185 }
1186 }
1187
1188 fn position_is_valid(&self, _: DockPosition) -> bool {
1189 true
1190 }
1191
1192 fn set_position(&mut self, position: DockPosition, cx: &mut ViewContext<Self>) {
1193 settings::update_settings_file::<AssistantSettings>(self.fs.clone(), cx, move |settings| {
1194 let dock = match position {
1195 DockPosition::Left => AssistantDockPosition::Left,
1196 DockPosition::Bottom => AssistantDockPosition::Bottom,
1197 DockPosition::Right => AssistantDockPosition::Right,
1198 };
1199 settings.set_dock(dock);
1200 });
1201 }
1202
1203 fn size(&self, cx: &WindowContext) -> Pixels {
1204 let settings = AssistantSettings::get_global(cx);
1205 match self.position(cx) {
1206 DockPosition::Left | DockPosition::Right => {
1207 self.width.unwrap_or(settings.default_width)
1208 }
1209 DockPosition::Bottom => self.height.unwrap_or(settings.default_height),
1210 }
1211 }
1212
1213 fn set_size(&mut self, size: Option<Pixels>, cx: &mut ViewContext<Self>) {
1214 match self.position(cx) {
1215 DockPosition::Left | DockPosition::Right => self.width = size,
1216 DockPosition::Bottom => self.height = size,
1217 }
1218 cx.notify();
1219 }
1220
1221 fn is_zoomed(&self, _: &WindowContext) -> bool {
1222 self.zoomed
1223 }
1224
1225 fn set_zoomed(&mut self, zoomed: bool, cx: &mut ViewContext<Self>) {
1226 self.zoomed = zoomed;
1227 cx.notify();
1228 }
1229
1230 fn set_active(&mut self, active: bool, cx: &mut ViewContext<Self>) {
1231 if active {
1232 let load_credentials = self.authenticate(cx);
1233 cx.spawn(|this, mut cx| async move {
1234 load_credentials.await?;
1235 this.update(&mut cx, |this, cx| {
1236 if this.is_authenticated(cx) && this.active_conversation_editor().is_none() {
1237 this.new_conversation(cx);
1238 }
1239 })
1240 })
1241 .detach_and_log_err(cx);
1242 }
1243 }
1244
1245 fn icon(&self, cx: &WindowContext) -> Option<IconName> {
1246 let settings = AssistantSettings::get_global(cx);
1247 if !settings.enabled || !settings.button {
1248 return None;
1249 }
1250
1251 Some(IconName::Ai)
1252 }
1253
1254 fn icon_tooltip(&self, _cx: &WindowContext) -> Option<&'static str> {
1255 Some("Assistant Panel")
1256 }
1257
1258 fn toggle_action(&self) -> Box<dyn Action> {
1259 Box::new(ToggleFocus)
1260 }
1261}
1262
1263impl EventEmitter<PanelEvent> for AssistantPanel {}
1264
1265impl FocusableView for AssistantPanel {
1266 fn focus_handle(&self, _cx: &AppContext) -> FocusHandle {
1267 self.focus_handle.clone()
1268 }
1269}
1270
1271enum ConversationEvent {
1272 MessagesEdited,
1273 SummaryChanged,
1274 StreamedCompletion,
1275}
1276
1277#[derive(Default)]
1278struct Summary {
1279 text: String,
1280 done: bool,
1281}
1282
1283pub struct Conversation {
1284 id: Option<String>,
1285 buffer: Model<Buffer>,
1286 embedded_scope: EmbeddedScope,
1287 message_anchors: Vec<MessageAnchor>,
1288 messages_metadata: HashMap<MessageId, MessageMetadata>,
1289 next_message_id: MessageId,
1290 summary: Option<Summary>,
1291 pending_summary: Task<Option<()>>,
1292 completion_count: usize,
1293 pending_completions: Vec<PendingCompletion>,
1294 model: LanguageModel,
1295 token_count: Option<usize>,
1296 pending_token_count: Task<Option<()>>,
1297 pending_save: Task<Result<()>>,
1298 path: Option<PathBuf>,
1299 _subscriptions: Vec<Subscription>,
1300}
1301
1302impl EventEmitter<ConversationEvent> for Conversation {}
1303
1304impl Conversation {
1305 fn new(
1306 model: LanguageModel,
1307 language_registry: Arc<LanguageRegistry>,
1308 embedded_scope: EmbeddedScope,
1309 cx: &mut ModelContext<Self>,
1310 ) -> Self {
1311 let markdown = language_registry.language_for_name("Markdown");
1312 let buffer = cx.new_model(|cx| {
1313 let mut buffer = Buffer::new(0, BufferId::new(cx.entity_id().as_u64()).unwrap(), "");
1314 buffer.set_language_registry(language_registry);
1315 cx.spawn(|buffer, mut cx| async move {
1316 let markdown = markdown.await?;
1317 buffer.update(&mut cx, |buffer: &mut Buffer, cx| {
1318 buffer.set_language(Some(markdown), cx)
1319 })?;
1320 anyhow::Ok(())
1321 })
1322 .detach_and_log_err(cx);
1323 buffer
1324 });
1325
1326 let mut this = Self {
1327 id: Some(Uuid::new_v4().to_string()),
1328 message_anchors: Default::default(),
1329 messages_metadata: Default::default(),
1330 next_message_id: Default::default(),
1331 summary: None,
1332 pending_summary: Task::ready(None),
1333 completion_count: Default::default(),
1334 pending_completions: Default::default(),
1335 token_count: None,
1336 pending_token_count: Task::ready(None),
1337 model,
1338 _subscriptions: vec![cx.subscribe(&buffer, Self::handle_buffer_event)],
1339 pending_save: Task::ready(Ok(())),
1340 path: None,
1341 buffer,
1342 embedded_scope,
1343 };
1344
1345 let message = MessageAnchor {
1346 id: MessageId(post_inc(&mut this.next_message_id.0)),
1347 start: language::Anchor::MIN,
1348 };
1349 this.message_anchors.push(message.clone());
1350 this.messages_metadata.insert(
1351 message.id,
1352 MessageMetadata {
1353 role: Role::User,
1354 sent_at: Local::now(),
1355 status: MessageStatus::Done,
1356 },
1357 );
1358
1359 this.count_remaining_tokens(cx);
1360 this
1361 }
1362
1363 fn serialize(&self, cx: &AppContext) -> SavedConversation {
1364 SavedConversation {
1365 id: self.id.clone(),
1366 zed: "conversation".into(),
1367 version: SavedConversation::VERSION.into(),
1368 text: self.buffer.read(cx).text(),
1369 message_metadata: self.messages_metadata.clone(),
1370 messages: self
1371 .messages(cx)
1372 .map(|message| SavedMessage {
1373 id: message.id,
1374 start: message.offset_range.start,
1375 })
1376 .collect(),
1377 summary: self
1378 .summary
1379 .as_ref()
1380 .map(|summary| summary.text.clone())
1381 .unwrap_or_default(),
1382 }
1383 }
1384
1385 async fn deserialize(
1386 saved_conversation: SavedConversation,
1387 model: LanguageModel,
1388 path: PathBuf,
1389 language_registry: Arc<LanguageRegistry>,
1390 cx: &mut AsyncAppContext,
1391 ) -> Result<Model<Self>> {
1392 let id = match saved_conversation.id {
1393 Some(id) => Some(id),
1394 None => Some(Uuid::new_v4().to_string()),
1395 };
1396
1397 let markdown = language_registry.language_for_name("Markdown");
1398 let mut message_anchors = Vec::new();
1399 let mut next_message_id = MessageId(0);
1400 let buffer = cx.new_model(|cx| {
1401 let mut buffer = Buffer::new(
1402 0,
1403 BufferId::new(cx.entity_id().as_u64()).unwrap(),
1404 saved_conversation.text,
1405 );
1406 for message in saved_conversation.messages {
1407 message_anchors.push(MessageAnchor {
1408 id: message.id,
1409 start: buffer.anchor_before(message.start),
1410 });
1411 next_message_id = cmp::max(next_message_id, MessageId(message.id.0 + 1));
1412 }
1413 buffer.set_language_registry(language_registry);
1414 cx.spawn(|buffer, mut cx| async move {
1415 let markdown = markdown.await?;
1416 buffer.update(&mut cx, |buffer: &mut Buffer, cx| {
1417 buffer.set_language(Some(markdown), cx)
1418 })?;
1419 anyhow::Ok(())
1420 })
1421 .detach_and_log_err(cx);
1422 buffer
1423 })?;
1424
1425 cx.new_model(|cx| {
1426 let mut this = Self {
1427 id,
1428 message_anchors,
1429 messages_metadata: saved_conversation.message_metadata,
1430 next_message_id,
1431 summary: Some(Summary {
1432 text: saved_conversation.summary,
1433 done: true,
1434 }),
1435 pending_summary: Task::ready(None),
1436 completion_count: Default::default(),
1437 pending_completions: Default::default(),
1438 token_count: None,
1439 pending_token_count: Task::ready(None),
1440 model,
1441 _subscriptions: vec![cx.subscribe(&buffer, Self::handle_buffer_event)],
1442 pending_save: Task::ready(Ok(())),
1443 path: Some(path),
1444 buffer,
1445 embedded_scope: EmbeddedScope::new(),
1446 };
1447 this.count_remaining_tokens(cx);
1448 this
1449 })
1450 }
1451
1452 fn handle_buffer_event(
1453 &mut self,
1454 _: Model<Buffer>,
1455 event: &language::Event,
1456 cx: &mut ModelContext<Self>,
1457 ) {
1458 if *event == language::Event::Edited {
1459 self.count_remaining_tokens(cx);
1460 cx.emit(ConversationEvent::MessagesEdited);
1461 }
1462 }
1463
1464 pub(crate) fn count_remaining_tokens(&mut self, cx: &mut ModelContext<Self>) {
1465 let request = self.to_completion_request(cx);
1466 self.pending_token_count = cx.spawn(|this, mut cx| {
1467 async move {
1468 cx.background_executor()
1469 .timer(Duration::from_millis(200))
1470 .await;
1471
1472 let token_count = cx
1473 .update(|cx| CompletionProvider::global(cx).count_tokens(request, cx))?
1474 .await?;
1475
1476 this.update(&mut cx, |this, cx| {
1477 this.token_count = Some(token_count);
1478 cx.notify()
1479 })?;
1480 anyhow::Ok(())
1481 }
1482 .log_err()
1483 });
1484 }
1485
1486 fn remaining_tokens(&self) -> Option<isize> {
1487 Some(self.model.max_token_count() as isize - self.token_count? as isize)
1488 }
1489
1490 fn set_model(&mut self, model: LanguageModel, cx: &mut ModelContext<Self>) {
1491 self.model = model;
1492 self.count_remaining_tokens(cx);
1493 }
1494
1495 fn assist(
1496 &mut self,
1497 selected_messages: HashSet<MessageId>,
1498 cx: &mut ModelContext<Self>,
1499 ) -> Vec<MessageAnchor> {
1500 let mut user_messages = Vec::new();
1501
1502 let last_message_id = if let Some(last_message_id) =
1503 self.message_anchors.iter().rev().find_map(|message| {
1504 message
1505 .start
1506 .is_valid(self.buffer.read(cx))
1507 .then_some(message.id)
1508 }) {
1509 last_message_id
1510 } else {
1511 return Default::default();
1512 };
1513
1514 let mut should_assist = false;
1515 for selected_message_id in selected_messages {
1516 let selected_message_role =
1517 if let Some(metadata) = self.messages_metadata.get(&selected_message_id) {
1518 metadata.role
1519 } else {
1520 continue;
1521 };
1522
1523 if selected_message_role == Role::Assistant {
1524 if let Some(user_message) = self.insert_message_after(
1525 selected_message_id,
1526 Role::User,
1527 MessageStatus::Done,
1528 cx,
1529 ) {
1530 user_messages.push(user_message);
1531 }
1532 } else {
1533 should_assist = true;
1534 }
1535 }
1536
1537 if should_assist {
1538 if !CompletionProvider::global(cx).is_authenticated() {
1539 log::info!("completion provider has no credentials");
1540 return Default::default();
1541 }
1542
1543 let request = self.to_completion_request(cx);
1544 let stream = CompletionProvider::global(cx).complete(request);
1545 let assistant_message = self
1546 .insert_message_after(last_message_id, Role::Assistant, MessageStatus::Pending, cx)
1547 .unwrap();
1548
1549 // Queue up the user's next reply.
1550 let user_message = self
1551 .insert_message_after(assistant_message.id, Role::User, MessageStatus::Done, cx)
1552 .unwrap();
1553 user_messages.push(user_message);
1554
1555 let task = cx.spawn({
1556 |this, mut cx| async move {
1557 let assistant_message_id = assistant_message.id;
1558 let stream_completion = async {
1559 let mut messages = stream.await?;
1560
1561 while let Some(message) = messages.next().await {
1562 let text = message?;
1563
1564 this.update(&mut cx, |this, cx| {
1565 let message_ix = this
1566 .message_anchors
1567 .iter()
1568 .position(|message| message.id == assistant_message_id)?;
1569 this.buffer.update(cx, |buffer, cx| {
1570 let offset = this.message_anchors[message_ix + 1..]
1571 .iter()
1572 .find(|message| message.start.is_valid(buffer))
1573 .map_or(buffer.len(), |message| {
1574 message.start.to_offset(buffer).saturating_sub(1)
1575 });
1576 buffer.edit([(offset..offset, text)], None, cx);
1577 });
1578 cx.emit(ConversationEvent::StreamedCompletion);
1579
1580 Some(())
1581 })?;
1582 smol::future::yield_now().await;
1583 }
1584
1585 this.update(&mut cx, |this, cx| {
1586 this.pending_completions
1587 .retain(|completion| completion.id != this.completion_count);
1588 this.summarize(cx);
1589 })?;
1590
1591 anyhow::Ok(())
1592 };
1593
1594 let result = stream_completion.await;
1595
1596 this.update(&mut cx, |this, cx| {
1597 if let Some(metadata) =
1598 this.messages_metadata.get_mut(&assistant_message.id)
1599 {
1600 match result {
1601 Ok(_) => {
1602 metadata.status = MessageStatus::Done;
1603 }
1604 Err(error) => {
1605 metadata.status = MessageStatus::Error(SharedString::from(
1606 error.to_string().trim().to_string(),
1607 ));
1608 }
1609 }
1610 cx.emit(ConversationEvent::MessagesEdited);
1611 }
1612 })
1613 .ok();
1614 }
1615 });
1616
1617 self.pending_completions.push(PendingCompletion {
1618 id: post_inc(&mut self.completion_count),
1619 _task: task,
1620 });
1621 }
1622
1623 user_messages
1624 }
1625
1626 fn to_completion_request(&self, cx: &mut ModelContext<Conversation>) -> LanguageModelRequest {
1627 let mut request = LanguageModelRequest {
1628 model: self.model.clone(),
1629 messages: self
1630 .messages(cx)
1631 .filter(|message| matches!(message.status, MessageStatus::Done))
1632 .map(|message| message.to_open_ai_message(self.buffer.read(cx)))
1633 .collect(),
1634 stop: vec![],
1635 temperature: 1.0,
1636 };
1637
1638 let context_message = self.embedded_scope.message(cx);
1639 request.messages.extend(context_message);
1640 request
1641 }
1642
1643 fn cancel_last_assist(&mut self) -> bool {
1644 self.pending_completions.pop().is_some()
1645 }
1646
1647 fn cycle_message_roles(&mut self, ids: HashSet<MessageId>, cx: &mut ModelContext<Self>) {
1648 for id in ids {
1649 if let Some(metadata) = self.messages_metadata.get_mut(&id) {
1650 metadata.role.cycle();
1651 cx.emit(ConversationEvent::MessagesEdited);
1652 cx.notify();
1653 }
1654 }
1655 }
1656
1657 fn insert_message_after(
1658 &mut self,
1659 message_id: MessageId,
1660 role: Role,
1661 status: MessageStatus,
1662 cx: &mut ModelContext<Self>,
1663 ) -> Option<MessageAnchor> {
1664 if let Some(prev_message_ix) = self
1665 .message_anchors
1666 .iter()
1667 .position(|message| message.id == message_id)
1668 {
1669 // Find the next valid message after the one we were given.
1670 let mut next_message_ix = prev_message_ix + 1;
1671 while let Some(next_message) = self.message_anchors.get(next_message_ix) {
1672 if next_message.start.is_valid(self.buffer.read(cx)) {
1673 break;
1674 }
1675 next_message_ix += 1;
1676 }
1677
1678 let start = self.buffer.update(cx, |buffer, cx| {
1679 let offset = self
1680 .message_anchors
1681 .get(next_message_ix)
1682 .map_or(buffer.len(), |message| message.start.to_offset(buffer) - 1);
1683 buffer.edit([(offset..offset, "\n")], None, cx);
1684 buffer.anchor_before(offset + 1)
1685 });
1686 let message = MessageAnchor {
1687 id: MessageId(post_inc(&mut self.next_message_id.0)),
1688 start,
1689 };
1690 self.message_anchors
1691 .insert(next_message_ix, message.clone());
1692 self.messages_metadata.insert(
1693 message.id,
1694 MessageMetadata {
1695 role,
1696 sent_at: Local::now(),
1697 status,
1698 },
1699 );
1700 cx.emit(ConversationEvent::MessagesEdited);
1701 Some(message)
1702 } else {
1703 None
1704 }
1705 }
1706
1707 fn split_message(
1708 &mut self,
1709 range: Range<usize>,
1710 cx: &mut ModelContext<Self>,
1711 ) -> (Option<MessageAnchor>, Option<MessageAnchor>) {
1712 let start_message = self.message_for_offset(range.start, cx);
1713 let end_message = self.message_for_offset(range.end, cx);
1714 if let Some((start_message, end_message)) = start_message.zip(end_message) {
1715 // Prevent splitting when range spans multiple messages.
1716 if start_message.id != end_message.id {
1717 return (None, None);
1718 }
1719
1720 let message = start_message;
1721 let role = message.role;
1722 let mut edited_buffer = false;
1723
1724 let mut suffix_start = None;
1725 if range.start > message.offset_range.start && range.end < message.offset_range.end - 1
1726 {
1727 if self.buffer.read(cx).chars_at(range.end).next() == Some('\n') {
1728 suffix_start = Some(range.end + 1);
1729 } else if self.buffer.read(cx).reversed_chars_at(range.end).next() == Some('\n') {
1730 suffix_start = Some(range.end);
1731 }
1732 }
1733
1734 let suffix = if let Some(suffix_start) = suffix_start {
1735 MessageAnchor {
1736 id: MessageId(post_inc(&mut self.next_message_id.0)),
1737 start: self.buffer.read(cx).anchor_before(suffix_start),
1738 }
1739 } else {
1740 self.buffer.update(cx, |buffer, cx| {
1741 buffer.edit([(range.end..range.end, "\n")], None, cx);
1742 });
1743 edited_buffer = true;
1744 MessageAnchor {
1745 id: MessageId(post_inc(&mut self.next_message_id.0)),
1746 start: self.buffer.read(cx).anchor_before(range.end + 1),
1747 }
1748 };
1749
1750 self.message_anchors
1751 .insert(message.index_range.end + 1, suffix.clone());
1752 self.messages_metadata.insert(
1753 suffix.id,
1754 MessageMetadata {
1755 role,
1756 sent_at: Local::now(),
1757 status: MessageStatus::Done,
1758 },
1759 );
1760
1761 let new_messages =
1762 if range.start == range.end || range.start == message.offset_range.start {
1763 (None, Some(suffix))
1764 } else {
1765 let mut prefix_end = None;
1766 if range.start > message.offset_range.start
1767 && range.end < message.offset_range.end - 1
1768 {
1769 if self.buffer.read(cx).chars_at(range.start).next() == Some('\n') {
1770 prefix_end = Some(range.start + 1);
1771 } else if self.buffer.read(cx).reversed_chars_at(range.start).next()
1772 == Some('\n')
1773 {
1774 prefix_end = Some(range.start);
1775 }
1776 }
1777
1778 let selection = if let Some(prefix_end) = prefix_end {
1779 cx.emit(ConversationEvent::MessagesEdited);
1780 MessageAnchor {
1781 id: MessageId(post_inc(&mut self.next_message_id.0)),
1782 start: self.buffer.read(cx).anchor_before(prefix_end),
1783 }
1784 } else {
1785 self.buffer.update(cx, |buffer, cx| {
1786 buffer.edit([(range.start..range.start, "\n")], None, cx)
1787 });
1788 edited_buffer = true;
1789 MessageAnchor {
1790 id: MessageId(post_inc(&mut self.next_message_id.0)),
1791 start: self.buffer.read(cx).anchor_before(range.end + 1),
1792 }
1793 };
1794
1795 self.message_anchors
1796 .insert(message.index_range.end + 1, selection.clone());
1797 self.messages_metadata.insert(
1798 selection.id,
1799 MessageMetadata {
1800 role,
1801 sent_at: Local::now(),
1802 status: MessageStatus::Done,
1803 },
1804 );
1805 (Some(selection), Some(suffix))
1806 };
1807
1808 if !edited_buffer {
1809 cx.emit(ConversationEvent::MessagesEdited);
1810 }
1811 new_messages
1812 } else {
1813 (None, None)
1814 }
1815 }
1816
1817 fn summarize(&mut self, cx: &mut ModelContext<Self>) {
1818 if self.message_anchors.len() >= 2 && self.summary.is_none() {
1819 if !CompletionProvider::global(cx).is_authenticated() {
1820 return;
1821 }
1822
1823 let messages = self
1824 .messages(cx)
1825 .take(2)
1826 .map(|message| message.to_open_ai_message(self.buffer.read(cx)))
1827 .chain(Some(LanguageModelRequestMessage {
1828 role: Role::User,
1829 content: "Summarize the conversation into a short title without punctuation"
1830 .into(),
1831 }));
1832 let request = LanguageModelRequest {
1833 model: self.model.clone(),
1834 messages: messages.collect(),
1835 stop: vec![],
1836 temperature: 1.0,
1837 };
1838
1839 let stream = CompletionProvider::global(cx).complete(request);
1840 self.pending_summary = cx.spawn(|this, mut cx| {
1841 async move {
1842 let mut messages = stream.await?;
1843
1844 while let Some(message) = messages.next().await {
1845 let text = message?;
1846 this.update(&mut cx, |this, cx| {
1847 this.summary
1848 .get_or_insert(Default::default())
1849 .text
1850 .push_str(&text);
1851 cx.emit(ConversationEvent::SummaryChanged);
1852 })?;
1853 }
1854
1855 this.update(&mut cx, |this, cx| {
1856 if let Some(summary) = this.summary.as_mut() {
1857 summary.done = true;
1858 cx.emit(ConversationEvent::SummaryChanged);
1859 }
1860 })?;
1861
1862 anyhow::Ok(())
1863 }
1864 .log_err()
1865 });
1866 }
1867 }
1868
1869 fn message_for_offset(&self, offset: usize, cx: &AppContext) -> Option<Message> {
1870 self.messages_for_offsets([offset], cx).pop()
1871 }
1872
1873 fn messages_for_offsets(
1874 &self,
1875 offsets: impl IntoIterator<Item = usize>,
1876 cx: &AppContext,
1877 ) -> Vec<Message> {
1878 let mut result = Vec::new();
1879
1880 let mut messages = self.messages(cx).peekable();
1881 let mut offsets = offsets.into_iter().peekable();
1882 let mut current_message = messages.next();
1883 while let Some(offset) = offsets.next() {
1884 // Locate the message that contains the offset.
1885 while current_message.as_ref().map_or(false, |message| {
1886 !message.offset_range.contains(&offset) && messages.peek().is_some()
1887 }) {
1888 current_message = messages.next();
1889 }
1890 let Some(message) = current_message.as_ref() else {
1891 break;
1892 };
1893
1894 // Skip offsets that are in the same message.
1895 while offsets.peek().map_or(false, |offset| {
1896 message.offset_range.contains(offset) || messages.peek().is_none()
1897 }) {
1898 offsets.next();
1899 }
1900
1901 result.push(message.clone());
1902 }
1903 result
1904 }
1905
1906 fn messages<'a>(&'a self, cx: &'a AppContext) -> impl 'a + Iterator<Item = Message> {
1907 let buffer = self.buffer.read(cx);
1908 let mut message_anchors = self.message_anchors.iter().enumerate().peekable();
1909 iter::from_fn(move || {
1910 if let Some((start_ix, message_anchor)) = message_anchors.next() {
1911 let metadata = self.messages_metadata.get(&message_anchor.id)?;
1912 let message_start = message_anchor.start.to_offset(buffer);
1913 let mut message_end = None;
1914 let mut end_ix = start_ix;
1915 while let Some((_, next_message)) = message_anchors.peek() {
1916 if next_message.start.is_valid(buffer) {
1917 message_end = Some(next_message.start);
1918 break;
1919 } else {
1920 end_ix += 1;
1921 message_anchors.next();
1922 }
1923 }
1924 let message_end = message_end
1925 .unwrap_or(language::Anchor::MAX)
1926 .to_offset(buffer);
1927 return Some(Message {
1928 index_range: start_ix..end_ix,
1929 offset_range: message_start..message_end,
1930 id: message_anchor.id,
1931 anchor: message_anchor.start,
1932 role: metadata.role,
1933 sent_at: metadata.sent_at,
1934 status: metadata.status.clone(),
1935 });
1936 }
1937 None
1938 })
1939 }
1940
1941 fn save(
1942 &mut self,
1943 debounce: Option<Duration>,
1944 fs: Arc<dyn Fs>,
1945 cx: &mut ModelContext<Conversation>,
1946 ) {
1947 self.pending_save = cx.spawn(|this, mut cx| async move {
1948 if let Some(debounce) = debounce {
1949 cx.background_executor().timer(debounce).await;
1950 }
1951
1952 let (old_path, summary) = this.read_with(&cx, |this, _| {
1953 let path = this.path.clone();
1954 let summary = if let Some(summary) = this.summary.as_ref() {
1955 if summary.done {
1956 Some(summary.text.clone())
1957 } else {
1958 None
1959 }
1960 } else {
1961 None
1962 };
1963 (path, summary)
1964 })?;
1965
1966 if let Some(summary) = summary {
1967 let conversation = this.read_with(&cx, |this, cx| this.serialize(cx))?;
1968 let path = if let Some(old_path) = old_path {
1969 old_path
1970 } else {
1971 let mut discriminant = 1;
1972 let mut new_path;
1973 loop {
1974 new_path = CONVERSATIONS_DIR.join(&format!(
1975 "{} - {}.zed.json",
1976 summary.trim(),
1977 discriminant
1978 ));
1979 if fs.is_file(&new_path).await {
1980 discriminant += 1;
1981 } else {
1982 break;
1983 }
1984 }
1985 new_path
1986 };
1987
1988 fs.create_dir(CONVERSATIONS_DIR.as_ref()).await?;
1989 fs.atomic_write(path.clone(), serde_json::to_string(&conversation).unwrap())
1990 .await?;
1991 this.update(&mut cx, |this, _| this.path = Some(path))?;
1992 }
1993
1994 Ok(())
1995 });
1996 }
1997}
1998
1999struct PendingCompletion {
2000 id: usize,
2001 _task: Task<()>,
2002}
2003
2004enum ConversationEditorEvent {
2005 TabContentChanged,
2006}
2007
2008#[derive(Copy, Clone, Debug, PartialEq)]
2009struct ScrollPosition {
2010 offset_before_cursor: gpui::Point<f32>,
2011 cursor: Anchor,
2012}
2013
2014struct ConversationEditor {
2015 conversation: Model<Conversation>,
2016 fs: Arc<dyn Fs>,
2017 workspace: WeakView<Workspace>,
2018 editor: View<Editor>,
2019 blocks: HashSet<BlockId>,
2020 scroll_position: Option<ScrollPosition>,
2021 _subscriptions: Vec<Subscription>,
2022}
2023
2024impl ConversationEditor {
2025 fn new(
2026 model: LanguageModel,
2027 language_registry: Arc<LanguageRegistry>,
2028 fs: Arc<dyn Fs>,
2029 workspace: View<Workspace>,
2030 cx: &mut ViewContext<Self>,
2031 ) -> Self {
2032 let conversation = cx
2033 .new_model(|cx| Conversation::new(model, language_registry, EmbeddedScope::new(), cx));
2034 Self::for_conversation(conversation, fs, workspace, cx)
2035 }
2036
2037 fn for_conversation(
2038 conversation: Model<Conversation>,
2039 fs: Arc<dyn Fs>,
2040 workspace: View<Workspace>,
2041 cx: &mut ViewContext<Self>,
2042 ) -> Self {
2043 let editor = cx.new_view(|cx| {
2044 let mut editor = Editor::for_buffer(conversation.read(cx).buffer.clone(), None, cx);
2045 editor.set_soft_wrap_mode(SoftWrap::EditorWidth, cx);
2046 editor.set_show_gutter(false, cx);
2047 editor.set_show_wrap_guides(false, cx);
2048 editor
2049 });
2050
2051 let _subscriptions = vec![
2052 cx.observe(&conversation, |_, _, cx| cx.notify()),
2053 cx.subscribe(&conversation, Self::handle_conversation_event),
2054 cx.subscribe(&editor, Self::handle_editor_event),
2055 cx.subscribe(&workspace, Self::handle_workspace_event),
2056 ];
2057
2058 let mut this = Self {
2059 conversation,
2060 editor,
2061 blocks: Default::default(),
2062 scroll_position: None,
2063 fs,
2064 workspace: workspace.downgrade(),
2065 _subscriptions,
2066 };
2067 this.update_active_buffer(workspace, cx);
2068 this.update_message_headers(cx);
2069 this
2070 }
2071
2072 fn assist(&mut self, _: &Assist, cx: &mut ViewContext<Self>) {
2073 self.conversation.update(cx, |conversation, cx| {
2074 report_assistant_event(
2075 self.workspace.clone(),
2076 Some(conversation),
2077 AssistantKind::Panel,
2078 cx,
2079 )
2080 });
2081
2082 let cursors = self.cursors(cx);
2083
2084 let user_messages = self.conversation.update(cx, |conversation, cx| {
2085 let selected_messages = conversation
2086 .messages_for_offsets(cursors, cx)
2087 .into_iter()
2088 .map(|message| message.id)
2089 .collect();
2090 conversation.assist(selected_messages, cx)
2091 });
2092 let new_selections = user_messages
2093 .iter()
2094 .map(|message| {
2095 let cursor = message
2096 .start
2097 .to_offset(self.conversation.read(cx).buffer.read(cx));
2098 cursor..cursor
2099 })
2100 .collect::<Vec<_>>();
2101 if !new_selections.is_empty() {
2102 self.editor.update(cx, |editor, cx| {
2103 editor.change_selections(
2104 Some(Autoscroll::Strategy(AutoscrollStrategy::Fit)),
2105 cx,
2106 |selections| selections.select_ranges(new_selections),
2107 );
2108 });
2109 // Avoid scrolling to the new cursor position so the assistant's output is stable.
2110 cx.defer(|this, _| this.scroll_position = None);
2111 }
2112 }
2113
2114 fn cancel_last_assist(&mut self, _: &editor::actions::Cancel, cx: &mut ViewContext<Self>) {
2115 if !self
2116 .conversation
2117 .update(cx, |conversation, _| conversation.cancel_last_assist())
2118 {
2119 cx.propagate();
2120 }
2121 }
2122
2123 fn cycle_message_role(&mut self, _: &CycleMessageRole, cx: &mut ViewContext<Self>) {
2124 let cursors = self.cursors(cx);
2125 self.conversation.update(cx, |conversation, cx| {
2126 let messages = conversation
2127 .messages_for_offsets(cursors, cx)
2128 .into_iter()
2129 .map(|message| message.id)
2130 .collect();
2131 conversation.cycle_message_roles(messages, cx)
2132 });
2133 }
2134
2135 fn cursors(&self, cx: &AppContext) -> Vec<usize> {
2136 let selections = self.editor.read(cx).selections.all::<usize>(cx);
2137 selections
2138 .into_iter()
2139 .map(|selection| selection.head())
2140 .collect()
2141 }
2142
2143 fn handle_conversation_event(
2144 &mut self,
2145 _: Model<Conversation>,
2146 event: &ConversationEvent,
2147 cx: &mut ViewContext<Self>,
2148 ) {
2149 match event {
2150 ConversationEvent::MessagesEdited => {
2151 self.update_message_headers(cx);
2152 self.conversation.update(cx, |conversation, cx| {
2153 conversation.save(Some(Duration::from_millis(500)), self.fs.clone(), cx);
2154 });
2155 }
2156 ConversationEvent::SummaryChanged => {
2157 cx.emit(ConversationEditorEvent::TabContentChanged);
2158 self.conversation.update(cx, |conversation, cx| {
2159 conversation.save(None, self.fs.clone(), cx);
2160 });
2161 }
2162 ConversationEvent::StreamedCompletion => {
2163 self.editor.update(cx, |editor, cx| {
2164 if let Some(scroll_position) = self.scroll_position {
2165 let snapshot = editor.snapshot(cx);
2166 let cursor_point = scroll_position.cursor.to_display_point(&snapshot);
2167 let scroll_top =
2168 cursor_point.row() as f32 - scroll_position.offset_before_cursor.y;
2169 editor.set_scroll_position(
2170 point(scroll_position.offset_before_cursor.x, scroll_top),
2171 cx,
2172 );
2173 }
2174 });
2175 }
2176 }
2177 }
2178
2179 fn handle_editor_event(
2180 &mut self,
2181 _: View<Editor>,
2182 event: &EditorEvent,
2183 cx: &mut ViewContext<Self>,
2184 ) {
2185 match event {
2186 EditorEvent::ScrollPositionChanged { autoscroll, .. } => {
2187 let cursor_scroll_position = self.cursor_scroll_position(cx);
2188 if *autoscroll {
2189 self.scroll_position = cursor_scroll_position;
2190 } else if self.scroll_position != cursor_scroll_position {
2191 self.scroll_position = None;
2192 }
2193 }
2194 EditorEvent::SelectionsChanged { .. } => {
2195 self.scroll_position = self.cursor_scroll_position(cx);
2196 }
2197 _ => {}
2198 }
2199 }
2200
2201 fn handle_workspace_event(
2202 &mut self,
2203 workspace: View<Workspace>,
2204 event: &WorkspaceEvent,
2205 cx: &mut ViewContext<Self>,
2206 ) {
2207 if let WorkspaceEvent::ActiveItemChanged = event {
2208 self.update_active_buffer(workspace, cx);
2209 }
2210 }
2211
2212 fn update_active_buffer(
2213 &mut self,
2214 workspace: View<Workspace>,
2215 cx: &mut ViewContext<'_, ConversationEditor>,
2216 ) {
2217 let active_buffer = workspace
2218 .read(cx)
2219 .active_item(cx)
2220 .and_then(|item| Some(item.act_as::<Editor>(cx)?.read(cx).buffer().clone()));
2221
2222 self.conversation.update(cx, |conversation, cx| {
2223 conversation
2224 .embedded_scope
2225 .set_active_buffer(active_buffer.clone(), cx);
2226
2227 conversation.count_remaining_tokens(cx);
2228 cx.notify();
2229 });
2230 }
2231
2232 fn cursor_scroll_position(&self, cx: &mut ViewContext<Self>) -> Option<ScrollPosition> {
2233 self.editor.update(cx, |editor, cx| {
2234 let snapshot = editor.snapshot(cx);
2235 let cursor = editor.selections.newest_anchor().head();
2236 let cursor_row = cursor.to_display_point(&snapshot.display_snapshot).row() as f32;
2237 let scroll_position = editor
2238 .scroll_manager
2239 .anchor()
2240 .scroll_position(&snapshot.display_snapshot);
2241
2242 let scroll_bottom = scroll_position.y + editor.visible_line_count().unwrap_or(0.);
2243 if (scroll_position.y..scroll_bottom).contains(&cursor_row) {
2244 Some(ScrollPosition {
2245 cursor,
2246 offset_before_cursor: point(scroll_position.x, cursor_row - scroll_position.y),
2247 })
2248 } else {
2249 None
2250 }
2251 })
2252 }
2253
2254 fn update_message_headers(&mut self, cx: &mut ViewContext<Self>) {
2255 self.editor.update(cx, |editor, cx| {
2256 let buffer = editor.buffer().read(cx).snapshot(cx);
2257 let excerpt_id = *buffer.as_singleton().unwrap().0;
2258 let old_blocks = std::mem::take(&mut self.blocks);
2259 let new_blocks = self
2260 .conversation
2261 .read(cx)
2262 .messages(cx)
2263 .map(|message| BlockProperties {
2264 position: buffer
2265 .anchor_in_excerpt(excerpt_id, message.anchor)
2266 .unwrap(),
2267 height: 2,
2268 style: BlockStyle::Sticky,
2269 render: Box::new({
2270 let conversation = self.conversation.clone();
2271 move |_cx| {
2272 let message_id = message.id;
2273 let sender = ButtonLike::new("role")
2274 .style(ButtonStyle::Filled)
2275 .child(match message.role {
2276 Role::User => Label::new("You").color(Color::Default),
2277 Role::Assistant => Label::new("Assistant").color(Color::Info),
2278 Role::System => Label::new("System").color(Color::Warning),
2279 })
2280 .tooltip(|cx| {
2281 Tooltip::with_meta(
2282 "Toggle message role",
2283 None,
2284 "Available roles: You (User), Assistant, System",
2285 cx,
2286 )
2287 })
2288 .on_click({
2289 let conversation = conversation.clone();
2290 move |_, cx| {
2291 conversation.update(cx, |conversation, cx| {
2292 conversation.cycle_message_roles(
2293 HashSet::from_iter(Some(message_id)),
2294 cx,
2295 )
2296 })
2297 }
2298 });
2299
2300 h_flex()
2301 .id(("message_header", message_id.0))
2302 .h_11()
2303 .relative()
2304 .gap_1()
2305 .child(sender)
2306 // TODO: Only show this if the message if the message has been sent
2307 .child(
2308 Label::new(
2309 FormatDistance::from_now(DateTimeType::Local(
2310 message.sent_at,
2311 ))
2312 .hide_prefix(true)
2313 .add_suffix(true)
2314 .to_string(),
2315 )
2316 .size(LabelSize::XSmall)
2317 .color(Color::Muted),
2318 )
2319 .children(
2320 if let MessageStatus::Error(error) = message.status.clone() {
2321 Some(
2322 div()
2323 .id("error")
2324 .tooltip(move |cx| Tooltip::text(error.clone(), cx))
2325 .child(Icon::new(IconName::XCircle)),
2326 )
2327 } else {
2328 None
2329 },
2330 )
2331 .into_any_element()
2332 }
2333 }),
2334 disposition: BlockDisposition::Above,
2335 })
2336 .collect::<Vec<_>>();
2337
2338 editor.remove_blocks(old_blocks, None, cx);
2339 let ids = editor.insert_blocks(new_blocks, None, cx);
2340 self.blocks = HashSet::from_iter(ids);
2341 });
2342 }
2343
2344 fn quote_selection(
2345 workspace: &mut Workspace,
2346 _: &QuoteSelection,
2347 cx: &mut ViewContext<Workspace>,
2348 ) {
2349 let Some(panel) = workspace.panel::<AssistantPanel>(cx) else {
2350 return;
2351 };
2352 let Some(editor) = workspace
2353 .active_item(cx)
2354 .and_then(|item| item.act_as::<Editor>(cx))
2355 else {
2356 return;
2357 };
2358
2359 let editor = editor.read(cx);
2360 let range = editor.selections.newest::<usize>(cx).range();
2361 let buffer = editor.buffer().read(cx).snapshot(cx);
2362 let start_language = buffer.language_at(range.start);
2363 let end_language = buffer.language_at(range.end);
2364 let language_name = if start_language == end_language {
2365 start_language.map(|language| language.code_fence_block_name())
2366 } else {
2367 None
2368 };
2369 let language_name = language_name.as_deref().unwrap_or("");
2370
2371 let selected_text = buffer.text_for_range(range).collect::<String>();
2372 let text = if selected_text.is_empty() {
2373 None
2374 } else {
2375 Some(if language_name == "markdown" {
2376 selected_text
2377 .lines()
2378 .map(|line| format!("> {}", line))
2379 .collect::<Vec<_>>()
2380 .join("\n")
2381 } else {
2382 format!("```{language_name}\n{selected_text}\n```")
2383 })
2384 };
2385
2386 // Activate the panel
2387 if !panel.focus_handle(cx).contains_focused(cx) {
2388 workspace.toggle_panel_focus::<AssistantPanel>(cx);
2389 }
2390
2391 if let Some(text) = text {
2392 panel.update(cx, |panel, cx| {
2393 if let Some(conversation) = panel
2394 .active_conversation_editor()
2395 .cloned()
2396 .or_else(|| panel.new_conversation(cx))
2397 {
2398 conversation.update(cx, |conversation, cx| {
2399 conversation
2400 .editor
2401 .update(cx, |editor, cx| editor.insert(&text, cx))
2402 });
2403 };
2404 });
2405 }
2406 }
2407
2408 fn copy(&mut self, _: &editor::actions::Copy, cx: &mut ViewContext<Self>) {
2409 let editor = self.editor.read(cx);
2410 let conversation = self.conversation.read(cx);
2411 if editor.selections.count() == 1 {
2412 let selection = editor.selections.newest::<usize>(cx);
2413 let mut copied_text = String::new();
2414 let mut spanned_messages = 0;
2415 for message in conversation.messages(cx) {
2416 if message.offset_range.start >= selection.range().end {
2417 break;
2418 } else if message.offset_range.end >= selection.range().start {
2419 let range = cmp::max(message.offset_range.start, selection.range().start)
2420 ..cmp::min(message.offset_range.end, selection.range().end);
2421 if !range.is_empty() {
2422 spanned_messages += 1;
2423 write!(&mut copied_text, "## {}\n\n", message.role).unwrap();
2424 for chunk in conversation.buffer.read(cx).text_for_range(range) {
2425 copied_text.push_str(chunk);
2426 }
2427 copied_text.push('\n');
2428 }
2429 }
2430 }
2431
2432 if spanned_messages > 1 {
2433 cx.write_to_clipboard(ClipboardItem::new(copied_text));
2434 return;
2435 }
2436 }
2437
2438 cx.propagate();
2439 }
2440
2441 fn split(&mut self, _: &Split, cx: &mut ViewContext<Self>) {
2442 self.conversation.update(cx, |conversation, cx| {
2443 let selections = self.editor.read(cx).selections.disjoint_anchors();
2444 for selection in selections.as_ref() {
2445 let buffer = self.editor.read(cx).buffer().read(cx).snapshot(cx);
2446 let range = selection
2447 .map(|endpoint| endpoint.to_offset(&buffer))
2448 .range();
2449 conversation.split_message(range, cx);
2450 }
2451 });
2452 }
2453
2454 fn save(&mut self, _: &Save, cx: &mut ViewContext<Self>) {
2455 self.conversation.update(cx, |conversation, cx| {
2456 conversation.save(None, self.fs.clone(), cx)
2457 });
2458 }
2459
2460 fn title(&self, cx: &AppContext) -> String {
2461 self.conversation
2462 .read(cx)
2463 .summary
2464 .as_ref()
2465 .map(|summary| summary.text.clone())
2466 .unwrap_or_else(|| "New Conversation".into())
2467 }
2468
2469 fn render_embedded_scope(&self, cx: &mut ViewContext<Self>) -> Option<impl Element> {
2470 let active_buffer = self
2471 .conversation
2472 .read(cx)
2473 .embedded_scope
2474 .active_buffer()?
2475 .clone();
2476
2477 Some(
2478 div()
2479 .p_4()
2480 .v_flex()
2481 .child(
2482 div()
2483 .h_flex()
2484 .items_center()
2485 .child(Icon::new(IconName::File))
2486 .child(
2487 div()
2488 .h_6()
2489 .child(Label::new("File Contexts"))
2490 .ml_1()
2491 .font_weight(FontWeight::SEMIBOLD),
2492 ),
2493 )
2494 .child(
2495 div()
2496 .ml_4()
2497 .child(self.render_active_buffer(active_buffer, cx)),
2498 ),
2499 )
2500 }
2501
2502 fn render_active_buffer(
2503 &self,
2504 buffer: Model<MultiBuffer>,
2505 cx: &mut ViewContext<Self>,
2506 ) -> impl Element {
2507 let buffer = buffer.read(cx);
2508 let icon_path;
2509 let path;
2510 if let Some(singleton) = buffer.as_singleton() {
2511 let singleton = singleton.read(cx);
2512
2513 path = singleton.file().map(|file| file.full_path(cx));
2514
2515 icon_path = path
2516 .as_ref()
2517 .and_then(|path| FileIcons::get_icon(path.as_path(), cx))
2518 .map(SharedString::from)
2519 .unwrap_or_else(|| SharedString::from("icons/file_icons/file.svg"));
2520 } else {
2521 icon_path = SharedString::from("icons/file_icons/file.svg");
2522 path = None;
2523 }
2524
2525 let file_name = path.map_or("Untitled".to_string(), |path| {
2526 path.to_string_lossy().to_string()
2527 });
2528
2529 let enabled = self
2530 .conversation
2531 .read(cx)
2532 .embedded_scope
2533 .active_buffer_enabled();
2534
2535 let file_name_text_color = if enabled {
2536 Color::Default
2537 } else {
2538 Color::Disabled
2539 };
2540
2541 div()
2542 .id("active-buffer")
2543 .h_flex()
2544 .cursor_pointer()
2545 .child(Icon::from_path(icon_path).color(file_name_text_color))
2546 .child(
2547 div()
2548 .h_6()
2549 .child(Label::new(file_name).color(file_name_text_color))
2550 .ml_1(),
2551 )
2552 .children(enabled.then(|| {
2553 div()
2554 .child(Icon::new(IconName::Check).color(file_name_text_color))
2555 .ml_1()
2556 }))
2557 .on_click(cx.listener(move |this, _, cx| {
2558 this.conversation.update(cx, |conversation, cx| {
2559 conversation
2560 .embedded_scope
2561 .set_active_buffer_enabled(!enabled);
2562 cx.notify();
2563 })
2564 }))
2565 }
2566}
2567
2568impl EventEmitter<ConversationEditorEvent> for ConversationEditor {}
2569
2570impl Render for ConversationEditor {
2571 fn render(&mut self, cx: &mut ViewContext<Self>) -> impl Element {
2572 //
2573 // The ConversationEditor has two main segments
2574 //
2575 // 1. Messages Editor
2576 // 2. Context
2577 // - File Context (currently only the active file)
2578 // - Project Diagnostics (Planned)
2579 // - Deep Code Context (Planned, for query and other tools for the model)
2580 //
2581
2582 div()
2583 .key_context("ConversationEditor")
2584 .capture_action(cx.listener(ConversationEditor::cancel_last_assist))
2585 .capture_action(cx.listener(ConversationEditor::save))
2586 .capture_action(cx.listener(ConversationEditor::copy))
2587 .capture_action(cx.listener(ConversationEditor::cycle_message_role))
2588 .on_action(cx.listener(ConversationEditor::assist))
2589 .on_action(cx.listener(ConversationEditor::split))
2590 .size_full()
2591 .v_flex()
2592 .child(
2593 div()
2594 .flex_grow()
2595 .pl_4()
2596 .bg(cx.theme().colors().editor_background)
2597 .child(self.editor.clone()),
2598 )
2599 .child(div().flex_shrink().children(self.render_embedded_scope(cx)))
2600 }
2601}
2602
2603impl FocusableView for ConversationEditor {
2604 fn focus_handle(&self, cx: &AppContext) -> FocusHandle {
2605 self.editor.focus_handle(cx)
2606 }
2607}
2608
2609#[derive(Clone, Debug)]
2610struct MessageAnchor {
2611 id: MessageId,
2612 start: language::Anchor,
2613}
2614
2615#[derive(Clone, Debug)]
2616pub struct Message {
2617 offset_range: Range<usize>,
2618 index_range: Range<usize>,
2619 id: MessageId,
2620 anchor: language::Anchor,
2621 role: Role,
2622 sent_at: DateTime<Local>,
2623 status: MessageStatus,
2624}
2625
2626impl Message {
2627 fn to_open_ai_message(&self, buffer: &Buffer) -> LanguageModelRequestMessage {
2628 let content = buffer
2629 .text_for_range(self.offset_range.clone())
2630 .collect::<String>();
2631 LanguageModelRequestMessage {
2632 role: self.role,
2633 content: content.trim_end().into(),
2634 }
2635 }
2636}
2637
2638enum InlineAssistantEvent {
2639 Confirmed {
2640 prompt: String,
2641 include_conversation: bool,
2642 },
2643 Canceled,
2644 Dismissed,
2645 IncludeConversationToggled {
2646 include_conversation: bool,
2647 },
2648}
2649
2650struct InlineAssistant {
2651 id: usize,
2652 prompt_editor: View<Editor>,
2653 workspace: WeakView<Workspace>,
2654 confirmed: bool,
2655 include_conversation: bool,
2656 measurements: Arc<Mutex<BlockMeasurements>>,
2657 prompt_history: VecDeque<String>,
2658 prompt_history_ix: Option<usize>,
2659 pending_prompt: String,
2660 codegen: Model<Codegen>,
2661 _subscriptions: Vec<Subscription>,
2662}
2663
2664impl EventEmitter<InlineAssistantEvent> for InlineAssistant {}
2665
2666impl Render for InlineAssistant {
2667 fn render(&mut self, cx: &mut ViewContext<Self>) -> impl Element {
2668 let measurements = *self.measurements.lock();
2669 h_flex()
2670 .w_full()
2671 .py_2()
2672 .border_y_1()
2673 .border_color(cx.theme().colors().border)
2674 .on_action(cx.listener(Self::confirm))
2675 .on_action(cx.listener(Self::cancel))
2676 .on_action(cx.listener(Self::toggle_include_conversation))
2677 .on_action(cx.listener(Self::move_up))
2678 .on_action(cx.listener(Self::move_down))
2679 .child(
2680 h_flex()
2681 .justify_center()
2682 .w(measurements.gutter_width)
2683 .child(
2684 IconButton::new("include_conversation", IconName::Ai)
2685 .on_click(cx.listener(|this, _, cx| {
2686 this.toggle_include_conversation(&ToggleIncludeConversation, cx)
2687 }))
2688 .selected(self.include_conversation)
2689 .tooltip(|cx| {
2690 Tooltip::for_action(
2691 "Include Conversation",
2692 &ToggleIncludeConversation,
2693 cx,
2694 )
2695 }),
2696 )
2697 .children(if let Some(error) = self.codegen.read(cx).error() {
2698 let error_message = SharedString::from(error.to_string());
2699 Some(
2700 div()
2701 .id("error")
2702 .tooltip(move |cx| Tooltip::text(error_message.clone(), cx))
2703 .child(Icon::new(IconName::XCircle).color(Color::Error)),
2704 )
2705 } else {
2706 None
2707 }),
2708 )
2709 .child(
2710 h_flex()
2711 .w_full()
2712 .ml(measurements.anchor_x - measurements.gutter_width)
2713 .child(self.render_prompt_editor(cx)),
2714 )
2715 }
2716}
2717
2718impl FocusableView for InlineAssistant {
2719 fn focus_handle(&self, cx: &AppContext) -> FocusHandle {
2720 self.prompt_editor.focus_handle(cx)
2721 }
2722}
2723
2724impl InlineAssistant {
2725 fn new(
2726 id: usize,
2727 measurements: Arc<Mutex<BlockMeasurements>>,
2728 include_conversation: bool,
2729 prompt_history: VecDeque<String>,
2730 codegen: Model<Codegen>,
2731 workspace: WeakView<Workspace>,
2732 cx: &mut ViewContext<Self>,
2733 ) -> Self {
2734 let prompt_editor = cx.new_view(|cx| {
2735 let mut editor = Editor::single_line(cx);
2736 let placeholder = match codegen.read(cx).kind() {
2737 CodegenKind::Transform { .. } => "Enter transformation prompt…",
2738 CodegenKind::Generate { .. } => "Enter generation prompt…",
2739 };
2740 editor.set_placeholder_text(placeholder, cx);
2741 editor
2742 });
2743 cx.focus_view(&prompt_editor);
2744
2745 let subscriptions = vec![
2746 cx.observe(&codegen, Self::handle_codegen_changed),
2747 cx.subscribe(&prompt_editor, Self::handle_prompt_editor_events),
2748 ];
2749
2750 Self {
2751 id,
2752 prompt_editor,
2753 workspace,
2754 confirmed: false,
2755 include_conversation,
2756 measurements,
2757 prompt_history,
2758 prompt_history_ix: None,
2759 pending_prompt: String::new(),
2760 codegen,
2761 _subscriptions: subscriptions,
2762 }
2763 }
2764
2765 fn handle_prompt_editor_events(
2766 &mut self,
2767 _: View<Editor>,
2768 event: &EditorEvent,
2769 cx: &mut ViewContext<Self>,
2770 ) {
2771 if let EditorEvent::Edited = event {
2772 self.pending_prompt = self.prompt_editor.read(cx).text(cx);
2773 cx.notify();
2774 }
2775 }
2776
2777 fn handle_codegen_changed(&mut self, _: Model<Codegen>, cx: &mut ViewContext<Self>) {
2778 let is_read_only = !self.codegen.read(cx).idle();
2779 self.prompt_editor.update(cx, |editor, cx| {
2780 let was_read_only = editor.read_only(cx);
2781 if was_read_only != is_read_only {
2782 if is_read_only {
2783 editor.set_read_only(true);
2784 } else {
2785 self.confirmed = false;
2786 editor.set_read_only(false);
2787 }
2788 }
2789 });
2790 cx.notify();
2791 }
2792
2793 fn cancel(&mut self, _: &editor::actions::Cancel, cx: &mut ViewContext<Self>) {
2794 cx.emit(InlineAssistantEvent::Canceled);
2795 }
2796
2797 fn confirm(&mut self, _: &menu::Confirm, cx: &mut ViewContext<Self>) {
2798 if self.confirmed {
2799 cx.emit(InlineAssistantEvent::Dismissed);
2800 } else {
2801 report_assistant_event(self.workspace.clone(), None, AssistantKind::Inline, cx);
2802
2803 let prompt = self.prompt_editor.read(cx).text(cx);
2804 self.prompt_editor
2805 .update(cx, |editor, _cx| editor.set_read_only(true));
2806 cx.emit(InlineAssistantEvent::Confirmed {
2807 prompt,
2808 include_conversation: self.include_conversation,
2809 });
2810 self.confirmed = true;
2811 cx.notify();
2812 }
2813 }
2814
2815 fn toggle_include_conversation(
2816 &mut self,
2817 _: &ToggleIncludeConversation,
2818 cx: &mut ViewContext<Self>,
2819 ) {
2820 self.include_conversation = !self.include_conversation;
2821 cx.emit(InlineAssistantEvent::IncludeConversationToggled {
2822 include_conversation: self.include_conversation,
2823 });
2824 cx.notify();
2825 }
2826
2827 fn move_up(&mut self, _: &MoveUp, cx: &mut ViewContext<Self>) {
2828 if let Some(ix) = self.prompt_history_ix {
2829 if ix > 0 {
2830 self.prompt_history_ix = Some(ix - 1);
2831 let prompt = self.prompt_history[ix - 1].clone();
2832 self.set_prompt(&prompt, cx);
2833 }
2834 } else if !self.prompt_history.is_empty() {
2835 self.prompt_history_ix = Some(self.prompt_history.len() - 1);
2836 let prompt = self.prompt_history[self.prompt_history.len() - 1].clone();
2837 self.set_prompt(&prompt, cx);
2838 }
2839 }
2840
2841 fn move_down(&mut self, _: &MoveDown, cx: &mut ViewContext<Self>) {
2842 if let Some(ix) = self.prompt_history_ix {
2843 if ix < self.prompt_history.len() - 1 {
2844 self.prompt_history_ix = Some(ix + 1);
2845 let prompt = self.prompt_history[ix + 1].clone();
2846 self.set_prompt(&prompt, cx);
2847 } else {
2848 self.prompt_history_ix = None;
2849 let pending_prompt = self.pending_prompt.clone();
2850 self.set_prompt(&pending_prompt, cx);
2851 }
2852 }
2853 }
2854
2855 fn set_prompt(&mut self, prompt: &str, cx: &mut ViewContext<Self>) {
2856 self.prompt_editor.update(cx, |editor, cx| {
2857 editor.buffer().update(cx, |buffer, cx| {
2858 let len = buffer.len(cx);
2859 buffer.edit([(0..len, prompt)], None, cx);
2860 });
2861 });
2862 }
2863
2864 fn render_prompt_editor(&self, cx: &mut ViewContext<Self>) -> impl IntoElement {
2865 let settings = ThemeSettings::get_global(cx);
2866 let text_style = TextStyle {
2867 color: if self.prompt_editor.read(cx).read_only(cx) {
2868 cx.theme().colors().text_disabled
2869 } else {
2870 cx.theme().colors().text
2871 },
2872 font_family: settings.ui_font.family.clone(),
2873 font_features: settings.ui_font.features,
2874 font_size: rems(0.875).into(),
2875 font_weight: FontWeight::NORMAL,
2876 font_style: FontStyle::Normal,
2877 line_height: relative(1.3),
2878 background_color: None,
2879 underline: None,
2880 strikethrough: None,
2881 white_space: WhiteSpace::Normal,
2882 };
2883 EditorElement::new(
2884 &self.prompt_editor,
2885 EditorStyle {
2886 background: cx.theme().colors().editor_background,
2887 local_player: cx.theme().players().local(),
2888 text: text_style,
2889 ..Default::default()
2890 },
2891 )
2892 }
2893}
2894
2895// This wouldn't need to exist if we could pass parameters when rendering child views.
2896#[derive(Copy, Clone, Default)]
2897struct BlockMeasurements {
2898 anchor_x: Pixels,
2899 gutter_width: Pixels,
2900}
2901
2902struct PendingInlineAssist {
2903 editor: WeakView<Editor>,
2904 inline_assistant: Option<(BlockId, View<InlineAssistant>)>,
2905 codegen: Model<Codegen>,
2906 _subscriptions: Vec<Subscription>,
2907 project: WeakModel<Project>,
2908}
2909
2910fn merge_ranges(ranges: &mut Vec<Range<Anchor>>, buffer: &MultiBufferSnapshot) {
2911 ranges.sort_unstable_by(|a, b| {
2912 a.start
2913 .cmp(&b.start, buffer)
2914 .then_with(|| b.end.cmp(&a.end, buffer))
2915 });
2916
2917 let mut ix = 0;
2918 while ix + 1 < ranges.len() {
2919 let b = ranges[ix + 1].clone();
2920 let a = &mut ranges[ix];
2921 if a.end.cmp(&b.start, buffer).is_gt() {
2922 if a.end.cmp(&b.end, buffer).is_lt() {
2923 a.end = b.end;
2924 }
2925 ranges.remove(ix + 1);
2926 } else {
2927 ix += 1;
2928 }
2929 }
2930}
2931
2932fn report_assistant_event(
2933 workspace: WeakView<Workspace>,
2934 conversation: Option<&Conversation>,
2935 assistant_kind: AssistantKind,
2936 cx: &mut AppContext,
2937) {
2938 let Some(workspace) = workspace.upgrade() else {
2939 return;
2940 };
2941
2942 let client = workspace.read(cx).project().read(cx).client();
2943 let telemetry = client.telemetry();
2944
2945 let conversation_id = conversation.and_then(|conversation| conversation.id.clone());
2946 let model_id = conversation
2947 .map(|c| c.model.telemetry_id())
2948 .unwrap_or_else(|| {
2949 CompletionProvider::global(cx)
2950 .default_model()
2951 .telemetry_id()
2952 });
2953 telemetry.report_assistant_event(conversation_id, assistant_kind, model_id)
2954}
2955
2956#[cfg(test)]
2957mod tests {
2958 use super::*;
2959 use crate::{FakeCompletionProvider, MessageId};
2960 use gpui::{AppContext, TestAppContext};
2961 use settings::SettingsStore;
2962
2963 #[gpui::test]
2964 fn test_inserting_and_removing_messages(cx: &mut AppContext) {
2965 let settings_store = SettingsStore::test(cx);
2966 cx.set_global(CompletionProvider::Fake(FakeCompletionProvider::default()));
2967 cx.set_global(settings_store);
2968 init(cx);
2969 let registry = Arc::new(LanguageRegistry::test(cx.background_executor().clone()));
2970
2971 let conversation = cx.new_model(|cx| {
2972 Conversation::new(LanguageModel::default(), registry, EmbeddedScope::new(), cx)
2973 });
2974 let buffer = conversation.read(cx).buffer.clone();
2975
2976 let message_1 = conversation.read(cx).message_anchors[0].clone();
2977 assert_eq!(
2978 messages(&conversation, cx),
2979 vec![(message_1.id, Role::User, 0..0)]
2980 );
2981
2982 let message_2 = conversation.update(cx, |conversation, cx| {
2983 conversation
2984 .insert_message_after(message_1.id, Role::Assistant, MessageStatus::Done, cx)
2985 .unwrap()
2986 });
2987 assert_eq!(
2988 messages(&conversation, cx),
2989 vec![
2990 (message_1.id, Role::User, 0..1),
2991 (message_2.id, Role::Assistant, 1..1)
2992 ]
2993 );
2994
2995 buffer.update(cx, |buffer, cx| {
2996 buffer.edit([(0..0, "1"), (1..1, "2")], None, cx)
2997 });
2998 assert_eq!(
2999 messages(&conversation, cx),
3000 vec![
3001 (message_1.id, Role::User, 0..2),
3002 (message_2.id, Role::Assistant, 2..3)
3003 ]
3004 );
3005
3006 let message_3 = conversation.update(cx, |conversation, cx| {
3007 conversation
3008 .insert_message_after(message_2.id, Role::User, MessageStatus::Done, cx)
3009 .unwrap()
3010 });
3011 assert_eq!(
3012 messages(&conversation, cx),
3013 vec![
3014 (message_1.id, Role::User, 0..2),
3015 (message_2.id, Role::Assistant, 2..4),
3016 (message_3.id, Role::User, 4..4)
3017 ]
3018 );
3019
3020 let message_4 = conversation.update(cx, |conversation, cx| {
3021 conversation
3022 .insert_message_after(message_2.id, Role::User, MessageStatus::Done, cx)
3023 .unwrap()
3024 });
3025 assert_eq!(
3026 messages(&conversation, cx),
3027 vec![
3028 (message_1.id, Role::User, 0..2),
3029 (message_2.id, Role::Assistant, 2..4),
3030 (message_4.id, Role::User, 4..5),
3031 (message_3.id, Role::User, 5..5),
3032 ]
3033 );
3034
3035 buffer.update(cx, |buffer, cx| {
3036 buffer.edit([(4..4, "C"), (5..5, "D")], None, cx)
3037 });
3038 assert_eq!(
3039 messages(&conversation, cx),
3040 vec![
3041 (message_1.id, Role::User, 0..2),
3042 (message_2.id, Role::Assistant, 2..4),
3043 (message_4.id, Role::User, 4..6),
3044 (message_3.id, Role::User, 6..7),
3045 ]
3046 );
3047
3048 // Deleting across message boundaries merges the messages.
3049 buffer.update(cx, |buffer, cx| buffer.edit([(1..4, "")], None, cx));
3050 assert_eq!(
3051 messages(&conversation, cx),
3052 vec![
3053 (message_1.id, Role::User, 0..3),
3054 (message_3.id, Role::User, 3..4),
3055 ]
3056 );
3057
3058 // Undoing the deletion should also undo the merge.
3059 buffer.update(cx, |buffer, cx| buffer.undo(cx));
3060 assert_eq!(
3061 messages(&conversation, cx),
3062 vec![
3063 (message_1.id, Role::User, 0..2),
3064 (message_2.id, Role::Assistant, 2..4),
3065 (message_4.id, Role::User, 4..6),
3066 (message_3.id, Role::User, 6..7),
3067 ]
3068 );
3069
3070 // Redoing the deletion should also redo the merge.
3071 buffer.update(cx, |buffer, cx| buffer.redo(cx));
3072 assert_eq!(
3073 messages(&conversation, cx),
3074 vec![
3075 (message_1.id, Role::User, 0..3),
3076 (message_3.id, Role::User, 3..4),
3077 ]
3078 );
3079
3080 // Ensure we can still insert after a merged message.
3081 let message_5 = conversation.update(cx, |conversation, cx| {
3082 conversation
3083 .insert_message_after(message_1.id, Role::System, MessageStatus::Done, cx)
3084 .unwrap()
3085 });
3086 assert_eq!(
3087 messages(&conversation, cx),
3088 vec![
3089 (message_1.id, Role::User, 0..3),
3090 (message_5.id, Role::System, 3..4),
3091 (message_3.id, Role::User, 4..5)
3092 ]
3093 );
3094 }
3095
3096 #[gpui::test]
3097 fn test_message_splitting(cx: &mut AppContext) {
3098 let settings_store = SettingsStore::test(cx);
3099 cx.set_global(settings_store);
3100 cx.set_global(CompletionProvider::Fake(FakeCompletionProvider::default()));
3101 init(cx);
3102 let registry = Arc::new(LanguageRegistry::test(cx.background_executor().clone()));
3103
3104 let conversation = cx.new_model(|cx| {
3105 Conversation::new(LanguageModel::default(), registry, EmbeddedScope::new(), cx)
3106 });
3107 let buffer = conversation.read(cx).buffer.clone();
3108
3109 let message_1 = conversation.read(cx).message_anchors[0].clone();
3110 assert_eq!(
3111 messages(&conversation, cx),
3112 vec![(message_1.id, Role::User, 0..0)]
3113 );
3114
3115 buffer.update(cx, |buffer, cx| {
3116 buffer.edit([(0..0, "aaa\nbbb\nccc\nddd\n")], None, cx)
3117 });
3118
3119 let (_, message_2) =
3120 conversation.update(cx, |conversation, cx| conversation.split_message(3..3, cx));
3121 let message_2 = message_2.unwrap();
3122
3123 // We recycle newlines in the middle of a split message
3124 assert_eq!(buffer.read(cx).text(), "aaa\nbbb\nccc\nddd\n");
3125 assert_eq!(
3126 messages(&conversation, cx),
3127 vec![
3128 (message_1.id, Role::User, 0..4),
3129 (message_2.id, Role::User, 4..16),
3130 ]
3131 );
3132
3133 let (_, message_3) =
3134 conversation.update(cx, |conversation, cx| conversation.split_message(3..3, cx));
3135 let message_3 = message_3.unwrap();
3136
3137 // We don't recycle newlines at the end of a split message
3138 assert_eq!(buffer.read(cx).text(), "aaa\n\nbbb\nccc\nddd\n");
3139 assert_eq!(
3140 messages(&conversation, cx),
3141 vec![
3142 (message_1.id, Role::User, 0..4),
3143 (message_3.id, Role::User, 4..5),
3144 (message_2.id, Role::User, 5..17),
3145 ]
3146 );
3147
3148 let (_, message_4) =
3149 conversation.update(cx, |conversation, cx| conversation.split_message(9..9, cx));
3150 let message_4 = message_4.unwrap();
3151 assert_eq!(buffer.read(cx).text(), "aaa\n\nbbb\nccc\nddd\n");
3152 assert_eq!(
3153 messages(&conversation, cx),
3154 vec![
3155 (message_1.id, Role::User, 0..4),
3156 (message_3.id, Role::User, 4..5),
3157 (message_2.id, Role::User, 5..9),
3158 (message_4.id, Role::User, 9..17),
3159 ]
3160 );
3161
3162 let (_, message_5) =
3163 conversation.update(cx, |conversation, cx| conversation.split_message(9..9, cx));
3164 let message_5 = message_5.unwrap();
3165 assert_eq!(buffer.read(cx).text(), "aaa\n\nbbb\n\nccc\nddd\n");
3166 assert_eq!(
3167 messages(&conversation, cx),
3168 vec![
3169 (message_1.id, Role::User, 0..4),
3170 (message_3.id, Role::User, 4..5),
3171 (message_2.id, Role::User, 5..9),
3172 (message_4.id, Role::User, 9..10),
3173 (message_5.id, Role::User, 10..18),
3174 ]
3175 );
3176
3177 let (message_6, message_7) = conversation.update(cx, |conversation, cx| {
3178 conversation.split_message(14..16, cx)
3179 });
3180 let message_6 = message_6.unwrap();
3181 let message_7 = message_7.unwrap();
3182 assert_eq!(buffer.read(cx).text(), "aaa\n\nbbb\n\nccc\ndd\nd\n");
3183 assert_eq!(
3184 messages(&conversation, cx),
3185 vec![
3186 (message_1.id, Role::User, 0..4),
3187 (message_3.id, Role::User, 4..5),
3188 (message_2.id, Role::User, 5..9),
3189 (message_4.id, Role::User, 9..10),
3190 (message_5.id, Role::User, 10..14),
3191 (message_6.id, Role::User, 14..17),
3192 (message_7.id, Role::User, 17..19),
3193 ]
3194 );
3195 }
3196
3197 #[gpui::test]
3198 fn test_messages_for_offsets(cx: &mut AppContext) {
3199 let settings_store = SettingsStore::test(cx);
3200 cx.set_global(CompletionProvider::Fake(FakeCompletionProvider::default()));
3201 cx.set_global(settings_store);
3202 init(cx);
3203 let registry = Arc::new(LanguageRegistry::test(cx.background_executor().clone()));
3204 let conversation = cx.new_model(|cx| {
3205 Conversation::new(LanguageModel::default(), registry, EmbeddedScope::new(), cx)
3206 });
3207 let buffer = conversation.read(cx).buffer.clone();
3208
3209 let message_1 = conversation.read(cx).message_anchors[0].clone();
3210 assert_eq!(
3211 messages(&conversation, cx),
3212 vec![(message_1.id, Role::User, 0..0)]
3213 );
3214
3215 buffer.update(cx, |buffer, cx| buffer.edit([(0..0, "aaa")], None, cx));
3216 let message_2 = conversation
3217 .update(cx, |conversation, cx| {
3218 conversation.insert_message_after(message_1.id, Role::User, MessageStatus::Done, cx)
3219 })
3220 .unwrap();
3221 buffer.update(cx, |buffer, cx| buffer.edit([(4..4, "bbb")], None, cx));
3222
3223 let message_3 = conversation
3224 .update(cx, |conversation, cx| {
3225 conversation.insert_message_after(message_2.id, Role::User, MessageStatus::Done, cx)
3226 })
3227 .unwrap();
3228 buffer.update(cx, |buffer, cx| buffer.edit([(8..8, "ccc")], None, cx));
3229
3230 assert_eq!(buffer.read(cx).text(), "aaa\nbbb\nccc");
3231 assert_eq!(
3232 messages(&conversation, cx),
3233 vec![
3234 (message_1.id, Role::User, 0..4),
3235 (message_2.id, Role::User, 4..8),
3236 (message_3.id, Role::User, 8..11)
3237 ]
3238 );
3239
3240 assert_eq!(
3241 message_ids_for_offsets(&conversation, &[0, 4, 9], cx),
3242 [message_1.id, message_2.id, message_3.id]
3243 );
3244 assert_eq!(
3245 message_ids_for_offsets(&conversation, &[0, 1, 11], cx),
3246 [message_1.id, message_3.id]
3247 );
3248
3249 let message_4 = conversation
3250 .update(cx, |conversation, cx| {
3251 conversation.insert_message_after(message_3.id, Role::User, MessageStatus::Done, cx)
3252 })
3253 .unwrap();
3254 assert_eq!(buffer.read(cx).text(), "aaa\nbbb\nccc\n");
3255 assert_eq!(
3256 messages(&conversation, cx),
3257 vec![
3258 (message_1.id, Role::User, 0..4),
3259 (message_2.id, Role::User, 4..8),
3260 (message_3.id, Role::User, 8..12),
3261 (message_4.id, Role::User, 12..12)
3262 ]
3263 );
3264 assert_eq!(
3265 message_ids_for_offsets(&conversation, &[0, 4, 8, 12], cx),
3266 [message_1.id, message_2.id, message_3.id, message_4.id]
3267 );
3268
3269 fn message_ids_for_offsets(
3270 conversation: &Model<Conversation>,
3271 offsets: &[usize],
3272 cx: &AppContext,
3273 ) -> Vec<MessageId> {
3274 conversation
3275 .read(cx)
3276 .messages_for_offsets(offsets.iter().copied(), cx)
3277 .into_iter()
3278 .map(|message| message.id)
3279 .collect()
3280 }
3281 }
3282
3283 #[gpui::test]
3284 async fn test_serialization(cx: &mut TestAppContext) {
3285 let settings_store = cx.update(SettingsStore::test);
3286 cx.set_global(settings_store);
3287 cx.set_global(CompletionProvider::Fake(FakeCompletionProvider::default()));
3288 cx.update(init);
3289 let registry = Arc::new(LanguageRegistry::test(cx.executor()));
3290 let conversation = cx.new_model(|cx| {
3291 Conversation::new(
3292 LanguageModel::default(),
3293 registry.clone(),
3294 EmbeddedScope::new(),
3295 cx,
3296 )
3297 });
3298 let buffer = conversation.read_with(cx, |conversation, _| conversation.buffer.clone());
3299 let message_0 =
3300 conversation.read_with(cx, |conversation, _| conversation.message_anchors[0].id);
3301 let message_1 = conversation.update(cx, |conversation, cx| {
3302 conversation
3303 .insert_message_after(message_0, Role::Assistant, MessageStatus::Done, cx)
3304 .unwrap()
3305 });
3306 let message_2 = conversation.update(cx, |conversation, cx| {
3307 conversation
3308 .insert_message_after(message_1.id, Role::System, MessageStatus::Done, cx)
3309 .unwrap()
3310 });
3311 buffer.update(cx, |buffer, cx| {
3312 buffer.edit([(0..0, "a"), (1..1, "b\nc")], None, cx);
3313 buffer.finalize_last_transaction();
3314 });
3315 let _message_3 = conversation.update(cx, |conversation, cx| {
3316 conversation
3317 .insert_message_after(message_2.id, Role::System, MessageStatus::Done, cx)
3318 .unwrap()
3319 });
3320 buffer.update(cx, |buffer, cx| buffer.undo(cx));
3321 assert_eq!(buffer.read_with(cx, |buffer, _| buffer.text()), "a\nb\nc\n");
3322 assert_eq!(
3323 cx.read(|cx| messages(&conversation, cx)),
3324 [
3325 (message_0, Role::User, 0..2),
3326 (message_1.id, Role::Assistant, 2..6),
3327 (message_2.id, Role::System, 6..6),
3328 ]
3329 );
3330
3331 let deserialized_conversation = Conversation::deserialize(
3332 conversation.read_with(cx, |conversation, cx| conversation.serialize(cx)),
3333 LanguageModel::default(),
3334 Default::default(),
3335 registry.clone(),
3336 &mut cx.to_async(),
3337 )
3338 .await
3339 .unwrap();
3340 let deserialized_buffer =
3341 deserialized_conversation.read_with(cx, |conversation, _| conversation.buffer.clone());
3342 assert_eq!(
3343 deserialized_buffer.read_with(cx, |buffer, _| buffer.text()),
3344 "a\nb\nc\n"
3345 );
3346 assert_eq!(
3347 cx.read(|cx| messages(&deserialized_conversation, cx)),
3348 [
3349 (message_0, Role::User, 0..2),
3350 (message_1.id, Role::Assistant, 2..6),
3351 (message_2.id, Role::System, 6..6),
3352 ]
3353 );
3354 }
3355
3356 fn messages(
3357 conversation: &Model<Conversation>,
3358 cx: &AppContext,
3359 ) -> Vec<(MessageId, Role, Range<usize>)> {
3360 conversation
3361 .read(cx)
3362 .messages(cx)
3363 .map(|message| (message.id, message.role, message.offset_range))
3364 .collect()
3365 }
3366}