looprs 0.5.1

Concise coding assistant REPL — core library
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

//! Adapters (hexagonal architecture) — implementations of ports.
//!
//! Portable adapters live in `looprs_core::adapters` and are re-exported here
//! for backwards compatibility. Adapters that depend on looprs internals
//! (`PluginsAdapter`, `RetryProvider`) remain in this module.

pub mod plugin_executor;
pub mod retry_provider;
pub mod sqlite_session_store;
pub mod ui_output;

// Re-export portable adapters from looprs-core.
pub use looprs_core::adapters::ChannelBroker;
pub use looprs_core::adapters::FsSessionStore;
pub use looprs_core::adapters::NullOutput;
pub use looprs_core::adapters::TerminalOutput;
pub use plugin_executor::PluginsAdapter;
pub use retry_provider::RetryProvider;
pub use sqlite_session_store::SqliteSessionStore;
pub use ui_output::UiOutput;

use crate::app_config::{AppConfig, SessionStoreBackend};
use crate::ports::SessionStore;

/// Create the session store selected by `persistence.session_store` in config.
///
/// - `sqlite` → `SqliteSessionStore` at `~/.looprs/sessions.db`
/// - `fs` (default) → `FsSessionStore` at `~/.looprs/sessions/`, with a
///   `$TMPDIR/looprs-sessions/` fallback if that path is not writable.
///
/// Returns `None` only when the selected backend cannot be initialised.
pub fn default_session_store() -> Option<Box<dyn SessionStore>> {
    let backend = AppConfig::load()
        .ok()
        .map(|c| c.persistence.session_store)
        .unwrap_or_default();

    match backend {
        SessionStoreBackend::Sqlite => {
            let db_path = dirs::home_dir()?.join(".looprs").join("sessions.db");
            match SqliteSessionStore::new(db_path) {
                Ok(store) => Some(Box::new(store) as Box<dyn SessionStore>),
                Err(e) => {
                    log::warn!("failed to open SQLite session store: {e}");
                    None
                }
            }
        }
        SessionStoreBackend::Fs => {
            let primary = dirs::home_dir().map(|h| h.join(".looprs").join("sessions"));
            primary
                .and_then(|d| FsSessionStore::new(d).ok())
                .map(|s| Box::new(s) as Box<dyn SessionStore>)
                .or_else(|| {
                    match FsSessionStore::new(std::env::temp_dir().join("looprs-sessions")) {
                        Ok(logger) => Some(Box::new(logger) as Box<dyn SessionStore>),
                        Err(e) => {
                            log::warn!("failed to initialize fallback session logger: {e}");
                            None
                        }
                    }
                })
        }
    }
}