shopify-client 1.2.0

Type-safe, async Rust client for the Shopify Admin and Storefront APIs
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

use crate::common::ServiceContext;

use crate::common::types::APIError;
use serde_json::{json, Value};

use super::queries;
use crate::common::http::execute_storefront_graphql as execute_graphql;
use crate::storefront::generated::types::content::{
    GetArticlesArgs, GetBlogArticlesArgs, GetBlogsArgs, GetPagesArgs,
};
use crate::storefront::generated::types::responses::{
    ArticleResponse, ArticlesResponse, BlogResponse, BlogsResponse, MenuResponse, PageResponse,
    PagesResponse,
};

use super::BlogRef;

pub async fn get_page_by_id(ctx: &ServiceContext, id: &str) -> Result<PageResponse, APIError> {
    execute_graphql(ctx, queries::get_page_by_id(), json!({ "id": id })).await
}

pub async fn get_page_by_handle(
    ctx: &ServiceContext,
    handle: &str,
) -> Result<PageResponse, APIError> {
    execute_graphql(
        ctx,
        queries::get_page_by_handle(),
        json!({ "handle": handle }),
    )
    .await
}

pub async fn get_pages(
    ctx: &ServiceContext,
    args: GetPagesArgs,
) -> Result<PagesResponse, APIError> {
    let variables = serde_json::to_value(&args).unwrap_or(json!({}));
    execute_graphql(ctx, queries::get_pages(), variables).await
}

pub async fn get_blog_by_id(ctx: &ServiceContext, id: &str) -> Result<BlogResponse, APIError> {
    execute_graphql(ctx, queries::get_blog_by_id(), json!({ "id": id })).await
}

pub async fn get_blog_by_handle(
    ctx: &ServiceContext,
    handle: &str,
) -> Result<BlogResponse, APIError> {
    execute_graphql(
        ctx,
        queries::get_blog_by_handle(),
        json!({ "handle": handle }),
    )
    .await
}

pub async fn get_blogs(
    ctx: &ServiceContext,
    args: GetBlogsArgs,
) -> Result<BlogsResponse, APIError> {
    let variables = serde_json::to_value(&args).unwrap_or(json!({}));
    execute_graphql(ctx, queries::get_blogs(), variables).await
}

pub async fn get_blog_with_articles(
    ctx: &ServiceContext,
    selector: BlogRef,
    args: GetBlogArticlesArgs,
) -> Result<BlogResponse, APIError> {
    let mut variables = serde_json::to_value(&args).unwrap_or(json!({}));
    if let Value::Object(ref mut map) = variables {
        match selector {
            BlogRef::Id(id) => {
                map.insert("id".to_string(), Value::String(id));
            }
            BlogRef::Handle(handle) => {
                map.insert("handle".to_string(), Value::String(handle));
            }
        }
    }
    execute_graphql(ctx, queries::get_blog_with_articles(), variables).await
}

pub async fn get_article_by_id(
    ctx: &ServiceContext,
    id: &str,
) -> Result<ArticleResponse, APIError> {
    execute_graphql(ctx, queries::get_article_by_id(), json!({ "id": id })).await
}

pub async fn get_articles(
    ctx: &ServiceContext,
    args: GetArticlesArgs,
) -> Result<ArticlesResponse, APIError> {
    let variables = serde_json::to_value(&args).unwrap_or(json!({}));
    execute_graphql(ctx, queries::get_articles(), variables).await
}

pub async fn get_menu(ctx: &ServiceContext, handle: &str) -> Result<MenuResponse, APIError> {
    execute_graphql(ctx, queries::get_menu(), json!({ "handle": handle })).await
}