1.0.101

fix(core): update
1.0.100
2020-09-29 19:39:13 +00:00 · 2020-09-29 19:39:13 +00:00 · 2020-09-24 18:17:53 +00:00 · 2020-09-24 18:17:52 +00:00
23 changed files with 243 additions and 174 deletions
--- a/.gitignore
+++ b/.gitignore
@ -15,8 +15,6 @@ node_modules/

 # builds
 dist/
-dist_web/
-dist_serve/
-dist_ts_web/
+dist_*/

 # custom
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@ -19,22 +19,35 @@ mirror:
  stage: security
  script:
    - npmci git mirror
+  only:
+    - tags
  tags:
    - lossless
    - docker
    - notpriv

-snyk:
+auditProductionDependencies:
+  image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
  stage: security
  script:
    - npmci npm prepare
-    - npmci command npm install -g snyk
-    - npmci command npm install --ignore-scripts
-    - npmci command snyk test
+    - npmci command npm install --production --ignore-scripts
+    - npmci command npm config set registry https://registry.npmjs.org
+    - npmci command npm audit --audit-level=high --only=prod --production
  tags:
-    - lossless
    - docker
-    - notpriv
+
+auditDevDependencies:
+  image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+  stage: security
+  script:
+    - npmci npm prepare
+    - npmci command npm install --ignore-scripts
+    - npmci command npm config set registry https://registry.npmjs.org
+    - npmci command npm audit --audit-level=high --only=dev
+  tags:
+    - docker
+  allow_failure: true

 # ====================
 # test stage
@ -49,9 +62,7 @@ testStable:
    - npmci npm test
  coverage: /\d+.?\d+?\%\s*coverage/
  tags:
-    - lossless
    - docker
-    - priv

 testBuild:
  stage: test
@ -62,9 +73,7 @@ testBuild:
    - npmci command npm run build
  coverage: /\d+.?\d+?\%\s*coverage/
  tags:
-    - lossless
    - docker
-    - notpriv

 release:
  stage: release
@ -84,6 +93,8 @@ release:
 codequality:
  stage: metadata
  allow_failure: true
