hypershell-reqwest-components 0.1.0-alpha

Modular DSL for shellscripting in Rust
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

#[cgp::re_export_imports]
mod preset {
    use std::vec::Vec;

    use cgp::core::component::UseDelegate;
    use cgp::extra::handler::{HandlerComponent, PipeHandlers, UseInputDelegate};
    use cgp::prelude::{cgp_preset, *};
    use hypershell_components::components::{
        HttpMethodTypeProviderComponent, MethodArgExtractorComponent, StringArgExtractorComponent,
        UrlTypeProviderComponent,
    };
    use hypershell_components::dsl::{
        GetMethod, Header, PostMethod, SimpleHttpRequest, StreamingHttpRequest, UrlEncodeArg,
        WithHeaders,
    };
    use hypershell_tokio_components::providers::{
        FuturesToTokioStream, WrapFuturesAsyncReadStream,
    };
    use hypershell_tokio_components::types::{FuturesAsyncReadStream, TokioAsyncReadStream};
    use reqwest::{Method, Url};

    use crate::components::RequestBuilderUpdaterComponent;
    use crate::dsl::CoreHttpRequest;
    use crate::providers::{
        ExtractReqwestMethod, HandleCoreHttpRequest, HandleSimpleHttpRequest,
        HandleStreamingHttpRequest, StreamToBody, UpdateRequestHeader, UpdateRequestHeaders,
        UrlEncodeStringArg,
    };

    cgp_preset! {
        HypershellReqwestPreset {
            HandlerComponent:
                ReqwestHandlerPreset::Provider,
            HttpMethodTypeProviderComponent:
                UseType<Method>,
            UrlTypeProviderComponent:
                UseType<Url>,
            StringArgExtractorComponent:
                ReqwestStringArgExtractorPreset::Provider,
            MethodArgExtractorComponent:
                MethodArgExtractorPreset::Provider,
            RequestBuilderUpdaterComponent:
                RequestBuilderUpdaterPreset::Provider,
        }
    }

    cgp_preset! {
        #[wrap_provider(UseDelegate)]
        ReqwestHandlerPreset {
            <Method, Url, Headers> SimpleHttpRequest<Method, Url, Headers>:
                HandleSimpleHttpRequest,
            <Method, Url, Headers> StreamingHttpRequest<Method, Url, Headers>:
                StreamingHttpHandlers::Provider,
            <Method, Url, Headers> CoreHttpRequest<Method, Url, Headers>:
                HandleCoreHttpRequest,
        }
    }

    cgp_preset! {
        #[wrap_provider(UseDelegate)]
        MethodArgExtractorPreset {
            [
                GetMethod,
                PostMethod,
            ]:
                ExtractReqwestMethod,
        }
    }

    cgp_preset! {
        #[wrap_provider(UseDelegate)]
        ReqwestStringArgExtractorPreset {
            <Arg> UrlEncodeArg<Arg>:
                UrlEncodeStringArg,
        }
    }

    cgp_preset! {
        #[wrap_provider(UseDelegate)]
        RequestBuilderUpdaterPreset {
            <Args> WithHeaders<Args>:
                UpdateRequestHeaders,
            <Key, Value> Header<Key, Value>:
                UpdateRequestHeader,
        }
    }

    cgp_preset! {
        #[wrap_provider(UseInputDelegate)]
        StreamingHttpHandlers {
            <S> FuturesAsyncReadStream<S>:
                PipeHandlers<Product![
                    FuturesToTokioStream,
                    StreamToBody,
                    HandleStreamingHttpRequest,
                    WrapFuturesAsyncReadStream,
                ]>,
            <S> TokioAsyncReadStream<S>:
                PipeHandlers<Product![
                    StreamToBody,
                    HandleStreamingHttpRequest,
                    WrapFuturesAsyncReadStream,
                ]>,
            Vec<u8>:
                PipeHandlers<Product![
                    HandleStreamingHttpRequest,
                    WrapFuturesAsyncReadStream,
                ]>,
        }
    }
}