Test_Pass_vs_Fails
100 removals
| Words removed | 473 |
| Total words | 802 |
| Words removed (%) | 58.98 |
179 lines
9 additions
| Words added | 11 |
| Total words | 340 |
| Words added (%) | 3.24 |
88 lines
--PASS--
--FAIL--
MqttClient :: version: 5.9.1
MqttClient :: version: 5.9.1
MqttClient :: environment node
MqttClient :: environment node
MqttClient :: options.protocol mqtt
MqttClient :: options.protocol mqtt
MqttClient :: options.protocolVersion 5
MqttClient :: options.protocolVersion 5
MqttClient :: options.username undefined
MqttClient :: options.username undefined
MqttClient :: options.keepalive 3
MqttClient :: options.keepalive 3
MqttClient :: options.reconnectPeriod 1000
MqttClient :: options.reconnectPeriod 1000
MqttClient :: options.rejectUnauthorized undefined
MqttClient :: options.rejectUnauthorized undefined
MqttClient :: options.properties.topicAliasMaximum undefined
MqttClient :: options.properties.topicAliasMaximum undefined
MqttClient :: clientId mqttjs_a5a072a9
MqttClient :: clientId mqttjs_3f49590c
MqttClient :: setting up stream
MqttClient :: setting up stream
connect :: calling method to clear reconnect
connect :: calling method to clear reconnect
_clearReconnect : clearing reconnect timer
_clearReconnect : clearing reconnect timer
connect :: using streamBuilder provided to client to create stream
connect :: using streamBuilder provided to client to create stream
connect :: pipe stream to writable stream
connect :: pipe stream to writable stream
connect: sending packet `connect`
connect: sending packet `connect`
_writePacket :: packet: {
_writePacket :: packet: {
cmd: 'connect',
cmd: 'connect',
protocolId: 'MQTT',
protocolId: 'MQTT',
protocolVersion: 5,
protocolVersion: 5,
clean: true,
clean: true,
clientId: 'mqttjs_a5a072a9',
clientId: 'mqttjs_3f49590c',
keepalive: 3,
keepalive: 3,
username: undefined,
username: undefined,
password: undefined,
password: undefined,
properties: { maximumPacketSize: 200 }
properties: { maximumPacketSize: 200 }
}
}
_writePacket :: emitting `packetsend`
_writePacket :: emitting `packetsend`
_writePacket :: writing to stream
_writePacket :: writing to stream
_writePacket :: writeToStream result true
_writePacket :: writeToStream result true
writable stream :: parsing buffer
writable stream :: parsing buffer
parser :: on packet push to packets array.
parser :: on packet push to packets array.
work :: getting next packet in queue
work :: getting next packet in queue
work :: packet pulled from queue
work :: packet pulled from queue
_handlePacket :: emitting packetreceive
_handlePacket :: emitting packetreceive
_handleConnack
_handleConnack
_setupKeepaliveManager :: keepalive 3 (seconds)
_setupKeepaliveManager :: keepalive 3 (seconds)
KeepaliveManager: set keepalive to 3000ms
KeepaliveManager: set keepalive to 3000ms
connect :: sending queued packets
connect :: sending queued packets
deliver :: entry undefined
deliver :: entry undefined
_resubscribe
_resubscribe
publish :: message `bar` to topic `foo`
publish :: message `bar` to topic `foo`
publish :: qos 1
publish :: qos 1
MqttClient:publish: packet cmd: publish
MqttClient:publish: packet cmd: publish
_sendPacket :: (mqttjs_a5a072a9) :: start
_sendPacket :: (mqttjs_3f49590c) :: start
storeAndSend :: store packet with cmd publish to outgoingStore
storeAndSend :: store packet with cmd publish to outgoingStore
_removeTopicAliasAndRecoverTopicName :: alias NaN, topic 'foo'
_removeTopicAliasAndRecoverTopicName :: alias NaN, topic 'foo'
noop :: undefined
noop :: undefined
_writePacket :: packet: {
_writePacket :: packet: {
cmd: 'publish',
cmd: 'publish',
topic: 'foo',
topic: 'foo',
payload: 'bar',
payload: 'bar',
qos: 1,
qos: 1,
retain: false,
retain: false,
messageId: 2938,
messageId: 11176,
dup: false,
dup: false,
properties: undefined
properties: undefined
}
}
_writePacket :: emitting `packetsend`
_writePacket :: emitting `packetsend`
_writePacket :: writing to stream
_writePacket :: writing to stream
_writePacket :: writeToStream result true
_writePacket :: writeToStream result true
_writePacket :: invoking cb
_writePacket :: invoking cb
noop :: undefined
noop :: undefined
_sendPacket :: (mqttjs_a5a072a9) :: end
_sendPacket :: (mqttjs_3f49590c) :: end
publish :: message `bar` to topic `foo`
publish :: message `bar` to topic `foo`
publish :: qos 1
publish :: qos 1
MqttClient:publish: packet cmd: publish
MqttClient:publish: packet cmd: publish
_sendPacket :: (mqttjs_a5a072a9) :: start
_sendPacket :: (mqttjs_3f49590c) :: start
storeAndSend :: store packet with cmd publish to outgoingStore
storeAndSend :: store packet with cmd publish to outgoingStore
_removeTopicAliasAndRecoverTopicName :: alias NaN, topic 'foo'
_removeTopicAliasAndRecoverTopicName :: alias NaN, topic 'foo'
noop :: undefined
noop :: undefined
_writePacket :: packet: {
_writePacket :: packet: {
cmd: 'publish',
cmd: 'publish',
topic: 'foo',
topic: 'foo',
payload: 'bar',
payload: 'bar',
qos: 1,
qos: 1,
retain: false,
retain: false,
messageId: 2939,
messageId: 11177,
dup: false,
dup: false,
properties: undefined
properties: undefined
}
}
_writePacket :: emitting `packetsend`
_writePacket :: emitting `packetsend`
_writePacket :: writing to stream
_writePacket :: writing to stream
_writePacket :: writeToStream result true
_writePacket :: writeToStream result true
_writePacket :: invoking cb
_writePacket :: invoking cb
noop :: undefined
noop :: undefined
_sendPacket :: (mqttjs_a5a072a9) :: end
_sendPacket :: (mqttjs_3f49590c) :: end
writable stream :: parsing buffer
parser :: on packet push to packets array.
parser :: on packet push to packets array.
work :: getting next packet in queue
work :: packet pulled from queue
_handlePacket :: emitting packetreceive
_handleAck :: packet type puback
noop :: null
_sendPing :: sending pingreq
_sendPacket :: (mqttjs_a5a072a9) :: start
_writePacket :: packet: { cmd: 'pingreq' }
_writePacket :: emitting `packetsend`
_writePacket :: writing to stream
_writePacket :: writeToStream result true
_writePacket :: invoking cb
noop :: undefined
work :: getting next packet in queue
work :: packet pulled from queue
_handlePacket :: emitting packetreceive
_handleAck :: packet type puback
noop :: null
onKeepaliveTimeout :: calling _cleanUp with force true
_cleanUp :: forced? true
_cleanUp :: (mqttjs_a5a072a9) :: destroying stream
_cleanUp :: client not disconnecting/reconnecting. Clearing and resetting reconnect.
_clearReconnect : clearing reconnect timer
_setupReconnect :: emit `offline` state
_setupReconnect :: set `reconnecting` to `true`
_setupReconnect :: setting reconnectTimer for 1000 ms
_destroyKeepaliveManager :: destroying keepalive manager
reconnectTimer :: reconnect triggered!
_reconnect: emitting reconnect to client
end :: (mqttjs_a5a072a9)
end :: cb? true
_clearReconnect : clearing reconnect timer
end :: (mqttjs_a5a072a9) :: immediately calling finish
end :: (mqttjs_a5a072a9) :: finish :: calling _cleanUp with force false
_cleanUp :: done callback provided for on stream close
_cleanUp :: forced? false
_cleanUp :: (mqttjs_a5a072a9) :: call _sendPacket with disconnect packet
_sendPacket :: (mqttjs_a5a072a9) :: start
_writePacket :: packet: { cmd: 'disconnect' }
_writePacket :: emitting `packetsend`
_writePacket :: writing to stream
_writePacket :: writeToStream result true
_writePacket :: invoking cb
_cleanUp :: (mqttjs_a5a072a9) :: destroying stream
client already connected. disconnecting first.
end :: (mqttjs_a5a072a9)
end :: cb? true
end :: (mqttjs_a5a072a9)
end :: cb? true
(mqttjs_a5a072a9)stream :: on close
_flushVolatile :: deleting volatile messages from the queue and setting their callbacks as error function
stream: emit close to MqttClient
close :: connected set to `false`
close :: clearing connackTimer
close :: calling _setupReconnect
_setupReconnect :: doing nothing...
end :: finish :: calling process.nextTick on closeStores
end :: closeStores: closing incoming and outgoing stores
end :: closeStores: emitting end
end :: closeStores: invoking callback with args
connect :: calling method to clear reconnect
_clearReconnect : clearing reconnect timer
connect :: using streamBuilder provided to client to create stream
connect :: pipe stream to writable stream
connect: sending packet `connect`
_writePacket :: packet: {
cmd: 'connect',
protocolId: 'MQTT',
protocolVersion: 5,
clean: true,
clientId: 'mqttjs_a5a072a9',
keepalive: 3,
username: undefined,
password: undefined,
properties: { maximumPacketSize: 200 }
}
_writePacket :: emitting `packetsend`
_writePacket :: writing to stream
_writePacket :: writeToStream result true
writable stream :: parsing buffer
parser :: on packet push to packets array.
work :: getting next packet in queue
work :: packet pulled from queue
_handlePacket :: emitting packetreceive
_handleConnack
connect :: sending queued packets
deliver :: entry undefined
_resubscribe