Drops whole measurement list if some of value is negative (#208)

Author: isaikevych

packages/opencensus-core/src/stats/stats.ts

@@ -114,18 +114,27 @@ export class Stats {
     return {name, unit, type: MeasureType.INT64, description};
   }
 
+  /**
+   * Verifies whether all measurements has positive value
+   * @param measurements A list of measurements
+   * @returns {boolean} Whether values is positive
+   */
+  private hasNegativeValue(measurements: Measurement[]): boolean {
+    return measurements.some(measurement => measurement.value < 0);
+  }
+
   /**
    * Updates all views with the new measurements.
    * @param measurements A list of measurements to record
    */
   record(...measurements: Measurement[]) {
-    for (const measurement of measurements) {
-      if (measurement.value < 0) {
-        this.logger.warn(`Dropping value ${
-            measurement.value}, value to record must be non-negative.`);
-        break;
-      }
+    if (this.hasNegativeValue(measurements)) {
+      this.logger.warn(`Dropping measurments ${measurements}, value to record
+          must be non-negative.`);
+      return;
+    }
 
+    for (const measurement of measurements) {
       const views = this.registeredViews[measurement.measure.name];
       if (!views) {
         break;

packages/opencensus-core/test/test-stats.ts

@@ -176,13 +176,14 @@ describe('Stats', () => {
       assert.strictEqual(aggregationData.value, measurement2.value);
     });
 
-    it('should stop record on negative value of multiple measurement', () => {
-      const measurments = [
-        {measure, tags, value: 1}, {measure, tags, value: -1},
-        {measure, tags, value: 1}
-      ];
-      stats.record(...measurments);
-      assert.equal(testExporter.recordedMeasurements.length, 1);
-    });
+    it('should skip whole multiple measurment if one of value is negative',
+       () => {
+         const measurments = [
+           {measure, tags, value: 1}, {measure, tags, value: -1},
+           {measure, tags, value: 1}
+         ];
+         stats.record(...measurments);
+         assert.equal(testExporter.recordedMeasurements.length, 0);
+       });
   });
 });