const assert = require("assert"); const Client = require("../../lib/client"); const extend = require("extend"); const Metric = require("../../lib/api/metric"); const sinon = require("sinon"); describe("api/metrics", function(){ const client = new Client({}); const metric = Metric(client); 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 = [ [, 500] ] var points = body.series[0].points; assert(Array.isArray(points)); assert.equal(points.length, 1); // point = [, 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 = [ [, 500], [, 1000] ] var points = body.series[0].points; assert(Array.isArray(points)); assert.equal(points.length, 2); // point = [, 500] var point = points[0]; assert(Array.isArray(point)); assert.equal(point.length, 2); assert.equal(point[1], 500); // point = [, 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 = [ [, 1000], ] var points = body.series[0].points; assert(Array.isArray(points)); assert.equal(points.length, 1); // point = [, 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: "count"}); // 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: "count", points: [], ...} var first_series = series[0] assert.equal(first_series.metric, "metrics.send.counter"); assert(first_series.hasOwnProperty("type")); assert.equal(first_series.type, "count"); }); it("should properly set convert metric_type to type", function(){ // Make our api call metric.send("metrics.send.counter", 5, {metric_type: "count"}); // 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: "count", points: [], ...} var first_series = series[0] assert.equal(first_series.metric, "metrics.send.counter"); assert(first_series.hasOwnProperty("type")); assert.equal(first_series.type, "count"); }); }); 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 = [ [, 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 = [ [, 500], [, 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 = [ [, 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: "count" } ]; 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: "count"} ] } // 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: "count", 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, "count"); }); it("should properly send metric_type as type", function(){ // Make our api call var metrics = [ { metric: "metric.send.counter", points: 5, metric_type: "count" } ]; 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: "count"} ] } // 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: "count", 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, "count"); }); }); });