Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 8398bb17ed | |||
| cfcb7a0ebb | |||
| ff47f86792 | |||
| 465477e862 | |||
| 6075085b0b |
@@ -389,7 +389,7 @@ impl Handler<SynchronizeDevice> for EnergyActor {
|
|||||||
pub struct ResDevState {
|
pub struct ResDevState {
|
||||||
pub id: DeviceId,
|
pub id: DeviceId,
|
||||||
last_ping: u64,
|
last_ping: u64,
|
||||||
online: bool,
|
pub online: bool,
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Get the state of devices
|
/// Get the state of devices
|
||||||
|
|||||||
@@ -64,6 +64,8 @@ pub async fn legacy_state(
|
|||||||
pub struct FullRelayState {
|
pub struct FullRelayState {
|
||||||
/// Indicates if the relay (or its parent device) is enabled or not
|
/// Indicates if the relay (or its parent device) is enabled or not
|
||||||
enabled: bool,
|
enabled: bool,
|
||||||
|
/// Indicate if the device is online or not
|
||||||
|
online: bool,
|
||||||
/// Indicates if relay is on or off
|
/// Indicates if relay is on or off
|
||||||
is_on: bool,
|
is_on: bool,
|
||||||
/// Relay name
|
/// Relay name
|
||||||
@@ -96,6 +98,8 @@ pub async fn relays_full_state(energy_actor: WebEnergyActor) -> HttpResult {
|
|||||||
let cached_consumption = energy_actor.send(energy_actor::GetCurrConsumption).await?;
|
let cached_consumption = energy_actor.send(energy_actor::GetCurrConsumption).await?;
|
||||||
let relays_consumption = energy_actor.send(energy_actor::RelaysConsumption).await?;
|
let relays_consumption = energy_actor.send(energy_actor::RelaysConsumption).await?;
|
||||||
let curr_consumption = consumption::get_curr_consumption().await.ok();
|
let curr_consumption = consumption::get_curr_consumption().await.ok();
|
||||||
|
let devices = energy_actor.send(energy_actor::GetDeviceLists).await?;
|
||||||
|
let devices_state = energy_actor.send(energy_actor::GetDevicesState).await?;
|
||||||
let mut relays = energy_actor.send(energy_actor::GetRelaysList).await?;
|
let mut relays = energy_actor.send(energy_actor::GetRelaysList).await?;
|
||||||
relays.sort_by_key(|r| -(r.priority as i64));
|
relays.sort_by_key(|r| -(r.priority as i64));
|
||||||
let relays_state = energy_actor.send(energy_actor::GetAllRelaysState).await?;
|
let relays_state = energy_actor.send(energy_actor::GetAllRelaysState).await?;
|
||||||
@@ -107,16 +111,24 @@ pub async fn relays_full_state(energy_actor: WebEnergyActor) -> HttpResult {
|
|||||||
relays: relays
|
relays: relays
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|r| {
|
.map(|r| {
|
||||||
let state = relays_state.iter().find(|s| s.id == r.id);
|
let device = devices
|
||||||
|
.iter()
|
||||||
|
.find(|d| d.relays.iter().any(|sr| sr.id == r.id))
|
||||||
|
.expect("All relay shall have an associated device!");
|
||||||
|
let device_state = devices_state.iter().find(|s| s.id == device.id);
|
||||||
|
let relay_state = relays_state.iter().find(|s| s.id == r.id);
|
||||||
FullRelayState {
|
FullRelayState {
|
||||||
enabled: r.enabled,
|
enabled: r.enabled && device.enabled,
|
||||||
is_on: state.map(|s| s.on).unwrap_or(false),
|
online: device_state.map(|d| d.online).unwrap_or(false),
|
||||||
|
is_on: relay_state.map(|s| s.on).unwrap_or(false),
|
||||||
name: r.name,
|
name: r.name,
|
||||||
priority: r.priority,
|
priority: r.priority,
|
||||||
r#for: state.map(|s| s.r#for).unwrap_or(0),
|
r#for: relay_state.map(|s| s.r#for).unwrap_or(0),
|
||||||
total_uptime: 0,
|
total_uptime: 0,
|
||||||
daily_requirement: r.daily_runtime.map(|r| r.min_runtime),
|
daily_requirement: r.daily_runtime.map(|r| r.min_runtime),
|
||||||
relay_forced_state: state.map(|s| s.forced_state.clone()).unwrap_or_default(),
|
relay_forced_state: relay_state
|
||||||
|
.map(|s| s.forced_state.clone())
|
||||||
|
.unwrap_or_default(),
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
.collect(),
|
.collect(),
|
||||||
|
|||||||
775
central_frontend/package-lock.json
generated
775
central_frontend/package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@@ -31,15 +31,15 @@
|
|||||||
"@types/react": "^19.2.7",
|
"@types/react": "^19.2.7",
|
||||||
"@types/react-dom": "^19.2.3",
|
"@types/react-dom": "^19.2.3",
|
||||||
"@types/semver": "^7.7.1",
|
"@types/semver": "^7.7.1",
|
||||||
"@typescript-eslint/eslint-plugin": "^8.48.1",
|
"@typescript-eslint/eslint-plugin": "^8.49.0",
|
||||||
"@typescript-eslint/parser": "^8.48.1",
|
"@typescript-eslint/parser": "^8.49.0",
|
||||||
"@vitejs/plugin-react": "^5.1.2",
|
"@vitejs/plugin-react": "^5.1.2",
|
||||||
"eslint": "^9.39.1",
|
"eslint": "^9.39.1",
|
||||||
"eslint-plugin-react-hooks": "^7.0.1",
|
"eslint-plugin-react-hooks": "^7.0.1",
|
||||||
"eslint-plugin-react-refresh": "^0.4.24",
|
"eslint-plugin-react-refresh": "^0.4.24",
|
||||||
"globals": "^16.5.0",
|
"globals": "^16.5.0",
|
||||||
"typescript": "^5.9.3",
|
"typescript": "^5.9.3",
|
||||||
"typescript-eslint": "^8.48.1",
|
"typescript-eslint": "^8.49.0",
|
||||||
"vite": "^7.2.7"
|
"vite": "^7.2.7"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user