67 lines
2.2 KiB
JavaScript
67 lines
2.2 KiB
JavaScript
import { PeakDetectorSimple } from './PeakDetection';
|
|
import { List } from 'immutable';
|
|
|
|
|
|
export default class DataAnalysis {
|
|
|
|
constructor() {
|
|
this._resetCache(null, 0);
|
|
}
|
|
|
|
analyze(analysisParameters, sessionId, allMeasurements) {
|
|
const cacheValid = (
|
|
this.sessionId === sessionId &&
|
|
this.analyzedUpToIdx <= allMeasurements.size &&
|
|
this.analysisParameters === analysisParameters);
|
|
|
|
let newData = null;
|
|
|
|
if (cacheValid) {
|
|
newData = allMeasurements.slice(this.analyzedUpToIdx);
|
|
}
|
|
else {
|
|
this._resetCache(analysisParameters, sessionId);
|
|
newData = allMeasurements;
|
|
console.log("cache reset");
|
|
}
|
|
|
|
// peaks
|
|
const newPeaks = this.peakDetectorSimple.addVector(newData.toArray());
|
|
this.allPeaks = this.allPeaks.concat(List(newPeaks));
|
|
|
|
// aggregated sum/max
|
|
this.aggregatedMomentum = newData.reduce((sum, x) => sum + x, this.aggregatedMomentum);
|
|
this.peakMax = newData.reduce((running, x) => Math.max(x, running), this.peakMax);
|
|
|
|
// windowed
|
|
const windowNumDataPoints = analysisParameters.windowSizeInSecs * analysisParameters.numMeasurementsPerSec;
|
|
const windowed = allMeasurements.slice(-windowNumDataPoints);
|
|
const peakMaxWindow = windowed.reduce((running, x) => Math.max(x, running), 0);
|
|
const momentumWindow = windowed.reduce((sum, x) => sum + x, 0);
|
|
|
|
this.analyzedUpToIdx = allMeasurements.size;
|
|
return {
|
|
peaks: this.allPeaks,
|
|
totalTime: allMeasurements / analysisParameters.numMeasurementsPerSec,
|
|
|
|
totalMomentum: this.aggregatedMomentum,
|
|
peakMax: this.peakMax,
|
|
|
|
momentumWindow: momentumWindow,
|
|
peakMaxWindow: peakMaxWindow,
|
|
};
|
|
}
|
|
|
|
|
|
_resetCache(analysisParameters, sessionId) {
|
|
this.peakDetectorSimple = analysisParameters ? new PeakDetectorSimple(analysisParameters.peakDetectorSimpleThreshold) : null;
|
|
this.allPeaks = List();
|
|
|
|
this.aggregatedMomentum = 0;
|
|
this.peakMax = 0;
|
|
|
|
this.sessionId = sessionId;
|
|
this.analyzedUpToIdx = 0;
|
|
this.analysisParameters = analysisParameters;
|
|
}
|
|
}; |