grafbase-local-server 0.19.2

A wrapper for the grafbase worker
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

use serde::{Deserialize, Serialize};

use super::{cursor::Cursor, query::Query};

#[derive(Debug, Serialize, Deserialize)]
pub struct QueryExecutionRequest {
    pub query: Query,
    pub pagination: Pagination,
    pub entity_type: String,
    pub database: String,
}

pub type QueryExecutionResponse = PaginatedHits<String>;

#[derive(Debug, Serialize, Deserialize)]
pub enum Pagination {
    Forward { first: u64, after: Option<Cursor> },
    Backward { last: u64, before: Cursor },
}

#[derive(Debug, Serialize, Deserialize)]
pub struct PaginatedHits<Id> {
    pub hits: Vec<Hit<Id>>,
    pub info: Info,
}

impl<T> PaginatedHits<T> {
    pub fn map_id<U, F: Fn(T) -> U>(self, f: F) -> PaginatedHits<U> {
        let PaginatedHits { hits, info } = self;
        PaginatedHits {
            hits: hits
                .into_iter()
                .map(|Hit { id, cursor, score }| Hit {
                    id: f(id),
                    cursor,
                    score,
                })
                .collect(),
            info,
        }
    }
}

#[derive(Debug, Serialize, Deserialize, PartialEq, Eq)]
pub struct Info {
    pub has_previous_page: bool,
    pub has_next_page: bool,
    pub total_hits: u64,
}

#[derive(Debug, Serialize, Deserialize)]
pub struct Hit<Id> {
    pub id: Id,
    pub cursor: Cursor,
    pub score: f32,
}