Merge pull request #1184 from pdrvsky/fix/metadata-request-nullable-a…

…rray

Change sent metadata topic array to be nullable (versions 1, 2 and 3)

src/protocol/requests/metadata/v1/request.js

@@ -1,8 +1,16 @@
-const requestV0 = require('../v0/request')
+const Encoder = require('../../../encoder')
+const { Metadata: apiKey } = require('../../apiKeys')
 
 /**
  * Metadata Request (Version: 1) => [topics]
  *   topics => STRING
  */
 
-module.exports = ({ topics }) => Object.assign(requestV0({ topics }), { apiVersion: 1 })
+module.exports = ({ topics }) => ({
+  apiKey,
+  apiVersion: 1,
+  apiName: 'Metadata',
+  encode: async () => {
+    return new Encoder().writeNullableArray(topics)
+  },
+})

src/protocol/requests/metadata/v2/request.js

@@ -1,8 +1,8 @@
-const requestV0 = require('../v0/request')
+const requestV1 = require('../v1/request')
 
 /**
  * Metadata Request (Version: 2) => [topics]
  *   topics => STRING
  */
 
-module.exports = ({ topics }) => Object.assign(requestV0({ topics }), { apiVersion: 2 })
+module.exports = ({ topics }) => Object.assign(requestV1({ topics }), { apiVersion: 2 })

src/protocol/requests/metadata/v3/request.js

@@ -1,8 +1,8 @@
-const requestV0 = require('../v0/request')
+const requestV1 = require('../v1/request')
 
 /**
  * Metadata Request (Version: 3) => [topics]
  *   topics => STRING
  */
 
-module.exports = ({ topics }) => Object.assign(requestV0({ topics }), { apiVersion: 3 })
+module.exports = ({ topics }) => Object.assign(requestV1({ topics }), { apiVersion: 3 })