Update winston logger to new types. This woll break older dependencies

dist/core.d.ts

-/// <reference types="winston" />
 import { InterfaceKafkaGeoname } from './kafka-geoname';
-import { LoggerInstance } from 'winston';
+import { Logger as LoggerInstance } from 'winston';
 import UriBuilder from './uri-builder';
 import { InterfaceReporter } from './reporter';
 export interface InterfaceCore {
@@ -45,7 +44,7 @@ declare class Core {
      * Get a logger instance
      * @returns {winston.LoggerInstance}
      */
-    getLogger(): LoggerInstance;
+    getLogger(): any;
     /**
      * Get Config object
      */

dist/logger.d.ts

-/// <reference types="winston" />
-import { LoggerInstance } from 'winston';
 declare class Logger {
     logDir: string;
     private logger;
     constructor(logDir: string);
-    getLogger(): LoggerInstance;
+    getLogger(): any;
     private setup();
 }
 export default Logger;

dist/stream/stream-producer-preparer.d.ts

@@ -4,6 +4,7 @@ import { Transform } from 'stream';
  * A type to for the PartitionCallback function
  */
 export declare type PartitionCallback = (chunk: any) => number;
+export declare type KeyCallback = (chunk: any) => number;
 /**
  * Prepare a value for kafka ProducerStream
  */
@@ -16,6 +17,10 @@ declare class StreamProducerPreparer extends Transform {
      * Partition
      */
     private readonly partition;
+    /**
+     * Should we use a key or not
+     */
+    private readonly key;
     constructor(opts: any);
     /**
      * @inheritDoc

dist/stream/stream-producer-preparer.js

@@ -11,8 +11,13 @@ class StreamProducerPreparer extends stream_1.Transform {
          * Partition
          */
         this.partition = -1;
+        /**
+         * Should we use a key or not
+         */
+        this.key = false;
         this.topic = opts.topic;
         this.partition = opts.partition || -1;
+        this.key = opts.key || false;
     }
     /**
      * @inheritDoc
@@ -28,8 +33,11 @@ class StreamProducerPreparer extends stream_1.Transform {
             value: chunk,
             partition: typeof this.partition === 'function' ? this.partition(chunk) : this.partition,
         };
+        if (typeof this.key === 'function') {
+            value.key = this.key(chunk);
+        }
         callback(null, value);
     }
 }
 exports.default = StreamProducerPreparer;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic3RyZWFtLXByb2R1Y2VyLXByZXBhcmVyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL3N0cmVhbS9zdHJlYW0tcHJvZHVjZXItcHJlcGFyZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7QUFBQSxtQ0FBbUM7QUFPbkM7O0dBRUc7QUFDSCw0QkFBNkIsU0FBUSxrQkFBUztJQVk1QyxZQUFZLElBQUk7UUFDZCxLQUFLLENBQUMsSUFBSSxDQUFDLENBQUM7UUFOZDs7V0FFRztRQUNjLGNBQVMsR0FBZ0MsQ0FBQyxDQUFDLENBQUM7UUFJM0QsSUFBSSxDQUFDLEtBQUssR0FBRyxJQUFJLENBQUMsS0FBSyxDQUFDO1FBQ3hCLElBQUksQ0FBQyxTQUFTLEdBQUcsSUFBSSxDQUFDLFNBQVMsSUFBSSxDQUFDLENBQUMsQ0FBQztJQUN4QyxDQUFDO0lBQ0Q7Ozs7OztPQU1HO0lBQ0ksVUFBVSxDQUFDLEtBQUssRUFBRSxRQUFRLEVBQUUsUUFBUTtRQUN6QyxpQ0FBaUM7UUFDakMsTUFBTSxLQUFLLEdBQUc7WUFDWixLQUFLLEVBQUUsSUFBSSxDQUFDLEtBQUs7WUFDakIsS0FBSyxFQUFFLEtBQUs7WUFDWixTQUFTLEVBQUUsT0FBTyxJQUFJLENBQUMsU0FBUyxLQUFLLFVBQVUsQ0FBQyxDQUFDLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFDLENBQUMsSUFBSSxDQUFDLFNBQVM7U0FDekYsQ0FBQztRQUNGLFFBQVEsQ0FBQyxJQUFJLEVBQUUsS0FBSyxDQUFDLENBQUM7SUFDeEIsQ0FBQztDQUNGO0FBRUQsa0JBQWUsc0JBQXNCLENBQUMifQ==
\ No newline at end of file
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic3RyZWFtLXByb2R1Y2VyLXByZXBhcmVyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL3N0cmVhbS9zdHJlYW0tcHJvZHVjZXItcHJlcGFyZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7QUFBQSxtQ0FBbUM7QUFTbkM7O0dBRUc7QUFDSCw0QkFBNkIsU0FBUSxrQkFBUztJQWlCNUMsWUFBWSxJQUFJO1FBQ2QsS0FBSyxDQUFDLElBQUksQ0FBQyxDQUFDO1FBWGQ7O1dBRUc7UUFDYyxjQUFTLEdBQWdDLENBQUMsQ0FBQyxDQUFDO1FBRTdEOztXQUVHO1FBQ2MsUUFBRyxHQUEwQixLQUFLLENBQUM7UUFJbEQsSUFBSSxDQUFDLEtBQUssR0FBRyxJQUFJLENBQUMsS0FBSyxDQUFDO1FBQ3hCLElBQUksQ0FBQyxTQUFTLEdBQUcsSUFBSSxDQUFDLFNBQVMsSUFBSSxDQUFDLENBQUMsQ0FBQztRQUN0QyxJQUFJLENBQUMsR0FBRyxHQUFHLElBQUksQ0FBQyxHQUFHLElBQUksS0FBSyxDQUFDO0lBQy9CLENBQUM7SUFDRDs7Ozs7O09BTUc7SUFDSSxVQUFVLENBQUMsS0FBSyxFQUFFLFFBQVEsRUFBRSxRQUFRO1FBQ3pDLGlDQUFpQztRQUNqQyxNQUFNLEtBQUssR0FBUztZQUNsQixLQUFLLEVBQUUsSUFBSSxDQUFDLEtBQUs7WUFDakIsS0FBSyxFQUFFLEtBQUs7WUFDWixTQUFTLEVBQUUsT0FBTyxJQUFJLENBQUMsU0FBUyxLQUFLLFVBQVUsQ0FBQyxDQUFDLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFDLENBQUMsSUFBSSxDQUFDLFNBQVM7U0FDekYsQ0FBQztRQUNGLElBQUksT0FBTyxJQUFJLENBQUMsR0FBRyxLQUFLLFVBQVUsRUFBRTtZQUNsQyxLQUFLLENBQUMsR0FBRyxHQUFHLElBQUksQ0FBQyxHQUFHLENBQUMsS0FBSyxDQUFDLENBQUM7U0FDN0I7UUFDRCxRQUFRLENBQUMsSUFBSSxFQUFFLEtBQUssQ0FBQyxDQUFDO0lBQ3hCLENBQUM7Q0FDRjtBQUVELGtCQUFlLHNCQUFzQixDQUFDIn0=
\ No newline at end of file

package-lock.json

@@ -67,14 +67,6 @@
       "resolved": "https://registry.npmjs.org/@types/tough-cookie/-/tough-cookie-2.3.2.tgz",
       "integrity": "sha512-vOVmaruQG5EatOU/jM6yU2uCp3Lz6mK1P5Ztu4iJjfM4SVHU9XYktPUQtKlIXuahqXHdEyUarMrBEwg5Cwu+bA=="
     },
-    "@types/winston": {
-      "version": "2.3.9",
-      "resolved": "https://registry.npmjs.org/@types/winston/-/winston-2.3.9.tgz",
-      "integrity": "sha512-zzruYOEtNgfS3SBjcij1F6HlH6My5n8WrBNhP3fzaRM22ba70QBC2ATs18jGr88Fy43c0z8vFJv5wJankfxv2A==",
-      "requires": {
-        "@types/node": "*"
-      }
-    },
     "ajv": {
       "version": "5.5.2",
       "resolved": "https://registry.npmjs.org/ajv/-/ajv-5.5.2.tgz",
@@ -1094,6 +1086,7 @@
           "version": "0.1.4",
           "bundled": true,
           "dev": true,
+          "optional": true,
           "requires": {
             "kind-of": "^3.0.2",
             "longest": "^1.0.1",
@@ -2276,7 +2269,8 @@
         "longest": {
           "version": "1.0.1",
           "bundled": true,
-          "dev": true
+          "dev": true,
+          "optional": true
         },
         "loose-envify": {
           "version": "1.3.1",

package.json

@@ -9,7 +9,6 @@
     "@types/es6-promise": "^3.3.0",
     "@types/node": "^9.6.18",
     "@types/request": "^2.47.0",
-    "@types/winston": "^2.3.9",
     "axios": "^0.18.0",
     "bunyan-format": "^0.2.1",
     "concurrently": "^3.5.1",

src/core.ts

@@ -2,7 +2,7 @@ import nconf = require('nconf');
 import sourcemap = require('source-map-support');
 import logger, {default as Logger} from './logger';
 import KafkaGeoname, {InterfaceKafkaGeoname} from './kafka-geoname';
-import {LoggerInstance} from 'winston';
+import {Logger as LoggerInstance} from 'winston';
 import UriBuilder from './uri-builder';
 import {InterfaceReporter, InterfaceReporterCollection, Reporter} from './reporter';
 import fs = require('fs');

src/logger.ts

 import * as fs from 'fs';
-import { LoggerInstance } from 'winston';
+import { Logger as LoggerInstance } from 'winston';
 import winston = require('winston');
 
 // get config file by convention

src/uri-builder.ts

 import yaml = require('js-yaml');
 import fs   = require('fs');
-import {LoggerInstance} from "winston";
+import {Logger as LoggerInstance} from "winston";
 
 export interface InterfaceProvider {
-  slug: string
-  alias: string[],
+  slug: string;
+  alias: string[];
   name: {
     de: string,
     fr: string,
     it: string,
     en: string,
-  }
+  };
   description: {
     de: string,
     fr: string,
     it: string,
     en: string,
-  },
-  url_pattern: string
-  identifier_rule: string
+  };
+  url_pattern: string;
+  identifier_rule: string;
 }
 
 export default class UrlBuilder {
@@ -64,4 +64,4 @@ export default class UrlBuilder {
 
 // More configurable. We like to generate those links from a small interface. So we cann simply add and delete them
 // we wana have a file from which we can load stuff into memory. We do not want to have DB overhead
-// perhaps e need a rest interface. Otherwise we will have problem to "live" reload the config
\ No newline at end of file
+// perhaps e need a rest interface. Otherwise we will have problem to "live" reload the config