ownserp 1.3.1

OwnSERP, an MCP server for the Serper.dev search API, over stdio and Streamable HTTP
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
117
118
119
120
121
122
123
124
125

use anyhow::{Context, bail};
use ownserp_core::{ApiKeySource, SerperClient, Settings};

use crate::cli::DoctorArgs;
use crate::output::emit;

pub(crate) fn run(args: DoctorArgs) -> anyhow::Result<()> {
    let settings = Settings::load(args.into_overrides()).context("resolving settings")?;
    emit(&format!("OwnSERP {}", env!("CARGO_PKG_VERSION")))?;
    emit(&format!(
        "api key source: {}",
        settings.api_key_source().label()
    ))?;
    if let Some(error) = settings.api_key_error() {
        emit(&format!("keychain error: {error}"))?;
    }
    emit(&format!("api key: {}", settings.masked_key()))?;
    emit(&format!("pack tier: {:?}", settings.pack()))?;
    emit(&format!(
        "usd per 1000 credits: {}",
        format_usd_rate(&settings)
    ))?;
    emit(&format!(
        "queries per second ceiling: {}",
        settings.qps().get()
    ))?;
    emit(&format!("cache ttl seconds: {}", settings.cache_ttl_secs()))?;
    emit(&format!("cache byte cap: {}", settings.cache_max_bytes()))?;
    emit(&format!(
        "ledger directory: {}",
        settings.ledger_dir().display()
    ))?;
    emit(&format!("batch tool enabled: {}", settings.enable_batch()))?;
    emit(&format!(
        "transport: {}",
        if settings.http() {
            "streamable http"
        } else {
            "stdio"
        }
    ))?;
    let hosts = settings.allowed_hosts().map_or_else(
        || "from the bind address".to_owned(),
        |hosts| hosts.join(", "),
    );
    emit(&format!("allowed hosts: {hosts}"))?;
    if let Some(path) = settings.profile_path() {
        emit(&format!(
            "profile: {} (exists: {})",
            path.display(),
            path.exists()
        ))?;
    }
    if settings.api_key_source() == ApiKeySource::Missing {
        emit("result: no API key; search tools will refuse until one is set")?;
        bail!("no API key; set SERPER_API_KEY or run ownserp config set-api-key");
    }
    let client = SerperClient::new(&settings).context("building the client")?;
    let runtime = tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .context("building the runtime")?;
    let (health, balance) =
        runtime.block_on(async { (client.health().await, client.live_balance().await) });
    let reachable = health.is_some();
    match health {
        Some(body) => emit(&format!("serper api health: {body}"))?,
        None => emit("serper api health: no answer from api.serper.dev/health")?,
    }
    match balance {
        Some(credits) => emit(&format!("account balance: {credits} credits"))?,
        None => emit("account balance: not reported; GET /account did not answer with a balance")?,
    }
    if !reachable {
        bail!("api.serper.dev/health did not answer");
    }
    Ok(())
}

fn format_usd_rate(settings: &Settings) -> String {
    match settings
        .usd_per_1k()
        .or_else(|| settings.pack().usd_per_1k())
    {
        Some(rate) => format!("${rate:.2}"),
        None => "set SERPER_USD_PER_1K".to_owned(),
    }
}

#[cfg(test)]
mod tests {
    use std::collections::BTreeMap;

    use ownserp_core::Overrides;

    use super::*;

    fn settings(pairs: &[(&str, &str)]) -> Settings {
        let map: BTreeMap<String, String> = pairs
            .iter()
            .map(|(key, value)| ((*key).to_owned(), (*value).to_owned()))
            .collect();
        let profile = std::env::temp_dir().join("ownserp-doctor-test.toml");
        std::fs::write(&profile, "").expect("profile");
        Settings::load_with(
            Overrides {
                profile: Some(profile),
                ledger_dir: Some(std::env::temp_dir().join("ownserp-doctor-test")),
                cache_ttl_secs: Some(0),
                ..Overrides::default()
            },
            |name| map.get(name).cloned(),
        )
        .expect("settings")
    }

    #[test]
    fn the_rate_comes_from_the_pack_or_the_override() {
        assert_eq!(format_usd_rate(&settings(&[])), "$1.00");
        assert_eq!(
            format_usd_rate(&settings(&[("SERPER_USD_PER_1K", "0.42")])),
            "$0.42"
        );
    }
}