Moved tests to typescript

Author: rob3000

package.json

@@ -73,6 +73,7 @@
         "uuid": "~3.4.0"
     },
     "devDependencies": {
+        "@types/mocha": "^8.0.3",
         "@types/node": "^14.0.27",
         "@typescript-eslint/eslint-plugin": "^3.9.0",
         "@typescript-eslint/parser": "^3.9.0",

src/index.ts

@@ -1,18 +1,7 @@
 "use strict";
 
-export { KStream } from "./lib/dsl/KStream";
-export { KTable } from "./lib/dsl/KTable";
+export { KStream, KTable } from "./lib/dsl";
 export { KafkaFactory } from "./lib/KafkaFactory";
 export { KafkaStreams } from "./lib/KafkaStreams";
-export { KStorage } from "./lib/KStorage.js";
+export { KStorage } from "./lib/KStorage";
 export { KafkaClient } from "./lib/client/KafkaClient";
-
-// module.exports = {
-//   default: KafkaStreams,
-//   KStream,
-//   KTable,
-//   KafkaFactory,
-//   KafkaStreams,
-//   KStorage,
-//   KafkaClient
-// };

src/lib/KStorage.ts

@@ -1,4 +1,4 @@
-import Promise from "bluebird";
+import { Promise } from "bluebird";
 
 export class KStorage {
 	public options: any;

src/lib/KafkaFactory.ts

@@ -1,7 +1,8 @@
 import debugFactory from "debug";
-const debug = debugFactory("kafka-streams:kafkafactory");
 import { JSKafkaClient, NativeKafkaClient } from "./client";
 
+const debug = debugFactory("kafka-streams:kafkafactory");
+
 export class KafkaFactory {
 	public config: any;
 	public batchOptions: any;

src/lib/KafkaStreams.ts

@@ -157,5 +157,3 @@ export class KafkaStreams extends EventEmitter {
     });
   }
 }
-
-export default KafkaStreams;

src/lib/actions/KeyCount.ts

@@ -1,4 +1,4 @@
-import Promise from "bluebird";
+import { Promise } from "bluebird";
 
 /**
  * used to count keys in a stream

src/lib/actions/LastState.ts

@@ -1,4 +1,4 @@
-import Promise from "bluebird";
+import { Promise } from "bluebird";
 
 /**
  * used to hold the last state of key values

src/lib/actions/Max.ts

@@ -1,4 +1,4 @@
-import Promise from "bluebird";
+import { Promise } from "bluebird";
 
 /**
  * used to grab the highest value of key values

src/lib/actions/Min.ts

@@ -1,4 +1,4 @@
-import Promise from "bluebird";
+import { Promise } from "bluebird";
 
 /**
  * used grab the lowest value of

src/lib/actions/Sum.ts

@@ -1,4 +1,4 @@
-import Promise from "bluebird";
+import { Promise } from "bluebird";
 
 /**
  * used to sum up key values in a stream