msgpack-js.js 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646
  1. /* jshint browser: true */
  2. /* global define, module */
  3. ( // Module boilerplate to support browser globals and browserify and AMD.
  4. typeof define === "function" ? function (m) { define("msgpack-js", m); } :
  5. typeof exports === "object" ? function (m) { module.exports = m(); } :
  6. function(m){ this.msgpack = m(); }
  7. )(function () {
  8. "use strict";
  9. var exports = {};
  10. exports.inspect = inspect;
  11. function inspect(buffer) {
  12. if (buffer === undefined) return "undefined";
  13. var view;
  14. var type;
  15. if (buffer instanceof ArrayBuffer) {
  16. type = "ArrayBuffer";
  17. view = new DataView(buffer);
  18. }
  19. else if (buffer instanceof DataView) {
  20. type = "DataView";
  21. view = buffer;
  22. }
  23. if (!view) return JSON.stringify(buffer);
  24. var bytes = [];
  25. for (var i = 0; i < buffer.byteLength; i++) {
  26. if (i > 20) {
  27. bytes.push("...");
  28. break;
  29. }
  30. var byte = view.getUint8(i).toString(16);
  31. if (byte.length === 1) byte = "0" + byte;
  32. bytes.push(byte);
  33. }
  34. return "<" + type + " " + bytes.join(" ") + ">";
  35. }
  36. // Encode string as utf8 into dataview at offset
  37. exports.utf8Write = utf8Write;
  38. function utf8Write(view, offset, string) {
  39. var byteLength = view.byteLength;
  40. for(var i = 0, l = string.length; i < l; i++) {
  41. var codePoint = string.charCodeAt(i);
  42. // One byte of UTF-8
  43. if (codePoint < 0x80) {
  44. view.setUint8(offset++, codePoint >>> 0 & 0x7f | 0x00);
  45. continue;
  46. }
  47. // Two bytes of UTF-8
  48. if (codePoint < 0x800) {
  49. view.setUint8(offset++, codePoint >>> 6 & 0x1f | 0xc0);
  50. view.setUint8(offset++, codePoint >>> 0 & 0x3f | 0x80);
  51. continue;
  52. }
  53. // Three bytes of UTF-8.
  54. if (codePoint < 0x10000) {
  55. view.setUint8(offset++, codePoint >>> 12 & 0x0f | 0xe0);
  56. view.setUint8(offset++, codePoint >>> 6 & 0x3f | 0x80);
  57. view.setUint8(offset++, codePoint >>> 0 & 0x3f | 0x80);
  58. continue;
  59. }
  60. // Four bytes of UTF-8
  61. if (codePoint < 0x110000) {
  62. view.setUint8(offset++, codePoint >>> 18 & 0x07 | 0xf0);
  63. view.setUint8(offset++, codePoint >>> 12 & 0x3f | 0x80);
  64. view.setUint8(offset++, codePoint >>> 6 & 0x3f | 0x80);
  65. view.setUint8(offset++, codePoint >>> 0 & 0x3f | 0x80);
  66. continue;
  67. }
  68. throw new Error("bad codepoint " + codePoint);
  69. }
  70. }
  71. exports.utf8Read = utf8Read;
  72. function utf8Read(view, offset, length) {
  73. var string = "";
  74. for (var i = offset, end = offset + length; i < end; i++) {
  75. var byte = view.getUint8(i);
  76. // One byte character
  77. if ((byte & 0x80) === 0x00) {
  78. string += String.fromCharCode(byte);
  79. continue;
  80. }
  81. // Two byte character
  82. if ((byte & 0xe0) === 0xc0) {
  83. string += String.fromCharCode(
  84. ((byte & 0x1f) << 6) |
  85. (view.getUint8(++i) & 0x3f)
  86. );
  87. continue;
  88. }
  89. // Three byte character
  90. if ((byte & 0xf0) === 0xe0) {
  91. string += String.fromCharCode(
  92. ((byte & 0x0f) << 12) |
  93. ((view.getUint8(++i) & 0x3f) << 6) |
  94. ((view.getUint8(++i) & 0x3f) << 0)
  95. );
  96. continue;
  97. }
  98. // Four byte character
  99. if ((byte & 0xf8) === 0xf0) {
  100. string += String.fromCharCode(
  101. ((byte & 0x07) << 18) |
  102. ((view.getUint8(++i) & 0x3f) << 12) |
  103. ((view.getUint8(++i) & 0x3f) << 6) |
  104. ((view.getUint8(++i) & 0x3f) << 0)
  105. );
  106. continue;
  107. }
  108. throw new Error("Invalid byte " + byte.toString(16));
  109. }
  110. return string;
  111. }
  112. exports.utf8ByteCount = utf8ByteCount;
  113. function utf8ByteCount(string) {
  114. var count = 0;
  115. for(var i = 0, l = string.length; i < l; i++) {
  116. var codePoint = string.charCodeAt(i);
  117. if (codePoint < 0x80) {
  118. count += 1;
  119. continue;
  120. }
  121. if (codePoint < 0x800) {
  122. count += 2;
  123. continue;
  124. }
  125. if (codePoint < 0x10000) {
  126. count += 3;
  127. continue;
  128. }
  129. if (codePoint < 0x110000) {
  130. count += 4;
  131. continue;
  132. }
  133. throw new Error("bad codepoint " + codePoint);
  134. }
  135. return count;
  136. }
  137. exports.encode = function (value) {
  138. var buffer = new ArrayBuffer(encodedSize(value));
  139. var view = new DataView(buffer);
  140. encode(value, view, 0);
  141. return buffer;
  142. };
  143. exports.decode = decode;
  144. // https://github.com/msgpack/msgpack/blob/master/spec.md
  145. // we reserve extension type 0x00 to encode javascript 'undefined'
  146. function Decoder(view, offset) {
  147. this.offset = offset || 0;
  148. this.view = view;
  149. }
  150. Decoder.prototype.map = function (length) {
  151. var value = {};
  152. for (var i = 0; i < length; i++) {
  153. var key = this.parse();
  154. value[key] = this.parse();
  155. }
  156. return value;
  157. };
  158. Decoder.prototype.bin = function (length) {
  159. var value = new ArrayBuffer(length);
  160. (new Uint8Array(value)).set(new Uint8Array(this.view.buffer, this.offset, length), 0);
  161. this.offset += length;
  162. return value;
  163. };
  164. Decoder.prototype.str = function (length) {
  165. var value = utf8Read(this.view, this.offset, length);
  166. this.offset += length;
  167. return value;
  168. };
  169. Decoder.prototype.array = function (length) {
  170. var value = new Array(length);
  171. for (var i = 0; i < length; i++) {
  172. value[i] = this.parse();
  173. }
  174. return value;
  175. };
  176. Decoder.prototype.parse = function () {
  177. var type = this.view.getUint8(this.offset);
  178. var value, length;
  179. // FixStr
  180. if ((type & 0xe0) === 0xa0) {
  181. length = type & 0x1f;
  182. this.offset++;
  183. return this.str(length);
  184. }
  185. // FixMap
  186. if ((type & 0xf0) === 0x80) {
  187. length = type & 0x0f;
  188. this.offset++;
  189. return this.map(length);
  190. }
  191. // FixArray
  192. if ((type & 0xf0) === 0x90) {
  193. length = type & 0x0f;
  194. this.offset++;
  195. return this.array(length);
  196. }
  197. // Positive FixNum
  198. if ((type & 0x80) === 0x00) {
  199. this.offset++;
  200. return type;
  201. }
  202. // Negative Fixnum
  203. if ((type & 0xe0) === 0xe0) {
  204. value = this.view.getInt8(this.offset);
  205. this.offset++;
  206. return value;
  207. }
  208. // Undefined as FixExt1
  209. if (type === 0xd4 && this.view.getUint8(this.offset + 1) === 0x00) {
  210. this.offset += 3;
  211. return undefined;
  212. }
  213. switch (type) {
  214. // str 8
  215. case 0xd9:
  216. length = this.view.getUint8(this.offset + 1);
  217. this.offset += 2;
  218. return this.str(length);
  219. // str 16
  220. case 0xda:
  221. length = this.view.getUint16(this.offset + 1);
  222. this.offset += 3;
  223. return this.str(length);
  224. // str 32
  225. case 0xdb:
  226. length = this.view.getUint32(this.offset + 1);
  227. this.offset += 5;
  228. return this.str(length);
  229. // bin 8
  230. case 0xc4:
  231. length = this.view.getUint8(this.offset + 1);
  232. this.offset += 2;
  233. return this.bin(length);
  234. // bin 16
  235. case 0xc5:
  236. length = this.view.getUint16(this.offset + 1);
  237. this.offset += 3;
  238. return this.bin(length);
  239. // bin 32
  240. case 0xc6:
  241. length = this.view.getUint32(this.offset + 1);
  242. this.offset += 5;
  243. return this.bin(length);
  244. // nil
  245. case 0xc0:
  246. this.offset++;
  247. return null;
  248. // false
  249. case 0xc2:
  250. this.offset++;
  251. return false;
  252. // true
  253. case 0xc3:
  254. this.offset++;
  255. return true;
  256. // uint8
  257. case 0xcc:
  258. value = this.view.getUint8(this.offset + 1);
  259. this.offset += 2;
  260. return value;
  261. // uint 16
  262. case 0xcd:
  263. value = this.view.getUint16(this.offset + 1);
  264. this.offset += 3;
  265. return value;
  266. // uint 32
  267. case 0xce:
  268. value = this.view.getUint32(this.offset + 1);
  269. this.offset += 5;
  270. return value;
  271. // uint 64
  272. case 0xcf:
  273. var high = this.view.getUint32(this.offset + 1);
  274. var low = this.view.getUint32(this.offset + 5);
  275. value = high*0x100000000 + low;
  276. this.offset += 9;
  277. return value;
  278. // int 8
  279. case 0xd0:
  280. value = this.view.getInt8(this.offset + 1);
  281. this.offset += 2;
  282. return value;
  283. // int 16
  284. case 0xd1:
  285. value = this.view.getInt16(this.offset + 1);
  286. this.offset += 3;
  287. return value;
  288. // int 32
  289. case 0xd2:
  290. value = this.view.getInt32(this.offset + 1);
  291. this.offset += 5;
  292. return value;
  293. // int 64
  294. case 0xd3:
  295. var high = this.view.getInt32(this.offset + 1);
  296. var low = this.view.getUint32(this.offset + 5);
  297. value = high*0x100000000 + low;
  298. this.offset += 9;
  299. return value;
  300. // map 16
  301. case 0xde:
  302. length = this.view.getUint16(this.offset + 1);
  303. this.offset += 3;
  304. return this.map(length);
  305. // map 32
  306. case 0xdf:
  307. length = this.view.getUint32(this.offset + 1);
  308. this.offset += 5;
  309. return this.map(length);
  310. // array 16
  311. case 0xdc:
  312. length = this.view.getUint16(this.offset + 1);
  313. this.offset += 3;
  314. return this.array(length);
  315. // array 32
  316. case 0xdd:
  317. length = this.view.getUint32(this.offset + 1);
  318. this.offset += 5;
  319. return this.array(length);
  320. // float
  321. case 0xca:
  322. value = this.view.getFloat32(this.offset + 1);
  323. this.offset += 5;
  324. return value;
  325. // double
  326. case 0xcb:
  327. value = this.view.getFloat64(this.offset + 1);
  328. this.offset += 9;
  329. return value;
  330. }
  331. throw new Error("Unknown type 0x" + type.toString(16));
  332. };
  333. function decode(buffer) {
  334. var view = new DataView(buffer);
  335. var decoder = new Decoder(view);
  336. var value = decoder.parse();
  337. if (decoder.offset !== buffer.byteLength) throw new Error((buffer.byteLength - decoder.offset) + " trailing bytes");
  338. return value;
  339. }
  340. function encode(value, view, offset) {
  341. var type = typeof value;
  342. // Strings Bytes
  343. if (type === "string") {
  344. var length = utf8ByteCount(value);
  345. // fix str
  346. if (length < 0x20) {
  347. view.setUint8(offset, length | 0xa0);
  348. utf8Write(view, offset + 1, value);
  349. return 1 + length;
  350. }
  351. // str 8
  352. if (length < 0x100) {
  353. view.setUint8(offset, 0xd9);
  354. view.setUint8(offset + 1, length);
  355. utf8Write(view, offset + 2, value);
  356. return 2 + length;
  357. }
  358. // str 16
  359. if (length < 0x10000) {
  360. view.setUint8(offset, 0xda);
  361. view.setUint16(offset + 1, length);
  362. utf8Write(view, offset + 3, value);
  363. return 3 + length;
  364. }
  365. // str 32
  366. if (length < 0x100000000) {
  367. view.setUint8(offset, 0xdb);
  368. view.setUint32(offset + 1, length);
  369. utf8Write(view, offset + 5, value);
  370. return 5 + length;
  371. }
  372. }
  373. if (value instanceof ArrayBuffer) {
  374. var length = value.byteLength;
  375. // bin 8
  376. if (length < 0x100) {
  377. view.setUint8(offset, 0xc4);
  378. view.setUint8(offset + 1, length);
  379. (new Uint8Array(view.buffer)).set(new Uint8Array(value), offset + 2);
  380. return 2 + length;
  381. }
  382. // bin 16
  383. if (length < 0x10000) {
  384. view.setUint8(offset, 0xc5);
  385. view.setUint16(offset + 1, length);
  386. (new Uint8Array(view.buffer)).set(new Uint8Array(value), offset + 3);
  387. return 3 + length;
  388. }
  389. // bin 32
  390. if (length < 0x100000000) {
  391. view.setUint8(offset, 0xc6);
  392. view.setUint32(offset + 1, length);
  393. (new Uint8Array(view.buffer)).set(new Uint8Array(value), offset + 5);
  394. return 5 + length;
  395. }
  396. }
  397. if (type === "number") {
  398. // Floating Point
  399. if ((value << 0) !== value) {
  400. view.setUint8(offset, 0xcb);
  401. view.setFloat64(offset + 1, value);
  402. return 9;
  403. }
  404. // Integers
  405. if (value >=0) {
  406. // positive fixnum
  407. if (value < 0x80) {
  408. view.setUint8(offset, value);
  409. return 1;
  410. }
  411. // uint 8
  412. if (value < 0x100) {
  413. view.setUint8(offset, 0xcc);
  414. view.setUint8(offset + 1, value);
  415. return 2;
  416. }
  417. // uint 16
  418. if (value < 0x10000) {
  419. view.setUint8(offset, 0xcd);
  420. view.setUint16(offset + 1, value);
  421. return 3;
  422. }
  423. // uint 32
  424. if (value < 0x100000000) {
  425. view.setUint8(offset, 0xce);
  426. view.setUint32(offset + 1, value);
  427. return 5;
  428. }
  429. throw new Error("Number too big 0x" + value.toString(16));
  430. }
  431. // negative fixnum
  432. if (value >= -0x20) {
  433. view.setInt8(offset, value);
  434. return 1;
  435. }
  436. // int 8
  437. if (value >= -0x80) {
  438. view.setUint8(offset, 0xd0);
  439. view.setInt8(offset + 1, value);
  440. return 2;
  441. }
  442. // int 16
  443. if (value >= -0x8000) {
  444. view.setUint8(offset, 0xd1);
  445. view.setInt16(offset + 1, value);
  446. return 3;
  447. }
  448. // int 32
  449. if (value >= -0x80000000) {
  450. view.setUint8(offset, 0xd2);
  451. view.setInt32(offset + 1, value);
  452. return 5;
  453. }
  454. throw new Error("Number too small -0x" + (-value).toString(16).substr(1));
  455. }
  456. // undefined
  457. if (type === "undefined") {
  458. view.setUint8(offset, 0xd4); // fixext 1
  459. view.setUint8(offset + 1, 0); // type (undefined)
  460. view.setUint8(offset + 2, 0); // data (ignored)
  461. return 3;
  462. }
  463. // null
  464. if (value === null) {
  465. view.setUint8(offset, 0xc0);
  466. return 1;
  467. }
  468. // Boolean
  469. if (type === "boolean") {
  470. view.setUint8(offset, value ? 0xc3 : 0xc2);
  471. return 1;
  472. }
  473. // Container Types
  474. if (type === "object") {
  475. var length, size = 0;
  476. var isArray = Array.isArray(value);
  477. if (isArray) {
  478. length = value.length;
  479. }
  480. else {
  481. var keys = Object.keys(value);
  482. length = keys.length;
  483. }
  484. var size;
  485. if (length < 0x10) {
  486. view.setUint8(offset, length | (isArray ? 0x90 : 0x80));
  487. size = 1;
  488. }
  489. else if (length < 0x10000) {
  490. view.setUint8(offset, isArray ? 0xdc : 0xde);
  491. view.setUint16(offset + 1, length);
  492. size = 3;
  493. }
  494. else if (length < 0x100000000) {
  495. view.setUint8(offset, isArray ? 0xdd : 0xdf);
  496. view.setUint32(offset + 1, length);
  497. size = 5;
  498. }
  499. if (isArray) {
  500. for (var i = 0; i < length; i++) {
  501. size += encode(value[i], view, offset + size);
  502. }
  503. }
  504. else {
  505. for (var i = 0; i < length; i++) {
  506. var key = keys[i];
  507. size += encode(key, view, offset + size);
  508. size += encode(value[key], view, offset + size);
  509. }
  510. }
  511. return size;
  512. }
  513. throw new Error("Unknown type " + type);
  514. }
  515. function encodedSize(value) {
  516. var type = typeof value;
  517. // Raw Bytes
  518. if (type === "string") {
  519. var length = utf8ByteCount(value);
  520. if (length < 0x20) {
  521. return 1 + length;
  522. }
  523. if (length < 0x100) {
  524. return 2 + length;
  525. }
  526. if (length < 0x10000) {
  527. return 3 + length;
  528. }
  529. if (length < 0x100000000) {
  530. return 5 + length;
  531. }
  532. }
  533. if (value instanceof ArrayBuffer) {
  534. var length = value.byteLength;
  535. if (length < 0x100) {
  536. return 2 + length;
  537. }
  538. if (length < 0x10000) {
  539. return 3 + length;
  540. }
  541. if (length < 0x100000000) {
  542. return 5 + length;
  543. }
  544. }
  545. if (type === "number") {
  546. // Floating Point
  547. // double
  548. if (value << 0 !== value) return 9;
  549. // Integers
  550. if (value >=0) {
  551. // positive fixnum
  552. if (value < 0x80) return 1;
  553. // uint 8
  554. if (value < 0x100) return 2;
  555. // uint 16
  556. if (value < 0x10000) return 3;
  557. // uint 32
  558. if (value < 0x100000000) return 5;
  559. // uint 64
  560. if (value < 0x10000000000000000) return 9;
  561. throw new Error("Number too big 0x" + value.toString(16));
  562. }
  563. // negative fixnum
  564. if (value >= -0x20) return 1;
  565. // int 8
  566. if (value >= -0x80) return 2;
  567. // int 16
  568. if (value >= -0x8000) return 3;
  569. // int 32
  570. if (value >= -0x80000000) return 5;
  571. // int 64
  572. if (value >= -0x8000000000000000) return 9;
  573. throw new Error("Number too small -0x" + value.toString(16).substr(1));
  574. }
  575. // undefined
  576. if (type === "undefined") return 3;
  577. // Boolean, null
  578. if (type === "boolean" || value === null) return 1;
  579. // Container Types
  580. if (type === "object") {
  581. var length, size = 0;
  582. if (Array.isArray(value)) {
  583. length = value.length;
  584. for (var i = 0; i < length; i++) {
  585. size += encodedSize(value[i]);
  586. }
  587. }
  588. else {
  589. var keys = Object.keys(value);
  590. length = keys.length;
  591. for (var i = 0; i < length; i++) {
  592. var key = keys[i];
  593. size += encodedSize(key) + encodedSize(value[key]);
  594. }
  595. }
  596. if (length < 0x10) {
  597. return 1 + size;
  598. }
  599. if (length < 0x10000) {
  600. return 3 + size;
  601. }
  602. if (length < 0x100000000) {
  603. return 5 + size;
  604. }
  605. throw new Error("Array or object too long 0x" + length.toString(16));
  606. }
  607. throw new Error("Unknown type " + type);
  608. }
  609. return exports;
  610. });