//! REPL operations on an [`Editor`]. use std::ops::Range;use std::sync::Arc; use anyhow::{Context as _, Result};use editor::{Editor, MultiBufferOffset};use gpui::{App, Entity, WeakEntity, Window, prelude::*};use language::{BufferSnapshot, Language, LanguageName, Point};use project::{ProjectItem as _, WorktreeId};use workspace::{Workspace, notifications::NotificationId}; use crate::kernels::PythonEnvKernelSpecification;use crate::repl_store::ReplStore;use crate::session::SessionEvent;use crate::{    ClearCurrentOutput, ClearOutputs, Interrupt, JupyterSettings, KernelSpecification, Restart,    Session, Shutdown,}; pub fn assign_kernelspec(    kernel_specification: KernelSpecification,    weak_editor: WeakEntity<Editor>,    window: &mut Window,    cx: &mut App,) -> Result<()> {    let store = ReplStore::global(cx);    if !store.read(cx).is_enabled() {        return Ok(());    }     let worktree_id = crate::repl_editor::worktree_id_for_editor(weak_editor.clone(), cx)        .context("editor is not in a worktree")?;     store.update(cx, |store, cx| {        store.set_active_kernelspec(worktree_id, kernel_specification.clone(), cx);    });     let fs = store.read(cx).fs().clone();     if let Some(session) = store.read(cx).get_session(weak_editor.entity_id()).cloned() {        // Drop previous session, start new one        session.update(cx, |session, cx| {            session.clear_outputs(cx);            session.shutdown(window, cx);            cx.notify();        });    }     let session =        cx.new(|cx| Session::new(weak_editor.clone(), fs, kernel_specification, window, cx));     weak_editor        .update(cx, |_editor, cx| {            cx.notify();             cx.subscribe(&session, {                let store = store.clone();                move |_this, _session, event, cx| match event {                    SessionEvent::Shutdown(shutdown_event) => {                        store.update(cx, |store, _cx| {                            store.remove_session(shutdown_event.entity_id());                        });                    }                }            })            .detach();        })        .ok();     store.update(cx, |store, _cx| {        store.insert_session(weak_editor.entity_id(), session.clone());    });     Ok(())} pub fn install_ipykernel_and_assign(    kernel_specification: KernelSpecification,    weak_editor: WeakEntity<Editor>,    window: &mut Window,    cx: &mut App,) -> Result<()> {    let KernelSpecification::PythonEnv(ref env_spec) = kernel_specification else {        return assign_kernelspec(kernel_specification, weak_editor, window, cx);    };     let python_path = env_spec.path.clone();    let env_name = env_spec.name.clone();    let env_spec = env_spec.clone();     struct IpykernelInstall;    let notification_id = NotificationId::unique::<IpykernelInstall>();     let workspace = Workspace::for_window(window, cx);    if let Some(workspace) = &workspace {        workspace.update(cx, |workspace, cx| {            workspace.show_toast(                workspace::Toast::new(                    notification_id.clone(),                    format!("Installing ipykernel in {}...", env_name),                ),                cx,            );        });    }     let weak_workspace = workspace.map(|w| w.downgrade());    let window_handle = window.window_handle();     let install_task = cx.background_spawn(async move {        let output = util::command::new_command(python_path.to_string_lossy().as_ref())            .args(&["-m", "pip", "install", "ipykernel"])            .output()            .await            .context("failed to run pip install ipykernel")?;         if output.status.success() {            anyhow::Ok(())        } else {            let stderr = String::from_utf8_lossy(&output.stderr);            anyhow::bail!("{}", stderr.lines().last().unwrap_or("unknown error"))        }    });     cx.spawn(async move |cx| {        let result = install_task.await;         match result {            Ok(()) => {                if let Some(weak_workspace) = &weak_workspace {                    weak_workspace                        .update(cx, |workspace, cx| {                            workspace.dismiss_toast(&notification_id, cx);                            workspace.show_toast(                                workspace::Toast::new(                                    notification_id.clone(),                                    format!("ipykernel installed in {}", env_name),                                )                                .autohide(),                                cx,                            );                        })                        .ok();                }                 window_handle                    .update(cx, |_, window, cx| {                        let updated_spec =                            KernelSpecification::PythonEnv(PythonEnvKernelSpecification {                                has_ipykernel: true,                                ..env_spec                            });                        assign_kernelspec(updated_spec, weak_editor, window, cx).ok();                    })                    .ok();            }            Err(error) => {                if let Some(weak_workspace) = &weak_workspace {                    weak_workspace                        .update(cx, |workspace, cx| {                            workspace.dismiss_toast(&notification_id, cx);                            workspace.show_toast(                                workspace::Toast::new(                                    notification_id.clone(),                                    format!(                                        "Failed to install ipykernel in {}: {}",                                        env_name, error                                    ),                                ),                                cx,                            );                        })                        .ok();                }            }        }    })    .detach();     Ok(())} pub fn run(    editor: WeakEntity<Editor>,    move_down: bool,    window: &mut Window,    cx: &mut App,) -> Result<()> {    let store = ReplStore::global(cx);    if !store.read(cx).is_enabled() {        return Ok(());    }    store.update(cx, |store, cx| store.ensure_kernelspecs(cx));     let editor = editor.upgrade().context("editor was dropped")?;    let selected_range = editor        .update(cx, |editor, cx| {            editor                .selections                .newest_adjusted(&editor.display_snapshot(cx))        })        .range();    let multibuffer = editor.read(cx).buffer().clone();    let Some(buffer) = multibuffer.read(cx).as_singleton() else {        return Ok(());    };     let Some(project_path) = buffer.read(cx).project_path(cx) else {        return Ok(());    };     let (runnable_ranges, next_cell_point) =        runnable_ranges(&buffer.read(cx).snapshot(), selected_range, cx);     for runnable_range in runnable_ranges {        let Some(language) = multibuffer.read(cx).language_at(runnable_range.start, cx) else {            continue;        };         let kernel_specification = store            .read(cx)            .active_kernelspec(project_path.worktree_id, Some(language.clone()), cx)            .with_context(|| format!("No kernel found for language: {}", language.name()))?;         let fs = store.read(cx).fs().clone();         let session = if let Some(session) = store.read(cx).get_session(editor.entity_id()).cloned()        {            session        } else {            let weak_editor = editor.downgrade();            let session =                cx.new(|cx| Session::new(weak_editor, fs, kernel_specification, window, cx));             editor.update(cx, |_editor, cx| {                cx.notify();                 cx.subscribe(&session, {                    let store = store.clone();                    move |_this, _session, event, cx| match event {                        SessionEvent::Shutdown(shutdown_event) => {                            store.update(cx, |store, _cx| {                                store.remove_session(shutdown_event.entity_id());                            });                        }                    }                })                .detach();            });             store.update(cx, |store, _cx| {                store.insert_session(editor.entity_id(), session.clone());            });             session        };         let selected_text;        let anchor_range;        let next_cursor;        {            let snapshot = multibuffer.read(cx).read(cx);            selected_text = snapshot                .text_for_range(runnable_range.clone())                .collect::<String>();            anchor_range = snapshot.anchor_before(runnable_range.start)                ..snapshot.anchor_after(runnable_range.end);            next_cursor = next_cell_point.map(|point| snapshot.anchor_after(point));        }         session.update(cx, |session, cx| {            session.execute(                selected_text,                anchor_range,                next_cursor,                move_down,                window,                cx,            );        });    }     anyhow::Ok(())} pub enum SessionSupport {    ActiveSession(Entity<Session>),    Inactive(KernelSpecification),    RequiresSetup(LanguageName),    Unsupported,} pub fn worktree_id_for_editor(editor: WeakEntity<Editor>, cx: &mut App) -> Option<WorktreeId> {    editor.upgrade().and_then(|editor| {        editor            .read(cx)            .buffer()            .read(cx)            .as_singleton()?            .read(cx)            .project_path(cx)            .map(|path| path.worktree_id)    })} pub fn session(editor: WeakEntity<Editor>, cx: &mut App) -> SessionSupport {    let store = ReplStore::global(cx);    let entity_id = editor.entity_id();     if let Some(session) = store.read(cx).get_session(entity_id).cloned() {        return SessionSupport::ActiveSession(session);    };     let Some(language) = get_language(editor.clone(), cx) else {        return SessionSupport::Unsupported;    };     let worktree_id = worktree_id_for_editor(editor, cx);     let Some(worktree_id) = worktree_id else {        return SessionSupport::Unsupported;    };     let kernelspec = store        .read(cx)        .active_kernelspec(worktree_id, Some(language.clone()), cx);     match kernelspec {        Some(kernelspec) => SessionSupport::Inactive(kernelspec),        None => {            // For language_supported, need to check available kernels for language            if language_supported(&language, cx) {                SessionSupport::RequiresSetup(language.name())            } else {                SessionSupport::Unsupported            }        }    }} pub fn clear_outputs(editor: WeakEntity<Editor>, cx: &mut App) {    let store = ReplStore::global(cx);    let entity_id = editor.entity_id();    let Some(session) = store.read(cx).get_session(entity_id).cloned() else {        return;    };    session.update(cx, |session, cx| {        session.clear_outputs(cx);        cx.notify();    });} pub fn clear_current_output(editor: WeakEntity<Editor>, cx: &mut App) {    let Some(editor_entity) = editor.upgrade() else {        return;    };     let store = ReplStore::global(cx);    let entity_id = editor.entity_id();    let Some(session) = store.read(cx).get_session(entity_id).cloned() else {        return;    };     let position = editor_entity.read(cx).selections.newest_anchor().head();     session.update(cx, |session, cx| {        session.clear_output_at_position(position, cx);    });} pub fn interrupt(editor: WeakEntity<Editor>, cx: &mut App) {    let store = ReplStore::global(cx);    let entity_id = editor.entity_id();    let Some(session) = store.read(cx).get_session(entity_id).cloned() else {        return;    };     session.update(cx, |session, cx| {        session.interrupt(cx);        cx.notify();    });} pub fn shutdown(editor: WeakEntity<Editor>, window: &mut Window, cx: &mut App) {    let store = ReplStore::global(cx);    let entity_id = editor.entity_id();    let Some(session) = store.read(cx).get_session(entity_id).cloned() else {        return;    };     session.update(cx, |session, cx| {        session.shutdown(window, cx);        cx.notify();    });} pub fn restart(editor: WeakEntity<Editor>, window: &mut Window, cx: &mut App) {    let Some(editor) = editor.upgrade() else {        return;    };     let entity_id = editor.entity_id();     let Some(session) = ReplStore::global(cx)        .read(cx)        .get_session(entity_id)        .cloned()    else {        return;    };     session.update(cx, |session, cx| {        session.restart(window, cx);        cx.notify();    });} pub fn setup_editor_session_actions(editor: &mut Editor, editor_handle: WeakEntity<Editor>) {    editor        .register_action({            let editor_handle = editor_handle.clone();            move |_: &ClearOutputs, _, cx| {                if !JupyterSettings::enabled(cx) {                    return;                }                 crate::clear_outputs(editor_handle.clone(), cx);            }        })        .detach();     editor        .register_action({            let editor_handle = editor_handle.clone();            move |_: &ClearCurrentOutput, _, cx| {                if !JupyterSettings::enabled(cx) {                    return;                }                 crate::clear_current_output(editor_handle.clone(), cx);            }        })        .detach();     editor        .register_action({            let editor_handle = editor_handle.clone();            move |_: &Interrupt, _, cx| {                if !JupyterSettings::enabled(cx) {                    return;                }                 crate::interrupt(editor_handle.clone(), cx);            }        })        .detach();     editor        .register_action({            let editor_handle = editor_handle.clone();            move |_: &Shutdown, window, cx| {                if !JupyterSettings::enabled(cx) {                    return;                }                 crate::shutdown(editor_handle.clone(), window, cx);            }        })        .detach();     editor        .register_action({            let editor_handle = editor_handle;            move |_: &Restart, window, cx| {                if !JupyterSettings::enabled(cx) {                    return;                }                 crate::restart(editor_handle.clone(), window, cx);            }        })        .detach();} fn cell_range(buffer: &BufferSnapshot, start_row: u32, end_row: u32) -> Range<Point> {    let mut snippet_end_row = end_row;    while buffer.is_line_blank(snippet_end_row) && snippet_end_row > start_row {        snippet_end_row -= 1;    }    Point::new(start_row, 0)..Point::new(snippet_end_row, buffer.line_len(snippet_end_row))} // Returns the ranges of the snippets in the buffer and the next point for moving the cursor tofn jupytext_cells(    buffer: &BufferSnapshot,    range: Range<Point>,) -> (Vec<Range<Point>>, Option<Point>) {    let mut current_row = range.start.row; 

Lines 1–500 of 1064. Load more