bkmr 7.4.1

Knowledge management for humans and agents — bookmarks, snippets, etc, searchable, executable.
Documentation 
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

// bkmr/src/cli/mod.rs
use crate::cli::args::{Cli, Commands};
use crate::cli::error::CliResult;
use crate::config::Settings;
use crate::infrastructure::di::ServiceContainer;

pub mod args;
pub mod bookmark_commands;
pub mod command_handler;
pub mod completion;
pub mod display;
pub mod error;
pub mod fzf;
pub mod hsearch_handler;
pub mod process;
pub mod tag_commands;

// Old execute_command removed - use execute_command_with_services with dependency injection

pub fn execute_command_with_services(
    cli: Cli,
    services: ServiceContainer,
    settings: &Settings,
) -> CliResult<()> {
    match cli.command {
        Some(Commands::Search { .. }) => {
            let handler =
                command_handler::SearchCommandHandler::with_services(services, settings.clone());
            handler.execute(cli)
        }
        Some(Commands::HSearch { .. }) => {
            hsearch_handler::hybrid_search(cli, &services)
        }
        Some(Commands::SemSearch { .. }) => {
            bookmark_commands::semantic_search(cli, &services)
        }
        Some(Commands::Open { .. }) => bookmark_commands::open(
            cli,
            services.bookmark_service.clone(),
            services.action_service.clone(),
            services.interpolation_service.clone(),
        ),
        Some(Commands::Add { .. }) => bookmark_commands::add(
            cli,
            services.bookmark_service.clone(),
            services.template_service.clone(),
        ),
        Some(Commands::Delete { .. }) => {
            bookmark_commands::delete(cli, services.bookmark_service.clone())
        }
        Some(Commands::Update { .. }) => bookmark_commands::update(
            cli,
            services.bookmark_service.clone(),
            services.tag_service.clone(),
        ),
        Some(Commands::Edit { .. }) => bookmark_commands::edit(
            cli,
            services.bookmark_service.clone(),
            services.template_service.clone(),
            settings,
        ),
        Some(Commands::Show { .. }) => bookmark_commands::show(cli, &services),
        Some(Commands::Tags { .. }) => tag_commands::show_tags(cli, &services),
        Some(Commands::Surprise { .. }) => bookmark_commands::surprise(cli, &services),
        Some(Commands::SetEmbeddable { .. }) => bookmark_commands::set_embeddable(cli, &services),
        Some(Commands::Backfill { .. }) => bookmark_commands::backfill(cli, &services),
        Some(Commands::ClearEmbeddings { .. }) => {
            bookmark_commands::clear_embeddings(cli, &services)
        }
        Some(Commands::LoadJson { .. }) => bookmark_commands::load_json(cli, &services),
        Some(Commands::ImportFiles { .. }) => bookmark_commands::import_files(cli, &services),
        Some(Commands::Info { .. }) => bookmark_commands::info(cli, &services, settings),
        Some(Commands::Lsp { no_interpolation }) => handle_lsp(settings, no_interpolation),
        Some(Commands::CreateDb { .. }) => {
            // This should never be reached as CreateDb is handled specially in main.rs
            Err(error::CliError::CommandFailed(
                "CreateDb command should be handled in main.rs".to_string(),
            ))
        }
        Some(Commands::Completion { .. }) => {
            // This should never be reached as Completion is handled specially in main.rs
            Err(error::CliError::CommandFailed(
                "Completion command should be handled in main.rs".to_string(),
            ))
        }
        Some(Commands::Xxx { ids, tags }) => {
            eprintln!("ids: {:?}, tags: {:?}", ids, tags);
            Ok(())
        }
        None => Ok(()),
    }
}

fn handle_lsp(settings: &Settings, no_interpolation: bool) -> CliResult<()> {
    use tokio::runtime::Runtime;

    // Create a tokio runtime for the LSP server
    let rt = Runtime::new().map_err(|e| {
        error::CliError::CommandFailed(format!("Failed to create async runtime: {}", e))
    })?;

    // Run the LSP server
    rt.block_on(async {
        crate::lsp::run_lsp_server(settings, no_interpolation).await;
    });

    Ok(())
}