pubrel.ts•816 B
import { IPubcompPacket, IPublishPacket, IPubrelPacket } from 'mqtt-packet'
import { PacketHandler } from '../shared'
const handlePubrel: PacketHandler = (client, packet: IPubrelPacket, done) => {
client.log('handling pubrel packet')
const callback = typeof done !== 'undefined' ? done : client.noop
const { messageId } = packet
const comp: IPubcompPacket = { cmd: 'pubcomp', messageId }
client.incomingStore.get(packet, (err, pub: IPublishPacket) => {
if (!err) {
client.emit('message', pub.topic, pub.payload as Buffer, pub)
client.handleMessage(pub, (err2) => {
if (err2) {
return callback(err2)
}
client.incomingStore.del(pub, client.noop)
client['_sendPacket'](comp, callback)
})
} else {
client['_sendPacket'](comp, callback)
}
})
}
export default handlePubrel