Merge pull request #20 from kalm/v3.2.0

V3.2.0

Author: fed135

.eslintignore

@@ -1,3 +1,4 @@
-**/*.min.js
+*.js
 examples
-node_modules
+node_modules
+scripts

.eslintrc

@@ -6,7 +6,7 @@
       "import/resolver": {
         "node": {
           "paths": ["packages"],
-          "extensions": [".js", ".json", ".ts"]
+          "extensions": [".ts", ".spec.ts"]
         }
       }
     },
@@ -17,6 +17,12 @@
         "object-curly-newline": 0,
         "no-plusplus": 0,
         "no-unused-expressions": 0,
+        "guard-for-in": 0,
+        "no-mixed-operators": 0,
+        "no-param-reassign": 0,
+        "arrow-parens": [2, "as-needed"],
+        "import/prefer-default-export": 0,
+        "no-continue": 0,
         "no-unused-vars": 0,
         "global-require": 0,
         "@typescript-eslint/no-unused-vars": [
@@ -27,7 +33,7 @@
     },
     "env": {
         "browser": true,
-        "mocha": true,
+        "jest": true,
         "node": true
     }
 }

.gitignore

@@ -41,4 +41,18 @@ NTH
 docs
 yarn.lock
 package-lock.json
-.vscode
+.vscode
+
+# built code
+packages/kalm/bin
+packages/ipc/bin
+packages/tcp/bin
+packages/udp/bin
+packages/ws/bin
+
+# built types reference
+packages/kalm/types.d.ts
+packages/ipc/types.d.ts
+packages/tcp/types.d.ts
+packages/udp/types.d.ts
+packages/ws/types.d.ts

.npmignore

@@ -9,4 +9,5 @@ tslint.json
 package-lock.json
 yarn.lock
 .vscode
-.github
+.github
+jest.config.js

.travis.yml

@@ -1,15 +1,16 @@
 language: node_js
 cache: yarn
 node_js:
+  - "12"
   - "10"
-  - "8"
 script:
   - yarn run lint
   - yarn run test
+  - yarn run build
   - yarn run bench
 sudo: false
 install: 
   - yarn
 before_install:
-  - npm install yarn@^1.13.0
+  - npm install yarn@^1.19.0
   - yarn --version

examples/chat/client.js examples/chat_websocket/client.jsexamples/chat/client.js renamed to examples/chat_websocket/client.js

@@ -1,5 +1,6 @@
 const kalm = require('kalm');
 const ws = require('@kalm/ws');
+
 const { randomBytes } = require('crypto');
 
 const Client = kalm.connect({
@@ -10,8 +11,8 @@ const Client = kalm.connect({
   routine: kalm.routines.realtime(),
 });
 
-Client.subscribe('r.evt', (evt, frame) => console.log(`${evt.name}: ${evt.msg}`, frame));
-Client.subscribe('r.sys', (evt, frame) => console.log(`[System]: ${evt.msg}`, frame));
+Client.subscribe('r.evt', (body, frame) => console.log(`${body.name}: ${body.msg}`, frame));
+Client.subscribe('r.sys', (body, frame) => console.log(`[System]: ${body.msg}`, frame));
 
 Client.on('connect', () => {
   Client.write('c.evt', { name: Client.label, msg: 'Hey everyone!' });

examples/chat/server.js examples/chat_websocket/server.jsexamples/chat/server.js renamed to examples/chat_websocket/server.js

@@ -10,8 +10,8 @@ const Server = kalm.listen({
 });
 
 Server.on('connection', (client) => {
-  client.subscribe('c.evt', (msg, evt) => {
-    Server.broadcast('r.evt', msg);
+  client.subscribe('c.evt', (body, frame) => {
+    Server.broadcast('r.evt', body);
   });
 
   Server.broadcast('r.sys', { msg: 'user joined' });

examples/compression/client.js

@@ -0,0 +1,23 @@
+const kalm = require('kalm');
+const ws = require('@kalm/ws');
+const snappy = require('snappy');
+
+const Client = kalm.connect({
+  transport: ws(),
+  port: 3938,
+  json: false,
+  routine: kalm.routines.realtime(),
+});
+
+Client.subscribe('foo', (body, frame) => {
+  snappy.uncompress(body, (decompressedMessage) => {
+    console.log('Server event', decompressedMessage, frame);
+  });
+});
+
+const payload = {
+  foo: 'bar',
+  message: 'hello from the client!',
+};
+
+Client.write('foo', snappy.compressSync(Buffer.from(JSON.stringify(payload))));

examples/compression/server.js

@@ -0,0 +1,27 @@
+const kalm = require('kalm');
+const ws = require('@kalm/ws');
+const snappy = require('snappy');
+
+const provider = kalm.listen({
+  label: 'internal',
+  transport: ws(),
+  port: 3000,
+  json: false,
+  routine: kalm.routines.realtime(),
+  host: '0.0.0.0', // Apply local ip
+});
+
+provider.on('connection', (client) => {
+  client.subscribe('foo', (body, frame) => {
+    snappy.uncompress(body, (decompressedMessage) => {
+      console.log('Client event', decompressedMessage, frame);
+    });
+  });
+
+  const payload = {
+    foo: 'bar',
+    message: 'hello from the server!',
+  };
+  
+  client.write('foo', snappy.compressSync(Buffer.from(JSON.stringify(payload))));
+});

examples/distributed_pub_sub/client.js

@@ -11,8 +11,8 @@ const Client = kalm.connect({
   routine: kalm.routines.realtime(),
 });
 
-Client.subscribe('r.evt', (evt, frame) => {
-  console.log('Relayed event', evt, frame);
+Client.subscribe('r.evt', (body, frame) => {
+  console.log('Relayed event', body, frame);
 });
 
 // now send some events