0.2.1

.github/workflows/release.yml

@@ -68,6 +68,8 @@ jobs:
           ref: 'develop'
       - name: install
         run: yarn
+      - name: build
+        run: yarn build
       - name: verify version
         run: |
           if [ "$(jq -r '.version' 'lerna.json')" != "${{ needs.details.outputs.title }}" ] ; then
@@ -120,7 +122,8 @@ jobs:
         run: |
           git fetch
           yarn lerna publish from-git --yes
-
+      - name: Verify
+        run: scripts/./verify ${{needs.details.outputs.title}}
 #      - name: patch
 #        run: |
 #          git config --global user.email "[email protected]"

lerna.json

@@ -2,5 +2,5 @@
   "npmClient": "yarn",
   "useWorkspaces": true,
   "packages": ["packages/*"],
-  "version": "0.2.0"
+  "version": "0.2.1"
 }

package.json

@@ -34,7 +34,7 @@
     "test-dom-env": "lerna run test-dom-env",
     "test-node-env": "lerna run test-node-env",
     "lint": "remark . --output && lerna run lint",
-    "version": "lerna version --no-push --force-publish",
+    "bumb": "lerna version --no-push --force-publish",
     "doc": "lerna run doc"
   },
   "author": "Scalecube (https://github.com/scalecube/scalecube-js)",

packages/api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/api",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "main": "lib/index.js",
   "module": "lib/index.js",

packages/browser/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/browser",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "unpkg": "dist/index.js",
   "main": "lib/index.js",
@@ -24,7 +24,7 @@
     "@babel/core": "^7.7.4",
     "@babel/plugin-transform-arrow-functions": "^7.7.4",
     "@babel/preset-env": "^7.7.4",
-    "@scalecube/api": "^0.2.0",
+    "@scalecube/api": "^0.2.1",
     "regenerator-runtime": "^0.13.3",
     "rollup": "^1.27.4",
     "rollup-plugin-babel": "^4.3.3",
@@ -41,11 +41,11 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/cluster-browser": "^0.2.0",
-    "@scalecube/routers": "^0.2.0",
-    "@scalecube/scalecube-microservice": "^0.2.0",
-    "@scalecube/transport-browser": "^0.2.0",
-    "@scalecube/utils": "^0.2.0",
+    "@scalecube/cluster-browser": "^0.2.1",
+    "@scalecube/routers": "^0.2.1",
+    "@scalecube/scalecube-microservice": "^0.2.1",
+    "@scalecube/transport-browser": "^0.2.1",
+    "@scalecube/utils": "^0.2.1",
     "rxjs": "^6.4.0"
   }
 }

packages/cluster-browser/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/cluster-browser",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "main": "cjs/index.js",
   "module": "es/index.js",
@@ -20,7 +20,7 @@
   },
   "author": "Scalecube (https://github.com/scalecube/scalecube-js)",
   "devDependencies": {
-    "@scalecube/api": "^0.2.0",
+    "@scalecube/api": "^0.2.1",
     "jest": "^24.6.0",
     "rollup": "^1.14.6",
     "rollup-plugin-filesize": "^6.1.1",
@@ -31,7 +31,7 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/utils": "^0.2.0",
+    "@scalecube/utils": "^0.2.1",
     "rxjs": "^6.4.0"
   }
 }

packages/cluster-nodejs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/cluster-nodejs",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "main": "lib/index.js",
   "module": "es/index.js",
@@ -20,7 +20,7 @@
   },
   "author": "Scalecube (https://github.com/scalecube/scalecube-js)",
   "devDependencies": {
-    "@scalecube/api": "^0.2.0",
+    "@scalecube/api": "^0.2.1",
     "jest": "^24.6.0",
     "rollup": "^1.14.6",
     "rollup-plugin-babel": "^4.3.3",
@@ -35,7 +35,7 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/utils": "^0.2.0",
+    "@scalecube/utils": "^0.2.1",
     "rxjs": "^6.4.0",
     "swim": "^0.6.0"
   }

packages/examples/Dockerfile

