bevy_request 0.1.0-alpha.0

A HTTP client library for bevy
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

use async_compat::CompatExt;
use bevy::{prelude::*, tasks::IoTaskPool};

use crate::{
    interface::{
        client::{Client, DefaultClient},
        headers::Headers,
        method::Method,
        url::Url,
    },
    internal::channel::Tx,
};

pub(crate) fn start_request(
    // TODO: which component is the most foundamental one?
    // or use the bundle `or` semantic?
    add: On<Add, Method>,
    query: Query<(&Url, &Method, Option<&Headers>, Option<&Client>)>,
    tx: Res<Tx>,
    default_client: Option<Res<DefaultClient>>,
) {
    let entity = add.entity;

    // filter out unrelated
    let Ok((url, method, headers, client)) = query.get(entity) else {
        warn!("missing url in request");
        return;
    };

    let pool = IoTaskPool::get();
    pool.spawn({
        let tx = tx.clone();
        let url = url.0.clone();
        let method = method.0.clone();
        // TODO: avoid clone
        let headers = headers.cloned();

        // client order:
        // 1. `Client` component
        // 2. `DefaultClient` Resource
        // 3. create a new client TODO: should by default reuse
        let client = client
            .map(|c| c.0.clone())
            .or(default_client.map(|r| r.0.clone()))
            .unwrap_or_default();

        async move {
            // build request
            let mut request = client.request(method, url);
            if let Some(headers) = headers {
                request = request.headers(headers.0);
            }

            // await response
            let response = request.send().await;
            tx.send(entity, response);
        }
        .compat()
    })
    .detach();
}