Removed default exports to use named exports

rob3000 · wtrocki · commit 8f7be0da41d9 · 2020-08-20T13:28:11.000+02:00
diff --git a/src/index.ts b/src/index.ts
@@ -1,18 +1,18 @@
 "use strict";
 
-import KStream from "./lib/dsl/KStream";
-import KTable from "./lib/dsl/KTable";
-import KafkaFactory from "./lib/KafkaFactory";
-import KafkaStreams from "./lib/KafkaStreams";
-import KStorage from "./lib/KStorage.js";
-import KafkaClient  from "./lib/client/KafkaClient";
+export { KStream } from "./lib/dsl/KStream";
+export { KTable } from "./lib/dsl/KTable";
+export { KafkaFactory } from "./lib/KafkaFactory";
+export { KafkaStreams } from "./lib/KafkaStreams";
+export { KStorage } from "./lib/KStorage.js";
+export { KafkaClient } from "./lib/client/KafkaClient";
 
-module.exports = {
-  default: KafkaStreams,
-  KStream,
-  KTable,
-  KafkaFactory,
-  KafkaStreams,
-  KStorage,
-  KafkaClient
-};
+// module.exports = {
+//   default: KafkaStreams,
+//   KStream,
+//   KTable,
+//   KafkaFactory,
+//   KafkaStreams,
+//   KStorage,
+//   KafkaClient
+// };
diff --git a/src/lib/KStorage.ts b/src/lib/KStorage.ts
@@ -1,8 +1,6 @@
-"use strict";
-
 import Promise from "bluebird";
 
