@scalecube/transport-browser - npm Package Compare versions

Comparing version 0.2.10-snapshot.feature-bugfix-api-missing-rxjs.1596043949 to 0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838

cjs/index.d.ts

@@ -1,7 +0,2 @@
-export declare const transport: {
-    clientTransport: {
-        start: (options: import("@scalecube/api/lib/transport").ClientTransportOptions) => Promise<import("@scalecube/api/lib/transport").RequestHandler>;
-        destroy: import("@scalecube/api/lib/transport").TDestroy;
-    };
-    serverTransport: import("@scalecube/api/lib/transport").ServerTransport;
-};
+import { TransportApi } from '@scalecube/api';
+export declare const transport: TransportApi.Transport;

es/index.d.ts

@@ -1,7 +0,2 @@
-export declare const transport: {
-    clientTransport: {
-        start: (options: import("@scalecube/api/lib/transport").ClientTransportOptions) => Promise<import("@scalecube/api/lib/transport").RequestHandler>;
-        destroy: import("@scalecube/api/lib/transport").TDestroy;
-    };
-    serverTransport: import("@scalecube/api/lib/transport").ServerTransport;
-};
+import { TransportApi } from '@scalecube/api';
+export declare const transport: TransportApi.Transport;

es/index.js

@@ -1,6 +0,22 @@
-import { setupServer, setupClient } from '@scalecube/rsocket-adapter';
-import { clientProvider, serverProvider } from './Provider/Provider';
-export var transport = {
-    clientTransport: setupClient(clientProvider),
-    serverTransport: setupServer(serverProvider),
-};
+import { createClient, createServer } from './connection';
+import { getFullAddress } from '@scalecube/utils';
+function createTransport() {
+    var client = createClient();
+    return {
+        clientTransport: {
+            start: function (options) {
+                return Promise.resolve({
+                    requestResponse: function (message) { return client.requestResponse(getFullAddress(options.remoteAddress), message); },
+                    requestStream: function (message) { return client.requestStream(getFullAddress(options.remoteAddress), message); },
+                });
+            },
+            destroy: function (options) {
+                client.shutdown(options.address);
+            },
+        },
+        serverTransport: function (options) {
+            return createServer(getFullAddress(options.localAddress), options.serviceCall);
+        },
+    };
+}
+export var transport = createTransport();

package.json

 {
   "name": "@scalecube/transport-browser",
-  "version": "0.2.10-snapshot.feature-bugfix-api-missing-rxjs.1596043949",
+  "version": "0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838",
   "private": false,
@@ -34,10 +34,11 @@ "main": "cjs/index.js",
   "dependencies": {
-    "@scalecube/api": "^0.2.10-snapshot.feature-bugfix-api-missing-rxjs.1596043949",
-    "@scalecube/rsocket-adapter": "^0.2.10-snapshot.feature-bugfix-api-missing-rxjs.1596043949",
-    "@scalecube/utils": "^0.2.10-snapshot.feature-bugfix-api-missing-rxjs.1596043949",
+    "@scalecube/api": "^0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838",
+    "@scalecube/rsocket-adapter": "^0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838",
+    "@scalecube/utils": "^0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838",
     "rsocket-core": "^0.0.16",
     "rsocket-events-client": "^0.0.22",
-    "rsocket-events-server": "^0.0.22"
+    "rsocket-events-server": "^0.0.22",
+    "rxjs": "^6.4.0"
   },
-  "gitHead": "02d2e49f02c790f8a71d5df2e08cb8e7eff29be8"
+  "gitHead": "1750715800d01cd61336c95439473ccdcdaa465a"
 }

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

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

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

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Number of low supply chain risk alerts

1

decreased by-80%

Worsened metrics

Total package byte prevSize

93074

decreased by-59.93%

Dependency count

7

increased by16.67%

Number of package files

10

decreased by-37.5%

Lines of code

2051

decreased by-60.98%

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• + Addedrxjs@^6.4.0

• Updated@scalecube/api@^0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838

• Updated@scalecube/rsocket-adapter@^0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838

• Updated@scalecube/utils@^0.2.10-snapshot.feature-bugfix-createGatewayProxy-unsubscribe-streams.1601511838