@@ -0,0 +1,17 @@
+# this docker is using us to verify published version
+FROM node:alpine
+RUN apk add python make g++
+COPY . /var/app
+WORKDIR /var/app
+ARG VERSION=next
+RUN yarn add \
+    @scalecube/browser@${VERSION} \
+    @scalecube/node@${VERSION} \
+    @scalecube/routers@${VERSION} \
+    @scalecube/transport-nodejs@${VERSION} \
+    @scalecube/utils@${VERSION} \
+    @scalecube/api@${VERSION}
+
+RUN yarn build
+
+CMD /bin/sh

packages/examples/k8s/package.json

@@ -5,6 +5,6 @@
   "license": "MIT",
   "private": false,
   "dependencies": {
-    "@scalecube/node": "^0.0.2-alpha.1584274445.3"
+    "@scalecube/node": "snapshot"
   }
 }

packages/examples/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/examples",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "rollup": "rollup/index.js",
   "license": "MIT",
@@ -22,7 +22,6 @@
     "@babel/plugin-transform-arrow-functions": "^7.7.4",
     "@babel/plugin-transform-async-to-generator": "^7.7.4",
     "@babel/preset-env": "^7.7.4",
-    "@scalecube/api": "^0.2.0",
     "jest": "^25.4.0",
     "npm-run-all": "^4.1.5",
     "parcel-bundler": "^1.12.3",
@@ -39,11 +38,12 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/browser": "^0.2.0",
-    "@scalecube/node": "^0.2.0",
-    "@scalecube/routers": "^0.2.0",
-    "@scalecube/transport-nodejs": "^0.2.0",
-    "@scalecube/utils": "^0.2.0"
+    "@scalecube/api": "^0.2.1",
+    "@scalecube/browser": "^0.2.1",
+    "@scalecube/node": "^0.2.1",
+    "@scalecube/routers": "^0.2.1",
+    "@scalecube/transport-nodejs": "^0.2.1",
+    "@scalecube/utils": "^0.2.1"
   },
   "browserslist": [
     "ie 11",

packages/examples/tests/greeting.spec.ts

@@ -19,9 +19,16 @@ describe('k8s', () => {
             });
             // The whole response has been received. Print out the result.
             resp.on('end', () => {
-              expect(data).toBe('"hello: test"');
-              execSync('/bin/bash -c "cd k8s && ./stop"', { stdio: 'inherit' });
-              done();
+              if (data === '"hello: test"') {
+                expect(data).toBe('"hello: test"');
+                execSync('/bin/bash -c "cd k8s && ./stop"', { stdio: 'inherit' });
+                done();
+              } else {
+                tries--;
+                if (tries <= 0) {
+                  expect(data).toBe('"hello: test"');
+                }
+              }
             });
             resp.on('error', (err: Error) => {
               throw Error('Service responded with error: ' + err.message);

packages/node/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/node",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "main": "lib/index.js",
   "types": "lib/index.d.ts",
@@ -18,7 +18,7 @@
   },
   "author": "Scalecube (https://github.com/scalecube/scalecube-js)",
   "devDependencies": {
-    "@scalecube/api": "^0.2.0",
+    "@scalecube/api": "^0.2.1",
     "rollup": "^1.27.4",
     "rollup-plugin-babel": "^4.3.3",
     "rollup-plugin-filesize": "^6.1.1",
@@ -28,11 +28,11 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/cluster-nodejs": "^0.2.0",
-    "@scalecube/routers": "^0.2.0",
-    "@scalecube/scalecube-microservice": "^0.2.0",
-    "@scalecube/transport-nodejs": "^0.2.0",
-    "@scalecube/utils": "^0.2.0",
+    "@scalecube/cluster-nodejs": "^0.2.1",
+    "@scalecube/routers": "^0.2.1",
+    "@scalecube/scalecube-microservice": "^0.2.1",
+    "@scalecube/transport-nodejs": "^0.2.1",
+    "@scalecube/utils": "^0.2.1",
     "rxjs": "^6.4.0"
   }
 }

packages/routers/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/routers",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "main": "cjs/index.js",
   "module": "es/index.js",
@@ -20,7 +20,7 @@
   },
   "author": "Scalecube (https://github.com/scalecube/scalecube-js)",
   "devDependencies": {
-    "@scalecube/api": "^0.2.0",
+    "@scalecube/api": "^0.2.1",
     "jest": "^24.6.0",
     "rollup": "^1.14.6",
     "rollup-plugin-filesize": "^6.1.1",
@@ -31,6 +31,6 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/utils": "^0.2.0"
+    "@scalecube/utils": "^0.2.1"
   }
 }

