forked from mqttjs/mqtt-packet
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathnumbers.js
67 lines (56 loc) · 1.39 KB
/
numbers.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
'use strict'
var Buffer = require('safe-buffer').Buffer
var max = 65536
var cache = {}
function generateBuffer (i) {
var buffer = Buffer.allocUnsafe(2)
buffer.writeUInt8(i >> 8, 0)
buffer.writeUInt8(i & 0x00FF, 0 + 1)
return buffer
}
function generateCache () {
for (var i = 0; i < max; i++) {
cache[i] = generateBuffer(i)
}
}
/**
* calcVariableByteIntLength - calculate the variable byte integer
* length field
*
* @api private
*/
function calcVariableByteIntLength (length) {
if (length >= 0 && length < 128) return 1
else if (length >= 128 && length < 16384) return 2
else if (length >= 16384 && length < 2097152) return 3
else if (length >= 2097152 && length < 268435456) return 4
else return 0
}
function genBufVariableByteInt (num) {
var digit = 0
var pos = 0
var length = calcVariableByteIntLength(num)
var buffer = Buffer.allocUnsafe(length)
do {
digit = num % 128 | 0
num = num / 128 | 0
if (num > 0) digit = digit | 0x80
buffer.writeUInt8(digit, pos++)
} while (num > 0)
return {
data: buffer,
length: length
}
}
function generate4ByteBuffer (num) {
var buffer = Buffer.allocUnsafe(4)
buffer.writeUInt32BE(num, 0)
return buffer
}
module.exports = {
cache: cache,
generateCache: generateCache,
generateNumber: generateBuffer,
genBufVariableByteInt: genBufVariableByteInt,
generate4ByteBuffer: generate4ByteBuffer
}