Accessing the Avro.Schema from a reader about avsc HOT 2 CLOSED

'use strict';
let avsc = require('avsc');

function toMessageBuffer(val, type, schemaId, length) {
  let buf = new Buffer(length || 1024);
  buf[0] = 0; // Magic byte.
  buf.writeInt32BE(schemaId, 1);

  let pos = type.encode(val, buf, 5);
  if (pos < 0) {
    // The buffer was too short, we need to resize.
    // return getMessageBuffer(type, val, schemaId, length - pos);
  }
  return buf.slice(0, pos);
}

// This could be any source - each key being the Unique Schema ID
let schema = {
    '8': {},
    '9': {},
    '10': {},
    '11': {},
    '12': {
        type: "record",
        name: "User",
        fields: [
            {
                name: "firstname",
                type: "string"
            },
            {
                name: "surname",
                type: "string"
            }
        ],
    },
    '13': {},
    '14': {},
}

// Our message
let message = {
    'firstname': 'John',
    'surname': 'Smith'
}

// Create the type from the unique schema
let type = avsc.parse(schema[12]);

// Encode a new message - the 3rd param is the unique schema id
let bufferedMessage = toMessageBuffer(message, type, 12, 1024);

/****************
 *  ~KAFKA~  *
 ****************/

console.log("=====Received Message=====");
let readerType = avsc.parse(schema[bufferedMessage[4]]); // Let's parse this shit with our unique schema ID

// Decode our message
let receivedMessage = readerType.decode(bufferedMessage, 5); // It lives at 5 just after our schema ID
console.log(readerType.toString(receivedMessage.value));