use anyhow::{Context as _, Result, anyhow};use collections::HashMap;use credentials_provider::CredentialsProvider;use editor::{Editor, EditorElement, EditorStyle};use futures::{FutureExt, Stream, StreamExt, future::BoxFuture};use gpui::{    AnyView, App, AsyncApp, Context, Entity, FontStyle, Subscription, Task, TextStyle, WhiteSpace,};use http_client::HttpClient;use language_model::{    AuthenticateError, LanguageModel, LanguageModelCompletionError, LanguageModelCompletionEvent,    LanguageModelId, LanguageModelName, LanguageModelProvider, LanguageModelProviderId,    LanguageModelProviderName, LanguageModelProviderState, LanguageModelRequest,    LanguageModelToolChoice, LanguageModelToolResultContent, LanguageModelToolUse, MessageContent,    RateLimiter, Role, StopReason,};use open_router::{Model, ResponseStreamEvent, list_models, stream_completion};use schemars::JsonSchema;use serde::{Deserialize, Serialize};use settings::{Settings, SettingsStore};use std::pin::Pin;use std::str::FromStr as _;use std::sync::Arc;use theme::ThemeSettings;use ui::{Icon, IconName, List, Tooltip, prelude::*};use util::ResultExt; use crate::{AllLanguageModelSettings, ui::InstructionListItem}; const PROVIDER_ID: &str = "openrouter";const PROVIDER_NAME: &str = "OpenRouter"; #[derive(Default, Clone, Debug, PartialEq)]pub struct OpenRouterSettings {    pub api_url: String,    pub available_models: Vec<AvailableModel>,} #[derive(Clone, Debug, PartialEq, Serialize, Deserialize, JsonSchema)]pub struct AvailableModel {    pub name: String,    pub display_name: Option<String>,    pub max_tokens: usize,    pub max_output_tokens: Option<u32>,    pub max_completion_tokens: Option<u32>,} pub struct OpenRouterLanguageModelProvider {    http_client: Arc<dyn HttpClient>,    state: gpui::Entity<State>,} pub struct State {    api_key: Option<String>,    api_key_from_env: bool,    http_client: Arc<dyn HttpClient>,    available_models: Vec<open_router::Model>,    fetch_models_task: Option<Task<Result<()>>>,    _subscription: Subscription,} const OPENROUTER_API_KEY_VAR: &str = "OPENROUTER_API_KEY"; impl State {    fn is_authenticated(&self) -> bool {        self.api_key.is_some()    }     fn reset_api_key(&self, cx: &mut Context<Self>) -> Task<Result<()>> {        let credentials_provider = <dyn CredentialsProvider>::global(cx);        let api_url = AllLanguageModelSettings::get_global(cx)            .open_router            .api_url            .clone();        cx.spawn(async move |this, cx| {            credentials_provider                .delete_credentials(&api_url, &cx)                .await                .log_err();            this.update(cx, |this, cx| {                this.api_key = None;                this.api_key_from_env = false;                cx.notify();            })        })    }     fn set_api_key(&mut self, api_key: String, cx: &mut Context<Self>) -> Task<Result<()>> {        let credentials_provider = <dyn CredentialsProvider>::global(cx);        let api_url = AllLanguageModelSettings::get_global(cx)            .open_router            .api_url            .clone();        cx.spawn(async move |this, cx| {            credentials_provider                .write_credentials(&api_url, "Bearer", api_key.as_bytes(), &cx)                .await                .log_err();            this.update(cx, |this, cx| {                this.api_key = Some(api_key);                cx.notify();            })        })    }     fn authenticate(&self, cx: &mut Context<Self>) -> Task<Result<(), AuthenticateError>> {        if self.is_authenticated() {            return Task::ready(Ok(()));        }         let credentials_provider = <dyn CredentialsProvider>::global(cx);        let api_url = AllLanguageModelSettings::get_global(cx)            .open_router            .api_url            .clone();        cx.spawn(async move |this, cx| {            let (api_key, from_env) = if let Ok(api_key) = std::env::var(OPENROUTER_API_KEY_VAR) {                (api_key, true)            } else {                let (_, api_key) = credentials_provider                    .read_credentials(&api_url, &cx)                    .await?                    .ok_or(AuthenticateError::CredentialsNotFound)?;                (                    String::from_utf8(api_key)                        .context(format!("invalid {} API key", PROVIDER_NAME))?,                    false,                )            };            this.update(cx, |this, cx| {                this.api_key = Some(api_key);                this.api_key_from_env = from_env;                cx.notify();            })?;             Ok(())        })    }     fn fetch_models(&mut self, cx: &mut Context<Self>) -> Task<Result<()>> {        let settings = &AllLanguageModelSettings::get_global(cx).open_router;        let http_client = self.http_client.clone();        let api_url = settings.api_url.clone();         cx.spawn(async move |this, cx| {            let models = list_models(http_client.as_ref(), &api_url).await?;             this.update(cx, |this, cx| {                this.available_models = models;                cx.notify();            })        })    }     fn restart_fetch_models_task(&mut self, cx: &mut Context<Self>) {        let task = self.fetch_models(cx);        self.fetch_models_task.replace(task);    }} impl OpenRouterLanguageModelProvider {    pub fn new(http_client: Arc<dyn HttpClient>, cx: &mut App) -> Self {        let state = cx.new(|cx| State {            api_key: None,            api_key_from_env: false,            http_client: http_client.clone(),            available_models: Vec::new(),            fetch_models_task: None,            _subscription: cx.observe_global::<SettingsStore>(|this: &mut State, cx| {                this.restart_fetch_models_task(cx);                cx.notify();            }),        });         Self { http_client, state }    }     fn create_language_model(&self, model: open_router::Model) -> Arc<dyn LanguageModel> {        Arc::new(OpenRouterLanguageModel {            id: LanguageModelId::from(model.id().to_string()),            model,            state: self.state.clone(),            http_client: self.http_client.clone(),            request_limiter: RateLimiter::new(4),        })    }} impl LanguageModelProviderState for OpenRouterLanguageModelProvider {    type ObservableEntity = State;     fn observable_entity(&self) -> Option<gpui::Entity<Self::ObservableEntity>> {        Some(self.state.clone())    }} impl LanguageModelProvider for OpenRouterLanguageModelProvider {    fn id(&self) -> LanguageModelProviderId {        LanguageModelProviderId(PROVIDER_ID.into())    }     fn name(&self) -> LanguageModelProviderName {        LanguageModelProviderName(PROVIDER_NAME.into())    }     fn icon(&self) -> IconName {        IconName::AiOpenRouter    }     fn default_model(&self, _cx: &App) -> Option<Arc<dyn LanguageModel>> {        Some(self.create_language_model(open_router::Model::default()))    }     fn default_fast_model(&self, _cx: &App) -> Option<Arc<dyn LanguageModel>> {        Some(self.create_language_model(open_router::Model::default_fast()))    }     fn provided_models(&self, cx: &App) -> Vec<Arc<dyn LanguageModel>> {        let mut models_from_api = self.state.read(cx).available_models.clone();        let mut settings_models = Vec::new();         for model in &AllLanguageModelSettings::get_global(cx)            .open_router            .available_models        {            settings_models.push(open_router::Model {                name: model.name.clone(),                display_name: model.display_name.clone(),                max_tokens: model.max_tokens,                supports_tools: Some(false),            });        }         for settings_model in &settings_models {            if let Some(pos) = models_from_api                .iter()                .position(|m| m.name == settings_model.name)            {                models_from_api[pos] = settings_model.clone();            } else {                models_from_api.push(settings_model.clone());            }        }         models_from_api            .into_iter()            .map(|model| self.create_language_model(model))            .collect()    }     fn is_authenticated(&self, cx: &App) -> bool {        self.state.read(cx).is_authenticated()    }     fn authenticate(&self, cx: &mut App) -> Task<Result<(), AuthenticateError>> {        self.state.update(cx, |state, cx| state.authenticate(cx))    }     fn configuration_view(&self, window: &mut Window, cx: &mut App) -> AnyView {        cx.new(|cx| ConfigurationView::new(self.state.clone(), window, cx))            .into()    }     fn reset_credentials(&self, cx: &mut App) -> Task<Result<()>> {        self.state.update(cx, |state, cx| state.reset_api_key(cx))    }} pub struct OpenRouterLanguageModel {    id: LanguageModelId,    model: open_router::Model,    state: gpui::Entity<State>,    http_client: Arc<dyn HttpClient>,    request_limiter: RateLimiter,} impl OpenRouterLanguageModel {    fn stream_completion(        &self,        request: open_router::Request,        cx: &AsyncApp,    ) -> BoxFuture<'static, Result<futures::stream::BoxStream<'static, Result<ResponseStreamEvent>>>>    {        let http_client = self.http_client.clone();        let Ok((api_key, api_url)) = cx.read_entity(&self.state, |state, cx| {            let settings = &AllLanguageModelSettings::get_global(cx).open_router;            (state.api_key.clone(), settings.api_url.clone())        }) else {            return futures::future::ready(Err(anyhow!(                "App state dropped: Unable to read API key or API URL from the application state"            )))            .boxed();        };         let future = self.request_limiter.stream(async move {            let api_key = api_key.ok_or_else(|| anyhow!("Missing OpenRouter API Key"))?;            let request = stream_completion(http_client.as_ref(), &api_url, &api_key, request);            let response = request.await?;            Ok(response)        });         async move { Ok(future.await?.boxed()) }.boxed()    }} impl LanguageModel for OpenRouterLanguageModel {    fn id(&self) -> LanguageModelId {        self.id.clone()    }     fn name(&self) -> LanguageModelName {        LanguageModelName::from(self.model.display_name().to_string())    }     fn provider_id(&self) -> LanguageModelProviderId {        LanguageModelProviderId(PROVIDER_ID.into())    }     fn provider_name(&self) -> LanguageModelProviderName {        LanguageModelProviderName(PROVIDER_NAME.into())    }     fn supports_tools(&self) -> bool {        self.model.supports_tool_calls()    }     fn telemetry_id(&self) -> String {        format!("openrouter/{}", self.model.id())    }     fn max_token_count(&self) -> usize {        self.model.max_token_count()    }     fn max_output_tokens(&self) -> Option<u32> {        self.model.max_output_tokens()    }     fn supports_tool_choice(&self, choice: LanguageModelToolChoice) -> bool {        match choice {            LanguageModelToolChoice::Auto => true,            LanguageModelToolChoice::Any => true,            LanguageModelToolChoice::None => true,        }    }     fn supports_images(&self) -> bool {        false    }     fn count_tokens(        &self,        request: LanguageModelRequest,        cx: &App,    ) -> BoxFuture<'static, Result<usize>> {        count_open_router_tokens(request, self.model.clone(), cx)    }     fn stream_completion(        &self,        request: LanguageModelRequest,        cx: &AsyncApp,    ) -> BoxFuture<        'static,        Result<            futures::stream::BoxStream<                'static,                Result<LanguageModelCompletionEvent, LanguageModelCompletionError>,            >,        >,    > {        let request = into_open_router(request, &self.model, self.max_output_tokens());        let completions = self.stream_completion(request, cx);        async move {            let mapper = OpenRouterEventMapper::new();            Ok(mapper.map_stream(completions.await?).boxed())        }        .boxed()    }} pub fn into_open_router(    request: LanguageModelRequest,    model: &Model,    max_output_tokens: Option<u32>,) -> open_router::Request {    let mut messages = Vec::new();    for req_message in request.messages {        for content in req_message.content {            match content {                MessageContent::Text(text) | MessageContent::Thinking { text, .. } => messages                    .push(match req_message.role {                        Role::User => open_router::RequestMessage::User { content: text },                        Role::Assistant => open_router::RequestMessage::Assistant {                            content: Some(text),                            tool_calls: Vec::new(),                        },                        Role::System => open_router::RequestMessage::System { content: text },                    }),                MessageContent::RedactedThinking(_) => {}                MessageContent::Image(_) => {}                MessageContent::ToolUse(tool_use) => {                    let tool_call = open_router::ToolCall {                        id: tool_use.id.to_string(),                        content: open_router::ToolCallContent::Function {                            function: open_router::FunctionContent {                                name: tool_use.name.to_string(),                                arguments: serde_json::to_string(&tool_use.input)                                    .unwrap_or_default(),                            },                        },                    };                     if let Some(open_router::RequestMessage::Assistant { tool_calls, .. }) =                        messages.last_mut()                    {                        tool_calls.push(tool_call);                    } else {                        messages.push(open_router::RequestMessage::Assistant {                            content: None,                            tool_calls: vec![tool_call],                        });                    }                }                MessageContent::ToolResult(tool_result) => {                    let content = match &tool_result.content {                      LanguageModelToolResultContent::Text(text) => {                          text.to_string()                        }                        LanguageModelToolResultContent::Image(_) => {                          "[Tool responded with an image, but Zed doesn't support these in Open AI models yet]".to_string()                        }                    };                     messages.push(open_router::RequestMessage::Tool {                        content: content,                        tool_call_id: tool_result.tool_use_id.to_string(),                    });                }            }        }    }     open_router::Request {        model: model.id().into(),        messages,        stream: true,        stop: request.stop,        temperature: request.temperature.unwrap_or(0.4),        max_tokens: max_output_tokens,        parallel_tool_calls: if model.supports_parallel_tool_calls() && !request.tools.is_empty() {            Some(false)        } else {            None        },        tools: request            .tools            .into_iter()            .map(|tool| open_router::ToolDefinition::Function {                function: open_router::FunctionDefinition {                    name: tool.name,                    description: Some(tool.description),                    parameters: Some(tool.input_schema),                },            })            .collect(),        tool_choice: request.tool_choice.map(|choice| match choice {            LanguageModelToolChoice::Auto => open_router::ToolChoice::Auto,            LanguageModelToolChoice::Any => open_router::ToolChoice::Required,            LanguageModelToolChoice::None => open_router::ToolChoice::None,        }),    }} pub struct OpenRouterEventMapper {    tool_calls_by_index: HashMap<usize, RawToolCall>,} impl OpenRouterEventMapper {    pub fn new() -> Self {        Self {            tool_calls_by_index: HashMap::default(),        }    }     pub fn map_stream(        mut self,        events: Pin<Box<dyn Send + Stream<Item = Result<ResponseStreamEvent>>>>,    ) -> impl Stream<Item = Result<LanguageModelCompletionEvent, LanguageModelCompletionError>>    {        events.flat_map(move |event| {            futures::stream::iter(match event {                Ok(event) => self.map_event(event),                Err(error) => vec![Err(LanguageModelCompletionError::Other(anyhow!(error)))],            })        })    }     pub fn map_event(        &mut self,

Lines 1–500 of 788. Load more