@bluexlab/kafka-ts - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

dist/index.d.ts

@@ -1,2 +0,2 @@
-import { EachMessagePayload } from 'kafkajs';
+import { EachMessagePayload, KafkaMessage } from 'kafkajs';
 
@@ -35,2 +35,7 @@ interface MessageProcessorType {
 
-export { type MessageProcessorType, NotificationConsumer, NotificationProducer };
+interface NotificationDefinition<T> {
+    fromJSON(data: Record<string, any>): T;
+}
+declare const parseNotification: <T>(message: KafkaMessage, notificationDefinition: NotificationDefinition<T>) => T;
+
+export { type MessageProcessorType, NotificationConsumer, NotificationProducer, parseNotification };

dist/index.js

@@ -12,2 +12,13 @@ // src/consumer.ts
 import snakeCase from "lodash/snakeCase";
+var toCamelCase = (obj) => {
+  if (isArray(obj)) {
+    return obj.map((v) => toCamelCase(v));
+  }
+  if (isPlainObject(obj)) {
+    return transform(obj, (result, value, key) => {
+      result[camelCase(key)] = toCamelCase(value);
+    });
+  }
+  return obj;
+};
 
@@ -18,2 +29,10 @@ // src/common.ts
 var consumerGroupId = process.env.NOTIFICATION_CONSUMER_GROUP_ID;
+var parseNotification = (message, notificationDefinition) => {
+  if (!message.value) throw new Error(`Message is empty ${message.key}`);
+  const rawContent = message.value.toString();
+  const jsonObj = JSON.parse(rawContent);
+  const keyConverted = toCamelCase(jsonObj);
+  const notification = notificationDefinition.fromJSON(keyConverted);
+  return notification;
+};
 
@@ -128,3 +147,4 @@ // src/consumer.ts
   NotificationConsumer,
-  NotificationProducer
+  NotificationProducer,
+  parseNotification
 };

package.json

 {
   "name": "@bluexlab/kafka-ts",
   "type": "module",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "The kafka producer and consumer client",
@@ -6,0 +6,0 @@ "exports": {

No alert changes

Improved metrics

Total package byte prevSize

14644

increased by14.74%

Lines of code

318

increased by15.64%

No dependency changes