diff --git a/src/QueueMessage.js b/src/QueueMessage.js index 7a146e0..2fbe424 100644 --- a/src/QueueMessage.js +++ b/src/QueueMessage.js @@ -51,12 +51,12 @@ class QueueMessage { static unserialize (buffer, ContentSchema = JSON) { if (!ContentSchema || ContentSchema === JSON) { if (buffer.toString('utf8', 0, 1) === '+') { - const jsonLength = buffer.slice(1, 5).readUInt32BE() + const jsonLength = buffer.subarray(1, 5).readUInt32BE() const { status, data, timeOut, attachArray } = JSON.parse(buffer.toString('utf8', 5, 5 + jsonLength)) let prevAttachmentLength = 5 + jsonLength const queueMessage = new this(status, data, timeOut, ContentSchema) for (const [key, length] of attachArray) { - queueMessage.addAttachment(key, buffer.slice(prevAttachmentLength, prevAttachmentLength + length)) + queueMessage.addAttachment(key, buffer.subarray(prevAttachmentLength, prevAttachmentLength + length)) prevAttachmentLength = prevAttachmentLength + length } diff --git a/test/Gathering.test.js b/test/Gathering.test.js index 5ab9d81..9d32690 100644 --- a/test/Gathering.test.js +++ b/test/Gathering.test.js @@ -87,7 +87,7 @@ describe('GatheringClient && GatheringServer', () => { if (!response.hasAttachment('test')) { done(new Error('Missing attachment name "test" from response')) } - if (!response.getAttachment('test') === buf) { + if (response.getAttachment('test') !== buf) { done(new Error('Attachment name "test" is not the same')) } return msg diff --git a/test/RPC.test.js b/test/RPC.test.js index 2229a2a..56cf12b 100644 --- a/test/RPC.test.js +++ b/test/RPC.test.js @@ -116,7 +116,7 @@ describe('RPCClient && RPCServer', () => { if (!response.hasAttachment('test')) { done(new Error('Missing attachment name "test" from response')) } - if (!response.getAttachment('test') === buf) { + if (response.getAttachment('test') !== buf) { done(new Error('Attachment name "test" is not the same')) } return msg