"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const shared_utils_1 = require("@nestjs/common/utils/shared.utils");
class KafkaParser {
    static parse(data) {
        data.value = this.decode(data.value);
        if (!shared_utils_1.isNil(data.key)) {
            data.key = this.decode(data.key);
        }
        if (!shared_utils_1.isNil(data.headers)) {
            const decodeHeaderByKey = (key) => {
                data.headers[key] = this.decode(data.headers[key]);
            };
            Object.keys(data.headers).forEach(decodeHeaderByKey);
        }
        else {
            data.headers = {};
        }
        return data;
    }
    static decode(value) {
        if (shared_utils_1.isNil(value)) {
            return null;
        }
        let result = value.toString();
        const startChar = result.charAt(0);
        // only try to parse objects and arrays
        if (startChar === '{' || startChar === '[') {
            try {
                result = JSON.parse(value.toString());
            }
            catch (e) { }
        }
        return result;
    }
}
exports.KafkaParser = KafkaParser;