File Explorer

/proc/self/root/proc/thread-self/root/var/runtime/node_modules/@aws-sdk/node_modules/.bin

This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.

0 dirs
4 files

mqtt_sub2.6 KB · 124 lines

1#!/usr/bin/env node2 3const mqtt = require('../')4const path = require('path')5const fs = require('fs')6const helpMe = require('help-me')({7  dir: path.join(__dirname, '..', 'doc')8})9const minimist = require('minimist')10 11function start (args) {12  args = minimist(args, {13    string: ['hostname', 'username', 'password', 'key', 'cert', 'ca', 'clientId', 'i', 'id'],14    boolean: ['stdin', 'help', 'clean', 'insecure'],15    alias: {16      port: 'p',17      hostname: ['h', 'host'],18      topic: 't',19      qos: 'q',20      clean: 'c',21      keepalive: 'k',22      clientId: ['i', 'id'],23      username: 'u',24      password: 'P',25      protocol: ['C', 'l'],26      verbose: 'v',27      help: '-H',28      ca: 'cafile'29    },30    default: {31      host: 'localhost',32      qos: 0,33      retain: false,34      clean: true,35      keepAlive: 30 // 30 sec36    }37  })38 39  if (args.help) {40    return helpMe.toStdout('subscribe')41  }42 43  args.topic = args.topic || args._.shift()44 45  if (!args.topic) {46    console.error('missing topic\n')47    return helpMe.toStdout('subscribe')48  }49 50  if (args.key) {51    args.key = fs.readFileSync(args.key)52  }53 54  if (args.cert) {55    args.cert = fs.readFileSync(args.cert)56  }57 58  if (args.ca) {59    args.ca = fs.readFileSync(args.ca)60  }61 62  if (args.key && args.cert && !args.protocol) {63    args.protocol = 'mqtts'64  }65 66  if (args.insecure) {67    args.rejectUnauthorized = false68  }69 70  if (args.port) {71    if (typeof args.port !== 'number') {72      console.warn('# Port: number expected, \'%s\' was given.', typeof args.port)73      return74    }75  }76 77  if (args['will-topic']) {78    args.will = {}79    args.will.topic = args['will-topic']80    args.will.payload = args['will-message']81    args.will.qos = args['will-qos']82    args.will.retain = args['will-retain']83  }84 85  args.keepAlive = args['keep-alive']86 87  const client = mqtt.connect(args)88 89  client.on('connect', function () {90    client.subscribe(args.topic, { qos: args.qos }, function (err, result) {91      if (err) {92        console.error(err)93        process.exit(1)94      }95 96      result.forEach(function (sub) {97        if (sub.qos > 2) {98          console.error('subscription negated to', sub.topic, 'with code', sub.qos)99          process.exit(1)100        }101      })102    })103  })104 105  client.on('message', function (topic, payload) {106    if (args.verbose) {107      console.log(topic, payload.toString())108    } else {109      console.log(payload.toString())110    }111  })112 113  client.on('error', function (err) {114    console.warn(err)115    client.end()116  })117}118 119module.exports = start120 121if (require.main === module) {122  start(process.argv.slice(2))123}124