@aws-amplify/pubsub - npm Package Compare versions

Comparing version 1.0.33-unstable.6 to 1.0.33-unstable.7

lib/Providers/MqttOverWSProvider.d.ts

@@ -21,2 +21,3 @@ import * as Observable from 'zen-observable';
     protected readonly clientsQueue: ClientsQueue;
+    protected readonly isSSLEnabled: boolean;
     protected getTopicForValue(value: any): any;
@@ -23,0 +24,0 @@ getProviderName(): string;

lib/Providers/MqttOverWSProvider.js

@@ -151,2 +151,9 @@ "use strict";
     });
+    Object.defineProperty(MqttOverWSProvider.prototype, "isSSLEnabled", {
+        get: function () {
+            return !this.options.aws_appsync_dangerously_connect_to_http_endpoint_for_testing;
+        },
+        enumerable: true,
+        configurable: true
+    });
     MqttOverWSProvider.prototype.getTopicForValue = function (value) { return typeof value === 'object' && value[topicSymbol]; };
@@ -181,3 +188,3 @@ MqttOverWSProvider.prototype.getProviderName = function () { return 'MqttOverWSProvider'; };
                                 client.connect({
-                                    useSSL: true,
+                                    useSSL: _this.isSSLEnabled,
                                     mqttVersion: 3,
@@ -184,0 +191,0 @@ onSuccess: function () { return resolve(client); },

lib/PubSub.js

@@ -74,3 +74,3 @@ "use strict";
             if (!this._awsAppSyncProvider) {
-                this._awsAppSyncProvider = new Providers_1.AWSAppSyncProvider();
+                this._awsAppSyncProvider = new Providers_1.AWSAppSyncProvider(this._options);
             }
@@ -77,0 +77,0 @@ return this._awsAppSyncProvider;

package.json

 {
   "name": "@aws-amplify/pubsub",
-  "version": "1.0.33-unstable.6+c3c1e68e",
+  "version": "1.0.33-unstable.7+4390e8ed",
   "description": "Pubsub category of aws-amplify",
@@ -53,3 +53,3 @@ "main": "./lib/index.js",
   "dependencies": {
-    "@aws-amplify/core": "1.0.32-unstable.6+c3c1e68e",
+    "@aws-amplify/core": "1.0.32-unstable.7+4390e8ed",
     "uuid": "^3.2.1",
@@ -84,3 +84,3 @@ "zen-observable": "^0.8.6"
   },
-  "gitHead": "c3c1e68ea4783a4f6ea475f3733edb9cd3413e58"
+  "gitHead": "4390e8edd24027af42ce4717ec116af8ddb9b2fc"
 }

src/Providers/MqttOverWSProvider.ts

@@ -81,2 +81,6 @@ /*
 
+    protected get isSSLEnabled() {
+        return !this.options.aws_appsync_dangerously_connect_to_http_endpoint_for_testing;
+    }
+    
     protected getTopicForValue(value) { return typeof value === 'object' && value[topicSymbol]; }
@@ -103,6 +107,6 @@
         };
-
+        
         await new Promise((resolve, reject) => {
             client.connect({
-                useSSL: true,
+                useSSL: this.isSSLEnabled,
                 mqttVersion: 3,
@@ -109,0 +113,0 @@ onSuccess: () => resolve(client),

src/PubSub.ts

@@ -39,3 +39,3 @@ /*
         if (!this._awsAppSyncProvider) {
-            this._awsAppSyncProvider = new AWSAppSyncProvider();
+            this._awsAppSyncProvider = new AWSAppSyncProvider(this._options);
         }
@@ -42,0 +42,0 @@ return this._awsAppSyncProvider;

New alerts

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Fixed alerts

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

5000571

increased by0.06%

Lines of code

30312

increased by0.07%

Worsened metrics

Published versions last year

358

decreased by-0.28%

Dependency changes

• Updated@aws-amplify/core@1.0.32-unstable.7+4390e8ed