Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
const flags =
MqttConnectFlag.User |
MqttConnectFlag.Pass |
MqttConnectFlag.Clr |
MqttConnectFlag.QoS1
const message = new MqttMessage(MessageType.Connect)
.setFlags(MqttMessageFlag.QoS0)
.writeString('MQTToT')
.writeU8(3)
.writeU8(flags)
.writeU16(60) // KEEP ALIVE
.writeRaw(zlib.deflateSync(d))
resolve(message)
}
const proto = new TCompactProtocol(trans) as any
// Write client id
proto.lastFieldId_ = 0
proto.writeFieldBegin('none', Thrift.Type.STRING, 1)
proto.writeString(deviceId.clientId)
proto.lastFieldId_ = 1
proto.writeFieldBegin('none', Thrift.Type.STRUCT, 4)
// Write user id
proto.lastFieldId_ = 0
proto.writeFieldBegin('none', Thrift.Type.I64, 1)
proto.writeI64(tokens.uid)
// Write information
proto.lastFieldId_ = 1
proto.writeFieldBegin('none', Thrift.Type.STRING, 2)
function parse(buffer, type) {
var transport = new thrift.TFramedTransport(buffer)
var protocol = new thrift.TCompactProtocol(transport)
type.read(protocol)
module.exports.bytes = parse.bytes = protocol.trans.readPos
return type
}
function encode(value) {
var output = []
var transport = new thrift.TBufferedTransport(null, function (buf) {
output.push(buf)
})
var protocol = new thrift.TCompactProtocol(transport)
value.write(protocol)
transport.flush()
return Buffer.concat(output)
}
exports.serializeThrift = function(obj) {
let output = []
let transport = new thrift.TBufferedTransport(null, function (buf) {
output.push(buf)
})
let protocol = new thrift.TCompactProtocol(transport)
obj.write(protocol)
transport.flush()
return Buffer.concat(output)
}
return new Promise((resolve, reject) => {
const trans = new TBufferedTransport(null, (msg, seqid) => {
resolve(msg)
})
const proto = new TCompactProtocol(trans)
payload.encode(proto)
proto.flush()
})
}
exports.decodeThrift = function(obj, buf, offset) {
if (!offset) {
offset = 0;
}
var transport = new thrift.TFramedTransport(buf);
transport.readPos = offset;
var protocol = new thrift.TCompactProtocol(transport);
obj.read(protocol);
return transport.readPos - offset;
}
this.writeData = TBufferedTransport.receiver(trans => {
this.bufferedTransport = trans
this.proto = new TCompactProtocol(trans)
}, 0)
})