intelli-shell 3.4.0

Like IntelliSense, but for shells
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

use std::time::Duration;

use indicatif::{ProgressBar, ProgressStyle};
use itertools::Itertools;
use tokio_util::sync::CancellationToken;
use tracing::instrument;

use super::{InteractiveProcess, Process, ProcessOutput};
use crate::{
    cli::SearchCommandsProcess,
    component::{Component, search::SearchCommandsComponent},
    config::Config,
    errors::{AppError, UserFacingError},
    format_error,
    service::IntelliShellService,
    widgets::SPINNER_CHARS,
};

impl Process for SearchCommandsProcess {
    #[instrument(skip_all)]
    async fn execute(
        self,
        config: Config,
        service: IntelliShellService,
        cancellation_token: CancellationToken,
    ) -> color_eyre::Result<ProcessOutput> {
        // Different behaviors based on ai flag
        if self.ai {
            // Validate we've a query
            let prompt = self.query.as_deref().unwrap_or_default();
            if prompt.trim().is_empty() {
                return Ok(ProcessOutput::fail().stderr(format_error!(
                    config.theme,
                    "{}",
                    UserFacingError::AiEmptyCommand
                )));
            }

            // Setup the progress bar
            let pb = ProgressBar::new_spinner();
            pb.set_style(
                ProgressStyle::with_template("{spinner:.blue} {wide_msg}")
                    .unwrap()
                    .tick_strings(&SPINNER_CHARS),
            );
            pb.enable_steady_tick(Duration::from_millis(100));
            pb.set_message("Thinking ...");

            // Suggest commands using AI
            let res = service.suggest_commands(prompt, cancellation_token).await;

            // Clear the spinner
            pb.finish_and_clear();

            // Handle the result
            match res {
                Ok(commands) => Ok(ProcessOutput::success().stdout(commands.into_iter().map(|c| c.cmd).join("\n"))),
                Err(AppError::UserFacing(err)) => {
                    Ok(ProcessOutput::fail().stderr(format_error!(config.theme, "{err}")))
                }
                Err(AppError::Unexpected(report)) => Err(report),
            }
        } else {
            // Merge config with args
            let (config, query) = merge_config(self, config);

            // Search for commands and handle result
            match service
                .search_commands(config.search.mode, config.search.user_only, &query)
                .await
            {
                Ok((commands, _)) => {
                    Ok(ProcessOutput::success().stdout(commands.into_iter().map(|c| c.cmd).join("\n")))
                }
                Err(AppError::UserFacing(err)) => {
                    Ok(ProcessOutput::fail().stderr(format_error!(config.theme, "{err}")))
                }
                Err(AppError::Unexpected(report)) => Err(report),
            }
        }
    }
}

impl InteractiveProcess for SearchCommandsProcess {
    #[instrument(skip_all)]
    fn into_component(
        self,
        config: Config,
        service: IntelliShellService,
        inline: bool,
        cancellation_token: CancellationToken,
    ) -> color_eyre::Result<Box<dyn Component>> {
        let ai = self.ai;
        let (config, query) = merge_config(self, config);
        Ok(Box::new(SearchCommandsComponent::new(
            service,
            config,
            inline,
            query,
            ai,
            cancellation_token,
        )))
    }
}

fn merge_config(p: SearchCommandsProcess, mut config: Config) -> (Config, String) {
    let SearchCommandsProcess {
        query,
        mode,
        user_only,
        ai: _,
    } = p;
    config.search.mode = mode.unwrap_or(config.search.mode);
    config.search.user_only = user_only || config.search.user_only;
    (config, query.unwrap_or_default())
}