mod model;pub mod provider;mod rate_limiter;mod registry;mod request;mod role;pub mod settings; use anyhow::Result;use client::{Client, UserStore};use futures::FutureExt;use futures::{future::BoxFuture, stream::BoxStream, StreamExt, TryStreamExt as _};use gpui::{    AnyElement, AnyView, AppContext, AsyncAppContext, Model, SharedString, Task, WindowContext,};pub use model::*;use project::Fs;use proto::Plan;pub(crate) use rate_limiter::*;pub use registry::*;pub use request::*;pub use role::*;use schemars::JsonSchema;use serde::{de::DeserializeOwned, Deserialize, Serialize};use std::{future::Future, sync::Arc};use ui::IconName; pub fn init(    user_store: Model<UserStore>,    client: Arc<Client>,    fs: Arc<dyn Fs>,    cx: &mut AppContext,) {    settings::init(fs, cx);    registry::init(user_store, client, cx);} /// The availability of a [`LanguageModel`].#[derive(Debug, PartialEq, Eq, Clone, Copy)]pub enum LanguageModelAvailability {    /// The language model is available to the general public.    Public,    /// The language model is available to users on the indicated plan.    RequiresPlan(Plan),} /// Configuration for caching language model messages.#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, JsonSchema)]pub struct LanguageModelCacheConfiguration {    pub max_cache_anchors: usize,    pub should_speculate: bool,    pub min_total_token: usize,} /// A completion event from a language model.#[derive(Debug, PartialEq, Clone, Serialize, Deserialize)]pub enum LanguageModelCompletionEvent {    Stop(StopReason),    Text(String),    ToolUse(LanguageModelToolUse),} #[derive(Debug, PartialEq, Clone, Serialize, Deserialize)]#[serde(rename_all = "snake_case")]pub enum StopReason {    EndTurn,    MaxTokens,    ToolUse,} #[derive(Debug, PartialEq, Eq, Hash, Clone, Serialize, Deserialize)]pub struct LanguageModelToolUse {    pub id: String,    pub name: String,    pub input: serde_json::Value,} pub trait LanguageModel: Send + Sync {    fn id(&self) -> LanguageModelId;    fn name(&self) -> LanguageModelName;    /// If None, falls back to [LanguageModelProvider::icon]    fn icon(&self) -> Option<IconName> {        None    }    fn provider_id(&self) -> LanguageModelProviderId;    fn provider_name(&self) -> LanguageModelProviderName;    fn telemetry_id(&self) -> String;     /// Returns the availability of this language model.    fn availability(&self) -> LanguageModelAvailability {        LanguageModelAvailability::Public    }     fn max_token_count(&self) -> usize;    fn max_output_tokens(&self) -> Option<u32> {        None    }     fn count_tokens(        &self,        request: LanguageModelRequest,        cx: &AppContext,    ) -> BoxFuture<'static, Result<usize>>;     fn stream_completion(        &self,        request: LanguageModelRequest,        cx: &AsyncAppContext,    ) -> BoxFuture<'static, Result<BoxStream<'static, Result<LanguageModelCompletionEvent>>>>;     fn stream_completion_text(        &self,        request: LanguageModelRequest,        cx: &AsyncAppContext,    ) -> BoxFuture<'static, Result<BoxStream<'static, Result<String>>>> {        let events = self.stream_completion(request, cx);         async move {            Ok(events                .await?                .filter_map(|result| async move {                    match result {                        Ok(LanguageModelCompletionEvent::Text(text)) => Some(Ok(text)),                        Ok(LanguageModelCompletionEvent::Stop(_)) => None,                        Ok(LanguageModelCompletionEvent::ToolUse(_)) => None,                        Err(err) => Some(Err(err)),                    }                })                .boxed())        }        .boxed()    }     fn use_any_tool(        &self,        request: LanguageModelRequest,        name: String,        description: String,        schema: serde_json::Value,        cx: &AsyncAppContext,    ) -> BoxFuture<'static, Result<BoxStream<'static, Result<String>>>>;     fn cache_configuration(&self) -> Option<LanguageModelCacheConfiguration> {        None    }     #[cfg(any(test, feature = "test-support"))]    fn as_fake(&self) -> &provider::fake::FakeLanguageModel {        unimplemented!()    }} impl dyn LanguageModel {    pub fn use_tool<T: LanguageModelTool>(        &self,        request: LanguageModelRequest,        cx: &AsyncAppContext,    ) -> impl 'static + Future<Output = Result<T>> {        let schema = schemars::schema_for!(T);        let schema_json = serde_json::to_value(&schema).unwrap();        let stream = self.use_any_tool(request, T::name(), T::description(), schema_json, cx);        async move {            let stream = stream.await?;            let response = stream.try_collect::<String>().await?;            Ok(serde_json::from_str(&response)?)        }    }     pub fn use_tool_stream<T: LanguageModelTool>(        &self,        request: LanguageModelRequest,        cx: &AsyncAppContext,    ) -> BoxFuture<'static, Result<BoxStream<'static, Result<String>>>> {        let schema = schemars::schema_for!(T);        let schema_json = serde_json::to_value(&schema).unwrap();        self.use_any_tool(request, T::name(), T::description(), schema_json, cx)    }} pub trait LanguageModelTool: 'static + DeserializeOwned + JsonSchema {    fn name() -> String;    fn description() -> String;} pub trait LanguageModelProvider: 'static {    fn id(&self) -> LanguageModelProviderId;    fn name(&self) -> LanguageModelProviderName;    fn icon(&self) -> IconName {        IconName::ZedAssistant    }    fn provided_models(&self, cx: &AppContext) -> Vec<Arc<dyn LanguageModel>>;    fn load_model(&self, _model: Arc<dyn LanguageModel>, _cx: &AppContext) {}    fn is_authenticated(&self, cx: &AppContext) -> bool;    fn authenticate(&self, cx: &mut AppContext) -> Task<Result<()>>;    fn configuration_view(&self, cx: &mut WindowContext) -> AnyView;    fn must_accept_terms(&self, _cx: &AppContext) -> bool {        false    }    fn render_accept_terms(&self, _cx: &mut WindowContext) -> Option<AnyElement> {        None    }    fn reset_credentials(&self, cx: &mut AppContext) -> Task<Result<()>>;} pub trait LanguageModelProviderState: 'static {    type ObservableEntity;     fn observable_entity(&self) -> Option<gpui::Model<Self::ObservableEntity>>;     fn subscribe<T: 'static>(        &self,        cx: &mut gpui::ModelContext<T>,        callback: impl Fn(&mut T, &mut gpui::ModelContext<T>) + 'static,    ) -> Option<gpui::Subscription> {        let entity = self.observable_entity()?;        Some(cx.observe(&entity, move |this, _, cx| {            callback(this, cx);        }))    }} #[derive(Clone, Eq, PartialEq, Hash, Debug, Ord, PartialOrd)]pub struct LanguageModelId(pub SharedString); #[derive(Clone, Eq, PartialEq, Hash, Debug, Ord, PartialOrd)]pub struct LanguageModelName(pub SharedString); #[derive(Clone, Eq, PartialEq, Hash, Debug, Ord, PartialOrd)]pub struct LanguageModelProviderId(pub SharedString); #[derive(Clone, Eq, PartialEq, Hash, Debug, Ord, PartialOrd)]pub struct LanguageModelProviderName(pub SharedString); impl From<String> for LanguageModelId {    fn from(value: String) -> Self {        Self(SharedString::from(value))    }} impl From<String> for LanguageModelName {    fn from(value: String) -> Self {        Self(SharedString::from(value))    }} impl From<String> for LanguageModelProviderId {    fn from(value: String) -> Self {        Self(SharedString::from(value))    }} impl From<String> for LanguageModelProviderName {    fn from(value: String) -> Self {        Self(SharedString::from(value))    }}