forked from OpenEnergyDashboard/OED
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request OpenEnergyDashboard#1039 from nathang15/add-radar-…
…graph-feature Add radar graph feature
- Loading branch information
Showing
23 changed files
with
999 additions
and
47 deletions.
There are no files selected for viewing
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,160 @@ | ||
| /* This Source Code Form is subject to the terms of the Mozilla Public | ||
| * License, v. 2.0. If a copy of the MPL was not distributed with this | ||
| * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ | ||
|
|
||
| import { TimeInterval } from '../../../common/TimeInterval'; | ||
| import { ActionType, Thunk, Dispatch, GetState } from '../types/redux/actions'; | ||
| import { State } from '../types/redux/state'; | ||
| import * as t from '../types/redux/radarReadings'; | ||
| import { readingsApi } from '../utils/api'; | ||
| import { LineReadings } from '../types/readings'; | ||
|
|
||
| /** | ||
| * @param state the Redux state | ||
| * @param meterID the ID of the meter to check | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| * @returns True if the readings for the given meter, time duration and unit are missing; false otherwise. | ||
| */ | ||
| function shouldFetchMeterRadarReadings(state: State, meterID: number, timeInterval: TimeInterval, unitID: number): boolean { | ||
| const timeIntervalIndex = timeInterval.toString(); | ||
|
|
||
| const readingsForID = state.readings.line.byMeterID[meterID]; | ||
| if (readingsForID === undefined) { | ||
| return true; | ||
| } | ||
|
|
||
| const readingsForTimeInterval = readingsForID[timeIntervalIndex]; | ||
| if (readingsForTimeInterval === undefined) { | ||
| return true; | ||
| } | ||
|
|
||
| const readingsForUnit = readingsForTimeInterval[unitID]; | ||
| if (readingsForUnit === undefined) { | ||
| return true; | ||
| } | ||
|
|
||
| return !readingsForUnit.isFetching; | ||
| } | ||
|
|
||
| /** | ||
| * @param state the Redux state | ||
| * @param groupID the ID of the group to check | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| * @returns True if the readings for the given group, time duration and unit are missing; false otherwise. | ||
| */ | ||
| function shouldFetchGroupRadarReadings(state: State, groupID: number, timeInterval: TimeInterval, unitID: number): boolean { | ||
| const timeIntervalIndex = timeInterval.toString(); | ||
|
|
||
| const readingsForID = state.readings.line.byGroupID[groupID]; | ||
| if (readingsForID === undefined) { | ||
| return true; | ||
| } | ||
|
|
||
| const readingsForTimeInterval = readingsForID[timeIntervalIndex]; | ||
| if (readingsForTimeInterval === undefined) { | ||
| return true; | ||
| } | ||
|
|
||
| const readingsForUnit = readingsForTimeInterval[unitID]; | ||
| if (readingsForUnit === undefined) { | ||
| return true; | ||
| } | ||
|
|
||
| return !readingsForUnit.isFetching; | ||
| } | ||
|
|
||
| /** | ||
| * @param meterIDs the IDs of the meters to get readings | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| */ | ||
| function requestMeterRadarReadings(meterIDs: number[], timeInterval: TimeInterval, unitID: number): t.RequestMeterRadarReadingAction { | ||
| return { type: ActionType.RequestMeterLineReadings, meterIDs, timeInterval, unitID }; | ||
| } | ||
|
|
||
| /** | ||
| * @param groupIDs the IDs of the groups to get readings | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| */ | ||
| function requestGroupRadarReadings(groupIDs: number[], timeInterval: TimeInterval, unitID: number): t.RequestGroupRadarReadingAction { | ||
| return { type: ActionType.RequestGroupLineReadings, groupIDs, timeInterval, unitID }; | ||
| } | ||
| /** | ||
| * @param meterIDs the IDs of the meters to get readings | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| * @param readings the readings for the given meters | ||
| */ | ||
| function receiveMeterRadarReadings( | ||
| meterIDs: number[], timeInterval: TimeInterval, unitID: number, readings: LineReadings): t.ReceiveMeterRadarReadingAction { | ||
| return { type: ActionType.ReceiveMeterLineReadings, meterIDs, timeInterval, unitID, readings }; | ||
| } | ||
|
|
||
| /** | ||
| * @param groupIDs the IDs of the groups to get readings | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| * @param readings the readings for the given groups | ||
| */ | ||
| function receiveGroupLineReadings( | ||
| groupIDs: number[], timeInterval: TimeInterval, unitID: number, readings: LineReadings): t.ReceiveGroupRadarReadingAction { | ||
| return { type: ActionType.ReceiveGroupLineReadings, groupIDs, timeInterval, unitID, readings }; | ||
| } | ||
|
|
||
| /** | ||
| * @param meterIDs the IDs of the meters to get readings | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| */ | ||
| function fetchMeterRadarReadings(meterIDs: number[], timeInterval: TimeInterval, unitID: number): Thunk { | ||
| return async (dispatch: Dispatch) => { | ||
| dispatch(requestMeterRadarReadings(meterIDs, timeInterval, unitID)); | ||
| const meterLineReadings = await readingsApi.meterRadarReadings(meterIDs, timeInterval, unitID); | ||
| dispatch(receiveMeterRadarReadings(meterIDs, timeInterval, unitID, meterLineReadings)); | ||
| }; | ||
| } | ||
|
|
||
| /** | ||
| * @param groupIDs the IDs of the groups to get readings | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| */ | ||
| function fetchGroupRadarReadings(groupIDs: number[], timeInterval: TimeInterval, unitID: number): Thunk { | ||
| return async (dispatch: Dispatch) => { | ||
| dispatch(requestGroupRadarReadings(groupIDs, timeInterval, unitID)); | ||
| const groupLineReadings = await readingsApi.groupRadarReadings(groupIDs, timeInterval, unitID); | ||
| dispatch(receiveGroupLineReadings(groupIDs, timeInterval, unitID, groupLineReadings)); | ||
| }; | ||
| } | ||
| /** | ||
| * Fetches readings for the radar chart of all selected meters and groups, if needed. | ||
| * @param timeInterval the interval over which to check | ||
| * @param unitID the ID of the unit for which to check | ||
| */ | ||
| export function fetchNeededRadarReadings(timeInterval: TimeInterval, unitID: number): Thunk { | ||
| return (dispatch: Dispatch, getState: GetState) => { | ||
| const state = getState(); | ||
| const promises: Array<Promise<any>> = []; | ||
|
|
||
| // Determine which meters are missing data for this time interval | ||
| const meterIDsToFetchForLine = state.graph.selectedMeters.filter( | ||
| id => shouldFetchMeterRadarReadings(state, id, timeInterval, unitID) | ||
| ); | ||
| if (meterIDsToFetchForLine.length > 0) { | ||
| promises.push(dispatch(fetchMeterRadarReadings(meterIDsToFetchForLine, timeInterval, unitID))); | ||
| } | ||
|
|
||
| // Determine which groups are missing data for this time interval | ||
| const groupIDsToFetchForLine = state.graph.selectedGroups.filter( | ||
| id => shouldFetchGroupRadarReadings(state, id, timeInterval, unitID) | ||
| ); | ||
| if (groupIDsToFetchForLine.length > 0) { | ||
| promises.push(dispatch(fetchGroupRadarReadings(groupIDsToFetchForLine, timeInterval, unitID))); | ||
| } | ||
|
|
||
| return Promise.all(promises); | ||
| }; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.