You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
355 lines
14 KiB
355 lines
14 KiB
var assert = require("assert");
|
|
var client = require("../../lib/client");
|
|
var extend = require("extend");
|
|
var metric = require("../../lib/api/metric");
|
|
var sinon = require("sinon");
|
|
|
|
describe("api/metrics", function(){
|
|
var stub_request;
|
|
beforeEach(function(){
|
|
// Setup `client.request` as a stub
|
|
stub_request = sinon.stub(client, "request");
|
|
});
|
|
afterEach(function(){
|
|
// Reset the original `client.request`
|
|
stub_request.restore();
|
|
stub_request = null;
|
|
});
|
|
describe("#send", function(){
|
|
it("should make a valid api call", function(){
|
|
// Make our api call
|
|
var now = parseInt(new Date().getTime() / 1000);
|
|
metric.send("metric.send", [[now, 500]]);
|
|
|
|
// Assert we properly called `client.request`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// Method and endpoint are correct
|
|
assert.equal(call_args[0], "POST");
|
|
assert.equal(call_args[1], "/series");
|
|
|
|
// Properly formatted body
|
|
// { body: series: [ {metric: "metric.send", host: undefined, tags: undefined, type: undefined} ] }
|
|
// DEV: host/tags/type are optional and should be undefined for this case
|
|
var data = call_args[2];
|
|
assert(data.hasOwnProperty("body"));
|
|
assert(data.body.hasOwnProperty("series"));
|
|
|
|
// Assert we have only 1 series
|
|
// series = [ {metric: "", ...}, ... ]
|
|
var series = data.body.series;
|
|
assert(Array.isArray(series));
|
|
assert.equal(series.length, 1);
|
|
|
|
// Assert the first series is properly formatted
|
|
// first_series = {metric: "", points: [], ...}
|
|
var first_series = series[0]
|
|
assert.equal(first_series.metric, "metric.send");
|
|
assert(Array.isArray(first_series.points));
|
|
assert.deepEqual(first_series.points, [[now, 500]]);
|
|
|
|
// These keys are optional and should be set, but undefined
|
|
assert(first_series.hasOwnProperty("host"));
|
|
assert.equal(first_series.host, undefined);
|
|
assert(first_series.hasOwnProperty("tags"));
|
|
assert.equal(first_series.tags, undefined);
|
|
assert(first_series.hasOwnProperty("type"));
|
|
assert.equal(first_series.type, undefined);
|
|
});
|
|
|
|
it("should properly normalize values to points", function(){
|
|
// Make our api call
|
|
metric.send("metrics.send.normalize", 500);
|
|
|
|
// Assert we called `client.request` with the correct `points`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// { body: series: [ {points: [], }, ] }
|
|
var body = call_args[2].body;
|
|
assert.equal(body.series.length, 1);
|
|
|
|
// points = [ [<timestamp>, 500] ]
|
|
var points = body.series[0].points;
|
|
assert(Array.isArray(points));
|
|
assert.equal(points.length, 1);
|
|
|
|
// point = [<timestamp>, 500]
|
|
var point = points[0];
|
|
assert(Array.isArray(point));
|
|
assert.equal(point.length, 2);
|
|
assert.equal(point[1], 500);
|
|
});
|
|
|
|
it("should properly normalize array of values to points", function(){
|
|
// Make our api call
|
|
metric.send("metrics.send.normalize", [500, 1000]);
|
|
|
|
// Assert we called `client.request` with the correct `points`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// { body: series: [ {points: [], }, ] }
|
|
var body = call_args[2].body;
|
|
assert.equal(body.series.length, 1);
|
|
|
|
// points = [ [<timestamp>, 500], [<timestamp>, 1000] ]
|
|
var points = body.series[0].points;
|
|
assert(Array.isArray(points));
|
|
assert.equal(points.length, 2);
|
|
|
|
// point = [<timestamp>, 500]
|
|
var point = points[0];
|
|
assert(Array.isArray(point));
|
|
assert.equal(point.length, 2);
|
|
assert.equal(point[1], 500);
|
|
|
|
// point = [<timestamp>, 1000]
|
|
point = points[1];
|
|
assert(Array.isArray(point));
|
|
assert.equal(point.length, 2);
|
|
assert.equal(point[1], 1000);
|
|
});
|
|
|
|
it("should not normalize correctly formatted points", function(){
|
|
// Make our api call
|
|
var now = parseInt(new Date().getTime() / 1000);
|
|
metric.send("metrics.send.normalize", [[now, 1000]]);
|
|
|
|
// Assert we called `client.request` with the correct `points`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// { body: series: [ {points: [], }, ] }
|
|
var body = call_args[2].body;
|
|
assert.equal(body.series.length, 1);
|
|
|
|
// points = [ [<timestamp>, 1000], ]
|
|
var points = body.series[0].points;
|
|
assert(Array.isArray(points));
|
|
assert.equal(points.length, 1);
|
|
|
|
// point = [<timestamp>, 500]
|
|
var point = points[0];
|
|
assert(Array.isArray(point));
|
|
assert.deepEqual(point, [now, 1000]);
|
|
});
|
|
|
|
it("should properly set metric type", function(){
|
|
// Make our api call
|
|
metric.send("metrics.send.counter", 5, {type: "counter"});
|
|
|
|
// Assert we called `client.request` with the correct `points`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// { body: series: [ {points: [], }, ] }
|
|
var body = call_args[2].body;
|
|
assert.equal(body.series.length, 1);
|
|
|
|
// Assert we have only 1 series
|
|
// series = [ {metric: "", ...}, ... ]
|
|
var series = body.series;
|
|
assert(Array.isArray(series));
|
|
assert.equal(series.length, 1);
|
|
|
|
// Assert the first series is properly formatted
|
|
// first_series = {metric: "", type: "counter", points: [], ...}
|
|
var first_series = series[0]
|
|
assert.equal(first_series.metric, "metrics.send.counter");
|
|
assert(first_series.hasOwnProperty("type"));
|
|
assert.equal(first_series.type, "counter");
|
|
});
|
|
|
|
it("should properly set convert metric_type to type", function(){
|
|
// Make our api call
|
|
metric.send("metrics.send.counter", 5, {metric_type: "counter"});
|
|
|
|
// Assert we called `client.request` with the correct `points`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// { body: series: [ {points: [], }, ] }
|
|
var body = call_args[2].body;
|
|
assert.equal(body.series.length, 1);
|
|
|
|
|
|
// Assert we have only 1 series
|
|
// series = [ {metric: "", ...}, ... ]
|
|
var series = body.series;
|
|
assert(Array.isArray(series));
|
|
assert.equal(series.length, 1);
|
|
|
|
// Assert the first series is properly formatted
|
|
// first_series = {metric: "", type: "counter", points: [], ...}
|
|
var first_series = series[0]
|
|
assert.equal(first_series.metric, "metrics.send.counter");
|
|
assert(first_series.hasOwnProperty("type"));
|
|
assert.equal(first_series.type, "counter");
|
|
});
|
|
});
|
|
|
|
describe("#send_all", function(){
|
|
it("should make a valid api call", function(){
|
|
// Make our api call
|
|
var now = parseInt(new Date().getTime() / 1000);
|
|
var metrics = [
|
|
{
|
|
metric: "metric.send_all",
|
|
points: [[now, 500]]
|
|
}
|
|
];
|
|
metric.send_all(metrics);
|
|
|
|
// Assert we properly called `client.request`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// Method and endpoint are correct
|
|
assert.equal(call_args[0], "POST");
|
|
assert.equal(call_args[1], "/series");
|
|
|
|
// Properly formatted body
|
|
// { body: series: [ {metric: "metric.send_all", host: undefined, tags: undefined, type: undefined} ] }
|
|
// DEV: host/tags/type are optional and should be undefined for this case
|
|
var data = call_args[2];
|
|
assert(data.hasOwnProperty("body"));
|
|
assert(data.body.hasOwnProperty("series"));
|
|
|
|
// Assert we have only 1 series
|
|
// series = [ {metric: "", ...}, ... ]
|
|
var series = data.body.series;
|
|
assert(Array.isArray(series));
|
|
assert.equal(series.length, 1);
|
|
|
|
// Assert the first series is properly formatted
|
|
// first_series = {metric: "", points: [], ...}
|
|
var first_series = series[0]
|
|
assert.equal(first_series.metric, "metric.send_all");
|
|
assert(Array.isArray(first_series.points));
|
|
assert.deepEqual(first_series.points, [[now, 500]]);
|
|
});
|
|
|
|
it("should properly normalize metric points", function(){
|
|
// Make our api call
|
|
var now = parseInt(new Date().getTime() / 1000);
|
|
var metrics = [
|
|
{
|
|
metric: "metric.send_all.normalize",
|
|
points: [[now, 500]]
|
|
},
|
|
{
|
|
metric: "metric.send_all.normalize",
|
|
points: [500, 1000]
|
|
},
|
|
{
|
|
metric: "metric.send_all.normalize",
|
|
points: 1000
|
|
}
|
|
];
|
|
metric.send_all(metrics);
|
|
|
|
// Assert we called `client.request` with the correct `points`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// { body: series: [ {points: [], }, ] }
|
|
var body = call_args[2].body;
|
|
assert.equal(body.series.length, 3);
|
|
|
|
// points = [ [<timestamp>, 500] ]
|
|
var points = body.series[0].points;
|
|
assert(Array.isArray(points));
|
|
assert.equal(points.length, 1);
|
|
assert.equal(points[0].length, 2);
|
|
assert.equal(points[0][1], 500);
|
|
|
|
// points = [ [<timestamp>, 500], [<timestamp>, 1000] ]
|
|
points = body.series[1].points;
|
|
assert(Array.isArray(points));
|
|
assert.equal(points.length, 2);
|
|
assert.equal(points[0].length, 2);
|
|
assert.equal(points[0][1], 500);
|
|
assert.equal(points[1].length, 2);
|
|
assert.equal(points[1][1], 1000);
|
|
|
|
// points = [ [<timestamp>, 1000] ]
|
|
points = body.series[2].points;
|
|
assert(Array.isArray(points));
|
|
assert.equal(points.length, 1);
|
|
assert.equal(points[0].length, 2);
|
|
assert.equal(points[0][1], 1000);
|
|
});
|
|
|
|
it("should properly send metric type", function(){
|
|
// Make our api call
|
|
var metrics = [
|
|
{
|
|
metric: "metric.send.counter",
|
|
points: 5,
|
|
type: "counter"
|
|
}
|
|
];
|
|
metric.send_all(metrics);
|
|
|
|
// Assert we properly called `client.request`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// Method and endpoint are correct
|
|
assert.equal(call_args[0], "POST");
|
|
assert.equal(call_args[1], "/series");
|
|
|
|
// Properly formatted body
|
|
// { body: series: [ {metric: "metric.send.counter", host: undefined, tags: undefined, type: "counter"} ] }
|
|
// DEV: host/tags are optional and should be undefined for this case
|
|
var data = call_args[2];
|
|
assert(data.hasOwnProperty("body"));
|
|
assert(data.body.hasOwnProperty("series"));
|
|
|
|
// Assert we have only 1 series
|
|
// series = [ {metric: "", ...}, ... ]
|
|
var series = data.body.series;
|
|
assert(Array.isArray(series));
|
|
assert.equal(series.length, 1);
|
|
|
|
// Assert the first series is properly formatted
|
|
// first_series = {metric: "", type: "counter", points: [], ...}
|
|
var first_series = series[0]
|
|
assert.equal(first_series.metric, "metric.send.counter");
|
|
assert(Array.isArray(first_series.points));
|
|
assert.deepEqual(first_series.type, "counter");
|
|
});
|
|
|
|
it("should properly send metric_type as type", function(){
|
|
// Make our api call
|
|
var metrics = [
|
|
{
|
|
metric: "metric.send.counter",
|
|
points: 5,
|
|
metric_type: "counter"
|
|
}
|
|
];
|
|
metric.send_all(metrics);
|
|
|
|
// Assert we properly called `client.request`
|
|
assert(stub_request.calledOnce);
|
|
var call_args = stub_request.getCall(0).args;
|
|
// Method and endpoint are correct
|
|
assert.equal(call_args[0], "POST");
|
|
assert.equal(call_args[1], "/series");
|
|
|
|
// Properly formatted body
|
|
// { body: series: [ {metric: "metric.send.counter", host: undefined, tags: undefined, type: "counter"} ] }
|
|
// DEV: host/tags are optional and should be undefined for this case
|
|
var data = call_args[2];
|
|
assert(data.hasOwnProperty("body"));
|
|
assert(data.body.hasOwnProperty("series"));
|
|
|
|
// Assert we have only 1 series
|
|
// series = [ {metric: "", ...}, ... ]
|
|
var series = data.body.series;
|
|
assert(Array.isArray(series));
|
|
assert.equal(series.length, 1);
|
|
|
|
// Assert the first series is properly formatted
|
|
// first_series = {metric: "", type: "counter", points: [], ...}
|
|
var first_series = series[0]
|
|
assert.equal(first_series.metric, "metric.send.counter");
|
|
assert(Array.isArray(first_series.points));
|
|
assert.deepEqual(first_series.type, "counter");
|
|
});
|
|
});
|
|
});
|