From b1172a6e28f05affcd59095757bd5ab7581f9f4b Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Sat, 6 Jan 2018 13:44:35 +0100
Subject: add datadog

---
 package-lock.json | 5 +++++
 package.json      | 1 +
 worker.js         | 8 ++++++++
 3 files changed, 14 insertions(+)

diff --git a/package-lock.json b/package-lock.json
index c7b494f..0a6f146 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -825,6 +825,11 @@
         "stack-trace": "0.0.10"
       }
     },
+    "winston-datadog": {
+      "version": "1.1.0",
+      "resolved": "https://registry.npmjs.org/winston-datadog/-/winston-datadog-1.1.0.tgz",
+      "integrity": "sha512-f3r1dsqXrK9o5nBRKFWaROf5QkoqJHGY6k0RMuwm4L+Oaab0JnQPGPkVxvJi9E1ylffGOrGFF/d9YCv2IP+IVg=="
+    },
     "winston-loggly-bulk": {
       "version": "2.0.0",
       "resolved": "https://registry.npmjs.org/winston-loggly-bulk/-/winston-loggly-bulk-2.0.0.tgz",
diff --git a/package.json b/package.json
index 43e460f..c79752a 100644
--- a/package.json
+++ b/package.json
@@ -9,6 +9,7 @@
     "mysql2": "^1.4.0",
     "sequelize": "^4.4.2",
     "winston": "^2.3.1",
+    "winston-datadog": "^1.1.0",
     "winston-loggly-bulk": "^2.0.0"
   },
   "devDependencies": {},
diff --git a/worker.js b/worker.js
index b0d9cf4..7cac550 100644
--- a/worker.js
+++ b/worker.js
@@ -8,6 +8,7 @@ const amqp = require("amqplib"),
     Promise = require("bluebird"),
     winston = require("winston"),
     loggly = require("winston-loggly-bulk"),
+    datadog = require("winston-datadog"),
     Seq = require("sequelize"),
     cacheManager = require("cache-manager"),
     api_name_mappings = require("../orm/mappings").map,
@@ -18,6 +19,7 @@ const RABBITMQ_URI = process.env.RABBITMQ_URI,
     DATABASE_URI = process.env.DATABASE_URI,
     QUEUE = process.env.QUEUE || "shrink",
     LOGGLY_TOKEN = process.env.LOGGLY_TOKEN,
+    DATADOG_TOKEN = process.env.DATADOG_TOKEN,
     // matches + players, 5 players with 50 matches as default
     BATCHSIZE = parseInt(process.env.BATCHSIZE) || 20,
     // maximum number of elements to be inserted in one statement
@@ -46,6 +48,12 @@ if (LOGGLY_TOKEN)
         json: true
     });
 
+// datadog integration
+if (DATADOG_TOKEN)
+    logger.add(new datadog({
+        api_key: DATADOG_TOKEN
+    }), null, true);
+
 // split an array into arrays of max chunksize
 function* chunks(arr) {
     for (let c=0, len=arr.length; c<len; c+=CHUNKSIZE)
-- 
cgit v1.3.1