Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Cleanup. Passes linter.

pull/10616/head
Hunter Trujillo 2017-01-25 14:35:32 -07:00
parent 2c65d3d825
commit e10eeb66cf
1 changed files with 37 additions and 193 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

230
ui/src/utils/timeSeriesToDygraph.js
View File

@ -8,257 +8,101 @@ import {STROKE_WIDTH} from 'src/shared/constants';
// activeQueryIndex is an optional argument that indicated which query's series we want highlighted. // activeQueryIndex is an optional argument that indicated which query's series we want highlighted.
export default function timeSeriesToDygraph(raw = [], activeQueryIndex, isInDataExplorer) { export default function timeSeriesToDygraph(raw = [], activeQueryIndex, isInDataExplorer) {
// collect results from each influx response // collect results from each influx response
const results = raw.reduce((acc, response, responseIndex) => { const results = raw.reduce((acc, rawResponse, responseIndex) => {
const responses = _.get(response, 'response.results', []) const responses = _.get(rawResponse, 'response.results', []);
const indexedResponses = responses.map((response) => ({...response, responseIndex})) const indexedResponses = responses.map((response) => ({...response, responseIndex}));
return [...acc, ...indexedResponses] return [...acc, ...indexedResponses];
}, []) }, []);
// collect each series // collect each series
const serieses = results.reduce((acc, {series, responseIndex}, index) => { const serieses = results.reduce((acc, {series, responseIndex}, index) => {
return [...acc, ...series.map((item) => ({...item, responseIndex, index}))]; return [...acc, ...series.map((item) => ({...item, responseIndex, index}))];
}, []) }, []);
// convert series into cells with rows and columns // convert series into cells with rows and columns
const cells = serieses.reduce((acc, {name, columns, values, index, responseIndex}) => { const cells = serieses.reduce((acc, {name, columns, values, index, responseIndex}) => {
const rows = values.map((values) => ({ const rows = values.map((vals) => ({
name, name,
columns, columns,
values, vals,
index, index,
})) }));
rows.forEach(({values: vals, columns: cols, name: n, index: seriesIndex}) => { rows.forEach(({vals, columns: cols, name: n, index: seriesIndex}) => {
const [time, ...rowValues] = vals const [time, ...rowValues] = vals;
rowValues.forEach((value, i) => { rowValues.forEach((value, i) => {
const column = cols[i + 1] const column = cols[i + 1];
acc.push({ acc.push({
label: `${n}.${column}`, label: `${n}.${column}`,
value, value,
time, time,
seriesIndex, seriesIndex,
responseIndex, responseIndex,
}) });
}) });
}) });
return acc return acc;
}, []) }, []);
const labels = cells.reduce((acc, {label, seriesIndex, responseIndex}) => { const labels = cells.reduce((acc, {label, seriesIndex, responseIndex}) => {
const existingLabel = acc.find(({ const existingLabel = acc.find(({
label: findLabel, label: findLabel,
seriesIndex: findSeriesIndex, seriesIndex: findSeriesIndex,
}) => findLabel === label && findSeriesIndex === seriesIndex) }) => findLabel === label && findSeriesIndex === seriesIndex);
if (!existingLabel) { if (!existingLabel) {
acc.push({ acc.push({
label, label,
seriesIndex, seriesIndex,
responseIndex, responseIndex,
}) });
} }
return acc return acc;
}, []) }, []);
const sortedLabels = _.sortBy(labels, 'label') const sortedLabels = _.sortBy(labels, 'label');
const timeSeries = cells.reduce((acc, cell) => { const timeSeries = cells.reduce((acc, cell) => {
let existingRowIndex = acc.findIndex(({time}) => cell.time === time) let existingRowIndex = acc.findIndex(({time}) => cell.time === time);
if (existingRowIndex === -1) { if (existingRowIndex === -1) {
acc.push({ acc.push({
time: cell.time, time: cell.time,
values: Array(sortedLabels.length).fill(null), values: Array(sortedLabels.length).fill(null),
}) });
existingRowIndex = acc.length - 1 existingRowIndex = acc.length - 1;
} }
const values = acc[existingRowIndex].values const values = acc[existingRowIndex].values;
const labelIndex = sortedLabels.findIndex(({label, seriesIndex}) => label === cell.label && cell.seriesIndex === seriesIndex); const labelIndex = sortedLabels.findIndex(({label, seriesIndex}) => label === cell.label && cell.seriesIndex === seriesIndex);
values[labelIndex] = cell.value values[labelIndex] = cell.value;
acc[existingRowIndex].values = values acc[existingRowIndex].values = values;
return acc return acc;
}, []) }, []);
const sortedTimeSeries = _.sortBy(timeSeries, 'time') const sortedTimeSeries = _.sortBy(timeSeries, 'time');
const {light, heavy} = STROKE_WIDTH; const {light, heavy} = STROKE_WIDTH;
const dygraphSeries = sortedLabels.reduce((acc, {label, responseIndex}) => { const dygraphSeries = sortedLabels.reduce((acc, {label, responseIndex}) => {
acc[label] = { acc[label] = {
strokeWidth: responseIndex === activeQueryIndex ? heavy : light, strokeWidth: responseIndex === activeQueryIndex ? heavy : light,
} };
if (!isInDataExplorer) { if (!isInDataExplorer) {
acc[label].axis = responseIndex === 0 ? 'y' : 'y2' acc[label].axis = responseIndex === 0 ? 'y' : 'y2';
} }
return acc return acc;
}, {}) }, {});
const timeSeriesToDygraph = { return {
timeSeries: sortedTimeSeries.map(({time, values}) => ([new Date(time), ...values])), timeSeries: sortedTimeSeries.map(({time, values}) => ([new Date(time), ...values])),
labels: ["time", ...sortedLabels.map(({label}) => label)], labels: ["time", ...sortedLabels.map(({label}) => label)],
dygraphSeries, dygraphSeries,
} };
return timeSeriesToDygraph;
// timeSeriesToDygraph , {labels: [], timeSeries: []}
// raw.forEach(({response}, queryIndex) => {
// // If a response is an empty result set or a query returned an error
// // from InfluxDB, don't try and parse.
// if (response.results.length) {
// if (isEmpty(response) || hasError(response)) {
// return;
// }
// }
//
// /**
// * response looks like:
// * {
// * results: [
// * { series: [...] },
// * { series: [...] },
// * ]
// * }
// */
// response.results.forEach(parseResult);
//
// function parseResult(s) {
// /*
// * s looks like:
// * {
// * series: [
// * {
// * name: "<measurement>",
// * columns: ["time", "<field name 1>", "<field name 2>", ...],
// * values: [<time>, <value of field 1>, <value of field 2>, ...],
// * },
// * }
// */
// s.series.forEach(parseSeries);
// }
//
// function parseSeries(series) {
// /*
// * series looks like:
// * {
// * name: "<measurement>",
// * columns: ["time", "<field name 1>", "<field name 2>", ...],
// * values: [
// * [<time1>, <value of field 1 @ time1>, <value of field 2 @ time1>, ...],
// * [<time2>, <value of field 1 @ time2>, <value of field 2 @ time2>, ...],
// * ]
// * }
// */
// const measurementName = series.name;
// const columns = series.columns;
// // Tags are only included in an influxdb response under certain circumstances, e.g.
// // when a query is using GROUP BY (<tag key>).
// const tags = Object.keys(series.tags || {}).map((key) => {
// return `[${key}=${series.tags[key]}]`;
// }).sort().join('');
//
// const c = columns.slice(1).sort();
// let previousColumnLength = 0;
//
// if (c.length != previousColumnLength) {
// previousColumnLength = c.length;
// }
//
// c.forEach((fieldName) => {
// let effectiveFieldName = `${measurementName}.${fieldName}${tags}`;
//
// // If there are duplicate effectiveFieldNames identify them by their queryIndex
// if (effectiveFieldName in dygraphSeries) {
// effectiveFieldName = `${effectiveFieldName}-${queryIndex}`;
// }
//
// // Given a field name, identify which column in the timeSeries result should hold the field's value
// // ex given this timeSeries [Date, 10, 20, 30] field index at 2 would correspond to value 20
// fieldToIndex[effectiveFieldName] = c.indexOf(fieldName);
// labels.push(effectiveFieldName);
//
// const {light, heavy} = STROKE_WIDTH;
//
// const dygraphSeriesStyles = {
// strokeWidth: queryIndex === activeQueryIndex ? heavy : light,
// };
//
// if (!isInDataExplorer) {
// dygraphSeriesStyles.axis = queryIndex === 0 ? 'y' : 'y2';
// }
//
// dygraphSeries[effectiveFieldName] = dygraphSeriesStyles;
// });
//
// (series.values || []).forEach(parseRow);
//
//
//
// function parseRow(row) {
// /**
// * row looks like:
// * [<time1>, <value of field 1 @ time1>, <value of field 2 @ time1>, ...]
// */
// const date = row[0];
// const dateString = date.toString();
// row.forEach((value, index) => {
// if (index === 0) {
// // index 0 in a row is always the timestamp
// if (!dateToFieldValue[dateString]) {
// dateToFieldValue[dateString] = {};
// dates[dateString] = date;
// }
// return;
// }
//
// const fieldName = columns[index];
// let effectiveFieldName = `${measurementName}.${fieldName}${tags}`;
//
// // If there are duplicate effectiveFieldNames identify them by their queryIndex
// if (effectiveFieldName in dateToFieldValue[dateString]) {
// effectiveFieldName = `${effectiveFieldName}-${queryIndex}`;
// }
//
// dateToFieldValue[dateString][effectiveFieldName] = value;
// });
// }
// }
// });
//
// function buildTimeSeries() {
// const allDates = Object.keys(dateToFieldValue);
// allDates.sort((a, b) => a - b);
// const rowLength = labels.length + 1;
// return allDates.map((date) => {
// const row = new Array(rowLength);
//
// row.fill(null);
// row[0] = new Date(dates[date]);
//
// const fieldsForRow = dateToFieldValue[date];
//
// Object.keys(fieldsForRow).forEach((effectiveFieldName) => {
// row[fieldToIndex[effectiveFieldName]] = fieldsForRow[effectiveFieldName];
// });
//
// return row;
// });
// }
}
function isEmpty(resp) {
return !resp.results[0].series;
}
function hasError(resp) {
return !!resp.results[0].error;
} }