+  only:
+    - tags
  script:
    - npmci command npm install -g tslint typescript
    - npmci npm prepare
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@ -0,0 +1,26 @@
+{
+  "json.schemas": [
+    {
+      "fileMatch": ["/npmextra.json"],
+      "schema": {
+        "type": "object",
+        "properties": {
+          "npmci": {
+            "type": "object",
+            "description": "settings for npmci"
+          },
+          "gitzone": {
+            "type": "object",
+            "description": "settings for gitzone",
+            "properties": {
+              "projectType": {
+                "type": "string",
+                "enum": ["website", "element", "service", "npm", "wcc"]
+              }
+            }
+          }
+        }
+      }
+    }
+  ]
+}
--- a/npmextra.json
+++ b/npmextra.json
@ -1,5 +1,6 @@
 {
  "gitzone": {
+    "projectType": "npm",
    "module": {
      "githost": "gitlab.com",
      "gitscope": "pushrocks",
--- a/package-lock.json
+++ b/package-lock.json
@ -1,6 +1,6 @@
 {
  "name": "@pushrocks/smartuniverse",
-  "version": "1.0.99",
+  "version": "1.0.101",
  "lockfileVersion": 1,
  "requires": true,
  "dependencies": {
@ -1210,9 +1210,9 @@
      }
    },
    "@gitzone/tstest": {
-      "version": "1.0.44",
-      "resolved": "https://verdaccio.lossless.one/@gitzone%2ftstest/-/tstest-1.0.44.tgz",
-      "integrity": "sha512-IzQ9mEboN17Vgm/ecW2GtJa8FsnxDawD0PTeWfvtFbS4KNcqOxVM/gkkO7H4f1eJuzDaMvKWlsjBt2DBRhKqSg==",
+      "version": "1.0.48",
+      "resolved": "https://verdaccio.lossless.one/@gitzone%2ftstest/-/tstest-1.0.48.tgz",
+      "integrity": "sha512-BfB8p/ApUdjkFHgpjR4UucBn8BMkEUM9LsyZJW9jkeZI2NNTiU2JV/67WcCf/sNmk5L4TqbaBMiiPSUHc2EEyg==",
      "dev": true,
      "requires": {
        "@gitzone/tsbundle": "^1.0.78",
@ -1222,7 +1222,7 @@
        "@pushrocks/smartdelay": "^2.0.10",
        "@pushrocks/smartexpress": "^3.0.76",
        "@pushrocks/smartfile": "^8.0.0",
-        "@pushrocks/smartlog": "^2.0.36",
+        "@pushrocks/smartlog": "^2.0.39",
        "@pushrocks/smartpromise": "^3.0.6",
        "@pushrocks/smartshell": "^2.0.25",
        "@pushrocks/tapbundle": "^3.2.9",
@ -1339,6 +1339,27 @@
        "@pushrocks/smartpromise": "^3.0.6"
      }
    },
+    "@pushrocks/isohash": {
+      "version": "1.0.2",
+      "resolved": "https://verdaccio.lossless.one/@pushrocks%2fisohash/-/isohash-1.0.2.tgz",
+      "integrity": "sha512-TeXlktpAoLFDeXFJyhHTUOIiaZQ2oSdtEdbVt8/sA3lBMBfu+BXgfq5RLvQnqCDFpWKGmu9hn0P5NNK6zXQUkw==",
+      "requires": {
+        "@pushrocks/smartenv": "^4.0.11",
+        "@pushrocks/smarthash": "^2.1.6"
+      },
+      "dependencies": {
+        "@pushrocks/smartenv": {
+          "version": "4.0.13",
+          "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartenv/-/smartenv-4.0.13.tgz",
+          "integrity": "sha512-6H9bBRrU8lKzIw2G+Cu6gUzIw2Gn/oYHY6gzxAzsozcUQG6tKKM5tU+A12FgVgOiVDDoki+h8LfDu2D85wqq8A==",
+          "requires": {
+            "@pushrocks/smartparam": "^1.1.6",
+            "@pushrocks/smartpromise": "^3.0.6",
+            "@types/node": "^14.11.2"
+          }
+        }
+      }
+    },
    "@pushrocks/isounique": {
      "version": "1.0.4",
      "resolved": "https://verdaccio.lossless.one/@pushrocks%2fisounique/-/isounique-1.0.4.tgz",
@ -1827,7 +1848,6 @@
      "version": "1.1.6",
      "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartparam/-/smartparam-1.1.6.tgz",
      "integrity": "sha512-1El/F2QTWYDGy4Nh6vz9Ry1JVg1FEeyexB7Uvi4zHElpXYVxwso6xImRTLj+SW50JAg7nwEZ+ljkzTG9XvnwWA==",
-      "dev": true,
      "requires": {
        "@pushrocks/smartpromise": "^3.0.6",
        "is-promise": "^2.1.0",
@ -1910,9 +1930,9 @@
      }
    },
    "@pushrocks/smartrequest": {
-      "version": "1.1.49",
-      "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartrequest/-/smartrequest-1.1.49.tgz",
-      "integrity": "sha512-LBzUoPZvtp5s0cjm4tIoA0IrKX3O0OBKkLdi7W7juQx3TI2JJP5cEYEzxTxTGUGYoWpmy10w18bA3iDx7qJ0Qg==",
+      "version": "1.1.51",
+      "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartrequest/-/smartrequest-1.1.51.tgz",
+      "integrity": "sha512-RJUvo7MEIAm+gFueJrmf8LcpVals5jp7PgOZ+ebGTvDoVwCpor0Z6nmJDOs9ykjFCIvvPhfiterQeb6hJr2uDw==",
      "requires": {
        "@pushrocks/smartpromise": "^3.0.6",
        "agentkeepalive": "^4.1.3",
@ -1944,23 +1964,37 @@
      }
    },
    "@pushrocks/smartsocket": {
-      "version": "1.1.60",
-      "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartsocket/-/smartsocket-1.1.60.tgz",
-      "integrity": "sha512-+1xFjRoovGiL1ijd4OTJyd8pS+bGu+f0p28IS7Kg9DbnmcSxWLU33RhUWaw6ywFnjHjSlsqDd8GMGeQCnLV4Bg==",
+      "version": "1.1.63",
+      "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartsocket/-/smartsocket-1.1.63.tgz",
+      "integrity": "sha512-ed0JabIzEUDBFie/PlMs7Oh5URbULhdaS4UPKXU6Rj9573sf4i7JuwRdgO+8ozR+jfnE3+fg2gDnJWeG4YUcGg==",
      "requires": {
        "@apiglobal/typedrequest-interfaces": "^1.0.15",
+        "@pushrocks/isohash": "^1.0.2",
+        "@pushrocks/isounique": "^1.0.4",
        "@pushrocks/lik": "^4.0.17",
        "@pushrocks/smartdelay": "^2.0.10",
+        "@pushrocks/smartenv": "^4.0.13",
        "@pushrocks/smartexpress": "^3.0.76",
-        "@pushrocks/smarthash": "^2.1.6",
        "@pushrocks/smartlog": "^2.0.39",
        "@pushrocks/smartpromise": "^3.0.6",
        "@pushrocks/smartrx": "^2.0.19",
-        "@pushrocks/smartunique": "^3.0.3",
+        "@pushrocks/smarttime": "^3.0.35",
        "@types/socket.io": "^2.1.11",
        "@types/socket.io-client": "^1.4.33",
        "socket.io": "^2.3.0",
        "socket.io-client": "^2.3.0"
+      },
+      "dependencies": {
+        "@pushrocks/smartenv": {
+          "version": "4.0.13",
+          "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmartenv/-/smartenv-4.0.13.tgz",
+          "integrity": "sha512-6H9bBRrU8lKzIw2G+Cu6gUzIw2Gn/oYHY6gzxAzsozcUQG6tKKM5tU+A12FgVgOiVDDoki+h8LfDu2D85wqq8A==",
+          "requires": {
+            "@pushrocks/smartparam": "^1.1.6",
+            "@pushrocks/smartpromise": "^3.0.6",
+            "@types/node": "^14.11.2"
+          }
+        }
      }
    },
    "@pushrocks/smartstring": {
@ -2293,9 +2327,9 @@
      }
    },
    "@types/puppeteer": {
-      "version": "2.1.4",
-      "resolved": "https://verdaccio.lossless.one/@types%2fpuppeteer/-/puppeteer-2.1.4.tgz",
-      "integrity": "sha512-IlJgM1wYKhRTuk5kT39KXCB+O1SQcCKEQTmjC2ilKnc2c76BpyKsdAO1kgaXRp5zeA6uZ5m4X2fdJsX7+u/iKg==",
+      "version": "2.1.5",
+      "resolved": "https://verdaccio.lossless.one/@types%2fpuppeteer/-/puppeteer-2.1.5.tgz",
+      "integrity": "sha512-ZZKAcX5XVEtSK+CLxz6FhofPt8y1D3yDtjGZHDFBZ4bGe8v2aaS6qBDHY4crruvpb4jsO7HKrPEx39IIqsZAUg==",
      "dev": true,
      "requires": {
        "@types/node": "*"
@ -3147,13 +3181,13 @@
      }
    },
    "browserslist": {
-      "version": "4.14.4",
-      "resolved": "https://verdaccio.lossless.one/browserslist/-/browserslist-4.14.4.tgz",
-      "integrity": "sha512-7FOuawafVdEwa5Jv4nzeik/PepAjVte6HmVGHsjt2bC237jeL9QlcTBDF3PnHEvcC6uHwLGYPwZHNZMB7wWAnw==",
+      "version": "4.14.5",
+      "resolved": "https://verdaccio.lossless.one/browserslist/-/browserslist-4.14.5.tgz",
+      "integrity": "sha512-Z+vsCZIvCBvqLoYkBFTwEYH3v5MCQbsAjp50ERycpOjnPmolg1Gjy4+KaWWpm8QOJt9GHkhdqAl14NpCX73CWA==",
      "dev": true,
      "requires": {
        "caniuse-lite": "^1.0.30001135",
-        "electron-to-chromium": "^1.3.570",
+        "electron-to-chromium": "^1.3.571",
        "escalade": "^3.1.0",
        "node-releases": "^1.1.61"
      }
@ -3325,9 +3359,9 @@
      }
    },
    "caniuse-lite": {
-      "version": "1.0.30001135",
-      "resolved": "https://verdaccio.lossless.one/caniuse-lite/-/caniuse-lite-1.0.30001135.tgz",
-      "integrity": "sha512-ziNcheTGTHlu9g34EVoHQdIu5g4foc8EsxMGC7Xkokmvw0dqNtX8BS8RgCgFBaAiSp2IdjvBxNdh0ssib28eVQ==",
+      "version": "1.0.30001137",
+      "resolved": "https://verdaccio.lossless.one/caniuse-lite/-/caniuse-lite-1.0.30001137.tgz",
+      "integrity": "sha512-54xKQZTqZrKVHmVz0+UvdZR6kQc7pJDgfhsMYDG19ID1BWoNnDMFm5Q3uSBSU401pBvKYMsHAt9qhEDcxmk8aw==",
      "dev": true
    },
    "caseless": {
@ -4588,9 +4622,9 @@
      "integrity": "sha1-WQxhFWsK4vTwJVcyoViyZrxWsh0="
    },
    "electron-to-chromium": {
-      "version": "1.3.571",
-      "resolved": "https://verdaccio.lossless.one/electron-to-chromium/-/electron-to-chromium-1.3.571.tgz",
-      "integrity": "sha512-UYEQ2Gtc50kqmyOmOVtj6Oqi38lm5yRJY3pLuWt6UIot0No1L09uu6Ja6/1XKwmz/p0eJFZTUZi+khd1PV1hHA==",
+      "version": "1.3.576",
+      "resolved": "https://verdaccio.lossless.one/electron-to-chromium/-/electron-to-chromium-1.3.576.tgz",
+      "integrity": "sha512-uSEI0XZ//5ic+0NdOqlxp0liCD44ck20OAGyLMSymIWTEAtHKVJi6JM18acOnRgUgX7Q65QqnI+sNncNvIy8ew==",
      "dev": true
    },
    "elliptic": {
@ -4832,7 +4866,7 @@
    },
    "esutils": {
      "version": "2.0.3",
-      "resolved": "https://registry.npmjs.org/esutils/-/esutils-2.0.3.tgz",
+      "resolved": "https://verdaccio.lossless.one/esutils/-/esutils-2.0.3.tgz",
      "integrity": "sha512-kVscqXk4OCp68SZ0dkgEKVi6/8ij300KBWTJq32P/dYeWTSwK41WyTxalN1eRmA5Z9UU/LX9D7FWSmV9SAYx6g==",
      "dev": true
    },
@ -6573,9 +6607,9 @@
      "dev": true
    },
    "ip-regex": {
-      "version": "4.1.0",
-      "resolved": "https://verdaccio.lossless.one/ip-regex/-/ip-regex-4.1.0.tgz",
-      "integrity": "sha512-pKnZpbgCTfH/1NLIlOduP/V+WRXzC2MOz3Qo8xmxk8C5GudJLgK5QyLVXOSWy3ParAH7Eemurl3xjv/WXYFvMA==",
+      "version": "4.2.0",
+      "resolved": "https://verdaccio.lossless.one/ip-regex/-/ip-regex-4.2.0.tgz",
+      "integrity": "sha512-n5cDDeTWWRwK1EBoWwRti+8nP4NbytBBY0pldmnIkq6Z55KNFmWofh4rl9dPZpj+U/nVq7gweR3ylrvMt4YZ5A==",
      "dev": true
    },
    "ipaddr.js": {
@ -8278,9 +8312,9 @@
      "dev": true
    },
    "postcss": {
-      "version": "7.0.34",
-      "resolved": "https://verdaccio.lossless.one/postcss/-/postcss-7.0.34.tgz",
-      "integrity": "sha512-H/7V2VeNScX9KE83GDrDZNiGT1m2H+UTnlinIzhjlLX9hfMUn1mHNnGeX81a1c8JSBdBvqk7c2ZOG6ZPn5itGw==",
+      "version": "7.0.35",
+      "resolved": "https://verdaccio.lossless.one/postcss/-/postcss-7.0.35.tgz",
+      "integrity": "sha512-3QT8bBJeX/S5zKTTjTCIjRF3If4avAT6kqxcASlTWEtAFCb9NH0OUxNDfgZSWdP5fJnBYCMEWkIFfWeugjzYMg==",
      "dev": true,
      "requires": {
        "chalk": "^2.4.2",
@ -8733,9 +8767,9 @@
      }
    },
    "postcss-selector-parser": {
-      "version": "6.0.3",
-      "resolved": "https://verdaccio.lossless.one/postcss-selector-parser/-/postcss-selector-parser-6.0.3.tgz",
-      "integrity": "sha512-0ClFaY4X1ra21LRqbW6y3rUbWcxnSVkDFG57R7Nxus9J9myPFlv+jYDMohzpkBx0RrjjiqjtycpchQ+PLGmZ9w==",
+      "version": "6.0.4",
+      "resolved": "https://verdaccio.lossless.one/postcss-selector-parser/-/postcss-selector-parser-6.0.4.tgz",
+      "integrity": "sha512-gjMeXBempyInaBqpp8gODmwZ52WaYsVOsfr4L4lDQ7n3ncD6mEyySiDtgzCT+NYC0mmeOLvtsF8iaEf0YT6dBw==",
      "dev": true,
      "requires": {
        "cssesc": "^3.0.0",
@ -10784,9 +10818,9 @@
      "dev": true
    },
    "uglify-js": {
-      "version": "3.10.4",
-      "resolved": "https://verdaccio.lossless.one/uglify-js/-/uglify-js-3.10.4.tgz",
-      "integrity": "sha512-kBFT3U4Dcj4/pJ52vfjCSfyLyvG9VYYuGYPmrPvAxRw/i7xHiT4VvCev+uiEMcEEiu6UNB6KgWmGtSUYIWScbw==",
+      "version": "3.11.0",
+      "resolved": "https://verdaccio.lossless.one/uglify-js/-/uglify-js-3.11.0.tgz",
+      "integrity": "sha512-e1KQFRCpOxnrJsJVqDUCjURq+wXvIn7cK2sRAx9XL3HYLL9aezOP4Pb1+Y3/o693EPk111Yj2Q+IUXxcpHlygQ==",
      "dev": true
    },
    "uncss": {
--- a/package.json
+++ b/package.json
@ -1,10 +1,10 @@
 {
  "name": "@pushrocks/smartuniverse",
-  "version": "1.0.99",
+  "version": "1.0.101",
  "private": false,
  "description": "messaging service for your micro services",
-  "main": "dist/index.js",
-  "typings": "dist/index.d.ts",
+  "main": "dist_ts/index.js",
+  "typings": "dist_ts/index.d.ts",
  "author": "Lossless GmbH",
  "license": "MIT",
  "scripts": {
@ -15,7 +15,7 @@
  },
  "devDependencies": {
    "@gitzone/tsbuild": "^2.1.25",
-    "@gitzone/tstest": "^1.0.44",
+    "@gitzone/tstest": "^1.0.48",
    "@pushrocks/tapbundle": "^3.2.9",
    "@types/node": "^14.11.2",
    "tslint": "^6.1.3",
@ -33,9 +33,9 @@
    "@pushrocks/smarthash": "^2.1.6",
    "@pushrocks/smartlog": "^2.0.39",
    "@pushrocks/smartpromise": "^3.0.6",
-    "@pushrocks/smartrequest": "^1.1.49",
+    "@pushrocks/smartrequest": "^1.1.51",
    "@pushrocks/smartrx": "^2.0.19",
-    "@pushrocks/smartsocket": "^1.1.60",
+    "@pushrocks/smartsocket": "^1.1.63",
    "@pushrocks/smarttime": "^3.0.35",
    "@pushrocks/smartunique": "^3.0.3"
  },
@ -43,11 +43,15 @@
    "ts/**/*",
    "ts_web/**/*",
    "dist/**/*",
-    "dist_web/**/*",
+    "dist_*/**/*",
+    "dist_ts/**/*",
    "dist_ts_web/**/*",
    "assets/**/*",
    "cli.js",
    "npmextra.json",
    "readme.md"
+  ],
+  "browserslist": [
+    "last 1 chrome versions"
  ]
 }
--- a/readme.md
+++ b/readme.md
@ -8,13 +8,20 @@ messaging service for micro services
 * [docs (typedoc)](https://pushrocks.gitlab.io/smartuniverse/)

 ## Status for master
-[![build status](https://gitlab.com/pushrocks/smartuniverse/badges/master/build.svg)](https://gitlab.com/pushrocks/smartuniverse/commits/master)
-[![coverage report](https://gitlab.com/pushrocks/smartuniverse/badges/master/coverage.svg)](https://gitlab.com/pushrocks/smartuniverse/commits/master)
-[![npm downloads per month](https://img.shields.io/npm/dm/@pushrocks/smartuniverse.svg)](https://www.npmjs.com/package/@pushrocks/smartuniverse)
-[![Known Vulnerabilities](https://snyk.io/test/npm/@pushrocks/smartuniverse/badge.svg)](https://snyk.io/test/npm/@pushrocks/smartuniverse)
-[![TypeScript](https://img.shields.io/badge/TypeScript->=%203.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
-[![node](https://img.shields.io/badge/node->=%2010.x.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
-[![JavaScript Style Guide](https://img.shields.io/badge/code%20style-prettier-ff69b4.svg)](https://prettier.io/)
+
+Status Category | Status Badge
+-- | --
+GitLab Pipelines | [![pipeline status](https://gitlab.com/pushrocks/smartuniverse/badges/master/pipeline.svg)](https://lossless.cloud)
+GitLab Pipline Test Coverage | [![coverage report](https://gitlab.com/pushrocks/smartuniverse/badges/master/coverage.svg)](https://lossless.cloud)
+npm | [![npm downloads per month](https://badgen.net/npm/dy/@pushrocks/smartuniverse)](https://lossless.cloud)
+Snyk | [![Known Vulnerabilities](https://badgen.net/snyk/pushrocks/smartuniverse)](https://lossless.cloud)
+TypeScript Support | [![TypeScript](https://badgen.net/badge/TypeScript/>=%203.x/blue?icon=typescript)](https://lossless.cloud)
+node Support | [![node](https://img.shields.io/badge/node->=%2010.x.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
+Code Style | [![Code Style](https://badgen.net/badge/style/prettier/purple)](https://lossless.cloud)
+PackagePhobia (total standalone install weight) | [![PackagePhobia](https://badgen.net/packagephobia/install/@pushrocks/smartuniverse)](https://lossless.cloud)
+PackagePhobia (package size on registry) | [![PackagePhobia](https://badgen.net/packagephobia/publish/@pushrocks/smartuniverse)](https://lossless.cloud)
+BundlePhobia (total size when bundled) | [![BundlePhobia](https://badgen.net/bundlephobia/minzip/@pushrocks/smartuniverse)](https://lossless.cloud)
+Platform support | [![Supports Windows 10](https://badgen.net/badge/supports%20Windows%2010/yes/green?icon=windows)](https://lossless.cloud) [![Supports Mac OS X](https://badgen.net/badge/supports%20Mac%20OS%20X/yes/green?icon=apple)](https://lossless.cloud)

 ## Usage

@ -33,7 +40,7 @@ Think Kafka, but without Kafka.
 import * as smartuniverse from '@pushrocks/smartuniverse';

 const myUniverse = new smartuniverse.Universe({
-  messageExpiryInMilliseconds: 60000 // the standard time in milliseconds until a message expires
+  messageExpiryInMilliseconds: 60000, // the standard time in milliseconds until a message expires
 });

 // create as many channels as you like
--- a/test/test.ts
+++ b/test/test.ts
@ -10,17 +10,17 @@ let testClientUniverse2: smartuniverse.ClientUniverse;
 let testClientChannel: smartuniverse.ClientUniverseChannel;

 const testServerData = {
-  serverAddress: 'http://localhost:8765'
+  serverAddress: 'http://localhost:8765',
 };

 const testChannelData = {
  channelName: 'awesomeTestChannel',
-  channelPass: 'awesomeChannelPass'
+  channelPass: 'awesomeChannelPass',
 };

 tap.test('first test', async () => {
  testUniverse = new smartuniverse.Universe({
-    messageExpiryInMilliseconds: 1000
+    messageExpiryInMilliseconds: 1000,
  });
 });

@ -32,7 +32,7 @@ tap.test('add a message to the SmartUniverse', async () => {
 tap.test('create smartuniverse client', async () => {
  testClientUniverse = new smartuniverse.ClientUniverse({
    serverAddress: testServerData.serverAddress,
-    autoReconnect: true
+    autoReconnect: true,
  });
  expect(testClientUniverse).to.be.instanceof(smartuniverse.ClientUniverse);
 });
@ -55,8 +55,8 @@ tap.test('should get a observable correctly', async () => {
 });

 tap.test('should send a message correctly', async () => {
-  await testClientUniverse.getChannel(testChannelData.channelName).sendMessage({
-    messageText: 'hello'
+  await testClientUniverse.getChannel(testChannelData.channelName).postMessage({
+    messageText: 'hello',
  });
 });

@ -67,25 +67,25 @@ tap.test('universe should contain the sent message', async () => {
 tap.test('a second client should be able to subscibe', async () => {
  testClientUniverse2 = new smartuniverse.ClientUniverse({
    serverAddress: testServerData.serverAddress,
-    autoReconnect: true
+    autoReconnect: true,
  });

  testClientUniverse2.addChannel(testChannelData.channelName, testChannelData.channelPass);
  await testClientUniverse2.start();
 });

-tap.test('should receive a message correctly', async tools => {
+tap.test('should receive a message correctly', async (tools) => {
  const done = tools.defer();
  const testChannel = testClientUniverse.getChannel(testChannelData.channelName);
  const testChannel2 = testClientUniverse2.getChannel(testChannelData.channelName);
-  const subscription = testChannel2.subscribe(messageArg => {
+  const subscription = testChannel2.subscribe((messageArg) => {
    if (messageArg.messageText === 'hellothere') {
      console.log('Yay##########');
      done.resolve();
    }
  });
-  await testChannel.sendMessage({
-    messageText: 'hellothere'
+  await testChannel.postMessage({
+    messageText: 'hellothere',
  });
  await done.promise;
 });
@ -103,33 +103,33 @@ interface IDemoReqRes {
 tap.test('ReactionRequest and ReactionResponse should work', async () => {
  const reactionResponse = new smartuniverse.ReactionResponse<IDemoReqRes>({
    channels: [testUniverse.getChannel(testChannelData.channelName)],
-    funcDef: async reqData => {
+    funcDef: async (reqData) => {
      console.log(reqData);
      return {
-        hereso: 'Hello there'
+        hereso: 'Hello there',
      };
    },
-    method: 'demo'
+    method: 'demo',
  });
  const reactionRequest = new smartuniverse.ReactionRequest<IDemoReqRes>({
-    method: 'demo'
+    method: 'demo',
  });
  const reactionResult = await reactionRequest.fire(
    [testClientUniverse2.getChannel(testChannelData.channelName)],
    {
-      wowso: 'wowza'
+      wowso: 'wowza',
    }
  );
  const result = await reactionResult.getFirstResult();
  console.log(result);
 });

-tap.test('should disconnect the client correctly', async tools => {
+tap.test('should disconnect the client correctly', async (tools) => {
  await testClientUniverse.stop();
  await testClientUniverse2.stop();
 });

-tap.test('should end the server correctly', async tools => {
+tap.test('should end the server correctly', async (tools) => {
  await testUniverse.stopServer();
 });

--- a/ts/index.ts
+++ b/ts/index.ts
@ -1,7 +1,7 @@
 // Client classes
-export * from './smartuniverse.classes.clientuniverse';
-export * from './smartuniverse.classes.clientuniversechannel';
-export * from './smartuniverse.classes.clientuniversemessage';
+export * from './smartuniverse.classes.client.universe';
+export * from './smartuniverse.classes.client.universechannel';
+export * from './smartuniverse.classes.client.universemessage';

 // Server classes
 export * from './smartuniverse.classes.universe';
@ -10,7 +10,7 @@ export * from './smartuniverse.classes.universechannel';
 export * from './smartuniverse.classes.universemessage';

 // Reaction Response
-export * from './smartuniverse.classes.reactionrequest';
-export * from './smartuniverse.classes.reactionresponse';
+export * from './smartuniverse.classes.event.reactionrequest';
+export * from './smartuniverse.classes.event.reactionresponse';

 export * from './interfaces';
--- a/ts/smartuniverse.classes.client.universe.ts
+++ b/ts/smartuniverse.classes.client.universe.ts
@ -6,8 +6,8 @@ import * as url from 'url';

 import * as interfaces from './interfaces';

-import { ClientUniverseChannel, ClientUniverseMessage } from './';
-import { ClientUniverseCache } from './smartuniverse.classes.clientuniversecache';
+import { ClientUniverseChannel, ClientUniverseMessage } from '.';
+import { ClientUniverseCache } from './smartuniverse.classes.client.universecache';
 import { logger } from './smartuniverse.logging';

 export interface IClientOptions {
@ -57,7 +57,7 @@ export class ClientUniverse {
   * @param passphraseArg
   */
  public getChannel(channelName: string): ClientUniverseChannel {
-    const clientUniverseChannel = this.clientUniverseCache.channelMap.find(channel => {
+    const clientUniverseChannel = this.clientUniverseCache.channelMap.find((channel) => {
      return channel.name === channelName;
    });
    return clientUniverseChannel;
@ -69,7 +69,7 @@ export class ClientUniverse {
   */
  public removeChannel(channelNameArg, notifyServer = true) {
    const clientUniverseChannel = this.clientUniverseCache.channelMap.findOneAndRemove(
-      channelItemArg => {
+      (channelItemArg) => {
        return channelItemArg.name === channelNameArg;
      }
    );
@ -99,11 +99,11 @@ export class ClientUniverse {
        password: 'UniverseClient',
        port: parseInt(parsedURL.port, 10),
        role: 'UniverseClient',
-        url: parsedURL.protocol + '//' + parsedURL.hostname
+        url: parsedURL.protocol + '//' + parsedURL.hostname,
      };
      this.smartsocketClient = new SmartsocketClient(socketConfig);

-      this.smartsocketClient.eventSubject.subscribe(async eventArg => {
+      this.smartsocketClient.eventSubject.subscribe(async (eventArg) => {
        switch (eventArg) {
          case 'disconnected':
            this.disconnect('upstreamEvent');
@ -119,14 +119,14 @@ export class ClientUniverse {
        funcName: 'unsubscribe',
        allowedRoles: [],
        funcDef: async (dataArg: interfaces.IServerUnsubscribeActionPayload) => {
-          const channel = this.clientUniverseCache.channelMap.find(channelArg => {
+          const channel = this.clientUniverseCache.channelMap.find((channelArg) => {
            return channelArg.name === dataArg.name;
          });
          if (channel) {
            channel.unsubscribe();
          }
          return {};
-        }
+        },
      });

      /**
@ -137,7 +137,7 @@ export class ClientUniverse {
      >({
        funcName: 'processMessage',
        allowedRoles: [],
-        funcDef: async messageDescriptorArg => {
+        funcDef: async (messageDescriptorArg) => {
          logger.log('info', 'Got message from server');
          const clientUniverseMessage = ClientUniverseMessage.createMessageFromMessageDescriptor(
            messageDescriptorArg
@ -149,14 +149,14 @@ export class ClientUniverse {
          if (targetChannel) {
            await targetChannel.emitMessageLocally(clientUniverseMessage);
            return {
-              messageStatus: 'ok'
+              messageStatus: 'ok',
            };
          } else {
            return {
-              messageStatus: 'channel not found'
+              messageStatus: 'channel not found',
            };
          }
-        }
+        },
      });

      // add functions
@ -165,7 +165,7 @@ export class ClientUniverse {

      await this.smartsocketClient.connect();
      logger.log('info', 'universe client connected successfully');
-      await this.clientUniverseCache.channelMap.forEach(async clientUniverseChannelArg => {
+      await this.clientUniverseCache.channelMap.forEach(async (clientUniverseChannelArg) => {
        await clientUniverseChannelArg.populateSubscriptionToServer();
      });
    }
--- a/ts/smartuniverse.classes.client.universecache.ts
+++ b/ts/smartuniverse.classes.client.universecache.ts
@ -1,5 +1,5 @@
 import * as plugins from './smartuniverse.plugins';
-import { ClientUniverseChannel } from './smartuniverse.classes.clientuniversechannel';
+import { ClientUniverseChannel } from './smartuniverse.classes.client.universechannel';

 /**
 * a cache for clients
--- a/ts/smartuniverse.classes.client.universechannel.ts
+++ b/ts/smartuniverse.classes.client.universechannel.ts
@ -1,10 +1,10 @@
 import * as plugins from './smartuniverse.plugins';
 import * as interfaces from './interfaces';

-import { ClientUniverse } from './';
-import { ClientUniverseMessage } from './smartuniverse.classes.clientuniversemessage';
-import { ReactionRequest } from './smartuniverse.classes.reactionrequest';
-import { ReactionResponse } from './smartuniverse.classes.reactionresponse';
+import { ClientUniverse } from '.';
+import { ClientUniverseMessage } from './smartuniverse.classes.client.universemessage';
+import { ReactionRequest } from './smartuniverse.classes.event.reactionrequest';
+import { ReactionResponse } from './smartuniverse.classes.event.reactionresponse';

 export class ClientUniverseChannel implements interfaces.IUniverseChannel {
  // ======
@ -55,10 +55,10 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
   */
  public subscribe(observingFunctionArg: (messageArg: ClientUniverseMessage<any>) => void) {
    return this.subject.subscribe(
-      messageArg => {
+      (messageArg) => {
        observingFunctionArg(messageArg);
      },
-      error => console.log(error)
+      (error) => console.log(error)
    );
  }

@ -73,7 +73,7 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
        interfaces.ISocketRequest_SubscribeChannel
      >('subscribeChannel', {
        name: this.name,
-        passphrase: this.passphrase
+        passphrase: this.passphrase,
      });
      this.status = response.subscriptionStatus;
    }
@ -87,7 +87,7 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
   * sends a message towards the server
   * @param messageArg
   */
-  public async sendMessage(messageArg: interfaces.IMessageCreator) {
+  public async postMessage(messageArg: interfaces.IMessageCreator) {
    await this.clientUniverseRef.start(); // its ok to call this multiple times
    const universeMessageToSend: interfaces.IUniverseMessage = {
      id: plugins.smartunique.shortId(),
@ -95,7 +95,7 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
      passphrase: this.passphrase,
      targetChannelName: this.name,
      messageText: messageArg.messageText,
-      payload: messageArg.payload
+      payload: messageArg.payload,
    };
    await this.clientUniverseRef.smartsocketClient.serverCall(
      'processMessage',
--- a/ts/smartuniverse.classes.client.universemessage.ts
+++ b/ts/smartuniverse.classes.client.universemessage.ts
--- a/ts/smartuniverse.classes.event.broadcastevent.ts
+++ b/ts/smartuniverse.classes.event.broadcastevent.ts
@ -2,19 +2,14 @@ import * as plugins from './smartuniverse.plugins';

 /**
 * broadcasts an event to multiple channels
- * also handles subsription
+ * also handles subscription
 */
 export class BroadcastEvent<T extends plugins.typedrequestInterfaces.ITypedEvent<any>> {
  public eventSubject = new plugins.smartrx.rxjs.Subject<T['payload']>();

-  constructor() {
-
-  };
-
-  public fire(eventPayloadArg: T['payload']) {
-
-  };
+  constructor() {}

+  public fire(eventPayloadArg: T['payload']) {}

  public subscribe(funcArg: (nextArg: T['payload']) => void): plugins.smartrx.rxjs.Subscription {
    return this.eventSubject.subscribe(funcArg);
--- a/ts/smartuniverse.classes.event.reactionrequest.ts
+++ b/ts/smartuniverse.classes.event.reactionrequest.ts
@ -1,9 +1,9 @@
 import * as plugins from './smartuniverse.plugins';
 import { UniverseChannel } from './smartuniverse.classes.universechannel';
-import { ClientUniverseChannel } from './smartuniverse.classes.clientuniversechannel';
-import { ReactionResult } from './smartuniverse.classes.reactionresult';
+import { ClientUniverseChannel } from './smartuniverse.classes.client.universechannel';
+import { ReactionResult } from './smartuniverse.classes.event.reactionresult';
 import { UniverseMessage } from './smartuniverse.classes.universemessage';
-import { ClientUniverseMessage } from './smartuniverse.classes.clientuniversemessage';
+import { ClientUniverseMessage } from './smartuniverse.classes.client.universemessage';

 export interface IReactionRequestConstructorOptions<
  T extends plugins.typedrequestInterfaces.ITypedRequest
@ -64,16 +64,16 @@ export class ReactionRequest<T extends plugins.typedrequestInterfaces.ITypedRequ
        typedRequestPayload: {
          method: this.method,
          request: requestDataArg,
-          response: null
-        }
+          response: null,
+        },
      };
-      channel.sendMessage({
+      channel.postMessage({
        messageText: 'reactionRequest',
-        payload
+        payload,
      });
    }
    plugins.smartdelay.delayFor(timeoutMillisArg).then(async () => {
-      await subscriptionMap.forEach(subscriptionArg => {
+      await subscriptionMap.forEach((subscriptionArg) => {
        subscriptionArg.unsubscribe();
      });
      reactionResult.complete();
--- a/ts/smartuniverse.classes.event.reactionresponse.ts
+++ b/ts/smartuniverse.classes.event.reactionresponse.ts
@ -1,10 +1,10 @@
 import * as plugins from './smartuniverse.plugins';

-import { ICombinatorPayload } from './smartuniverse.classes.reactionrequest';
+import { ICombinatorPayload } from './smartuniverse.classes.event.reactionrequest';
 import { UniverseChannel } from './smartuniverse.classes.universechannel';
-import { ClientUniverseChannel } from './smartuniverse.classes.clientuniversechannel';
+import { ClientUniverseChannel } from './smartuniverse.classes.client.universechannel';
 import { UniverseMessage } from './smartuniverse.classes.universemessage';
-import { ClientUniverseMessage } from './smartuniverse.classes.clientuniversemessage';
+import { ClientUniverseMessage } from './smartuniverse.classes.client.universemessage';

 export type TReactionResponseFuncDef<T extends plugins.typedrequestInterfaces.ITypedRequest> = (
  dataArg: T['request']
@ -28,7 +28,7 @@ export class ReactionResponse<T extends plugins.typedrequestInterfaces.ITypedReq
    this.channels.addArray(optionsArg.channels);
    this.funcDef = optionsArg.funcDef;
    for (const channel of this.channels.getArray()) {
-      channel.subscribe(messageArg => {
+      channel.subscribe((messageArg) => {
        this.processMessageForReaction(channel, messageArg);
      });
    }
@ -51,12 +51,12 @@ export class ReactionResponse<T extends plugins.typedrequestInterfaces.ITypedReq
        ...messageArg.payload,
        typedRequestPayload: {
          ...messageArg.payload.typedRequestPayload,
-          response
-        }
+          response,
+        },
      };
-      channelArg.sendMessage({
+      channelArg.postMessage({
        messageText: 'reactionResponse',
-        payload
+        payload,
      });
    }
  }
--- a/ts/smartuniverse.classes.event.reactionresult.ts
+++ b/ts/smartuniverse.classes.event.reactionresult.ts
@ -1,5 +1,5 @@
 import * as plugins from './smartuniverse.plugins';
-import { ReactionResponse } from './smartuniverse.classes.reactionresponse';
+import { ReactionResponse } from './smartuniverse.classes.event.reactionresponse';

 export class ReactionResult<T extends plugins.typedrequestInterfaces.ITypedRequest> {
  private resultReplaySubject = new plugins.smartrx.rxjs.ReplaySubject<T['response']>();
@ -7,7 +7,7 @@ export class ReactionResult<T extends plugins.typedrequestInterfaces.ITypedReque
  private completeDeferred = plugins.smartpromise.defer<Array<T['response']>>();

  constructor() {
-    this.resultSubscribe(responseArg => {
+    this.resultSubscribe((responseArg) => {
      this.endResult.push(responseArg);
    });
  }
@ -29,7 +29,7 @@ export class ReactionResult<T extends plugins.typedrequestInterfaces.ITypedReque
   */
  public async getFirstResult() {
    const done = plugins.smartpromise.defer<T['response']>();
-    const subscription = this.resultReplaySubject.subscribe(result => {
+    const subscription = this.resultReplaySubject.subscribe((result) => {
      done.resolve(result);
      subscription.unsubscribe();
    });
--- a/ts/smartuniverse.classes.universe.ts
+++ b/ts/smartuniverse.classes.universe.ts
@ -70,7 +70,7 @@ export class Universe {
   * returns a channel
   */
  public getChannel(channelNameArg: string) {
-    return this.universeCache.channelMap.find(channelArg => {
+    return this.universeCache.channelMap.find((channelArg) => {
      return channelArg.name === channelNameArg;
    });
  }
@ -87,7 +87,7 @@ export class Universe {
          return `smartuniverse server ${this.getUniverseVersion()}`;
        },
        forceSsl: false,
-        port: portArg
+        port: portArg,
      });
    } else {
      console.log('Universe is using externally supplied server');
@ -100,7 +100,7 @@ export class Universe {
    // add a role for the clients
    const ClientRole = new plugins.smartsocket.SocketRole({
      name: 'UniverseClient',
-      passwordHash: plugins.smarthash.sha256FromStringSync('UniverseClient') // authentication happens on another level
+      passwordHash: plugins.smarthash.sha256FromStringSync('UniverseClient'), // authentication happens on another level
    });

    // add the role to smartsocket
@ -115,13 +115,13 @@ export class Universe {
        const universeConnection = new UniverseConnection({
          universe: this,
          socketConnection: socketConnectionArg,
-          authenticationRequests: [dataArg]
+          authenticationRequests: [dataArg],
        });
        await UniverseConnection.addConnectionToCache(this, universeConnection);
        return {
-          subscriptionStatus: 'subscribed'
+          subscriptionStatus: 'subscribed',
        };
-      }
+      },
    });

    const socketFunctionProcessMessage = new plugins.smartsocket.SocketFunction({
@ -133,17 +133,11 @@ export class Universe {
          socketConnectionArg
        );
        if (universeConnection) {
-          logger.log(
-            'ok',
-            'found UniverseConnection for socket for incoming message'
-          );
+          logger.log('ok', 'found UniverseConnection for socket for incoming message');
        } else {
-          logger.log(
-            'warn',
-            'found no Authorized channel for incoming message'
-          );
+          logger.log('warn', 'found no Authorized channel for incoming message');
          return {
-            error: 'You need to authenticate for a channel'
+            error: 'You need to authenticate for a channel',
          };
        }
        const unauthenticatedMessage = UniverseMessage.createMessageFromPayload(
@ -158,7 +152,7 @@ export class Universe {
          const authenticatedMessage = unauthenticatedMessage;
          await this.universeCache.addMessage(authenticatedMessage);
        }
-      }
+      },
    });

    // add socket functions
--- a/ts/smartuniverse.classes.universecache.ts
+++ b/ts/smartuniverse.classes.universecache.ts
@ -7,7 +7,6 @@ import { ObjectMap } from '@pushrocks/lik';

 import { Observable, from } from 'rxjs';
 import { filter } from 'rxjs/operators';
-import { rxjs } from '@pushrocks/smartrx';
 import { UniverseConnection } from './smartuniverse.classes.universeconnection';
 import { Universe } from './smartuniverse.classes.universe';

@ -58,7 +57,7 @@ export class UniverseCache {
    messageArg.setUniverseCache(this);
    UniverseChannel.authorizeAMessageForAChannel(this, messageArg);
    this.messageMap.add(messageArg);
-    messageArg.universeChannelList.forEach(universeChannel => {
+    messageArg.universeChannelList.forEach((universeChannel) => {
      universeChannel.push(messageArg);
    });
  }
@ -71,7 +70,7 @@ export class UniverseCache {
    channelName?: string
  ): Observable<UniverseMessage<any>> {
    const messageObservable = from(this.messageMap.getArray()).pipe(
-      filter(messageArg => {
+      filter((messageArg) => {
        return messageArg.smartTimestamp.isYoungerThanMilliSeconds(this.destructionTime);
      })
    );
--- a/ts/smartuniverse.classes.universechannel.ts
+++ b/ts/smartuniverse.classes.universechannel.ts
@ -34,7 +34,7 @@ export class UniverseChannel {
   * returns boolean wether certain channel exists
   */
  public static async doesChannelExists(universeCacheArg: UniverseCache, channelNameArg: string) {
-    const channel = universeCacheArg.channelMap.find(channelArg => {
+    const channel = universeCacheArg.channelMap.find((channelArg) => {
      return channelArg.name === channelNameArg;
    });
    if (channel) {
@ -55,7 +55,7 @@ export class UniverseChannel {
    universeCacheArg: UniverseCache,
    universeMessageArg: UniverseMessage<any>
  ): UniverseChannel {
-    const foundChannel = universeCacheArg.channelMap.find(universeChannel => {
+    const foundChannel = universeCacheArg.channelMap.find((universeChannel) => {
      const result = universeChannel.authenticate(universeMessageArg);
      return result;
    });
@ -73,7 +73,7 @@ export class UniverseChannel {
  }

  public static getUniverseChannelByName(universeRef: Universe, universeChannelName: string) {
-    return universeRef.universeCache.channelMap.find(channelArg => {
+    return universeRef.universeCache.channelMap.find((channelArg) => {
      return channelArg.name === universeChannelName;
    });
  }
@ -118,7 +118,7 @@ export class UniverseChannel {
  public async push(messageArg: UniverseMessage<any>) {
    this.subject.next(messageArg);
    const universeConnectionsWithChannelAccess: UniverseConnection[] = [];
-    await this.universeRef.universeCache.connectionMap.forEach(async socketConnection => {
+    await this.universeRef.universeCache.connectionMap.forEach(async (socketConnection) => {
      if (socketConnection.authenticatedChannels.includes(this)) {
        universeConnectionsWithChannelAccess.push(socketConnection);
      }
@ -132,7 +132,7 @@ export class UniverseChannel {
        passphrase: messageArg.passphrase,
        targetChannelName: this.name,
        messageText: messageArg.messageText,
-        payload: messageArg.payload
+        payload: messageArg.payload,
      };
      smartsocket.clientCall(
        'processMessage',
@ -145,24 +145,24 @@ export class UniverseChannel {
  // functions to interact with a channel locally
  public subscribe(observingFunctionArg: (messageArg: UniverseMessage<any>) => void) {
    return this.subject.subscribe(
-      messageArg => {
+      (messageArg) => {
        observingFunctionArg(messageArg);
      },
-      error => console.log(error)
+      (error) => console.log(error)
    );
  }

  /**
   * sends a message to the channel
   */
-  public async sendMessage(messageDescriptor: interfaces.IMessageCreator) {
+  public async postMessage(messageDescriptor: interfaces.IMessageCreator) {
    const messageToSend = new UniverseMessage({
      id: plugins.smartunique.shortId(),
      messageText: messageDescriptor.messageText,
      payload: messageDescriptor.payload,
      targetChannelName: this.name,
      passphrase: this.passphrase,
-      timestamp: Date.now()
+      timestamp: Date.now(),
    });
    this.universeRef.universeCache.addMessage(messageToSend);
  }
--- a/ts/smartuniverse.classes.universeconnection.ts
+++ b/ts/smartuniverse.classes.universeconnection.ts
@ -37,7 +37,7 @@ export class UniverseConnection {
    universeConnectionArg: UniverseConnection
  ): Promise<UniverseConnection> {
    let connectionToReturn: UniverseConnection;
-    universeCache.connectionMap.forEach(async existingConnection => {
+    universeCache.connectionMap.forEach(async (existingConnection) => {
      if (existingConnection.socketConnection === universeConnectionArg.socketConnection) {
        connectionToReturn = await this.mergeUniverseConnections(
          existingConnection,
@ -87,7 +87,7 @@ export class UniverseConnection {
    universeCache: UniverseCache,
    socketConnectionArg: plugins.smartsocket.SocketConnection
  ): UniverseConnection {
-    const universeConnection = universeCache.connectionMap.find(universeConnectionArg => {
+    const universeConnection = universeCache.connectionMap.find((universeConnectionArg) => {
      return universeConnectionArg.socketConnection === socketConnectionArg;
    });
    return universeConnection;
@ -124,7 +124,7 @@ export class UniverseConnection {
    this.universeRef = optionsArg.universe;
    this.authenticationRequests = optionsArg.authenticationRequests;
    this.socketConnection = optionsArg.socketConnection;
-    this.socketConnection.eventSubject.subscribe(async eventArg => {
+    this.socketConnection.eventSubject.subscribe(async (eventArg) => {
      switch (eventArg) {
        case 'disconnected':
          await this.disconnect('upstreamevent');
--- a/ts/smartuniverse.classes.universemessage.ts
+++ b/ts/smartuniverse.classes.universemessage.ts
@ -81,7 +81,7 @@ export class UniverseMessage<T> implements interfaces.IUniverseMessage {
        .then(async () => {
          this.universeCache.messageMap.remove(this);
        })
-        .catch(err => {
+        .catch((err) => {
          console.log(err);
          console.log(this);
        });
--- a/ts/smartuniverse.plugins.ts
+++ b/ts/smartuniverse.plugins.ts
@ -34,5 +34,5 @@ export {
  smartrequest,
  smartsocket,
  smarttime,
-  smartunique
+  smartunique,
 };
Author	SHA1	Message	Date
Phil Kunz	82f4413064	1.0.101	2020-09-29 19:39:13 +00:00
Phil Kunz	71bccf54f1	fix(core): update	2020-09-29 19:39:13 +00:00
Phil Kunz	78ee8f2592	1.0.100	2020-09-24 18:17:53 +00:00
Phil Kunz	820ce76fe3	fix(core): update	2020-09-24 18:17:52 +00:00