File Explorer

/proc/self/root/var/runtime/node_modules/@aws-sdk/node_modules/mqtt-packet
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 /.
3 dirs
13 files
constants.js4.9 KB · 188 lines
1/* Protocol - protocol constants */2const protocol = module.exports3 4/* Command code => mnemonic */5protocol.types = {6  0: 'reserved',7  1: 'connect',8  2: 'connack',9  3: 'publish',10  4: 'puback',11  5: 'pubrec',12  6: 'pubrel',13  7: 'pubcomp',14  8: 'subscribe',15  9: 'suback',16  10: 'unsubscribe',17  11: 'unsuback',18  12: 'pingreq',19  13: 'pingresp',20  14: 'disconnect',21  15: 'auth'22}23 24/* Mnemonic => Command code */25protocol.codes = {}26for (const k in protocol.types) {27  const v = protocol.types[k]28  protocol.codes[v] = k29}30 31/* Header */32protocol.CMD_SHIFT = 433protocol.CMD_MASK = 0xF034protocol.DUP_MASK = 0x0835protocol.QOS_MASK = 0x0336protocol.QOS_SHIFT = 137protocol.RETAIN_MASK = 0x0138 39/* Length */40protocol.VARBYTEINT_MASK = 0x7F41protocol.VARBYTEINT_FIN_MASK = 0x8042protocol.VARBYTEINT_MAX = 26843545543 44/* Connack */45protocol.SESSIONPRESENT_MASK = 0x0146protocol.SESSIONPRESENT_HEADER = Buffer.from([protocol.SESSIONPRESENT_MASK])47protocol.CONNACK_HEADER = Buffer.from([protocol.codes.connack << protocol.CMD_SHIFT])48 49/* Connect */50protocol.USERNAME_MASK = 0x8051protocol.PASSWORD_MASK = 0x4052protocol.WILL_RETAIN_MASK = 0x2053protocol.WILL_QOS_MASK = 0x1854protocol.WILL_QOS_SHIFT = 355protocol.WILL_FLAG_MASK = 0x0456protocol.CLEAN_SESSION_MASK = 0x0257protocol.CONNECT_HEADER = Buffer.from([protocol.codes.connect << protocol.CMD_SHIFT])58 59/* Properties */60protocol.properties = {61  sessionExpiryInterval: 17,62  willDelayInterval: 24,63  receiveMaximum: 33,64  maximumPacketSize: 39,65  topicAliasMaximum: 34,66  requestResponseInformation: 25,67  requestProblemInformation: 23,68  userProperties: 38,69  authenticationMethod: 21,70  authenticationData: 22,71  payloadFormatIndicator: 1,72  messageExpiryInterval: 2,73  contentType: 3,74  responseTopic: 8,75  correlationData: 9,76  maximumQoS: 36,77  retainAvailable: 37,78  assignedClientIdentifier: 18,79  reasonString: 31,80  wildcardSubscriptionAvailable: 40,81  subscriptionIdentifiersAvailable: 41,82  sharedSubscriptionAvailable: 42,83  serverKeepAlive: 19,84  responseInformation: 26,85  serverReference: 28,86  topicAlias: 35,87  subscriptionIdentifier: 1188}89protocol.propertiesCodes = {}90for (const prop in protocol.properties) {91  const id = protocol.properties[prop]92  protocol.propertiesCodes[id] = prop93}94protocol.propertiesTypes = {95  sessionExpiryInterval: 'int32',96  willDelayInterval: 'int32',97  receiveMaximum: 'int16',98  maximumPacketSize: 'int32',99  topicAliasMaximum: 'int16',100  requestResponseInformation: 'byte',101  requestProblemInformation: 'byte',102  userProperties: 'pair',103  authenticationMethod: 'string',104  authenticationData: 'binary',105  payloadFormatIndicator: 'byte',106  messageExpiryInterval: 'int32',107  contentType: 'string',108  responseTopic: 'string',109  correlationData: 'binary',110  maximumQoS: 'int8',111  retainAvailable: 'byte',112  assignedClientIdentifier: 'string',113  reasonString: 'string',114  wildcardSubscriptionAvailable: 'byte',115  subscriptionIdentifiersAvailable: 'byte',116  sharedSubscriptionAvailable: 'byte',117  serverKeepAlive: 'int16',118  responseInformation: 'string',119  serverReference: 'string',120  topicAlias: 'int16',121  subscriptionIdentifier: 'var'122}123 124function genHeader (type) {125  return [0, 1, 2].map(qos => {126    return [0, 1].map(dup => {127      return [0, 1].map(retain => {128        const buf = Buffer.alloc(1)129        buf.writeUInt8(130          protocol.codes[type] << protocol.CMD_SHIFT |131          (dup ? protocol.DUP_MASK : 0) |132          qos << protocol.QOS_SHIFT | retain, 0, true)133        return buf134      })135    })136  })137}138 139/* Publish */140protocol.PUBLISH_HEADER = genHeader('publish')141 142/* Subscribe */143protocol.SUBSCRIBE_HEADER = genHeader('subscribe')144protocol.SUBSCRIBE_OPTIONS_QOS_MASK = 0x03145protocol.SUBSCRIBE_OPTIONS_NL_MASK = 0x01146protocol.SUBSCRIBE_OPTIONS_NL_SHIFT = 2147protocol.SUBSCRIBE_OPTIONS_RAP_MASK = 0x01148protocol.SUBSCRIBE_OPTIONS_RAP_SHIFT = 3149protocol.SUBSCRIBE_OPTIONS_RH_MASK = 0x03150protocol.SUBSCRIBE_OPTIONS_RH_SHIFT = 4151protocol.SUBSCRIBE_OPTIONS_RH = [0x00, 0x10, 0x20]152protocol.SUBSCRIBE_OPTIONS_NL = 0x04153protocol.SUBSCRIBE_OPTIONS_RAP = 0x08154protocol.SUBSCRIBE_OPTIONS_QOS = [0x00, 0x01, 0x02]155 156/* Unsubscribe */157protocol.UNSUBSCRIBE_HEADER = genHeader('unsubscribe')158 159/* Confirmations */160protocol.ACKS = {161  unsuback: genHeader('unsuback'),162  puback: genHeader('puback'),163  pubcomp: genHeader('pubcomp'),164  pubrel: genHeader('pubrel'),165  pubrec: genHeader('pubrec')166}167 168protocol.SUBACK_HEADER = Buffer.from([protocol.codes.suback << protocol.CMD_SHIFT])169 170/* Protocol versions */171protocol.VERSION3 = Buffer.from([3])172protocol.VERSION4 = Buffer.from([4])173protocol.VERSION5 = Buffer.from([5])174protocol.VERSION131 = Buffer.from([131])175protocol.VERSION132 = Buffer.from([132])176 177/* QoS */178protocol.QOS = [0, 1, 2].map(qos => {179  return Buffer.from([qos])180})181 182/* Empty packets */183protocol.EMPTY = {184  pingreq: Buffer.from([protocol.codes.pingreq << 4, 0]),185  pingresp: Buffer.from([protocol.codes.pingresp << 4, 0]),186  disconnect: Buffer.from([protocol.codes.disconnect << 4, 0])187}188