From 2a62e540bcaddf755a61608bdeaedc62a59f6c18 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Sat, 6 Jan 2018 13:46:08 +0100
Subject: add datadog

---
 worker.js | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index f94c11b..5c0f753 100644
--- a/worker.js
+++ b/worker.js
@@ -7,13 +7,15 @@ const amqp = require("amqplib"),
     Promise = require("bluebird"),
     winston = require("winston"),
     loggly = require("winston-loggly-bulk"),
+    datadog = require("winston-datadog"),
     request = require("request-promise"),
     moment = require("moment");
 
 const RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost",
     QUEUE = process.env.QUEUE || "telesuck",
     SHRINK_QUEUE = process.env.SHRINK_QUEUE || "shrink",
-    LOGGLY_TOKEN = process.env.LOGGLY_TOKEN;
+    LOGGLY_TOKEN = process.env.LOGGLY_TOKEN,
+    DATADOG_TOKEN = process.env.DATADOG_TOKEN;
 
 const logger = new (winston.Logger)({
     transports: [
@@ -33,6 +35,12 @@ if (LOGGLY_TOKEN)
         json: true
     });
 
+// datadog integration
+if (DATADOG_TOKEN)
+    logger.add(new datadog({
+        api_key: DATADOG_TOKEN
+    }), null, true);
+
 amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
     process.on("SIGINT", () => {
         rabbit.close();
-- 
cgit v1.3.1