enphase 0.4.0

An async wrapper around the Enphase APIs - both direct local access to Envoy devices, and the Enlighten cloud service
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

use core::cmp;

use chrono::DateTime;
use chrono::Utc;

#[derive(Clone, Debug)]
pub struct AggregateProduction {
	pub timestamp: DateTime<Utc>,
	pub inverters_reporting: u16,
	pub instantaneous_power_watts: i32
}

impl Default for AggregateProduction {
	#[inline]
	fn default() -> Self {
		Self {
			timestamp: DateTime::<Utc>::MIN_UTC,
			inverters_reporting: 0,
			instantaneous_power_watts: 0
		}
	}
}

impl From<&[crate::envoy::Inverter]> for AggregateProduction {
	#[inline]
	fn from(raw: &[crate::envoy::Inverter]) -> Self {
		let mut aggregate = Self { inverters_reporting: raw.len() as u16, ..Default::default() };
		for inverter in raw {
			aggregate.timestamp = cmp::max(aggregate.timestamp, inverter.last_report_date);
			aggregate.instantaneous_power_watts += inverter.last_report_watts as i32;
		}
		aggregate
	}
}

impl From<crate::cloud::MicroinverterProduction> for AggregateProduction {
	#[inline]
	fn from(raw: crate::cloud::MicroinverterProduction) -> Self {
		Self {
			timestamp: raw.end_at,
			inverters_reporting: raw.devices_reporting,
			instantaneous_power_watts: raw.instantaneous_power_watts
		}
	}
}