mqtts - npm Package Compare versions

Comparing version 1.0.0-alpha.0 to 1.0.0-alpha.1

dist/mqtt.client.d.ts

@@ -6,6 +6,5 @@ /// <reference types="node" />
 import { Transport } from './transport';
-import { ConnectRequestOptions, SubscribeReturnCode } from './packets';
+import { ConnectRequestOptions, ConnectResponsePacket, DefaultPacketReadResultMap, DefaultPacketWriteOptions, PacketReadResultMap, PacketWriteOptionsMap, PacketWriter, PublishRequestPacket, SubscribeReturnCode } from './packets';
 import { MqttMessageOutgoing } from './mqtt.message';
 import { Writable } from 'stream';
-import { DefaultPacketReadResultMap, PacketReadResultMap, DefaultPacketWriteOptions, PacketWriteOptionsMap, PacketWriter } from './packets';
 import { PacketType } from './mqtt.constants';
@@ -57,2 +56,4 @@ import { MqttBaseClient } from './mqtt.base-client';
     protected handlePacket(packet: MqttParseResult<ReadMap, PacketType>): Promise<void>;
+    protected onConnAck(connAck: ConnectResponsePacket): void;
+    protected onPublish(publish: PublishRequestPacket): void;
     protected logReceivedPacket(packet: {
@@ -59,0 +60,0 @@ type: PacketType;

dist/mqtt.client.js

@@ -7,10 +7,10 @@ "use strict";
 const transport_1 = require("./transport");
+const packets_1 = require("./packets");
 const errors_1 = require("./errors");
 const stream_1 = require("stream");
-const packets_1 = require("./packets");
 const mqtt_constants_1 = require("./mqtt.constants");
-const debug = require("debug");
 const mqtt_base_client_1 = require("./mqtt.base-client");
 const mqtt_listener_1 = require("./mqtt.listener");
 const mqtt_utilities_1 = require("./mqtt.utilities");
+const debug = require("debug");
 class MqttClient extends mqtt_base_client_1.MqttBaseClient {
@@ -224,40 +224,15 @@ constructor(options) {
     async handlePacket(packet) {
-        var _a, _b;
         this.logReceivedPacket(packet);
         let forceCheckFlows = false;
+        // The following "type assertions" are valid as clients extending MqttClient have to implement their own methods
         switch (packet.type) {
             case mqtt_constants_1.PacketType.ConnAck: {
-                const connack = packet;
-                if (connack.data.isSuccess) {
-                    this.setReady();
-                    this.emitConnect(connack.data);
-                    if ((_a = this.connectOptions) === null || _a === void 0 ? void 0 : _a.keepAlive) {
-                        this.updateKeepAlive(this.connectOptions.keepAlive);
-                    }
-                }
-                else {
-                    this.setFatal();
-                    this.emitError(new errors_1.ConnectError(connack.data.errorName));
-                    this.setDisconnected(connack.data.errorName).catch(e => this.emitWarning(e));
-                }
+                this.onConnAck(packet.data);
                 break;
             }
             case mqtt_constants_1.PacketType.Publish: {
-                const pub = packet.data;
-                this.startFlow(flow_1.incomingPublishFlow({
-                    topic: pub.topic,
-                    payload: pub.payload,
-                    qosLevel: pub.qos,
-                    retained: pub.retain,
-                    duplicate: pub.duplicate,
-                }, (_b = pub.identifier) !== null && _b !== void 0 ? _b : undefined))
-                    .then(async (m) => {
-                    this.emitMessage(m);
-                    await this.messageListener.handleMessage(m);
-                })
-                    .catch(e => this.emitWarning(e));
+                this.onPublish(packet.data);
                 break;
             }
             case mqtt_constants_1.PacketType.Disconnect: {
-                // ? this.disconnect();
                 this.setDisconnected('disconnect packet received').catch(e => this.emitWarning(e));
@@ -273,2 +248,32 @@ break;
     }
+    onConnAck(connAck) {
+        var _a;
+        if (connAck.isSuccess) {
+            this.setReady();
+            this.emitConnect(connAck);
+            if ((_a = this.connectOptions) === null || _a === void 0 ? void 0 : _a.keepAlive) {
+                this.updateKeepAlive(this.connectOptions.keepAlive);
+            }
+        }
+        else {
+            this.setFatal();
+            this.emitError(new errors_1.ConnectError(connAck.errorName));
+            this.setDisconnected(connAck.errorName).catch(e => this.emitWarning(e));
+        }
+    }
+    onPublish(publish) {
+        var _a;
+        this.startFlow(flow_1.incomingPublishFlow({
+            topic: publish.topic,
+            payload: publish.payload,
+            qosLevel: publish.qos,
+            retained: publish.retain,
+            duplicate: publish.duplicate,
+        }, (_a = publish.identifier) !== null && _a !== void 0 ? _a : undefined))
+            .then(async (m) => {
+            this.emitMessage(m);
+            await this.messageListener.handleMessage(m);
+        })
+            .catch(e => this.emitWarning(e));
+    }
     logReceivedPacket(packet) {
@@ -303,3 +308,3 @@ if (packet.type !== mqtt_constants_1.PacketType.PingReq && packet.type !== mqtt_constants_1.PacketType.PingResp)
         super.setDisconnected();
-        this.emitDisconnect(reason);
+        this.emitDisconnect(`reason: ${reason} willReconnect: ${willReconnect}`);
         if (!this.transport.duplex.destroyed) {
@@ -306,0 +311,0 @@ await new Promise(resolve => this.transport.duplex.end(resolve));

package.json

 {
   "name": "mqtts",
-  "version": "1.0.0-alpha.0",
+  "version": "1.0.0-alpha.1",
   "description": "MQTT client in Typescript",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

158826

increased by0.14%

Lines of code

2350

increased by0.26%

Number of medium supply chain risk alerts

3

decreased by-25%

No dependency changes