bcode_server 0.0.1-alpha.0

Local bcode daemon runtime
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

//! Transport-neutral application operations for federated session search.

use super::ServerState;

/// One federated search result with optional bounded hydration.
pub struct SearchResult {
    pub response: bcode_session_search::FederatedSessionSearchResponse,
    pub hydrated_hits: Vec<bcode_session_search::HydratedSessionSearchHit>,
}

/// Execute one federated session search without transport framing.
pub async fn search(
    state: &ServerState,
    request: &bcode_session_search::SessionSearchRequest,
    policy: &bcode_session_search::SessionSearchPlanPolicy,
    routes: &[bcode_session_search::SessionSearchContentRoute],
    hydrate: bool,
) -> Result<SearchResult, bcode_session_search::SessionSearchServiceError> {
    let mut response = super::session_search::search_federated_with_policy_and_routes(
        state, request, policy, routes,
    )
    .await?;
    let hydrated_hits = if hydrate {
        let started = std::time::Instant::now();
        let hydrated = super::session_search::hydrate_hits(state, response.hits.clone()).await;
        super::session_search::report_hydration_outcomes(
            &mut response,
            &hydrated,
            u64::try_from(started.elapsed().as_millis()).unwrap_or(u64::MAX),
        );
        hydrated
    } else {
        Vec::new()
    };
    Ok(SearchResult {
        response,
        hydrated_hits,
    })
}