gthings 0.3.6

CLI binary for gthings — browser-automated web research toolkit
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

use gthings_common::config::GthingsConfig;
use gthings_common::trace::TraceWriter;
use gthings_search::types::*;

/// Format output for a single search query result.
fn output_search_results(
    results: &[SearchResult],
    meta: &SearchMeta,
    json: bool,
) -> Result<(), anyhow::Error> {
    if json {
        let value = serde_json::json!({
            "meta": meta,
            "results": results,
        });
        let output = serde_json::to_string_pretty(&value)?;
        println!("{}", output);
    } else {
        println!(
            "Search results ({} total, {} ms)",
            meta.total, meta.duration_ms
        );
        println!("Query: {}", meta.query);
        println!();
        for (i, r) in results.iter().enumerate() {
            println!("{}. {}", i + 1, r.title);
            println!("   URL: {}", r.url);
            println!("   {}", r.snippet);
            println!();
        }
    }
    Ok(())
}

/// Handler for `search query <query> [--count N]`
pub(crate) async fn handle_search_query(
    config: &GthingsConfig,
    query: &str,
    count: usize,
    json: bool,
    trace: Option<&mut TraceWriter>,
) -> Result<(), anyhow::Error> {
    let searcher = gthings_search::GoogleSearch::new(config.clone());
    let results = searcher.query(query, count, None, trace).await?;

    let meta = SearchMeta {
        total: results.len(),
        query: query.to_string(),
        duration_ms: 0,
    };

    output_search_results(&results, &meta, json)?;
    Ok(())
}

/// Handler for `search batch <queries...> [--count N]`
pub(crate) async fn handle_search_batch(
    config: &GthingsConfig,
    queries: &[String],
    count: usize,
    json: bool,
    trace: Option<&mut TraceWriter>,
) -> Result<(), anyhow::Error> {
    let processor = gthings_search::BatchProcessor::new(config.clone());
    let result = processor.search(queries, count, trace).await?;

    output_search_results(&result.results, &result.meta, json)?;
    Ok(())
}

/// Handler for `search harvest <queries...> [--count N] [--max N] [--concurrency N] [--follow-concurrency N]`
#[allow(clippy::too_many_arguments)]
pub(crate) async fn handle_search_harvest(
    config: &GthingsConfig,
    queries: &[String],
    count: usize,
    max: Option<usize>,
    concurrency: Option<usize>,
    follow_concurrency: Option<usize>,
    json: bool,
    trace: Option<&mut TraceWriter>,
) -> Result<(), anyhow::Error> {
    let max_pages = max.unwrap_or(count);

    // Apply CLI overrides to config
    let mut config = config.clone();
    if let Some(c) = concurrency {
        config.search_concurrency = c;
    }
    if let Some(fc) = follow_concurrency {
        config.follow_concurrency = fc;
    }

    let processor = gthings_search::BatchProcessor::new(config);
    let result = processor.harvest(queries, count, max_pages, trace).await?;

    if json {
        let output = serde_json::to_string_pretty(&result)?;
        println!("{}", output);
    } else {
        println!(
            "Harvest complete — {} queries, {} search results, {} pages followed ({} ms)",
            result.meta.queries.len(),
            result.meta.total_search_results,
            result.meta.pages_followed,
            result.meta.duration_ms,
        );
        println!();
        if !result.search_results.is_empty() {
            println!("── Search Results ──");
            for (i, r) in result.search_results.iter().enumerate() {
                println!("{}. {} — {}", i + 1, r.title, r.url);
            }
            println!();
        }
        if !result.read_pages.is_empty() {
            println!("── Followed Pages ──");
            for (i, p) in result.read_pages.iter().enumerate() {
                let status = if p.success { "OK" } else { "FAIL" };
                let len_info = p
                    .content
                    .as_ref()
                    .map(|c| format!(" ({} chars)", c.len()))
                    .unwrap_or_default();
                println!("{}. [{}] {}{}", i + 1, status, p.url, len_info);
            }
        }
    }
    Ok(())
}