format and lint

Author: duncanista

src/index.spec.ts

@@ -2,7 +2,13 @@ import http from "http";
 import nock from "nock";
 
 import { Context, Handler } from "aws-lambda";
-import { datadog, getTraceHeaders, sendDistributionMetric, sendDistributionMetricWithDate, _metricsQueue } from "./index";
+import {
+  datadog,
+  getTraceHeaders,
+  sendDistributionMetric,
+  sendDistributionMetricWithDate,
+  _metricsQueue,
+} from "./index";
 import { incrementErrorsMetric, incrementInvocationsMetric } from "./metrics/enhanced-metrics";
 import { LogLevel, setLogLevel } from "./utils";
 import { HANDLER_STREAMING, STREAM_RESPONSE } from "./constants";
@@ -407,7 +413,7 @@ describe("datadog", () => {
     const logger = {
       debug: jest.fn(),
       error: jest.fn(),
-      warn: jest.fn()
+      warn: jest.fn(),
     };
 
     const wrapped = datadog(handler, { forceWrap: true, logger: logger, debugLogging: true });
@@ -442,25 +448,24 @@ describe("datadog", () => {
   });
 });
 
-
 describe("sendDistributionMetric", () => {
   beforeEach(() => {
-    _metricsQueue.reset()
+    _metricsQueue.reset();
     setLogLevel(LogLevel.NONE);
-  })
+  });
   it("enqueues a metric for later processing when metrics listener is not initialized", () => {
     sendDistributionMetric("metric", 1, "first-tag", "second-tag");
-    expect(_metricsQueue.length).toBe(1); 
-  })
-})
+    expect(_metricsQueue.length).toBe(1);
+  });
+});
 
 describe("sendDistributionMetricWithDate", () => {
   beforeEach(() => {
-    _metricsQueue.reset()
+    _metricsQueue.reset();
     setLogLevel(LogLevel.NONE);
-  })
+  });
   it("enqueues a metric for later processing when metrics listener is not initialized", () => {
     sendDistributionMetricWithDate("metric", 1, new Date(), "first-tag", "second-tag");
-    expect(_metricsQueue.length).toBe(1); 
-  })
-})
+    expect(_metricsQueue.length).toBe(1);
+  });
+});

src/metrics/index.ts

@@ -1,4 +1,4 @@
 export { MetricsConfig, MetricsListener } from "./listener";
-export { MetricsQueue } from './queue'
+export { MetricsQueue } from "./queue";
 export { KMSService } from "./kms-service";
 export { incrementErrorsMetric, incrementInvocationsMetric } from "./enhanced-metrics";

src/metrics/queue.spec.ts

@@ -5,13 +5,13 @@ describe("MetricsQueue", () => {
   const logger = {
     debug: jest.fn(),
     error: jest.fn(),
-    warn: jest.fn()
+    warn: jest.fn(),
   };
   describe("push", () => {
     beforeEach(() => {
       setLogLevel(LogLevel.NONE);
       setLogger(logger);
-    })
+    });
     it("resets metrics queue when its full", () => {
       setLogLevel(LogLevel.WARNING);
       const queue = new MetricsQueue();
@@ -20,18 +20,21 @@ describe("MetricsQueue", () => {
       }
 
       // The queue should have been reset and only contain the last metric
-      expect(queue.length).toBe(1)
-      expect(logger.warn).toHaveBeenLastCalledWith('{"status":"warning","message":"datadog:Metrics queue is full, dropping all metrics."}');
-    })
+      expect(queue.length).toBe(1);
+      expect(logger.warn).toHaveBeenLastCalledWith(
+        '{"status":"warning","message":"datadog:Metrics queue is full, dropping all metrics."}',
+      );
+    });
 
     it("enqueue metric", () => {
       setLogLevel(LogLevel.DEBUG);
       const queue = new MetricsQueue();
       queue.push({ name: "metric", tags: [], value: 1 });
-      expect(queue.length).toBe(1)
-      expect(logger.debug).toHaveBeenLastCalledWith('{"status":"debug","message":"datadog:Metrics Listener was not initialized. Enqueuing metric for later processing."}');
-    })
-    
+      expect(queue.length).toBe(1);
+      expect(logger.debug).toHaveBeenLastCalledWith(
+        '{"status":"debug","message":"datadog:Metrics Listener was not initialized. Enqueuing metric for later processing."}',
+      );
+    });
   });
 
   describe("shift", () => {
@@ -48,7 +51,7 @@ describe("MetricsQueue", () => {
     });
   });
 
-  it("resets the queue", () => { 
+  it("resets the queue", () => {
     const queue = new MetricsQueue();
     queue.push({ name: "metric", tags: [], value: 1 });
     queue.push({ name: "metric", tags: [], value: 2 });
@@ -62,4 +65,4 @@ describe("MetricsQueue", () => {
     queue.push({ name: "metric", tags: [], value: 2 });
     expect(queue.length).toBe(2);
   });
-})
+});

src/metrics/queue.ts

@@ -24,7 +24,7 @@ export class MetricsQueue {
   /**
    * Enqueues a metric for later processing.
    * If the queue is full, all metrics are dropped. But the new metric is still enqueued.
-   * 
+   *
    * @param metric The metric to be enqueued.
    */
   public push(metric: MetricParameters) {

src/utils/log.spec.ts

@@ -5,7 +5,7 @@ describe("logger", () => {
     const logger = {
       debug: jest.fn(),
       error: jest.fn(),
-      warn: jest.fn()
+      warn: jest.fn(),
     };
 
     setLogger(logger);
@@ -18,7 +18,7 @@ describe("logger", () => {
     const logger = {
       debug: jest.fn(),
       error: jest.fn(),
-      warn: jest.fn()
+      warn: jest.fn(),
     };
 
     setLogger(logger);
@@ -31,7 +31,7 @@ describe("logger", () => {
     const logger = {
       debug: jest.fn(),
       error: jest.fn(),
-      warn: jest.fn()
+      warn: jest.fn(),
     };
 
     setLogger(logger);
@@ -47,7 +47,7 @@ describe("logger", () => {
     const logger = {
       debug: jest.fn(),
       error: jest.fn(),
-      warn: jest.fn()
+      warn: jest.fn(),
     };
 
     setLogger(logger);