small fixes

packages/kafka-avro-lib/index.ts

@@ -1,5 +1,15 @@
 import { AvroDecoder } from './avroDecoder';
 import { AvroProducer } from './avroProducer';
 import { getMessageHeaderValue } from './utils';
+import { Action, HeaderNames, MessageHeaders, MessagePayload, TopicAvroSettings} from './types'
 
-export { AvroProducer, AvroDecoder, getMessageHeaderValue };
+export { 
+    Action,
+    AvroProducer,
+    AvroDecoder,
+    HeaderNames,
+    getMessageHeaderValue,
+    MessageHeaders,
+    MessagePayload,
+    TopicAvroSettings
+};

packages/kafka-avro-lib/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@func-fun/kafka-avro-lib",
-  "version": "1.0.0-beta.0",
+  "version": "1.0.0-beta.1",
   "type": "module",
   "repository": {
     "type": "git",

packages/kafka-avro-lib/types.ts

@@ -24,5 +24,5 @@ export interface TopicAvroSettings {
   compression?: number;
 }
 
-export type MessageHeaders = { [key in HeaderNames]?: string } | IHeaders;
+export type MessageHeaders = { [key in HeaderNames]?: Buffer } | { [key: string]: Buffer };
 export type MessagePayload = Record<string, string | number | boolean | Array<unknown> | Record<string, unknown>>;

packages/kafka-avro-lib/utils.ts

@@ -2,8 +2,10 @@ import { HeaderNames, MessageHeaders } from './types';
 
 export const getMessageHeaderValue = (headers: MessageHeaders, header: HeaderNames | string): string | null => {
   for (const key in headers) {
-    if (header === key) {
-      return Buffer.from(headers[header]).toString();
+    const headerValue = headers[header as keyof MessageHeaders];
+
+    if (header === key && undefined !== headerValue) {
+      return Buffer.from(headerValue).toString();
     }
   }