use std::{ ops::RangeInclusive, sync::{Arc, LazyLock}, time::Duration,}; use anyhow::{anyhow, bail};use bitflags::bitflags;use client::Client;use db::kvp::KEY_VALUE_STORE;use editor::{Editor, EditorEvent};use futures::AsyncReadExt;use gpui::{ div, rems, App, Context, DismissEvent, Entity, EventEmitter, FocusHandle, Focusable, PromptLevel, Render, Task, Window,};use http_client::HttpClient;use language::Buffer;use project::Project;use regex::Regex;use serde_derive::Serialize;use ui::{prelude::*, Button, ButtonStyle, IconPosition, Tooltip};use util::ResultExt;use workspace::{DismissDecision, ModalView, Workspace};use zed_actions::feedback::GiveFeedback; use crate::{system_specs::SystemSpecs, OpenZedRepo}; // For UI testing purposesconst SEND_SUCCESS_IN_DEV_MODE: bool = true;const SEND_TIME_IN_DEV_MODE: Duration = Duration::from_secs(2); // Temporary, until tests are in place#[cfg(debug_assertions)]const DEV_MODE: bool = true; #[cfg(not(debug_assertions))]const DEV_MODE: bool = false; const DATABASE_KEY_NAME: &str = "email_address";static EMAIL_REGEX: LazyLock<Regex> = LazyLock::new(|| Regex::new(r"\b[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Z|a-z]{2,}\b").unwrap());const FEEDBACK_CHAR_LIMIT: RangeInclusive<i32> = 10..=5000;const FEEDBACK_SUBMISSION_ERROR_TEXT: &str = "Feedback failed to submit, see error log for details."; #[derive(Serialize)]struct FeedbackRequestBody<'a> { feedback_text: &'a str, email: Option<String>, installation_id: Option<Arc<str>>, metrics_id: Option<Arc<str>>, system_specs: SystemSpecs, is_staff: bool,} bitflags! { #[derive(Debug, Clone, PartialEq)] struct InvalidStateFlags: u8 { const EmailAddress = 0b00000001; const CharacterCount = 0b00000010; }} #[derive(Debug, Clone, PartialEq)]enum CannotSubmitReason { InvalidState { flags: InvalidStateFlags }, AwaitingSubmission,} #[derive(Debug, Clone, PartialEq)]enum SubmissionState { CanSubmit, CannotSubmit { reason: CannotSubmitReason },} pub struct FeedbackModal { system_specs: SystemSpecs, feedback_editor: Entity<Editor>, email_address_editor: Entity<Editor>, submission_state: Option<SubmissionState>, dismiss_modal: bool, character_count: i32,} impl Focusable for FeedbackModal { fn focus_handle(&self, cx: &App) -> FocusHandle { self.feedback_editor.focus_handle(cx) }}impl EventEmitter<DismissEvent> for FeedbackModal {} impl ModalView for FeedbackModal { fn on_before_dismiss( &mut self, window: &mut Window, cx: &mut Context<Self>, ) -> DismissDecision { self.update_email_in_store(window, cx); if self.dismiss_modal { return DismissDecision::Dismiss(true); } let has_feedback = self.feedback_editor.read(cx).text_option(cx).is_some(); if !has_feedback { return DismissDecision::Dismiss(true); } let answer = window.prompt( PromptLevel::Info, "Discard feedback?", None, &["Yes", "No"], cx, ); cx.spawn_in(window, move |this, mut cx| async move { if answer.await.ok() == Some(0) { this.update(&mut cx, |this, cx| { this.dismiss_modal = true; cx.emit(DismissEvent) }) .log_err(); } }) .detach(); DismissDecision::Pending }} impl FeedbackModal { pub fn register(workspace: &mut Workspace, _: &mut Window, cx: &mut Context<Workspace>) { let _handle = cx.entity().downgrade(); workspace.register_action(move |workspace, _: &GiveFeedback, window, cx| { workspace .with_local_workspace(window, cx, |workspace, window, cx| { let markdown = workspace .app_state() .languages .language_for_name("Markdown"); let project = workspace.project().clone(); let system_specs = SystemSpecs::new(window, cx); cx.spawn_in(window, |workspace, mut cx| async move { let markdown = markdown.await.log_err(); let buffer = project.update(&mut cx, |project, cx| { project.create_local_buffer("", markdown, cx) })?; let system_specs = system_specs.await; workspace.update_in(&mut cx, |workspace, window, cx| { workspace.toggle_modal(window, cx, move |window, cx| { FeedbackModal::new(system_specs, project, buffer, window, cx) }); })?; anyhow::Ok(()) }) .detach_and_log_err(cx); }) .detach_and_log_err(cx); }); } pub fn new( system_specs: SystemSpecs, project: Entity<Project>, buffer: Entity<Buffer>, window: &mut Window, cx: &mut Context<Self>, ) -> Self { let email_address_editor = cx.new(|cx| { let mut editor = Editor::single_line(window, cx); editor.set_placeholder_text("Email address (optional)", cx); if let Ok(Some(email_address)) = KEY_VALUE_STORE.read_kvp(DATABASE_KEY_NAME) { editor.set_text(email_address, window, cx) } editor }); let feedback_editor = cx.new(|cx| { let mut editor = Editor::for_buffer(buffer, Some(project.clone()), window, cx); editor.set_placeholder_text( "You can use markdown to organize your feedback with code and links.", cx, ); editor.set_show_gutter(false, cx); editor.set_show_indent_guides(false, cx); editor.set_show_edit_predictions(Some(false), window, cx); editor.set_vertical_scroll_margin(5, cx); editor.set_use_modal_editing(false); editor.set_soft_wrap(); editor }); cx.subscribe(&feedback_editor, |this, editor, event: &EditorEvent, cx| { if matches!(event, EditorEvent::Edited { .. }) { this.character_count = editor .read(cx) .buffer() .read(cx) .as_singleton() .expect("Feedback editor is never a multi-buffer") .read(cx) .len() as i32; cx.notify(); } }) .detach(); Self { system_specs: system_specs.clone(), feedback_editor, email_address_editor, submission_state: None, dismiss_modal: false, character_count: 0, } } pub fn submit( &mut self, window: &mut Window, cx: &mut Context<Self>, ) -> Task<anyhow::Result<()>> { let feedback_text = self.feedback_editor.read(cx).text(cx).trim().to_string(); let email = self.email_address_editor.read(cx).text_option(cx); let answer = window.prompt( PromptLevel::Info, "Ready to submit your feedback?", None, &["Yes, Submit!", "No"], cx, ); let client = Client::global(cx).clone(); let specs = self.system_specs.clone(); cx.spawn_in(window, |this, mut cx| async move { let answer = answer.await.ok(); if answer == Some(0) { this.update(&mut cx, |this, cx| { this.submission_state = Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::AwaitingSubmission, }); cx.notify(); }) .log_err(); let res = FeedbackModal::submit_feedback(&feedback_text, email, client, specs).await; match res { Ok(_) => { this.update(&mut cx, |this, cx| { this.dismiss_modal = true; cx.notify(); cx.emit(DismissEvent) }) .ok(); } Err(error) => { log::error!("{}", error); this.update_in(&mut cx, |this, window, cx| { let prompt = window.prompt( PromptLevel::Critical, FEEDBACK_SUBMISSION_ERROR_TEXT, None, &["OK"], cx, ); cx.spawn_in(window, |_, _cx| async move { prompt.await.ok(); }) .detach(); this.submission_state = Some(SubmissionState::CanSubmit); cx.notify(); }) .log_err(); } } } }) .detach(); Task::ready(Ok(())) } async fn submit_feedback( feedback_text: &str, email: Option<String>, zed_client: Arc<Client>, system_specs: SystemSpecs, ) -> anyhow::Result<()> { if DEV_MODE { smol::Timer::after(SEND_TIME_IN_DEV_MODE).await; if SEND_SUCCESS_IN_DEV_MODE { return Ok(()); } else { return Err(anyhow!("Error submitting feedback")); } } let telemetry = zed_client.telemetry(); let installation_id = telemetry.installation_id(); let metrics_id = telemetry.metrics_id(); let is_staff = telemetry.is_staff(); let http_client = zed_client.http_client(); let feedback_endpoint = http_client.build_url("/api/feedback"); let request = FeedbackRequestBody { feedback_text, email, installation_id, metrics_id, system_specs, is_staff: is_staff.unwrap_or(false), }; let json_bytes = serde_json::to_vec(&request)?; let request = http_client::http::Request::post(feedback_endpoint) .header("content-type", "application/json") .body(json_bytes.into())?; let mut response = http_client.send(request).await?; let mut body = String::new(); response.body_mut().read_to_string(&mut body).await?; let response_status = response.status(); if !response_status.is_success() { bail!("Feedback API failed with error: {}", response_status) } Ok(()) } fn update_submission_state(&mut self, cx: &mut Context<Self>) { if self.awaiting_submission() { return; } let mut invalid_state_flags = InvalidStateFlags::empty(); let valid_email_address = match self.email_address_editor.read(cx).text_option(cx) { Some(email_address) => EMAIL_REGEX.is_match(&email_address), None => true, }; if !valid_email_address { invalid_state_flags |= InvalidStateFlags::EmailAddress; } if !FEEDBACK_CHAR_LIMIT.contains(&self.character_count) { invalid_state_flags |= InvalidStateFlags::CharacterCount; } if invalid_state_flags.is_empty() { self.submission_state = Some(SubmissionState::CanSubmit); } else { self.submission_state = Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::InvalidState { flags: invalid_state_flags, }, }); } } fn update_email_in_store(&self, window: &mut Window, cx: &mut Context<Self>) { let email = self.email_address_editor.read(cx).text_option(cx); cx.spawn_in(window, |_, _| async move { match email { Some(email) => { KEY_VALUE_STORE .write_kvp(DATABASE_KEY_NAME.to_string(), email) .await .ok(); } None => { KEY_VALUE_STORE .delete_kvp(DATABASE_KEY_NAME.to_string()) .await .ok(); } } }) .detach(); } fn valid_email_address(&self) -> bool { !self.in_invalid_state(InvalidStateFlags::EmailAddress) } fn valid_character_count(&self) -> bool { !self.in_invalid_state(InvalidStateFlags::CharacterCount) } fn in_invalid_state(&self, flag: InvalidStateFlags) -> bool { match self.submission_state { Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::InvalidState { ref flags }, }) => flags.contains(flag), _ => false, } } fn awaiting_submission(&self) -> bool { matches!( self.submission_state, Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::AwaitingSubmission }) ) } fn can_submit(&self) -> bool { matches!(self.submission_state, Some(SubmissionState::CanSubmit)) } fn cancel(&mut self, _: &menu::Cancel, _: &mut Window, cx: &mut Context<Self>) { cx.emit(DismissEvent) }} impl Render for FeedbackModal { fn render(&mut self, _: &mut Window, cx: &mut Context<Self>) -> impl IntoElement { self.update_submission_state(cx); let submit_button_text = if self.awaiting_submission() { "Submitting..." } else { "Submit" }; let open_zed_repo = cx.listener(|_, _, window, cx| window.dispatch_action(Box::new(OpenZedRepo), cx)); v_flex() .elevation_3(cx) .key_context("GiveFeedback") .on_action(cx.listener(Self::cancel)) .min_w(rems(40.)) .max_w(rems(96.)) .h(rems(32.)) .p_4() .gap_2() .child(Headline::new("Give Feedback")) .child( Label::new(if self.character_count < *FEEDBACK_CHAR_LIMIT.start() { format!( "Feedback must be at least {} characters.", FEEDBACK_CHAR_LIMIT.start() ) } else { format!( "Characters: {}", *FEEDBACK_CHAR_LIMIT.end() - self.character_count ) }) .color(if self.valid_character_count() { Color::Success } else { Color::Error }), ) .child( div() .flex_1() .bg(cx.theme().colors().editor_background) .p_2() .border_1() .rounded_sm() .border_color(cx.theme().colors().border) .child(self.feedback_editor.clone()), ) .child( v_flex() .gap_1() .child( h_flex() .bg(cx.theme().colors().editor_background) .p_2() .border_1() .rounded_sm() .border_color(if self.valid_email_address() { cx.theme().colors().border } else { cx.theme().status().error_border }) .child(self.email_address_editor.clone()), ) .child( Label::new("Provide an email address if you want us to be able to reply.") .size(LabelSize::Small) .color(Color::Muted), ), ) .child( h_flex()Lines 1–500 of 543. Load more
use std::{ ops::RangeInclusive, sync::{Arc, LazyLock}, time::Duration, }; use anyhow::{anyhow, bail}; use bitflags::bitflags; use client::Client; use db::kvp::KEY_VALUE_STORE; use editor::{Editor, EditorEvent}; use futures::AsyncReadExt; use gpui::{ div, rems, App, Context, DismissEvent, Entity, EventEmitter, FocusHandle, Focusable, PromptLevel, Render, Task, Window, }; use http_client::HttpClient; use language::Buffer; use project::Project; use regex::Regex; use serde_derive::Serialize; use ui::{prelude::*, Button, ButtonStyle, IconPosition, Tooltip}; use util::ResultExt; use workspace::{DismissDecision, ModalView, Workspace}; use zed_actions::feedback::GiveFeedback; use crate::{system_specs::SystemSpecs, OpenZedRepo}; // For UI testing purposes const SEND_SUCCESS_IN_DEV_MODE: bool = true; const SEND_TIME_IN_DEV_MODE: Duration = Duration::from_secs(2); // Temporary, until tests are in place #[cfg(debug_assertions)] const DEV_MODE: bool = true; #[cfg(not(debug_assertions))] const DEV_MODE: bool = false; const DATABASE_KEY_NAME: &str = "email_address"; static EMAIL_REGEX: LazyLock<Regex> = LazyLock::new(|| Regex::new(r"\b[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Z|a-z]{2,}\b").unwrap()); const FEEDBACK_CHAR_LIMIT: RangeInclusive<i32> = 10..=5000; const FEEDBACK_SUBMISSION_ERROR_TEXT: &str = "Feedback failed to submit, see error log for details."; #[derive(Serialize)] struct FeedbackRequestBody<'a> { feedback_text: &'a str, email: Option<String>, installation_id: Option<Arc<str>>, metrics_id: Option<Arc<str>>, system_specs: SystemSpecs, is_staff: bool, } bitflags! { #[derive(Debug, Clone, PartialEq)] struct InvalidStateFlags: u8 { const EmailAddress = 0b00000001; const CharacterCount = 0b00000010; } } #[derive(Debug, Clone, PartialEq)] enum CannotSubmitReason { InvalidState { flags: InvalidStateFlags }, AwaitingSubmission, } #[derive(Debug, Clone, PartialEq)] enum SubmissionState { CanSubmit, CannotSubmit { reason: CannotSubmitReason }, } pub struct FeedbackModal { system_specs: SystemSpecs, feedback_editor: Entity<Editor>, email_address_editor: Entity<Editor>, submission_state: Option<SubmissionState>, dismiss_modal: bool, character_count: i32, } impl Focusable for FeedbackModal { fn focus_handle(&self, cx: &App) -> FocusHandle { self.feedback_editor.focus_handle(cx) } } impl EventEmitter<DismissEvent> for FeedbackModal {} impl ModalView for FeedbackModal { fn on_before_dismiss( &mut self, window: &mut Window, cx: &mut Context<Self>, ) -> DismissDecision { self.update_email_in_store(window, cx); if self.dismiss_modal { return DismissDecision::Dismiss(true); } let has_feedback = self.feedback_editor.read(cx).text_option(cx).is_some(); if !has_feedback { return DismissDecision::Dismiss(true); } let answer = window.prompt( PromptLevel::Info, "Discard feedback?", None, &["Yes", "No"], cx, ); cx.spawn_in(window, move |this, mut cx| async move { if answer.await.ok() == Some(0) { this.update(&mut cx, |this, cx| { this.dismiss_modal = true; cx.emit(DismissEvent) }) .log_err(); } }) .detach(); DismissDecision::Pending } } impl FeedbackModal { pub fn register(workspace: &mut Workspace, _: &mut Window, cx: &mut Context<Workspace>) { let _handle = cx.entity().downgrade(); workspace.register_action(move |workspace, _: &GiveFeedback, window, cx| { workspace .with_local_workspace(window, cx, |workspace, window, cx| { let markdown = workspace .app_state() .languages .language_for_name("Markdown"); let project = workspace.project().clone(); let system_specs = SystemSpecs::new(window, cx); cx.spawn_in(window, |workspace, mut cx| async move { let markdown = markdown.await.log_err(); let buffer = project.update(&mut cx, |project, cx| { project.create_local_buffer("", markdown, cx) })?; let system_specs = system_specs.await; workspace.update_in(&mut cx, |workspace, window, cx| { workspace.toggle_modal(window, cx, move |window, cx| { FeedbackModal::new(system_specs, project, buffer, window, cx) }); })?; anyhow::Ok(()) }) .detach_and_log_err(cx); }) .detach_and_log_err(cx); }); } pub fn new( system_specs: SystemSpecs, project: Entity<Project>, buffer: Entity<Buffer>, window: &mut Window, cx: &mut Context<Self>, ) -> Self { let email_address_editor = cx.new(|cx| { let mut editor = Editor::single_line(window, cx); editor.set_placeholder_text("Email address (optional)", cx); if let Ok(Some(email_address)) = KEY_VALUE_STORE.read_kvp(DATABASE_KEY_NAME) { editor.set_text(email_address, window, cx) } editor }); let feedback_editor = cx.new(|cx| { let mut editor = Editor::for_buffer(buffer, Some(project.clone()), window, cx); editor.set_placeholder_text( "You can use markdown to organize your feedback with code and links.", cx, ); editor.set_show_gutter(false, cx); editor.set_show_indent_guides(false, cx); editor.set_show_edit_predictions(Some(false), window, cx); editor.set_vertical_scroll_margin(5, cx); editor.set_use_modal_editing(false); editor.set_soft_wrap(); editor }); cx.subscribe(&feedback_editor, |this, editor, event: &EditorEvent, cx| { if matches!(event, EditorEvent::Edited { .. }) { this.character_count = editor .read(cx) .buffer() .read(cx) .as_singleton() .expect("Feedback editor is never a multi-buffer") .read(cx) .len() as i32; cx.notify(); } }) .detach(); Self { system_specs: system_specs.clone(), feedback_editor, email_address_editor, submission_state: None, dismiss_modal: false, character_count: 0, } } pub fn submit( &mut self, window: &mut Window, cx: &mut Context<Self>, ) -> Task<anyhow::Result<()>> { let feedback_text = self.feedback_editor.read(cx).text(cx).trim().to_string(); let email = self.email_address_editor.read(cx).text_option(cx); let answer = window.prompt( PromptLevel::Info, "Ready to submit your feedback?", None, &["Yes, Submit!", "No"], cx, ); let client = Client::global(cx).clone(); let specs = self.system_specs.clone(); cx.spawn_in(window, |this, mut cx| async move { let answer = answer.await.ok(); if answer == Some(0) { this.update(&mut cx, |this, cx| { this.submission_state = Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::AwaitingSubmission, }); cx.notify(); }) .log_err(); let res = FeedbackModal::submit_feedback(&feedback_text, email, client, specs).await; match res { Ok(_) => { this.update(&mut cx, |this, cx| { this.dismiss_modal = true; cx.notify(); cx.emit(DismissEvent) }) .ok(); } Err(error) => { log::error!("{}", error); this.update_in(&mut cx, |this, window, cx| { let prompt = window.prompt( PromptLevel::Critical, FEEDBACK_SUBMISSION_ERROR_TEXT, None, &["OK"], cx, ); cx.spawn_in(window, |_, _cx| async move { prompt.await.ok(); }) .detach(); this.submission_state = Some(SubmissionState::CanSubmit); cx.notify(); }) .log_err(); } } } }) .detach(); Task::ready(Ok(())) } async fn submit_feedback( feedback_text: &str, email: Option<String>, zed_client: Arc<Client>, system_specs: SystemSpecs, ) -> anyhow::Result<()> { if DEV_MODE { smol::Timer::after(SEND_TIME_IN_DEV_MODE).await; if SEND_SUCCESS_IN_DEV_MODE { return Ok(()); } else { return Err(anyhow!("Error submitting feedback")); } } let telemetry = zed_client.telemetry(); let installation_id = telemetry.installation_id(); let metrics_id = telemetry.metrics_id(); let is_staff = telemetry.is_staff(); let http_client = zed_client.http_client(); let feedback_endpoint = http_client.build_url("/api/feedback"); let request = FeedbackRequestBody { feedback_text, email, installation_id, metrics_id, system_specs, is_staff: is_staff.unwrap_or(false), }; let json_bytes = serde_json::to_vec(&request)?; let request = http_client::http::Request::post(feedback_endpoint) .header("content-type", "application/json") .body(json_bytes.into())?; let mut response = http_client.send(request).await?; let mut body = String::new(); response.body_mut().read_to_string(&mut body).await?; let response_status = response.status(); if !response_status.is_success() { bail!("Feedback API failed with error: {}", response_status) } Ok(()) } fn update_submission_state(&mut self, cx: &mut Context<Self>) { if self.awaiting_submission() { return; } let mut invalid_state_flags = InvalidStateFlags::empty(); let valid_email_address = match self.email_address_editor.read(cx).text_option(cx) { Some(email_address) => EMAIL_REGEX.is_match(&email_address), None => true, }; if !valid_email_address { invalid_state_flags |= InvalidStateFlags::EmailAddress; } if !FEEDBACK_CHAR_LIMIT.contains(&self.character_count) { invalid_state_flags |= InvalidStateFlags::CharacterCount; } if invalid_state_flags.is_empty() { self.submission_state = Some(SubmissionState::CanSubmit); } else { self.submission_state = Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::InvalidState { flags: invalid_state_flags, }, }); } } fn update_email_in_store(&self, window: &mut Window, cx: &mut Context<Self>) { let email = self.email_address_editor.read(cx).text_option(cx); cx.spawn_in(window, |_, _| async move { match email { Some(email) => { KEY_VALUE_STORE .write_kvp(DATABASE_KEY_NAME.to_string(), email) .await .ok(); } None => { KEY_VALUE_STORE .delete_kvp(DATABASE_KEY_NAME.to_string()) .await .ok(); } } }) .detach(); } fn valid_email_address(&self) -> bool { !self.in_invalid_state(InvalidStateFlags::EmailAddress) } fn valid_character_count(&self) -> bool { !self.in_invalid_state(InvalidStateFlags::CharacterCount) } fn in_invalid_state(&self, flag: InvalidStateFlags) -> bool { match self.submission_state { Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::InvalidState { ref flags }, }) => flags.contains(flag), _ => false, } } fn awaiting_submission(&self) -> bool { matches!( self.submission_state, Some(SubmissionState::CannotSubmit { reason: CannotSubmitReason::AwaitingSubmission }) ) } fn can_submit(&self) -> bool { matches!(self.submission_state, Some(SubmissionState::CanSubmit)) } fn cancel(&mut self, _: &menu::Cancel, _: &mut Window, cx: &mut Context<Self>) { cx.emit(DismissEvent) } } impl Render for FeedbackModal { fn render(&mut self, _: &mut Window, cx: &mut Context<Self>) -> impl IntoElement { self.update_submission_state(cx); let submit_button_text = if self.awaiting_submission() { "Submitting..." } else { "Submit" }; let open_zed_repo = cx.listener(|_, _, window, cx| window.dispatch_action(Box::new(OpenZedRepo), cx)); v_flex() .elevation_3(cx) .key_context("GiveFeedback") .on_action(cx.listener(Self::cancel)) .min_w(rems(40.)) .max_w(rems(96.)) .h(rems(32.)) .p_4() .gap_2() .child(Headline::new("Give Feedback")) .child( Label::new(if self.character_count < *FEEDBACK_CHAR_LIMIT.start() { format!( "Feedback must be at least {} characters.", FEEDBACK_CHAR_LIMIT.start() ) } else { format!( "Characters: {}", *FEEDBACK_CHAR_LIMIT.end() - self.character_count ) }) .color(if self.valid_character_count() { Color::Success } else { Color::Error }), ) .child( div() .flex_1() .bg(cx.theme().colors().editor_background) .p_2() .border_1() .rounded_sm() .border_color(cx.theme().colors().border) .child(self.feedback_editor.clone()), ) .child( v_flex() .gap_1() .child( h_flex() .bg(cx.theme().colors().editor_background) .p_2() .border_1() .rounded_sm() .border_color(if self.valid_email_address() { cx.theme().colors().border } else { cx.theme().status().error_border }) .child(self.email_address_editor.clone()), ) .child( Label::new("Provide an email address if you want us to be able to reply.") .size(LabelSize::Small) .color(Color::Muted), ), ) .child( h_flex()