cdsapi 0.1.1

Rust client for the Copernicus Climate Data Store (CDS) API, inspired by the Python cdsapi library.
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

use anyhow::{Result, bail};
use serde_json::Value;

use crate::client::RemoteFile;
use crate::util::urljoin;

#[derive(Debug, serde::Deserialize)]
pub(crate) struct ApiReply {
    pub(crate) state: String,
    #[serde(default)]
    pub(crate) request_id: Option<String>,

    #[serde(default)]
    pub(crate) location: Option<String>,
    #[serde(default, alias = "contentLength", alias = "content_length")]
    pub(crate) content_length: Option<u64>,
    #[serde(default, alias = "contentType", alias = "content_type")]
    pub(crate) content_type: Option<String>,

    #[serde(default)]
    pub(crate) result: Option<Value>,

    #[serde(default)]
    pub(crate) error: Option<ApiError>,
}

#[derive(Debug, serde::Deserialize)]
pub(crate) struct ApiError {
    #[serde(default)]
    pub(crate) message: Option<String>,
    #[serde(default)]
    pub(crate) reason: Option<String>,
}

#[derive(Debug, serde::Deserialize)]
struct ApiResultLocation {
    location: String,
    #[serde(alias = "contentLength", alias = "content_length")]
    content_length: u64,
    #[serde(default, alias = "contentType", alias = "content_type")]
    content_type: Option<String>,
}

pub(crate) fn remote_file_from_reply(reply: &ApiReply, base_url: &str) -> Result<RemoteFile> {
    // 1) If API returns {"result": {"location":...,"contentLength":...}}
    if let Some(result) = &reply.result {
        if let Ok(r) = serde_json::from_value::<ApiResultLocation>(result.clone()) {
            return Ok(RemoteFile {
                location: urljoin(base_url, &r.location),
                content_length: r.content_length,
                content_type: r.content_type,
            });
        }
    }

    // 2) Or it returns location/contentLength at top-level
    if let (Some(location), Some(content_length)) = (&reply.location, reply.content_length) {
        return Ok(RemoteFile {
            location: urljoin(base_url, location),
            content_length,
            content_type: reply.content_type.clone(),
        });
    }

    bail!("missing download info in API reply")
}