thegraph-client-subgraphs 0.3.2

A client for The Graph network's Subgraphs data service
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

use thegraph_core::BlockPointer;
use thegraph_graphql_http::{
    http::request::IntoRequestParameters,
    http_client::{ReqwestExt, ResponseResult},
};
use url::Url;

#[derive(Debug, serde::Deserialize)]
pub struct Meta {
    pub block: BlockPointer,
}

/// Send an authenticated GraphQL query to a subgraph.
pub async fn send_query<T>(
    client: &reqwest::Client,
    url: Url,
    auth: Option<&str>,
    query: impl IntoRequestParameters + Send,
) -> Result<ResponseResult<T>, String>
where
    T: for<'de> serde::Deserialize<'de>,
{
    let mut builder = client.post(url);

    if let Some(auth) = auth {
        builder = builder.bearer_auth(auth)
    }

    let res = builder
        .send_graphql(query)
        .await
        .map_err(|err| err.to_string())?;

    Ok(res)
}

pub async fn send_subgraph_query<T>(
    client: &reqwest::Client,
    subgraph_url: Url,
    auth: Option<&str>,
    query: impl IntoRequestParameters + Send,
) -> Result<T, String>
where
    T: for<'de> serde::Deserialize<'de>,
{
    send_query(client, subgraph_url, auth, query)
        .await
        .map_err(|err| format!("Error sending subgraph graphql query: {err}"))?
        .map_err(|err| err.to_string())
}