-class KStorage {
+export class KStorage {
 	public options: any;
 	public state: any;
 
diff --git a/src/lib/KafkaFactory.ts b/src/lib/KafkaFactory.ts
@@ -1,11 +1,8 @@
-"use strict";
-
 import debugFactory from "debug";
 const debug = debugFactory("kafka-streams:kafkafactory");
-import JSKafkaClient from "./client/JSKafkaClient";
-import NativeKafkaClient from "./client/NativeKafkaClient";
+import { JSKafkaClient, NativeKafkaClient } from "./client";
 
-class KafkaFactory {
+export class KafkaFactory {
 	public config: any;
 	public batchOptions: any;
 
@@ -40,5 +37,3 @@ class KafkaFactory {
 	  return new JSKafkaClient(topic, this.config);
 	}
 }
-
-export default KafkaFactory;
diff --git a/src/lib/KafkaStreams.ts b/src/lib/KafkaStreams.ts
@@ -1,16 +1,13 @@
-"use strict";
-
 import { EventEmitter } from "events";
-import KafkaFactory from "./KafkaFactory";
-import KStream from "./dsl/KStream";
-import KTable from "./dsl/KTable";
-import KStorage from "./KStorage";
+import { KafkaFactory } from "./KafkaFactory";
+import { KStream, KTable } from "./dsl";
+import { KStorage } from "./KStorage";
 
 /**
  * Stream object factory
  * inhabits EventEmitter(events)
  */
-class KafkaStreams extends EventEmitter {
+export class KafkaStreams extends EventEmitter {
   public config: any;
   public factory: any;
   public storageClass: any;
diff --git a/src/lib/StorageMerger.ts b/src/lib/StorageMerger.ts
@@ -1,10 +1,8 @@
-"use strict";
-
 /**
  * static class, that helps with merging
  * KStorages (e.g. joining two KTables)
  */
-class StorageMerger {
+export class StorageMerger {
 
   /**
      * merges the content of multiple storages
@@ -31,5 +29,3 @@ class StorageMerger {
   }
 
 }
-
-export default StorageMerger;
diff --git a/src/lib/actions/KeyCount.ts b/src/lib/actions/KeyCount.ts
@@ -1,5 +1,3 @@
-"use strict";
-
 import Promise from "bluebird";
 
 /**
diff --git a/src/lib/actions/LastState.ts b/src/lib/actions/LastState.ts
@@ -1,5 +1,3 @@
-"use strict";
-
 import Promise from "bluebird";
 
 /**
diff --git a/src/lib/actions/Max.ts b/src/lib/actions/Max.ts
@@ -1,5 +1,3 @@
-"use strict";
-
 import Promise from "bluebird";
 
 /**
diff --git a/src/lib/actions/Min.ts b/src/lib/actions/Min.ts
@@ -1,5 +1,3 @@
-"use strict";
-
 import Promise from "bluebird";
 
 /**
diff --git a/src/lib/actions/Sum.ts b/src/lib/actions/Sum.ts
@@ -1,5 +1,3 @@
-"use strict";
-
 import Promise from "bluebird";
 
 /**
diff --git a/src/lib/actions/Window.ts b/src/lib/actions/Window.ts
@@ -1,5 +1,3 @@
-"use strict";
-
 import { async as createSubject } from "most-subject";
 
 /**
diff --git a/src/lib/client/JSKafkaClient.ts b/src/lib/client/JSKafkaClient.ts
@@ -1,14 +1,12 @@
-"use strict";
-
 import uuid from "uuid";
 import { Kafka, PartitionDrainer, Drainer, Publisher } from "sinek";
 import debugFactory from "debug";
 const debug = debugFactory("kafka-streams:jsclient");
-import KafkaClient from "./KafkaClient";
+import { KafkaClient } from "./KafkaClient";
 
 const NOOP = () => { };
 
-class JSKafkaClient extends KafkaClient {
+export class JSKafkaClient extends KafkaClient {
 	public topic: any;
 	public config: any;
 	public kafkaConsumerClient: any;
@@ -331,5 +329,3 @@ class JSKafkaClient extends KafkaClient {
 	  }
 	}
 }
-
-export default JSKafkaClient;
diff --git a/src/lib/client/KafkaClient.ts b/src/lib/client/KafkaClient.ts
@@ -1,8 +1,6 @@
-"use strict";
-
 import { EventEmitter } from "events";
 
-class KafkaClient extends EventEmitter {
+export class KafkaClient extends EventEmitter {
 
   constructor() {
     super();
@@ -14,5 +12,3 @@ class KafkaClient extends EventEmitter {
     return Math.floor(Math.random() * (max - min + 1)) + min;
   }
 }
-
-export default KafkaClient;
diff --git a/src/lib/client/NativeKafkaClient.ts b/src/lib/client/NativeKafkaClient.ts
@@ -1,14 +1,12 @@
-"use strict";
-
 import uuid from "uuid";
 import { NConsumer, NProducer } from "sinek";
 import debugFactory from "debug";
 const debug = debugFactory("kafka-streams:nativeclient");
-import KafkaClient from "./KafkaClient";
+import { KafkaClient } from "./KafkaClient";
 
 const NOOP = () => { };
 
-class NativeKafkaClient extends KafkaClient {
+export class NativeKafkaClient extends KafkaClient {
 	public topic: any;
 	public config: any;
 	public batchOptions: any;
@@ -287,5 +285,3 @@ class NativeKafkaClient extends KafkaClient {
 	  }
 	}
 }
-
-export default NativeKafkaClient;
diff --git a/src/lib/client/index.ts b/src/lib/client/index.ts
@@ -0,0 +1,3 @@
+export * from "./JSKafkaClient";
+export * from "./NativeKafkaClient";
+export * from "./KafkaClient";
diff --git a/src/lib/dsl/KStream.ts b/src/lib/dsl/KStream.ts
@@ -1,19 +1,17 @@
-"use strict";
-
 import Promise from "bluebird";
 import { async as createSubject } from "most-subject";
 import lodashClone from "lodash.clone";
 import lodashCloneDeep from "lodash.clonedeep";
-import StreamDSL from "./StreamDSL";
-import messageProduceHandle from "../messageProduceHandle";
+import { StreamDSL } from "./StreamDSL";
+import { messageProduceHandle } from "../messageProduceHandle";
 import { Window } from "../actions";
 
 const NOOP = () => { };
 
 /**
  * change-log representation of a stream
  */
-class KStream extends StreamDSL {
+export class KStream extends StreamDSL {
   public started: any;
 
   /**
@@ -370,5 +368,3 @@ class KStream extends StreamDSL {
     return this.storage.close();
   }
 }
-
-export default KStream;
diff --git a/src/lib/dsl/KTable.ts b/src/lib/dsl/KTable.ts
@@ -3,18 +3,18 @@
 import { EventEmitter } from "events";
 import * as most from "most";
 import Promise from "bluebird";
-import StreamDSL from "./StreamDSL";
+import { StreamDSL } from "./StreamDSL";
 import { LastState } from "../actions";
-import StorageMerger from "../StorageMerger";
-import messageProduceHandle from "../messageProduceHandle";
+import { StorageMerger } from "../StorageMerger";
+import { messageProduceHandle } from "../messageProduceHandle";
 
 const MESSAGE = "message";
 const NOOP = () => { };
 
 /**
  * table representation of a stream
  */
-class KTable extends StreamDSL {
+export class KTable extends StreamDSL {
   public _tee: any;
   public started: any;
   public finalised: any;
@@ -366,5 +366,3 @@ class KTable extends StreamDSL {
     return this.storage.close();
   }
 }
-
-export default KTable;
diff --git a/src/lib/dsl/StreamDSL.ts b/src/lib/dsl/StreamDSL.ts
@@ -1,14 +1,12 @@
-"use strict";
-
 import { EventEmitter } from "events";
 import * as most from "most";
 import Promise from "bluebird";
 import uuid from "uuid";
 import debugFactory from "debug";
 const debug = debugFactory("kafka-streams:streamdsl");
 import KStorage from "../KStorage";
-import KafkaClient from "../client/KafkaClient";
-import messageProduceHandle from "../messageProduceHandle";
+import { KafkaClient } from "../client/KafkaClient";
+import { messageProduceHandle } from "../messageProduceHandle";
 import PRODUCE_TYPES from "../produceTypes";
 import { KeyCount, Sum, Min, Max } from "../actions";
 
@@ -19,7 +17,7 @@ const DEFAULT_AUTO_FLUSH_BUFFER_SIZE = 100;
 /**
  * Stream base class
  */
-class StreamDSL {
+export class StreamDSL {
   public noTopicProvided: any;
   public topicName: any;
   public kafka: any;
@@ -1142,5 +1140,3 @@ class StreamDSL {
     });
   }
 }
-
-export default StreamDSL;
diff --git a/src/lib/messageProduceHandle.ts b/src/lib/messageProduceHandle.ts
@@ -1,5 +1,3 @@
-"use strict";
-
 import debugFactory from "debug";
 const debug = debugFactory("kafka-streams:mph");
 import PRODUCE_TYPES from "./produceTypes";
@@ -72,7 +70,7 @@ const produceTypeSelection = (produceType, kafka, compressionType, topic, partit
  * @param producerErrorCallback
  * @return {Promise<void>}
  */
-const messageProduceHandle = (kafka, message, outputTopicName, produceType, compressionType, version, producerErrorCallback) => {
+export const messageProduceHandle = (kafka, message, outputTopicName, produceType, compressionType, version, producerErrorCallback) => {
 
   let _topic = outputTopicName;
   let _key = null;
@@ -157,6 +155,3 @@ const messageProduceHandle = (kafka, message, outputTopicName, produceType, comp
     }
   });
 };
-
-export default messageProduceHandle;
-
diff --git a/src/lib/produceTypes.ts b/src/lib/produceTypes.ts
@@ -1,4 +1,3 @@
-"use strict";
 
 export default {
   SEND: "send",

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,3 @@`
`1`		`-"use strict";`
`2`		`-`
`3`	`1`	`import Promise from "bluebird";`
`4`	`2`
`5`	`3`	`/**`