packages/rsocket-adapter/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/rsocket-adapter",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "main": "cjs/index.js",
   "module": "es/index.js",
@@ -20,7 +20,7 @@
   },
   "author": "Scalecube (https://github.com/scalecube/scalecube-js)",
   "devDependencies": {
-    "@scalecube/api": "^0.2.0",
+    "@scalecube/api": "^0.2.1",
     "jest": "^24.6.0",
     "rollup": "^1.14.6",
     "rollup-plugin-commonjs": "^10.0.1",
@@ -32,7 +32,7 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/utils": "^0.2.0",
+    "@scalecube/utils": "^0.2.1",
     "rsocket-core": "^0.0.16",
     "rsocket-flowable": "^0.0.14",
     "rsocket-types": "^0.0.16",

packages/rsocket-ws-gateway/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scalecube/rsocket-ws-gateway",
-  "version": "0.2.0",
+  "version": "0.2.1",
   "private": false,
   "main": "lib/index.js",
   "types": "lib/index.d.ts",
@@ -21,8 +21,8 @@
   },
   "author": "Scalecube (https://github.com/scalecube/scalecube-js)",
   "devDependencies": {
-    "@scalecube/api": "^0.2.0",
-    "@scalecube/browser": "^0.2.0",
+    "@scalecube/api": "^0.2.1",
+    "@scalecube/browser": "^0.2.1",
     "jest": "^24.6.0",
     "rollup": "^1.14.6",
     "rollup-plugin-babel": "^4.3.3",
@@ -35,7 +35,7 @@
     "typescript": "^3.2.4"
   },
   "dependencies": {
-    "@scalecube/utils": "^0.2.0",
+    "@scalecube/utils": "^0.2.1",
     "rsocket-core": "^0.0.16",
     "rsocket-flowable": "^0.0.14",
     "rsocket-websocket-client": "^0.0.16",

packages/rsocket-ws-gateway/src/createGatewayProxy.ts

@@ -8,23 +8,31 @@ interface Proxy {
   [state: string]: any;
 }
 
+type ConnectionOptions = Partial<{
+  keepAlive: number;
+  lifetime: number;
+}>
+
 export function createGatewayProxy(
   url: string,
   definition: MicroserviceApi.ServiceDefinition,
   requestResponse?: any,
-  requestStream?: any
+  requestStream?: any,
+  options?: ConnectionOptions
 ): Promise<Proxy>;
 export function createGatewayProxy(
   url: string,
   definition: MicroserviceApi.ServiceDefinition[],
   requestResponse?: any,
-  requestStream?: any
+  requestStream?: any,
+  options?: ConnectionOptions
 ): Promise<Proxy[]>;
 export function createGatewayProxy(
   url: string,
   definitions: any,
   customRequestResponse?: any,
-  customRequestStream?: any
+  customRequestStream?: any,
+  options?: ConnectionOptions
 ): any {
   const isDefinitionsArray = Array.isArray(definitions);
   let defs: MicroserviceApi.ServiceDefinition[];
@@ -36,7 +44,7 @@ export function createGatewayProxy(
   const proxies: Proxy[] = [];
   let socket;
   return new Promise(async (resolve, reject) => {
-    socket = await connect(url).catch((e) => {
+    socket = await connect(url, options).catch((e) => {
       reject(e);
     });
 
@@ -67,14 +75,14 @@ export function createGatewayProxy(
   });
 }
 
-const connect = (url) => {
+const connect = (url, options: ConnectionOptions = {}) => {
   return new Promise((resolve, reject) => {
     const client = new RSocketClient({
       serializers: JsonSerializers,
       setup: {
         dataMimeType: 'application/json',
-        keepAlive: 100000,
-        lifetime: 100000,
+        keepAlive: options.keepAlive || 100000,
+        lifetime: options.lifetime || 100000,
         metadataMimeType: 'application/json',
       },
       transport: new RSocketWebSocketClient({ url }),