File: example-parsing.js

package info (click to toggle)
node-mqtt-packet 9.0.2-1
  • links: PTS, VCS
  • area: main
  • in suites: sid, trixie
  • size: 352 kB
  • sloc: javascript: 4,978; sh: 10; makefile: 2
file content (26 lines) | stat: -rw-r--r-- 592 bytes parent folder | download | duplicates (3)
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
var mqtt = require('mqtt-packet')
var parser = mqtt.parser()
 
// Synchronously emits all the parsed packets 
parser.on('packet', function(packet) {
  console.log(packet)
  // Prints: 
  // 
  // { 
  //   cmd: 'publish', 
  //   retain: false, 
  //   qos: 0, 
  //   dup: false, 
  //   length: 10, 
  //   topic: 'test', 
  //   payload: <Buffer 74 65 73 74> 
  // } 
})
 
parser.parse(Buffer.from([
  48, 10, // Header (publish) 
  0, 4, // Topic length 
  116, 101, 115, 116, // Topic (test) 
  116, 101, 115, 116 // Payload (test) 
]))
// Returns the number of bytes left in the parser