Comparing version 3.4.1 to 3.5.0
@@ -0,1 +1,4 @@ | ||
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var msgpack = require('./')() // namespace our extensions | ||
@@ -25,3 +28,3 @@ var a = new MyType(2, 'a') | ||
function mytipeEncode (obj) { | ||
var buf = new Buffer(obj.size) | ||
var buf = Buffer.allocUnsafe(obj.size) | ||
buf.fill(obj.value) | ||
@@ -28,0 +31,0 @@ return buf |
@@ -0,1 +1,4 @@ | ||
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var assert = require('assert') | ||
@@ -50,3 +53,3 @@ var bl = require('bl') | ||
var buf = bl() | ||
var header = new Buffer(1) | ||
var header = Buffer.allocUnsafe(1) | ||
@@ -53,0 +56,0 @@ header.writeInt8(type, 0) |
@@ -0,1 +1,4 @@ | ||
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var bl = require('bl') | ||
@@ -12,9 +15,9 @@ var TOLERANCE = 0.1 | ||
} else if (obj === null) { | ||
buf = new Buffer(1) | ||
buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0xc0 | ||
} else if (obj === true) { | ||
buf = new Buffer(1) | ||
buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0xc3 | ||
} else if (obj === false) { | ||
buf = new Buffer(1) | ||
buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0xc2 | ||
@@ -24,3 +27,3 @@ } else if (typeof obj === 'string') { | ||
if (len < 32) { | ||
buf = new Buffer(1 + len) | ||
buf = Buffer.allocUnsafe(1 + len) | ||
buf[0] = 0xa0 | len | ||
@@ -32,3 +35,3 @@ if (len > 0) { | ||
// str8, but only when not in compatibility mode | ||
buf = new Buffer(2 + len) | ||
buf = Buffer.allocUnsafe(2 + len) | ||
buf[0] = 0xd9 | ||
@@ -38,3 +41,3 @@ buf[1] = len | ||
} else if (len <= 0xffff) { | ||
buf = new Buffer(3 + len) | ||
buf = Buffer.allocUnsafe(3 + len) | ||
buf[0] = 0xda | ||
@@ -44,3 +47,3 @@ buf.writeUInt16BE(len, 1) | ||
} else { | ||
buf = new Buffer(5 + len) | ||
buf = Buffer.allocUnsafe(5 + len) | ||
buf[0] = 0xdb | ||
@@ -54,11 +57,11 @@ buf.writeUInt32BE(len, 1) | ||
if (obj.length <= 0xff) { | ||
buf = new Buffer(2) | ||
buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xc4 | ||
buf[1] = obj.length | ||
} else if (obj.length <= 0xffff) { | ||
buf = new Buffer(3) | ||
buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xc5 | ||
buf.writeUInt16BE(obj.length, 1) | ||
} else { | ||
buf = new Buffer(5) | ||
buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xc6 | ||
@@ -71,10 +74,10 @@ buf.writeUInt32BE(obj.length, 1) | ||
if (obj.length < 16) { | ||
buf = new Buffer(1) | ||
buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0x90 | obj.length | ||
} else if (obj.length < 65536) { | ||
buf = new Buffer(3) | ||
buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xdc | ||
buf.writeUInt16BE(obj.length, 1) | ||
} else { | ||
buf = new Buffer(5) | ||
buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xdd | ||
@@ -95,18 +98,18 @@ buf.writeUInt32BE(obj.length, 1) | ||
if (obj < 128) { | ||
buf = new Buffer(1) | ||
buf = Buffer.allocUnsafe(1) | ||
buf[0] = obj | ||
} else if (obj < 256) { | ||
buf = new Buffer(2) | ||
buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xcc | ||
buf[1] = obj | ||
} else if (obj < 65536) { | ||
buf = new Buffer(3) | ||
buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xcd | ||
buf.writeUInt16BE(obj, 1) | ||
} else if (obj <= 0xffffffff) { | ||
buf = new Buffer(5) | ||
buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xce | ||
buf.writeUInt32BE(obj, 1) | ||
} else if (obj <= 9007199254740991) { | ||
buf = new Buffer(9) | ||
buf = Buffer.allocUnsafe(9) | ||
buf[0] = 0xcf | ||
@@ -119,18 +122,18 @@ write64BitUint(buf, obj) | ||
if (obj >= -32) { | ||
buf = new Buffer(1) | ||
buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0x100 + obj | ||
} else if (obj >= -128) { | ||
buf = new Buffer(2) | ||
buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xd0 | ||
buf.writeInt8(obj, 1) | ||
} else if (obj >= -32768) { | ||
buf = new Buffer(3) | ||
buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xd1 | ||
buf.writeInt16BE(obj, 1) | ||
} else if (obj > -214748365) { | ||
buf = new Buffer(5) | ||
buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xd2 | ||
buf.writeInt32BE(obj, 1) | ||
} else if (obj >= -9007199254740991) { | ||
buf = new Buffer(9) | ||
buf = Buffer.allocUnsafe(9) | ||
buf[0] = 0xd3 | ||
@@ -201,3 +204,3 @@ write64BitInt(buf, 1, obj) | ||
return bl().append(new Buffer(headers)).append(encoded) | ||
return bl().append(Buffer.from(headers)).append(encoded) | ||
} | ||
@@ -222,6 +225,6 @@ | ||
if (length < 16) { | ||
header = new Buffer(1) | ||
header = Buffer.allocUnsafe(1) | ||
header[0] = 0x80 | length | ||
} else { | ||
header = new Buffer(3) | ||
header = Buffer.allocUnsafe(3) | ||
header[0] = 0xde | ||
@@ -280,3 +283,3 @@ header.writeUInt16BE(length, 1) | ||
buf = new Buffer(5) | ||
buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xca | ||
@@ -288,3 +291,3 @@ buf.writeFloatBE(obj, 1) | ||
if (forceFloat64 || Math.abs(obj - buf.readFloatBE(1)) > TOLERANCE) { | ||
buf = new Buffer(9) | ||
buf = Buffer.allocUnsafe(9) | ||
buf[0] = 0xcb | ||
@@ -291,0 +294,0 @@ buf.writeDoubleBE(obj, 1) |
@@ -0,1 +1,3 @@ | ||
'use strict' | ||
var Transform = require('readable-stream').Transform | ||
@@ -2,0 +4,0 @@ var inherits = require('inherits') |
{ | ||
"name": "msgpack5", | ||
"version": "3.4.1", | ||
"version": "3.5.0", | ||
"description": "A msgpack v5 implementation for node.js and the browser, with extension points", | ||
@@ -24,4 +24,3 @@ "main": "index.js", | ||
"v5", | ||
"msgpack", | ||
"v5", | ||
"MessagePack", | ||
"ext" | ||
@@ -36,11 +35,11 @@ ], | ||
"devDependencies": { | ||
"browserify": "^10.2.4", | ||
"browserify": "^14.0.0", | ||
"faucet": "0.0.1", | ||
"jshint": "^2.5.2", | ||
"level-test": "^2.0.0", | ||
"pre-commit": "1.0.10", | ||
"standard": "^8.0.0", | ||
"tape": "^4.0.0", | ||
"jshint": "^2.9.5", | ||
"level-test": "^2.0.3", | ||
"pre-commit": "^1.2.2", | ||
"standard": "^10.0.0", | ||
"tape": "^4.7.0", | ||
"testling": "^1.7.1", | ||
"uglify-js": "^2.4.15" | ||
"uglify-js": "^3.0.0" | ||
}, | ||
@@ -66,6 +65,7 @@ "standard": { | ||
"dependencies": { | ||
"bl": "^1.0.0", | ||
"inherits": "^2.0.1", | ||
"readable-stream": "^2.0.1" | ||
"bl": "^1.2.1", | ||
"inherits": "^2.0.3", | ||
"readable-stream": "^2.3.3", | ||
"safe-buffer": "^5.1.1" | ||
} | ||
} |
@@ -87,2 +87,3 @@ msgpack5 [![Build Status](https://travis-ci.org/mcollina/msgpack5.png)](https://travis-ci.org/mcollina/msgpack5) | ||
<a name="api"></a> | ||
## API | ||
@@ -101,2 +102,3 @@ | ||
<a name="msgpack"></a> | ||
### msgpack(options(obj)) | ||
@@ -114,2 +116,3 @@ | ||
<a name="encode"></a> | ||
### encode(object) | ||
@@ -121,2 +124,3 @@ | ||
<a name="decode"></a> | ||
### decode(buf) | ||
@@ -130,2 +134,3 @@ | ||
<a name="registerEncoder"></a> | ||
### registerEncoder(check(obj), encode(obj)) | ||
@@ -144,2 +149,3 @@ | ||
<a name="registerDecoder"></a> | ||
### registerDecoder(type, decode(buf)) | ||
@@ -157,2 +163,3 @@ | ||
<a name="register"></a> | ||
### register(type, constructor, encode(obj), decode(buf)) | ||
@@ -178,2 +185,3 @@ | ||
<a name="encoder"></a> | ||
### encoder() | ||
@@ -185,2 +193,3 @@ | ||
<a name="decoder"></a> | ||
### decoder() | ||
@@ -187,0 +196,0 @@ |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -10,3 +11,3 @@ var msgpack = require('../') | ||
buf = new Buffer(size) | ||
buf = Buffer.allocUnsafe(size) | ||
buf.fill('a') | ||
@@ -24,3 +25,3 @@ | ||
all.push(build(1)) | ||
all.push(new Buffer(0)) | ||
all.push(Buffer.allocUnsafe(0)) | ||
@@ -38,3 +39,3 @@ all.forEach(function (orig) { | ||
t.test('decoding a buffer of length ' + orig.length, function (t) { | ||
var buf = new Buffer(2 + orig.length) | ||
var buf = Buffer.allocUnsafe(2 + orig.length) | ||
buf[0] = 0xc4 | ||
@@ -59,3 +60,3 @@ buf[1] = orig.length | ||
var orig = build(Math.pow(2, 6)) | ||
var buf = new Buffer(2 + orig.length) | ||
var buf = Buffer.allocUnsafe(2 + orig.length) | ||
buf[0] = 0xc4 | ||
@@ -75,3 +76,3 @@ buf[1] = Math.pow(2, 8) - 1 // set bigger size | ||
var encoder = msgpack() | ||
var buf = new Buffer(1) | ||
var buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0xc4 | ||
@@ -78,0 +79,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -17,3 +18,3 @@ var msgpack = require('../') | ||
function mytipeEncode (obj) { | ||
var buf = new Buffer(obj.size) | ||
var buf = Buffer.allocUnsafe(obj.size) | ||
buf.fill(obj.value) | ||
@@ -76,3 +77,3 @@ return buf | ||
var obj = encoder.encode(new MyType(250, 'a')) | ||
var buf = new Buffer(obj.length) | ||
var buf = Buffer.allocUnsafe(obj.length) | ||
buf[0] = 0xc7 | ||
@@ -91,3 +92,3 @@ buf.writeUInt8(obj.length + 2, 1) // set bigger size | ||
t.test('decoding an incomplete header of variable ext data up to 0xff', function (t) { | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xc7 | ||
@@ -94,0 +95,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -31,3 +32,3 @@ var msgpack = require('../') | ||
t.test('decoding a string of length ' + str.length, function (t) { | ||
var buf = new Buffer(2 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(2 + Buffer.byteLength(str)) | ||
buf[0] = 0xd9 | ||
@@ -54,3 +55,3 @@ buf[1] = Buffer.byteLength(str) | ||
} | ||
var buf = new Buffer(2 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(2 + Buffer.byteLength(str)) | ||
buf[0] = 0xd9 | ||
@@ -70,3 +71,3 @@ buf[1] = Buffer.byteLength(str) + 10 // set bigger size | ||
var encoder = msgpack() | ||
var buf = new Buffer(1) | ||
var buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0xd9 | ||
@@ -73,0 +74,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -68,3 +69,3 @@ var msgpack = require('../') | ||
var size = computeLength(array) | ||
var buf = new Buffer(size) | ||
var buf = Buffer.allocUnsafe(size) | ||
buf[0] = 0x90 | array.length + 2 // set bigger size | ||
@@ -71,0 +72,0 @@ var pos = 1 |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -77,3 +78,3 @@ var msgpack = require('../') | ||
qos: 1, | ||
payload: new Buffer('world'), | ||
payload: Buffer.from('world'), | ||
messageId: '42', | ||
@@ -91,3 +92,3 @@ ttl: 1416309270167 | ||
var map = encoder.encode({'a': 'b', 'c': 'd', 'e': 'f'}) | ||
var buf = new Buffer(map.length) | ||
var buf = Buffer.allocUnsafe(map.length) | ||
buf[0] = 0x80 | 5 // set bigger size | ||
@@ -94,0 +95,0 @@ map.copy(buf, 1, 1, map.length) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -28,3 +29,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer(3) | ||
var buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xd1 | ||
@@ -47,3 +48,3 @@ buf.writeInt16BE(num, 1) | ||
var encoder = msgpack() | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xd1 | ||
@@ -50,0 +51,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -28,3 +29,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer(3) | ||
var buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xcd | ||
@@ -47,3 +48,3 @@ buf.writeUInt16BE(num, 1) | ||
var encoder = msgpack() | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xcd | ||
@@ -50,0 +51,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -53,3 +54,3 @@ var msgpack = require('../') | ||
var array = build(0xffff / 2) | ||
var buf = new Buffer(3 + array.length) | ||
var buf = Buffer.allocUnsafe(3 + array.length) | ||
buf[0] = 0xdc | ||
@@ -75,3 +76,3 @@ buf.writeUInt16BE(array.length + 10, 1) // set bigger size | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xdc | ||
@@ -78,0 +79,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -10,3 +11,3 @@ var msgpack = require('../') | ||
buf = new Buffer(size) | ||
buf = Buffer.allocUnsafe(size) | ||
buf.fill('a') | ||
@@ -37,3 +38,3 @@ | ||
t.test('decoding a buffer of length ' + orig.length, function (t) { | ||
var buf = new Buffer(3 + orig.length) | ||
var buf = Buffer.allocUnsafe(3 + orig.length) | ||
buf[0] = 0xc5 | ||
@@ -58,3 +59,3 @@ buf.writeUInt16BE(orig.length, 1) | ||
var orig = build(Math.pow(2, 12)) | ||
var buf = new Buffer(3 + orig.length) | ||
var buf = Buffer.allocUnsafe(3 + orig.length) | ||
buf[0] = 0xc5 | ||
@@ -74,3 +75,3 @@ buf[1] = Math.pow(2, 16) - 1 // set bigger size | ||
var encoder = msgpack() | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xc5 | ||
@@ -77,0 +78,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -17,3 +18,3 @@ var msgpack = require('../') | ||
function mytipeEncode (obj) { | ||
var buf = new Buffer(obj.size) | ||
var buf = Buffer.allocUnsafe(obj.size) | ||
buf.fill(obj.value) | ||
@@ -60,3 +61,3 @@ return buf | ||
var obj = encoder.encode(new MyType(0xfff0, 'a')) | ||
var buf = new Buffer(obj.length) | ||
var buf = Buffer.allocUnsafe(obj.length) | ||
buf[0] = 0xc8 | ||
@@ -75,3 +76,3 @@ buf.writeUInt16BE(obj.length + 2, 1) // set bigger size | ||
t.test('decoding an incomplete header of variable ext data up between 0x0100 and 0xffff', function (t) { | ||
var buf = new Buffer(3) | ||
var buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xc8 | ||
@@ -78,0 +79,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -60,3 +61,3 @@ var msgpack = require('../') | ||
var map = encoder.encode(build(Math.pow(2, 12) + 1, 42)) | ||
var buf = new Buffer(map.length) | ||
var buf = Buffer.allocUnsafe(map.length) | ||
buf[0] = 0xde | ||
@@ -76,3 +77,3 @@ buf.writeUInt16BE(Math.pow(2, 16) - 1, 1) // set bigger size | ||
var encoder = msgpack() | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xde | ||
@@ -79,0 +80,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -12,15 +13,15 @@ var msgpack = require('../') | ||
str = new Buffer(Math.pow(2, 8)) | ||
str = Buffer.allocUnsafe(Math.pow(2, 8)) | ||
str.fill('a') | ||
all.push(str.toString()) | ||
str = new Buffer(Math.pow(2, 8) + 1) | ||
str = Buffer.allocUnsafe(Math.pow(2, 8) + 1) | ||
str.fill('a') | ||
all.push(str.toString()) | ||
str = new Buffer(Math.pow(2, 14)) | ||
str = Buffer.allocUnsafe(Math.pow(2, 14)) | ||
str.fill('a') | ||
all.push(str.toString()) | ||
str = new Buffer(Math.pow(2, 16) - 1) | ||
str = Buffer.allocUnsafe(Math.pow(2, 16) - 1) | ||
str.fill('a') | ||
@@ -40,3 +41,3 @@ all.push(str.toString()) | ||
t.test('decoding a string of length ' + str.length, function (t) { | ||
var buf = new Buffer(3 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(3 + Buffer.byteLength(str)) | ||
buf[0] = 0xda | ||
@@ -63,3 +64,3 @@ buf.writeUInt16BE(Buffer.byteLength(str), 1) | ||
} | ||
var buf = new Buffer(3 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(3 + Buffer.byteLength(str)) | ||
buf[0] = 0xda | ||
@@ -79,3 +80,3 @@ buf.writeUInt16BE(Buffer.byteLength(str) + 10, 1) // set bigger size | ||
var encoder = msgpack() | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xda | ||
@@ -82,0 +83,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -27,3 +28,3 @@ var msgpack = require('../') | ||
t.test('decoding a string of length ' + str.length, function (t) { | ||
var buf = new Buffer(1 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(1 + Buffer.byteLength(str)) | ||
buf[0] = 0xa0 | Buffer.byteLength(str) | ||
@@ -49,3 +50,3 @@ if (str.length > 0) { | ||
var str = 'aaa' | ||
var buf = new Buffer(1 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(1 + Buffer.byteLength(str)) | ||
buf[0] = 0xa0 | Buffer.byteLength(str) + 2 // set bigger size | ||
@@ -52,0 +53,0 @@ buf.write(str, 1) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -27,3 +28,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer(5) | ||
var buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xd2 | ||
@@ -46,3 +47,3 @@ buf.writeInt32BE(num, 1) | ||
var encoder = msgpack() | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf[0] = 0xd2 | ||
@@ -49,0 +50,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -28,3 +29,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer(5) | ||
var buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xce | ||
@@ -47,3 +48,3 @@ buf.writeUInt32BE(num, 1) | ||
var encoder = msgpack() | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf[0] = 0xce | ||
@@ -50,0 +51,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -24,3 +25,3 @@ var msgpack = require('../') | ||
t.test('decoding a string of length ' + str.length, function (t) { | ||
var buf = new Buffer(1 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(1 + Buffer.byteLength(str)) | ||
buf[0] = 0xa0 | Buffer.byteLength(str) | ||
@@ -27,0 +28,0 @@ buf.write(str, 1) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -47,3 +48,3 @@ var msgpack = require('../') | ||
var array = build(0xffff + 42) | ||
var buf = new Buffer(5 + array.length) | ||
var buf = Buffer.allocUnsafe(5 + array.length) | ||
buf[0] = 0xdd | ||
@@ -69,3 +70,3 @@ buf.writeUInt32BE(array.length + 10, 1) // set bigger size | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf[0] = 0xdd | ||
@@ -72,0 +73,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -10,3 +11,3 @@ var msgpack = require('../') | ||
buf = new Buffer(size) | ||
buf = Buffer.allocUnsafe(size) | ||
buf.fill('a') | ||
@@ -36,3 +37,3 @@ | ||
t.test('decoding a buffer of length ' + orig.length, function (t) { | ||
var buf = new Buffer(5 + orig.length) | ||
var buf = Buffer.allocUnsafe(5 + orig.length) | ||
buf[0] = 0xc6 | ||
@@ -57,3 +58,3 @@ buf.writeUInt32BE(orig.length, 1) | ||
var orig = build(Math.pow(2, 18)) | ||
var buf = new Buffer(5 + orig.length) | ||
var buf = Buffer.allocUnsafe(5 + orig.length) | ||
buf[0] = 0xc6 | ||
@@ -73,3 +74,3 @@ buf[1] = Math.pow(2, 32) - 1 // set bigger size | ||
var encoder = msgpack() | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf[0] = 0xc6 | ||
@@ -76,0 +77,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -17,3 +18,3 @@ var msgpack = require('../') | ||
function mytipeEncode (obj) { | ||
var buf = new Buffer(obj.size) | ||
var buf = Buffer.allocUnsafe(obj.size) | ||
buf.fill(obj.value) | ||
@@ -60,3 +61,3 @@ return buf | ||
var obj = encoder.encode(new MyType(0xffffff, 'a')) | ||
var buf = new Buffer(obj.length) | ||
var buf = Buffer.allocUnsafe(obj.length) | ||
buf[0] = 0xc9 | ||
@@ -75,3 +76,3 @@ buf.writeUInt32BE(obj.length + 2, 1) // set bigger size | ||
t.test('decoding an incomplete header of variable ext data up between 0x10000 and 0xffffffff', function (t) { | ||
var buf = new Buffer(5) | ||
var buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xc9 | ||
@@ -78,0 +79,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -12,11 +13,11 @@ var msgpack = require('../') | ||
str = new Buffer(Math.pow(2, 16)) | ||
str = Buffer.allocUnsafe(Math.pow(2, 16)) | ||
str.fill('a') | ||
all.push(str.toString()) | ||
str = new Buffer(Math.pow(2, 16) + 1) | ||
str = Buffer.allocUnsafe(Math.pow(2, 16) + 1) | ||
str.fill('a') | ||
all.push(str.toString()) | ||
str = new Buffer(Math.pow(2, 20)) | ||
str = Buffer.allocUnsafe(Math.pow(2, 20)) | ||
str.fill('a') | ||
@@ -36,3 +37,3 @@ all.push(str.toString()) | ||
t.test('decoding a string of length ' + str.length, function (t) { | ||
var buf = new Buffer(5 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(5 + Buffer.byteLength(str)) | ||
buf[0] = 0xdb | ||
@@ -59,3 +60,3 @@ buf.writeUInt32BE(Buffer.byteLength(str), 1) | ||
} | ||
var buf = new Buffer(5 + Buffer.byteLength(str)) | ||
var buf = Buffer.allocUnsafe(5 + Buffer.byteLength(str)) | ||
buf[0] = 0xdb | ||
@@ -75,3 +76,3 @@ buf.writeUInt32BE(Buffer.byteLength(str) + 10, 1) // set bigger size | ||
var encoder = msgpack() | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf[0] = 0xdb | ||
@@ -78,0 +79,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -23,3 +24,3 @@ var msgpack = require('../') | ||
t.test('decoding' + num, function (t) { | ||
var buf = new Buffer([num + 0x100]) | ||
var buf = Buffer.from([num + 0x100]) | ||
t.equal(encoder.decode(buf), num, 'must decode correctly') | ||
@@ -26,0 +27,0 @@ t.end() |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -38,3 +39,3 @@ var msgpack = require('../') | ||
var encoder = msgpack() | ||
var buf = new Buffer(8) | ||
var buf = Buffer.allocUnsafe(8) | ||
buf[0] = 0xd3 | ||
@@ -41,0 +42,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -38,3 +39,3 @@ var msgpack = require('../') | ||
var encoder = msgpack() | ||
var buf = new Buffer(8) | ||
var buf = Buffer.allocUnsafe(8) | ||
buf[0] = 0xcf | ||
@@ -41,0 +42,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -23,3 +24,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer([num]) | ||
var buf = Buffer.from([num]) | ||
t.equal(encoder.decode(buf), num, 'must decode correctly') | ||
@@ -26,0 +27,0 @@ t.end() |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -25,3 +26,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer([0xcc, num]) | ||
var buf = Buffer.from([0xcc, num]) | ||
t.equal(encoder.decode(buf), num, 'must decode correctly') | ||
@@ -42,3 +43,3 @@ t.end() | ||
var encoder = msgpack() | ||
var buf = new Buffer(1) | ||
var buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0xcc | ||
@@ -45,0 +46,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -25,3 +26,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer(3) | ||
var buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xd0 | ||
@@ -44,3 +45,3 @@ buf.writeInt8(num, 1) | ||
var encoder = msgpack() | ||
var buf = new Buffer(1) | ||
var buf = Buffer.allocUnsafe(1) | ||
buf[0] = 0xd0 | ||
@@ -47,0 +48,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -11,3 +12,3 @@ var msgpack = require('../') | ||
t.equal(encoder.encode(true).length, 1, 'encode true as a buffer of length 1') | ||
t.equal(encoder.decode(new Buffer([0xc3])), true, 'decode 0xc3 as true') | ||
t.equal(encoder.decode(Buffer.from([0xc3])), true, 'decode 0xc3 as true') | ||
t.equal(encoder.decode(encoder.encode(true)), true, 'mirror test true') | ||
@@ -17,3 +18,3 @@ | ||
t.equal(encoder.encode(false).length, 1, 'encode false as a buffer of length 1') | ||
t.equal(encoder.decode(new Buffer([0xc2])), false, 'decode 0xc2 as false') | ||
t.equal(encoder.decode(Buffer.from([0xc2])), false, 'decode 0xc2 as false') | ||
t.equal(encoder.decode(encoder.encode(false)), false, 'mirror test false') | ||
@@ -20,0 +21,0 @@ |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -27,3 +28,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer(9) | ||
var buf = Buffer.allocUnsafe(9) | ||
var dec | ||
@@ -49,3 +50,3 @@ buf[0] = 0xcb | ||
var encoder = msgpack() | ||
var buf = new Buffer(8) | ||
var buf = Buffer.allocUnsafe(8) | ||
buf[0] = 0xcb | ||
@@ -52,0 +53,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -19,3 +20,3 @@ var msgpack = require('../') | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf.writeUInt8(0x42, 0) | ||
@@ -48,3 +49,3 @@ buf.writeUInt8(obj.data, 1) | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(3) | ||
var buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xd4 | ||
@@ -51,0 +52,0 @@ buf[1] = 0x42 |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -16,3 +17,3 @@ var msgpack = require('../') | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(1) | ||
var buf = Buffer.allocUnsafe(1) | ||
buf.writeUInt8(obj.data, 0) | ||
@@ -43,3 +44,3 @@ return buf | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(3) | ||
var buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xd4 | ||
@@ -71,3 +72,3 @@ buf[1] = 0x42 | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf.writeUInt16BE(obj.data, 0) | ||
@@ -98,3 +99,3 @@ return buf | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf[0] = 0xd5 | ||
@@ -126,3 +127,3 @@ buf[1] = 0x42 | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf.writeUInt32BE(obj.data, 0) | ||
@@ -153,3 +154,3 @@ return buf | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(6) | ||
var buf = Buffer.allocUnsafe(6) | ||
buf[0] = 0xd6 | ||
@@ -181,3 +182,3 @@ buf[1] = 0x44 | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(8) | ||
var buf = Buffer.allocUnsafe(8) | ||
buf.writeUInt32BE(obj.data / 2, 0) | ||
@@ -209,3 +210,3 @@ buf.writeUInt32BE(obj.data / 2, 4) | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(10) | ||
var buf = Buffer.allocUnsafe(10) | ||
buf[0] = 0xd7 | ||
@@ -238,3 +239,3 @@ buf[1] = 0x44 | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(16) | ||
var buf = Buffer.allocUnsafe(16) | ||
buf.writeUInt32BE(obj.data / 4, 0) | ||
@@ -268,3 +269,3 @@ buf.writeUInt32BE(obj.data / 4, 4) | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(18) | ||
var buf = Buffer.allocUnsafe(18) | ||
buf[0] = 0xd8 | ||
@@ -299,3 +300,3 @@ buf[1] = 0x46 | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf.writeUInt32BE(obj.data, 0) | ||
@@ -339,3 +340,3 @@ return buf | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(8) | ||
var buf = Buffer.allocUnsafe(8) | ||
buf.writeUInt32BE(obj.data / 2, 0) | ||
@@ -367,3 +368,3 @@ buf.writeUInt32BE(obj.data / 2, 4) | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(10) | ||
var buf = Buffer.allocUnsafe(10) | ||
buf[0] = 0xd7 | ||
@@ -396,3 +397,3 @@ buf[1] = 0x44 | ||
function mytypeEncode (obj) { | ||
var buf = new Buffer(16) | ||
var buf = Buffer.allocUnsafe(16) | ||
buf.writeUInt32BE(obj.data / 4, 0) | ||
@@ -426,3 +427,3 @@ buf.writeUInt32BE(obj.data / 4, 4) | ||
t.test('decoding a custom obj encoded as ' + orig.data, function (t) { | ||
var buf = new Buffer(18) | ||
var buf = Buffer.allocUnsafe(18) | ||
buf[0] = 0xd8 | ||
@@ -447,3 +448,3 @@ buf[1] = 0x46 | ||
var encoder = msgpack() | ||
var buf = new Buffer(2) | ||
var buf = Buffer.allocUnsafe(2) | ||
buf[0] = 0xd4 | ||
@@ -461,3 +462,3 @@ buf = bl().append(buf) | ||
var encoder = msgpack() | ||
var buf = new Buffer(3) | ||
var buf = Buffer.allocUnsafe(3) | ||
buf[0] = 0xd5 | ||
@@ -475,3 +476,3 @@ buf = bl().append(buf) | ||
var encoder = msgpack() | ||
var buf = new Buffer(5) | ||
var buf = Buffer.allocUnsafe(5) | ||
buf[0] = 0xd6 | ||
@@ -489,3 +490,3 @@ buf = bl().append(buf) | ||
var encoder = msgpack() | ||
var buf = new Buffer(9) | ||
var buf = Buffer.allocUnsafe(9) | ||
buf[0] = 0xd7 | ||
@@ -503,3 +504,3 @@ buf = bl().append(buf) | ||
var encoder = msgpack() | ||
var buf = new Buffer(17) | ||
var buf = Buffer.allocUnsafe(17) | ||
buf[0] = 0xd8 | ||
@@ -506,0 +507,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -36,3 +37,3 @@ var msgpack = require('../') | ||
t.test('decoding ' + num, function (t) { | ||
var buf = new Buffer(5) | ||
var buf = Buffer.allocUnsafe(5) | ||
var dec | ||
@@ -58,3 +59,3 @@ buf[0] = 0xca | ||
var encoder = msgpack() | ||
var buf = new Buffer(4) | ||
var buf = Buffer.allocUnsafe(4) | ||
buf[0] = 0xca | ||
@@ -61,0 +62,0 @@ buf = bl().append(buf) |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -11,3 +12,3 @@ var msgpack = require('../') | ||
t.equal(encoder.encode(null).length, 1, 'encode a buffer of length 1') | ||
t.equal(encoder.decode(new Buffer([0xc0])), null, 'decode 0xc0 as null') | ||
t.equal(encoder.decode(Buffer.from([0xc0])), null, 'decode 0xc0 as null') | ||
t.equal(encoder.decode(encoder.encode(null)), null, 'mirror test null') | ||
@@ -14,0 +15,0 @@ |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -10,5 +11,5 @@ var fs = require('fs') | ||
var map = { | ||
first: new Buffer('first'), | ||
second: new Buffer('second'), | ||
third: new Buffer('third') | ||
first: Buffer.from('first'), | ||
second: Buffer.from('second'), | ||
third: Buffer.from('third') | ||
} | ||
@@ -15,0 +16,0 @@ var pack = msgpack() |
'use strict' | ||
var Buffer = require('safe-buffer').Buffer | ||
var test = require('tape').test | ||
@@ -108,3 +109,3 @@ var msgpack = require('../') | ||
function mytypeEncode () { | ||
return new Buffer(0) | ||
return Buffer.allocUnsafe(0) | ||
} | ||
@@ -139,3 +140,3 @@ | ||
function mytypeEncode () { | ||
return new Buffer(0) | ||
return Buffer.allocUnsafe(0) | ||
} | ||
@@ -142,0 +143,0 @@ |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
446917
9213
239
4
+ Addedsafe-buffer@^5.1.1
Updatedbl@^1.2.1
Updatedinherits@^2.0.3
Updatedreadable-stream@^2.3.3