language_model_selector.rs

  1use std::{cmp::Reverse, sync::Arc};
  2
  3use agent_settings::AgentSettings;
  4use collections::{HashMap, HashSet, IndexMap};
  5use fuzzy::{StringMatch, StringMatchCandidate, match_strings};
  6use gpui::{
  7    Action, AnyElement, App, BackgroundExecutor, DismissEvent, FocusHandle, ForegroundExecutor,
  8    Subscription, Task,
  9};
 10use language_model::{
 11    AuthenticateError, ConfiguredModel, IconOrSvg, LanguageModel, LanguageModelId,
 12    LanguageModelProvider, LanguageModelProviderId, LanguageModelRegistry,
 13};
 14use ordered_float::OrderedFloat;
 15use picker::{Picker, PickerDelegate};
 16use settings::Settings;
 17use ui::prelude::*;
 18use zed_actions::agent::OpenSettings;
 19
 20use crate::ui::{ModelSelectorFooter, ModelSelectorHeader, ModelSelectorListItem};
 21
 22type OnModelChanged = Arc<dyn Fn(Arc<dyn LanguageModel>, &mut App) + 'static>;
 23type GetActiveModel = Arc<dyn Fn(&App) -> Option<ConfiguredModel> + 'static>;
 24type OnToggleFavorite = Arc<dyn Fn(Arc<dyn LanguageModel>, bool, &mut App) + 'static>;
 25
 26pub type LanguageModelSelector = Picker<LanguageModelPickerDelegate>;
 27
 28pub fn language_model_selector(
 29    get_active_model: impl Fn(&App) -> Option<ConfiguredModel> + 'static,
 30    on_model_changed: impl Fn(Arc<dyn LanguageModel>, &mut App) + 'static,
 31    on_toggle_favorite: impl Fn(Arc<dyn LanguageModel>, bool, &mut App) + 'static,
 32    popover_styles: bool,
 33    focus_handle: FocusHandle,
 34    window: &mut Window,
 35    cx: &mut Context<LanguageModelSelector>,
 36) -> LanguageModelSelector {
 37    let delegate = LanguageModelPickerDelegate::new(
 38        get_active_model,
 39        on_model_changed,
 40        on_toggle_favorite,
 41        popover_styles,
 42        focus_handle,
 43        window,
 44        cx,
 45    );
 46
 47    if popover_styles {
 48        Picker::list(delegate, window, cx)
 49            .show_scrollbar(true)
 50            .width(rems(20.))
 51            .max_height(Some(rems(20.).into()))
 52    } else {
 53        Picker::list(delegate, window, cx).show_scrollbar(true)
 54    }
 55}
 56
 57fn all_models(cx: &App) -> GroupedModels {
 58    let lm_registry = LanguageModelRegistry::global(cx).read(cx);
 59    let providers = lm_registry.visible_providers();
 60
 61    let mut favorites_index = FavoritesIndex::default();
 62
 63    for sel in &AgentSettings::get_global(cx).favorite_models {
 64        favorites_index
 65            .entry(sel.provider.0.clone().into())
 66            .or_default()
 67            .insert(sel.model.clone().into());
 68    }
 69
 70    let recommended = providers
 71        .iter()
 72        .flat_map(|provider| {
 73            provider
 74                .recommended_models(cx)
 75                .into_iter()
 76                .map(|model| ModelInfo::new(&**provider, model, &favorites_index))
 77        })
 78        .collect();
 79
 80    let all = providers
 81        .iter()
 82        .flat_map(|provider| {
 83            provider
 84                .provided_models(cx)
 85                .into_iter()
 86                .map(|model| ModelInfo::new(&**provider, model, &favorites_index))
 87        })
 88        .collect();
 89
 90    GroupedModels::new(all, recommended)
 91}
 92
 93type FavoritesIndex = HashMap<LanguageModelProviderId, HashSet<LanguageModelId>>;
 94
 95#[derive(Clone)]
 96struct ModelInfo {
 97    model: Arc<dyn LanguageModel>,
 98    icon: IconOrSvg,
 99    is_favorite: bool,
100}
101
102impl ModelInfo {
103    fn new(
104        provider: &dyn LanguageModelProvider,
105        model: Arc<dyn LanguageModel>,
106        favorites_index: &FavoritesIndex,
107    ) -> Self {
108        let is_favorite = favorites_index
109            .get(&provider.id())
110            .map_or(false, |set| set.contains(&model.id()));
111
112        Self {
113            model,
114            icon: provider.icon(),
115            is_favorite,
116        }
117    }
118}
119
120pub struct LanguageModelPickerDelegate {
121    on_model_changed: OnModelChanged,
122    get_active_model: GetActiveModel,
123    on_toggle_favorite: OnToggleFavorite,
124    all_models: Arc<GroupedModels>,
125    filtered_entries: Vec<LanguageModelPickerEntry>,
126    selected_index: usize,
127    _authenticate_all_providers_task: Task<()>,
128    _subscriptions: Vec<Subscription>,
129    popover_styles: bool,
130    focus_handle: FocusHandle,
131}
132
133impl LanguageModelPickerDelegate {
134    fn new(
135        get_active_model: impl Fn(&App) -> Option<ConfiguredModel> + 'static,
136        on_model_changed: impl Fn(Arc<dyn LanguageModel>, &mut App) + 'static,
137        on_toggle_favorite: impl Fn(Arc<dyn LanguageModel>, bool, &mut App) + 'static,
138        popover_styles: bool,
139        focus_handle: FocusHandle,
140        window: &mut Window,
141        cx: &mut Context<Picker<Self>>,
142    ) -> Self {
143        let on_model_changed = Arc::new(on_model_changed);
144        let models = all_models(cx);
145        let entries = models.entries();
146
147        Self {
148            on_model_changed,
149            all_models: Arc::new(models),
150            selected_index: Self::get_active_model_index(&entries, get_active_model(cx)),
151            filtered_entries: entries,
152            get_active_model: Arc::new(get_active_model),
153            on_toggle_favorite: Arc::new(on_toggle_favorite),
154            _authenticate_all_providers_task: Self::authenticate_all_providers(cx),
155            _subscriptions: vec![cx.subscribe_in(
156                &LanguageModelRegistry::global(cx),
157                window,
158                |picker, _, event, window, cx| {
159                    match event {
160                        language_model::Event::ProviderStateChanged(_)
161                        | language_model::Event::AddedProvider(_)
162                        | language_model::Event::RemovedProvider(_) => {
163                            let query = picker.query(cx);
164                            picker.delegate.all_models = Arc::new(all_models(cx));
165                            // Update matches will automatically drop the previous task
166                            // if we get a provider event again
167                            picker.update_matches(query, window, cx)
168                        }
169                        _ => {}
170                    }
171                },
172            )],
173            popover_styles,
174            focus_handle,
175        }
176    }
177
178    fn get_active_model_index(
179        entries: &[LanguageModelPickerEntry],
180        active_model: Option<ConfiguredModel>,
181    ) -> usize {
182        entries
183            .iter()
184            .position(|entry| {
185                if let LanguageModelPickerEntry::Model(model) = entry {
186                    active_model
187                        .as_ref()
188                        .map(|active_model| {
189                            active_model.model.id() == model.model.id()
190                                && active_model.provider.id() == model.model.provider_id()
191                        })
192                        .unwrap_or_default()
193                } else {
194                    false
195                }
196            })
197            .unwrap_or(0)
198    }
199
200    /// Authenticates all providers in the [`LanguageModelRegistry`].
201    ///
202    /// We do this so that we can populate the language selector with all of the
203    /// models from the configured providers.
204    fn authenticate_all_providers(cx: &mut App) -> Task<()> {
205        let authenticate_all_providers = LanguageModelRegistry::global(cx)
206            .read(cx)
207            .visible_providers()
208            .iter()
209            .map(|provider| (provider.id(), provider.name(), provider.authenticate(cx)))
210            .collect::<Vec<_>>();
211
212        cx.spawn(async move |_cx| {
213            for (provider_id, provider_name, authenticate_task) in authenticate_all_providers {
214                if let Err(err) = authenticate_task.await {
215                    if matches!(err, AuthenticateError::CredentialsNotFound) {
216                        // Since we're authenticating these providers in the
217                        // background for the purposes of populating the
218                        // language selector, we don't care about providers
219                        // where the credentials are not found.
220                    } else {
221                        // Some providers have noisy failure states that we
222                        // don't want to spam the logs with every time the
223                        // language model selector is initialized.
224                        //
225                        // Ideally these should have more clear failure modes
226                        // that we know are safe to ignore here, like what we do
227                        // with `CredentialsNotFound` above.
228                        match provider_id.0.as_ref() {
229                            "lmstudio" | "ollama" => {
230                                // LM Studio and Ollama both make fetch requests to the local APIs to determine if they are "authenticated".
231                                //
232                                // These fail noisily, so we don't log them.
233                            }
234                            "copilot_chat" => {
235                                // Copilot Chat returns an error if Copilot is not enabled, so we don't log those errors.
236                            }
237                            _ => {
238                                log::error!(
239                                    "Failed to authenticate provider: {}: {err:#}",
240                                    provider_name.0
241                                );
242                            }
243                        }
244                    }
245                }
246            }
247        })
248    }
249
250    pub fn active_model(&self, cx: &App) -> Option<ConfiguredModel> {
251        (self.get_active_model)(cx)
252    }
253
254    pub fn favorites_count(&self) -> usize {
255        self.all_models.favorites.len()
256    }
257
258    pub fn cycle_favorite_models(&mut self, window: &mut Window, cx: &mut Context<Picker<Self>>) {
259        if self.all_models.favorites.is_empty() {
260            return;
261        }
262
263        let active_model = (self.get_active_model)(cx);
264        let active_provider_id = active_model.as_ref().map(|m| m.provider.id());
265        let active_model_id = active_model.as_ref().map(|m| m.model.id());
266
267        let current_index = self
268            .all_models
269            .favorites
270            .iter()
271            .position(|info| {
272                Some(info.model.provider_id()) == active_provider_id
273                    && Some(info.model.id()) == active_model_id
274            })
275            .unwrap_or(usize::MAX);
276
277        let next_index = if current_index == usize::MAX {
278            0
279        } else {
280            (current_index + 1) % self.all_models.favorites.len()
281        };
282
283        let next_model = self.all_models.favorites[next_index].model.clone();
284
285        (self.on_model_changed)(next_model, cx);
286
287        // Align the picker selection with the newly-active model
288        let new_index =
289            Self::get_active_model_index(&self.filtered_entries, (self.get_active_model)(cx));
290        self.set_selected_index(new_index, window, cx);
291    }
292}
293
294struct GroupedModels {
295    favorites: Vec<ModelInfo>,
296    recommended: Vec<ModelInfo>,
297    all: IndexMap<LanguageModelProviderId, Vec<ModelInfo>>,
298}
299
300impl GroupedModels {
301    pub fn new(all: Vec<ModelInfo>, recommended: Vec<ModelInfo>) -> Self {
302        let favorites = all
303            .iter()
304            .filter(|info| info.is_favorite)
305            .cloned()
306            .collect();
307
308        let mut all_by_provider: IndexMap<_, Vec<ModelInfo>> = IndexMap::default();
309        for model in all {
310            let provider = model.model.provider_id();
311            if let Some(models) = all_by_provider.get_mut(&provider) {
312                models.push(model);
313            } else {
314                all_by_provider.insert(provider, vec![model]);
315            }
316        }
317
318        Self {
319            favorites,
320            recommended,
321            all: all_by_provider,
322        }
323    }
324
325    fn entries(&self) -> Vec<LanguageModelPickerEntry> {
326        let mut entries = Vec::new();
327
328        if !self.favorites.is_empty() {
329            entries.push(LanguageModelPickerEntry::Separator("Favorite".into()));
330            for info in &self.favorites {
331                entries.push(LanguageModelPickerEntry::Model(info.clone()));
332            }
333        }
334
335        if !self.recommended.is_empty() {
336            entries.push(LanguageModelPickerEntry::Separator("Recommended".into()));
337            for info in &self.recommended {
338                entries.push(LanguageModelPickerEntry::Model(info.clone()));
339            }
340        }
341
342        for models in self.all.values() {
343            if models.is_empty() {
344                continue;
345            }
346            entries.push(LanguageModelPickerEntry::Separator(
347                models[0].model.provider_name().0,
348            ));
349            for info in models {
350                entries.push(LanguageModelPickerEntry::Model(info.clone()));
351            }
352        }
353
354        entries
355    }
356}
357
358enum LanguageModelPickerEntry {
359    Model(ModelInfo),
360    Separator(SharedString),
361}
362
363struct ModelMatcher {
364    models: Vec<ModelInfo>,
365    fg_executor: ForegroundExecutor,
366    bg_executor: BackgroundExecutor,
367    candidates: Vec<StringMatchCandidate>,
368}
369
370impl ModelMatcher {
371    fn new(
372        models: Vec<ModelInfo>,
373        fg_executor: ForegroundExecutor,
374        bg_executor: BackgroundExecutor,
375    ) -> ModelMatcher {
376        let candidates = Self::make_match_candidates(&models);
377        Self {
378            models,
379            fg_executor,
380            bg_executor,
381            candidates,
382        }
383    }
384
385    pub fn fuzzy_search(&self, query: &str) -> Vec<ModelInfo> {
386        let mut matches = self.fg_executor.block_on(match_strings(
387            &self.candidates,
388            query,
389            false,
390            true,
391            100,
392            &Default::default(),
393            self.bg_executor.clone(),
394        ));
395
396        let sorting_key = |mat: &StringMatch| {
397            let candidate = &self.candidates[mat.candidate_id];
398            (Reverse(OrderedFloat(mat.score)), candidate.id)
399        };
400        matches.sort_unstable_by_key(sorting_key);
401
402        let matched_models: Vec<_> = matches
403            .into_iter()
404            .map(|mat| self.models[mat.candidate_id].clone())
405            .collect();
406
407        matched_models
408    }
409
410    pub fn exact_search(&self, query: &str) -> Vec<ModelInfo> {
411        self.models
412            .iter()
413            .filter(|m| {
414                m.model
415                    .name()
416                    .0
417                    .to_lowercase()
418                    .contains(&query.to_lowercase())
419            })
420            .cloned()
421            .collect::<Vec<_>>()
422    }
423
424    fn make_match_candidates(model_infos: &Vec<ModelInfo>) -> Vec<StringMatchCandidate> {
425        model_infos
426            .iter()
427            .enumerate()
428            .map(|(index, model)| {
429                StringMatchCandidate::new(
430                    index,
431                    &format!(
432                        "{}/{}",
433                        &model.model.provider_name().0,
434                        &model.model.name().0
435                    ),
436                )
437            })
438            .collect::<Vec<_>>()
439    }
440}
441
442impl PickerDelegate for LanguageModelPickerDelegate {
443    type ListItem = AnyElement;
444
445    fn match_count(&self) -> usize {
446        self.filtered_entries.len()
447    }
448
449    fn selected_index(&self) -> usize {
450        self.selected_index
451    }
452
453    fn set_selected_index(&mut self, ix: usize, _: &mut Window, cx: &mut Context<Picker<Self>>) {
454        self.selected_index = ix.min(self.filtered_entries.len().saturating_sub(1));
455        cx.notify();
456    }
457
458    fn can_select(
459        &mut self,
460        ix: usize,
461        _window: &mut Window,
462        _cx: &mut Context<Picker<Self>>,
463    ) -> bool {
464        match self.filtered_entries.get(ix) {
465            Some(LanguageModelPickerEntry::Model(_)) => true,
466            Some(LanguageModelPickerEntry::Separator(_)) | None => false,
467        }
468    }
469
470    fn placeholder_text(&self, _window: &mut Window, _cx: &mut App) -> Arc<str> {
471        "Select a model…".into()
472    }
473
474    fn update_matches(
475        &mut self,
476        query: String,
477        window: &mut Window,
478        cx: &mut Context<Picker<Self>>,
479    ) -> Task<()> {
480        let all_models = self.all_models.clone();
481        let active_model = (self.get_active_model)(cx);
482        let fg_executor = cx.foreground_executor();
483        let bg_executor = cx.background_executor();
484
485        let language_model_registry = LanguageModelRegistry::global(cx);
486
487        let configured_providers = language_model_registry
488            .read(cx)
489            .visible_providers()
490            .into_iter()
491            .filter(|provider| provider.is_authenticated(cx))
492            .collect::<Vec<_>>();
493
494        let configured_provider_ids = configured_providers
495            .iter()
496            .map(|provider| provider.id())
497            .collect::<Vec<_>>();
498
499        let recommended_models = all_models
500            .recommended
501            .iter()
502            .filter(|m| configured_provider_ids.contains(&m.model.provider_id()))
503            .cloned()
504            .collect::<Vec<_>>();
505
506        let available_models = all_models
507            .all
508            .values()
509            .flat_map(|models| models.iter())
510            .filter(|m| configured_provider_ids.contains(&m.model.provider_id()))
511            .cloned()
512            .collect::<Vec<_>>();
513
514        let matcher_rec =
515            ModelMatcher::new(recommended_models, fg_executor.clone(), bg_executor.clone());
516        let matcher_all =
517            ModelMatcher::new(available_models, fg_executor.clone(), bg_executor.clone());
518
519        let recommended = matcher_rec.exact_search(&query);
520        let all = matcher_all.fuzzy_search(&query);
521
522        let filtered_models = GroupedModels::new(all, recommended);
523
524        cx.spawn_in(window, async move |this, cx| {
525            this.update_in(cx, |this, window, cx| {
526                this.delegate.filtered_entries = filtered_models.entries();
527                // Finds the currently selected model in the list
528                let new_index =
529                    Self::get_active_model_index(&this.delegate.filtered_entries, active_model);
530                this.set_selected_index(new_index, Some(picker::Direction::Down), true, window, cx);
531                cx.notify();
532            })
533            .ok();
534        })
535    }
536
537    fn confirm(&mut self, _secondary: bool, window: &mut Window, cx: &mut Context<Picker<Self>>) {
538        if let Some(LanguageModelPickerEntry::Model(model_info)) =
539            self.filtered_entries.get(self.selected_index)
540        {
541            let model = model_info.model.clone();
542            (self.on_model_changed)(model.clone(), cx);
543
544            let current_index = self.selected_index;
545            self.set_selected_index(current_index, window, cx);
546
547            cx.emit(DismissEvent);
548        }
549    }
550
551    fn dismissed(&mut self, _: &mut Window, cx: &mut Context<Picker<Self>>) {
552        cx.emit(DismissEvent);
553    }
554
555    fn render_match(
556        &self,
557        ix: usize,
558        selected: bool,
559        _: &mut Window,
560        cx: &mut Context<Picker<Self>>,
561    ) -> Option<Self::ListItem> {
562        match self.filtered_entries.get(ix)? {
563            LanguageModelPickerEntry::Separator(title) => {
564                Some(ModelSelectorHeader::new(title, ix > 1).into_any_element())
565            }
566            LanguageModelPickerEntry::Model(model_info) => {
567                let active_model = (self.get_active_model)(cx);
568                let active_provider_id = active_model.as_ref().map(|m| m.provider.id());
569                let active_model_id = active_model.map(|m| m.model.id());
570
571                let is_selected = Some(model_info.model.provider_id()) == active_provider_id
572                    && Some(model_info.model.id()) == active_model_id;
573
574                let is_favorite = model_info.is_favorite;
575                let handle_action_click = {
576                    let model = model_info.model.clone();
577                    let on_toggle_favorite = self.on_toggle_favorite.clone();
578                    cx.listener(move |picker, _, window, cx| {
579                        on_toggle_favorite(model.clone(), !is_favorite, cx);
580                        picker.refresh(window, cx);
581                    })
582                };
583
584                Some(
585                    ModelSelectorListItem::new(ix, model_info.model.name().0)
586                        .map(|this| match &model_info.icon {
587                            IconOrSvg::Icon(icon_name) => this.icon(*icon_name),
588                            IconOrSvg::Svg(icon_path) => this.icon_path(icon_path.clone()),
589                        })
590                        .is_selected(is_selected)
591                        .is_focused(selected)
592                        .is_favorite(is_favorite)
593                        .on_toggle_favorite(handle_action_click)
594                        .into_any_element(),
595                )
596            }
597        }
598    }
599
600    fn render_footer(
601        &self,
602        _window: &mut Window,
603        _cx: &mut Context<Picker<Self>>,
604    ) -> Option<gpui::AnyElement> {
605        let focus_handle = self.focus_handle.clone();
606
607        if !self.popover_styles {
608            return None;
609        }
610
611        Some(ModelSelectorFooter::new(OpenSettings.boxed_clone(), focus_handle).into_any_element())
612    }
613}
614
615#[cfg(test)]
616mod tests {
617    use super::*;
618    use futures::{future::BoxFuture, stream::BoxStream};
619    use gpui::{AsyncApp, TestAppContext, http_client};
620    use language_model::{
621        LanguageModelCompletionError, LanguageModelCompletionEvent, LanguageModelId,
622        LanguageModelName, LanguageModelProviderId, LanguageModelProviderName,
623        LanguageModelRequest, LanguageModelToolChoice,
624    };
625    use ui::IconName;
626
627    #[derive(Clone)]
628    struct TestLanguageModel {
629        name: LanguageModelName,
630        id: LanguageModelId,
631        provider_id: LanguageModelProviderId,
632        provider_name: LanguageModelProviderName,
633    }
634
635    impl TestLanguageModel {
636        fn new(name: &str, provider: &str) -> Self {
637            Self {
638                name: LanguageModelName::from(name.to_string()),
639                id: LanguageModelId::from(name.to_string()),
640                provider_id: LanguageModelProviderId::from(provider.to_string()),
641                provider_name: LanguageModelProviderName::from(provider.to_string()),
642            }
643        }
644    }
645
646    impl LanguageModel for TestLanguageModel {
647        fn id(&self) -> LanguageModelId {
648            self.id.clone()
649        }
650
651        fn name(&self) -> LanguageModelName {
652            self.name.clone()
653        }
654
655        fn provider_id(&self) -> LanguageModelProviderId {
656            self.provider_id.clone()
657        }
658
659        fn provider_name(&self) -> LanguageModelProviderName {
660            self.provider_name.clone()
661        }
662
663        fn supports_tools(&self) -> bool {
664            false
665        }
666
667        fn supports_tool_choice(&self, _choice: LanguageModelToolChoice) -> bool {
668            false
669        }
670
671        fn supports_images(&self) -> bool {
672            false
673        }
674
675        fn telemetry_id(&self) -> String {
676            format!("{}/{}", self.provider_id.0, self.name.0)
677        }
678
679        fn max_token_count(&self) -> u64 {
680            1000
681        }
682
683        fn count_tokens(
684            &self,
685            _: LanguageModelRequest,
686            _: &App,
687        ) -> BoxFuture<'static, http_client::Result<u64>> {
688            unimplemented!()
689        }
690
691        fn stream_completion(
692            &self,
693            _: LanguageModelRequest,
694            _: &AsyncApp,
695        ) -> BoxFuture<
696            'static,
697            Result<
698                BoxStream<
699                    'static,
700                    Result<LanguageModelCompletionEvent, LanguageModelCompletionError>,
701                >,
702                LanguageModelCompletionError,
703            >,
704        > {
705            unimplemented!()
706        }
707    }
708
709    fn create_models(model_specs: Vec<(&str, &str)>) -> Vec<ModelInfo> {
710        create_models_with_favorites(model_specs, vec![])
711    }
712
713    fn create_models_with_favorites(
714        model_specs: Vec<(&str, &str)>,
715        favorites: Vec<(&str, &str)>,
716    ) -> Vec<ModelInfo> {
717        model_specs
718            .into_iter()
719            .map(|(provider, name)| {
720                let is_favorite = favorites
721                    .iter()
722                    .any(|(fav_provider, fav_name)| *fav_provider == provider && *fav_name == name);
723                ModelInfo {
724                    model: Arc::new(TestLanguageModel::new(name, provider)),
725                    icon: IconOrSvg::Icon(IconName::Ai),
726                    is_favorite,
727                }
728            })
729            .collect()
730    }
731
732    fn assert_models_eq(result: Vec<ModelInfo>, expected: Vec<&str>) {
733        assert_eq!(
734            result.len(),
735            expected.len(),
736            "Number of models doesn't match"
737        );
738
739        for (i, expected_name) in expected.iter().enumerate() {
740            assert_eq!(
741                result[i].model.telemetry_id(),
742                *expected_name,
743                "Model at position {} doesn't match expected model",
744                i
745            );
746        }
747    }
748
749    #[gpui::test]
750    fn test_exact_match(cx: &mut TestAppContext) {
751        let models = create_models(vec![
752            ("zed", "Claude 3.7 Sonnet"),
753            ("zed", "Claude 3.7 Sonnet Thinking"),
754            ("zed", "gpt-4.1"),
755            ("zed", "gpt-4.1-nano"),
756            ("openai", "gpt-3.5-turbo"),
757            ("openai", "gpt-4.1"),
758            ("openai", "gpt-4.1-nano"),
759            ("ollama", "mistral"),
760            ("ollama", "deepseek"),
761        ]);
762        let matcher = ModelMatcher::new(
763            models,
764            cx.foreground_executor().clone(),
765            cx.background_executor.clone(),
766        );
767
768        // The order of models should be maintained, case doesn't matter
769        let results = matcher.exact_search("GPT-4.1");
770        assert_models_eq(
771            results,
772            vec![
773                "zed/gpt-4.1",
774                "zed/gpt-4.1-nano",
775                "openai/gpt-4.1",
776                "openai/gpt-4.1-nano",
777            ],
778        );
779    }
780
781    #[gpui::test]
782    fn test_fuzzy_match(cx: &mut TestAppContext) {
783        let models = create_models(vec![
784            ("zed", "Claude 3.7 Sonnet"),
785            ("zed", "Claude 3.7 Sonnet Thinking"),
786            ("zed", "gpt-4.1"),
787            ("zed", "gpt-4.1-nano"),
788            ("openai", "gpt-3.5-turbo"),
789            ("openai", "gpt-4.1"),
790            ("openai", "gpt-4.1-nano"),
791            ("ollama", "mistral"),
792            ("ollama", "deepseek"),
793        ]);
794        let matcher = ModelMatcher::new(
795            models,
796            cx.foreground_executor().clone(),
797            cx.background_executor.clone(),
798        );
799
800        // Results should preserve models order whenever possible.
801        // In the case below, `zed/gpt-4.1` and `openai/gpt-4.1` have identical
802        // similarity scores, but `zed/gpt-4.1` was higher in the models list,
803        // so it should appear first in the results.
804        let results = matcher.fuzzy_search("41");
805        assert_models_eq(
806            results,
807            vec![
808                "zed/gpt-4.1",
809                "openai/gpt-4.1",
810                "zed/gpt-4.1-nano",
811                "openai/gpt-4.1-nano",
812            ],
813        );
814
815        // Model provider should be searchable as well
816        let results = matcher.fuzzy_search("ol"); // meaning "ollama"
817        assert_models_eq(results, vec!["ollama/mistral", "ollama/deepseek"]);
818
819        // Fuzzy search
820        let results = matcher.fuzzy_search("z4n");
821        assert_models_eq(results, vec!["zed/gpt-4.1-nano"]);
822    }
823
824    #[gpui::test]
825    fn test_recommended_models_also_appear_in_other(_cx: &mut TestAppContext) {
826        let recommended_models = create_models(vec![("zed", "claude")]);
827        let all_models = create_models(vec![
828            ("zed", "claude"), // Should also appear in "other"
829            ("zed", "gemini"),
830            ("copilot", "o3"),
831        ]);
832
833        let grouped_models = GroupedModels::new(all_models, recommended_models);
834
835        let actual_all_models = grouped_models
836            .all
837            .values()
838            .flatten()
839            .cloned()
840            .collect::<Vec<_>>();
841
842        // Recommended models should also appear in "all"
843        assert_models_eq(
844            actual_all_models,
845            vec!["zed/claude", "zed/gemini", "copilot/o3"],
846        );
847    }
848
849    #[gpui::test]
850    fn test_models_from_different_providers(_cx: &mut TestAppContext) {
851        let recommended_models = create_models(vec![("zed", "claude")]);
852        let all_models = create_models(vec![
853            ("zed", "claude"), // Should also appear in "other"
854            ("zed", "gemini"),
855            ("copilot", "claude"), // Different provider, should appear in "other"
856        ]);
857
858        let grouped_models = GroupedModels::new(all_models, recommended_models);
859
860        let actual_all_models = grouped_models
861            .all
862            .values()
863            .flatten()
864            .cloned()
865            .collect::<Vec<_>>();
866
867        // All models should appear in "all" regardless of recommended status
868        assert_models_eq(
869            actual_all_models,
870            vec!["zed/claude", "zed/gemini", "copilot/claude"],
871        );
872    }
873
874    #[gpui::test]
875    fn test_favorites_section_appears_when_favorites_exist(_cx: &mut TestAppContext) {
876        let recommended_models = create_models(vec![("zed", "claude")]);
877        let all_models = create_models_with_favorites(
878            vec![("zed", "claude"), ("zed", "gemini"), ("openai", "gpt-4")],
879            vec![("zed", "gemini")],
880        );
881
882        let grouped_models = GroupedModels::new(all_models, recommended_models);
883        let entries = grouped_models.entries();
884
885        assert!(matches!(
886            entries.first(),
887            Some(LanguageModelPickerEntry::Separator(s)) if s == "Favorite"
888        ));
889
890        assert_models_eq(grouped_models.favorites, vec!["zed/gemini"]);
891    }
892
893    #[gpui::test]
894    fn test_no_favorites_section_when_no_favorites(_cx: &mut TestAppContext) {
895        let recommended_models = create_models(vec![("zed", "claude")]);
896        let all_models = create_models(vec![("zed", "claude"), ("zed", "gemini")]);
897
898        let grouped_models = GroupedModels::new(all_models, recommended_models);
899        let entries = grouped_models.entries();
900
901        assert!(matches!(
902            entries.first(),
903            Some(LanguageModelPickerEntry::Separator(s)) if s == "Recommended"
904        ));
905
906        assert!(grouped_models.favorites.is_empty());
907    }
908
909    #[gpui::test]
910    fn test_models_have_correct_actions(_cx: &mut TestAppContext) {
911        let recommended_models =
912            create_models_with_favorites(vec![("zed", "claude")], vec![("zed", "claude")]);
913        let all_models = create_models_with_favorites(
914            vec![("zed", "claude"), ("zed", "gemini"), ("openai", "gpt-4")],
915            vec![("zed", "claude")],
916        );
917
918        let grouped_models = GroupedModels::new(all_models, recommended_models);
919        let entries = grouped_models.entries();
920
921        for entry in &entries {
922            if let LanguageModelPickerEntry::Model(info) = entry {
923                if info.model.telemetry_id() == "zed/claude" {
924                    assert!(info.is_favorite, "zed/claude should be a favorite");
925                } else {
926                    assert!(
927                        !info.is_favorite,
928                        "{} should not be a favorite",
929                        info.model.telemetry_id()
930                    );
931                }
932            }
933        }
934    }
935
936    #[gpui::test]
937    fn test_favorites_appear_in_other_sections(_cx: &mut TestAppContext) {
938        let favorites = vec![("zed", "gemini"), ("openai", "gpt-4")];
939
940        let recommended_models =
941            create_models_with_favorites(vec![("zed", "claude")], favorites.clone());
942
943        let all_models = create_models_with_favorites(
944            vec![
945                ("zed", "claude"),
946                ("zed", "gemini"),
947                ("openai", "gpt-4"),
948                ("openai", "gpt-3.5"),
949            ],
950            favorites,
951        );
952
953        let grouped_models = GroupedModels::new(all_models, recommended_models);
954
955        assert_models_eq(grouped_models.favorites, vec!["zed/gemini", "openai/gpt-4"]);
956        assert_models_eq(grouped_models.recommended, vec!["zed/claude"]);
957        assert_models_eq(
958            grouped_models.all.values().flatten().cloned().collect(),
959            vec!["zed/claude", "zed/gemini", "openai/gpt-4", "openai/gpt-3.5"],
960        );
961    }
962}