cinnamon 2.0.0-alpha.1

A type-safe, async Nightscout client for Rust: API v3 with v1/v2 fallback, JWT auth, incremental sync and realtime streams.
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

//! `GET /api/v2/ddata/at/{time}`: the data window Nightscout's plugins compute from.

use serde::{Deserialize, Serialize};
use serde_json::Value;

use super::{
    DeviceStatus, Extra, ProfileStore, Timestamp, Treatment, de, properties::PropertySgv, time,
};

/// A snapshot of the server's in-memory data (roughly the last two days before `at`).
#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
#[non_exhaustive]
pub struct DData {
    /// Sensor glucose samples.
    #[serde(default, deserialize_with = "de::null_as_empty")]
    pub sgvs: Vec<PropertySgv>,
    /// Meter glucose samples.
    #[serde(default, deserialize_with = "de::null_as_empty")]
    pub mbgs: Vec<PropertySgv>,
    /// Calibrations.
    #[serde(default, deserialize_with = "de::null_as_empty")]
    pub cals: Vec<Value>,
    /// Treatments.
    #[serde(default, deserialize_with = "tolerant_vec")]
    pub treatments: Vec<Treatment>,
    /// Profile documents.
    #[serde(default, deserialize_with = "tolerant_vec")]
    pub profiles: Vec<ProfileStore>,
    /// Device status reports.
    #[serde(default, deserialize_with = "tolerant_vec")]
    pub devicestatus: Vec<DeviceStatus>,
    /// Food items.
    #[serde(default, deserialize_with = "de::null_as_empty")]
    pub food: Vec<Value>,
    /// Database statistics.
    #[serde(default)]
    pub dbstats: Option<Value>,
    /// When the server last refreshed this data.
    #[serde(rename = "lastUpdated", default, with = "time::millis")]
    pub last_updated: Option<Timestamp>,
    /// Pre-filtered treatment lists (`sitechangeTreatments`, `tempbasalTreatments`, …) and
    /// other fields.
    #[serde(flatten)]
    pub extra: Extra,
}

/// Decodes each element independently, skipping the ones that fail.
pub(crate) fn tolerant_vec<'de, D, T>(d: D) -> Result<Vec<T>, D::Error>
where
    D: serde::Deserializer<'de>,
    T: serde::de::DeserializeOwned,
{
    Ok(Option::<Vec<Value>>::deserialize(d)?
        .unwrap_or_default()
        .into_iter()
        .filter_map(|v| serde_json::from_value(v).ok())
        .collect())
}