Compare commits
20 Commits
Author | SHA1 | Date | |
---|---|---|---|
39ed2dbd73 | |||
b1defd95a3 | |||
a4ad33a0ee | |||
18fad25b8c | |||
82f4413064 | |||
71bccf54f1 | |||
78ee8f2592 | |||
820ce76fe3 | |||
5d8c2064e0 | |||
9d1fc94e06 | |||
c4640a3bc7 | |||
b6392ec6ba | |||
bd4897f392 | |||
dbdc8a2811 | |||
908d00981b | |||
669ef262d7 | |||
30053fe441 | |||
afb4e3339a | |||
e413a8116d | |||
ffeed0565c |
4
.gitignore
vendored
4
.gitignore
vendored
@ -15,8 +15,6 @@ node_modules/
|
|||||||
|
|
||||||
# builds
|
# builds
|
||||||
dist/
|
dist/
|
||||||
dist_web/
|
dist_*/
|
||||||
dist_serve/
|
|
||||||
dist_ts_web/
|
|
||||||
|
|
||||||
# custom
|
# custom
|
102
.gitlab-ci.yml
102
.gitlab-ci.yml
@ -3,14 +3,14 @@ image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
|||||||
|
|
||||||
cache:
|
cache:
|
||||||
paths:
|
paths:
|
||||||
- .npmci_cache/
|
- .npmci_cache/
|
||||||
key: "$CI_BUILD_STAGE"
|
key: '$CI_BUILD_STAGE'
|
||||||
|
|
||||||
stages:
|
stages:
|
||||||
- security
|
- security
|
||||||
- test
|
- test
|
||||||
- release
|
- release
|
||||||
- metadata
|
- metadata
|
||||||
|
|
||||||
# ====================
|
# ====================
|
||||||
# security stage
|
# security stage
|
||||||
@ -18,21 +18,36 @@ stages:
|
|||||||
mirror:
|
mirror:
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci git mirror
|
- npmci git mirror
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- notpriv
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
snyk:
|
auditProductionDependencies:
|
||||||
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci command npm install -g snyk
|
- npmci command npm install --production --ignore-scripts
|
||||||
- npmci command npm install --ignore-scripts
|
- npmci command npm config set registry https://registry.npmjs.org
|
||||||
- npmci command snyk test
|
- npmci command npm audit --audit-level=high --only=prod --production
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- 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
|
# test stage
|
||||||
@ -41,37 +56,36 @@ snyk:
|
|||||||
testStable:
|
testStable:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci node install stable
|
- npmci node install stable
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci npm test
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- priv
|
|
||||||
|
|
||||||
testBuild:
|
testBuild:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci node install lts
|
- npmci node install stable
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command npm run build
|
- npmci command npm run build
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
|
||||||
|
|
||||||
release:
|
release:
|
||||||
stage: release
|
stage: release
|
||||||
script:
|
script:
|
||||||
- npmci node install lts
|
- npmci node install stable
|
||||||
- npmci npm publish
|
- npmci npm publish
|
||||||
only:
|
only:
|
||||||
- tags
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- notpriv
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
# ====================
|
# ====================
|
||||||
# metadata stage
|
# metadata stage
|
||||||
@ -79,35 +93,39 @@ release:
|
|||||||
codequality:
|
codequality:
|
||||||
stage: metadata
|
stage: metadata
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
script:
|
script:
|
||||||
- npmci command npm install -g tslint typescript
|
- npmci command npm install -g tslint typescript
|
||||||
|
- npmci npm prepare
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
|
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- priv
|
- docker
|
||||||
|
- priv
|
||||||
|
|
||||||
trigger:
|
trigger:
|
||||||
stage: metadata
|
stage: metadata
|
||||||
script:
|
script:
|
||||||
- npmci trigger
|
- npmci trigger
|
||||||
only:
|
only:
|
||||||
- tags
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- notpriv
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
pages:
|
pages:
|
||||||
image: hosttoday/ht-docker-dbase:npmci
|
|
||||||
services:
|
|
||||||
- docker:stable-dind
|
|
||||||
stage: metadata
|
stage: metadata
|
||||||
script:
|
script:
|
||||||
|
- npmci node install lts
|
||||||
- npmci command npm install -g @gitzone/tsdoc
|
- npmci command npm install -g @gitzone/tsdoc
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command tsdoc
|
- npmci command tsdoc
|
||||||
tags:
|
tags:
|
||||||
|
- lossless
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
- notpriv
|
||||||
only:
|
only:
|
||||||
@ -115,5 +133,5 @@ pages:
|
|||||||
artifacts:
|
artifacts:
|
||||||
expire_in: 1 week
|
expire_in: 1 week
|
||||||
paths:
|
paths:
|
||||||
- public
|
- public
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
26
.vscode/settings.json
vendored
Normal file
26
.vscode/settings.json
vendored
Normal file
@ -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"]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
@ -1,5 +1,6 @@
|
|||||||
{
|
{
|
||||||
"gitzone": {
|
"gitzone": {
|
||||||
|
"projectType": "npm",
|
||||||
"module": {
|
"module": {
|
||||||
"githost": "gitlab.com",
|
"githost": "gitlab.com",
|
||||||
"gitscope": "pushrocks",
|
"gitscope": "pushrocks",
|
||||||
|
9948
package-lock.json
generated
9948
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
58
package.json
58
package.json
@ -1,53 +1,57 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartuniverse",
|
"name": "@pushrocks/smartuniverse",
|
||||||
"version": "1.0.93",
|
"version": "1.0.103",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "messaging service for your micro services",
|
"description": "messaging service for your micro services",
|
||||||
"main": "dist/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
"author": "Lossless GmbH",
|
"author": "Lossless GmbH",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "(tstest test/)",
|
"test": "(tstest test/)",
|
||||||
"testManual": "(tsrun test/test.ts)",
|
"testManual": "(tsrun test/test.ts)",
|
||||||
"build": "(tsbuild)",
|
"build": "(tsbuild --web && tsbundle --from ./ts/index.ts --to dist_bundle/bundle.js)",
|
||||||
"format": "(gitzone format)"
|
"format": "(gitzone format)"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@gitzone/tsbuild": "^2.1.17",
|
"@gitzone/tsbuild": "^2.1.25",
|
||||||
"@gitzone/tstest": "^1.0.28",
|
"@gitzone/tstest": "^1.0.48",
|
||||||
"@pushrocks/tapbundle": "^3.0.13",
|
"@pushrocks/tapbundle": "^3.2.9",
|
||||||
"@types/node": "^12.12.6",
|
"@types/node": "^14.11.2",
|
||||||
"tslint": "^5.20.1",
|
"tslint": "^6.1.3",
|
||||||
"tslint-config-prettier": "^1.18.0"
|
"tslint-config-prettier": "^1.18.0"
|
||||||
},
|
},
|
||||||
"peerDependencies": {
|
"peerDependencies": {
|
||||||
"rxjs": "*"
|
"rxjs": "*"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@apiglobal/typedrequest-interfaces": "^1.0.7",
|
"@apiglobal/typedrequest-interfaces": "^1.0.15",
|
||||||
"@pushrocks/lik": "^3.0.11",
|
"@pushrocks/lik": "^4.0.17",
|
||||||
"@pushrocks/smartdelay": "^2.0.6",
|
"@pushrocks/smartdelay": "^2.0.10",
|
||||||
"@pushrocks/smartexpress": "^3.0.52",
|
"@pushrocks/smartexpress": "^3.0.76",
|
||||||
"@pushrocks/smartfile": "^7.0.6",
|
"@pushrocks/smartfile": "^8.0.0",
|
||||||
"@pushrocks/smarthash": "^2.0.6",
|
"@pushrocks/smarthash": "^2.1.6",
|
||||||
"@pushrocks/smartlog": "^2.0.21",
|
"@pushrocks/smartlog": "^2.0.39",
|
||||||
"@pushrocks/smartpromise": "^3.0.6",
|
"@pushrocks/smartpromise": "^3.0.6",
|
||||||
"@pushrocks/smartrequest": "^1.1.42",
|
"@pushrocks/smartrequest": "^1.1.51",
|
||||||
"@pushrocks/smartrx": "^2.0.5",
|
"@pushrocks/smartrx": "^2.0.19",
|
||||||
"@pushrocks/smartsocket": "^1.1.58",
|
"@pushrocks/smartsocket": "^1.1.67",
|
||||||
"@pushrocks/smarttime": "^3.0.12",
|
"@pushrocks/smarttime": "^3.0.35",
|
||||||
"@pushrocks/smartunique": "^3.0.1"
|
"@pushrocks/smartunique": "^3.0.3"
|
||||||
},
|
},
|
||||||
"files": [
|
"files": [
|
||||||
"ts/*",
|
"ts/**/*",
|
||||||
"ts_web/*",
|
"ts_web/**/*",
|
||||||
"dist/*",
|
"dist/**/*",
|
||||||
"dist_web/*",
|
"dist_*/**/*",
|
||||||
"dist_ts_web/*",
|
"dist_ts/**/*",
|
||||||
"assets/*",
|
"dist_ts_web/**/*",
|
||||||
|
"assets/**/*",
|
||||||
"cli.js",
|
"cli.js",
|
||||||
"npmextra.json",
|
"npmextra.json",
|
||||||
"readme.md"
|
"readme.md"
|
||||||
|
],
|
||||||
|
"browserslist": [
|
||||||
|
"last 1 chrome versions"
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
|
27
readme.md
27
readme.md
@ -8,13 +8,20 @@ messaging service for micro services
|
|||||||
* [docs (typedoc)](https://pushrocks.gitlab.io/smartuniverse/)
|
* [docs (typedoc)](https://pushrocks.gitlab.io/smartuniverse/)
|
||||||
|
|
||||||
## Status for master
|
## Status for master
|
||||||
[](https://gitlab.com/pushrocks/smartuniverse/commits/master)
|
|
||||||
[](https://gitlab.com/pushrocks/smartuniverse/commits/master)
|
Status Category | Status Badge
|
||||||
[](https://www.npmjs.com/package/@pushrocks/smartuniverse)
|
-- | --
|
||||||
[](https://snyk.io/test/npm/@pushrocks/smartuniverse)
|
GitLab Pipelines | [](https://lossless.cloud)
|
||||||
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
GitLab Pipline Test Coverage | [](https://lossless.cloud)
|
||||||
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
npm | [](https://lossless.cloud)
|
||||||
[](https://prettier.io/)
|
Snyk | [](https://lossless.cloud)
|
||||||
|
TypeScript Support | [](https://lossless.cloud)
|
||||||
|
node Support | [](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
|
Code Style | [](https://lossless.cloud)
|
||||||
|
PackagePhobia (total standalone install weight) | [](https://lossless.cloud)
|
||||||
|
PackagePhobia (package size on registry) | [](https://lossless.cloud)
|
||||||
|
BundlePhobia (total size when bundled) | [](https://lossless.cloud)
|
||||||
|
Platform support | [](https://lossless.cloud) [](https://lossless.cloud)
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
|
||||||
@ -33,7 +40,7 @@ Think Kafka, but without Kafka.
|
|||||||
import * as smartuniverse from '@pushrocks/smartuniverse';
|
import * as smartuniverse from '@pushrocks/smartuniverse';
|
||||||
|
|
||||||
const myUniverse = new smartuniverse.Universe({
|
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
|
// create as many channels as you like
|
||||||
@ -47,6 +54,10 @@ myUniverse.start(8765); // start the server and provide the port on which to lis
|
|||||||
|
|
||||||
All your microservices represents clients in the universe that may talk to each other using the universe server.
|
All your microservices represents clients in the universe that may talk to each other using the universe server.
|
||||||
|
|
||||||
|
## Contribution
|
||||||
|
|
||||||
|
We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
|
||||||
|
|
||||||
For further information read the linked docs at the top of this readme.
|
For further information read the linked docs at the top of this readme.
|
||||||
|
|
||||||
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
||||||
|
41
test/test.ts
41
test/test.ts
@ -10,17 +10,17 @@ let testClientUniverse2: smartuniverse.ClientUniverse;
|
|||||||
let testClientChannel: smartuniverse.ClientUniverseChannel;
|
let testClientChannel: smartuniverse.ClientUniverseChannel;
|
||||||
|
|
||||||
const testServerData = {
|
const testServerData = {
|
||||||
serverAddress: 'http://localhost:8765'
|
serverAddress: 'http://localhost:8765',
|
||||||
};
|
};
|
||||||
|
|
||||||
const testChannelData = {
|
const testChannelData = {
|
||||||
channelName: 'awesomeTestChannel',
|
channelName: 'awesomeTestChannel',
|
||||||
channelPass: 'awesomeChannelPass'
|
channelPass: 'awesomeChannelPass',
|
||||||
};
|
};
|
||||||
|
|
||||||
tap.test('first test', async () => {
|
tap.test('first test', async () => {
|
||||||
testUniverse = new smartuniverse.Universe({
|
testUniverse = new smartuniverse.Universe({
|
||||||
messageExpiryInMilliseconds: 1000
|
messageExpiryInMilliseconds: 1000,
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -31,7 +31,8 @@ tap.test('add a message to the SmartUniverse', async () => {
|
|||||||
// testing message handling
|
// testing message handling
|
||||||
tap.test('create smartuniverse client', async () => {
|
tap.test('create smartuniverse client', async () => {
|
||||||
testClientUniverse = new smartuniverse.ClientUniverse({
|
testClientUniverse = new smartuniverse.ClientUniverse({
|
||||||
serverAddress: testServerData.serverAddress
|
serverAddress: testServerData.serverAddress,
|
||||||
|
autoReconnect: true,
|
||||||
});
|
});
|
||||||
expect(testClientUniverse).to.be.instanceof(smartuniverse.ClientUniverse);
|
expect(testClientUniverse).to.be.instanceof(smartuniverse.ClientUniverse);
|
||||||
});
|
});
|
||||||
@ -54,8 +55,8 @@ tap.test('should get a observable correctly', async () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
tap.test('should send a message correctly', async () => {
|
tap.test('should send a message correctly', async () => {
|
||||||
await testClientUniverse.getChannel(testChannelData.channelName).sendMessage({
|
await testClientUniverse.getChannel(testChannelData.channelName).postMessage({
|
||||||
messageText: 'hello'
|
messageText: 'hello',
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -65,7 +66,8 @@ tap.test('universe should contain the sent message', async () => {
|
|||||||
|
|
||||||
tap.test('a second client should be able to subscibe', async () => {
|
tap.test('a second client should be able to subscibe', async () => {
|
||||||
testClientUniverse2 = new smartuniverse.ClientUniverse({
|
testClientUniverse2 = new smartuniverse.ClientUniverse({
|
||||||
serverAddress: testServerData.serverAddress
|
serverAddress: testServerData.serverAddress,
|
||||||
|
autoReconnect: true,
|
||||||
});
|
});
|
||||||
|
|
||||||
testClientUniverse2.addChannel(testChannelData.channelName, testChannelData.channelPass);
|
testClientUniverse2.addChannel(testChannelData.channelName, testChannelData.channelPass);
|
||||||
@ -76,20 +78,20 @@ tap.test('should receive a message correctly', async (tools) => {
|
|||||||
const done = tools.defer();
|
const done = tools.defer();
|
||||||
const testChannel = testClientUniverse.getChannel(testChannelData.channelName);
|
const testChannel = testClientUniverse.getChannel(testChannelData.channelName);
|
||||||
const testChannel2 = testClientUniverse2.getChannel(testChannelData.channelName);
|
const testChannel2 = testClientUniverse2.getChannel(testChannelData.channelName);
|
||||||
const subscription = testChannel2.subscribe(messageArg => {
|
const subscription = testChannel2.subscribe((messageArg) => {
|
||||||
if (messageArg.messageText === 'hellothere') {
|
if (messageArg.messageText === 'hellothere') {
|
||||||
console.log('Yay##########');
|
console.log('Yay##########');
|
||||||
done.resolve();
|
done.resolve();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
await testChannel.sendMessage({
|
await testChannel.postMessage({
|
||||||
messageText: 'hellothere'
|
messageText: 'hellothere',
|
||||||
});
|
});
|
||||||
await done.promise;
|
await done.promise;
|
||||||
});
|
});
|
||||||
|
|
||||||
interface IDemoReqRes {
|
interface IDemoReqRes {
|
||||||
method: 'demo',
|
method: 'demo';
|
||||||
request: {
|
request: {
|
||||||
wowso: string;
|
wowso: string;
|
||||||
};
|
};
|
||||||
@ -101,20 +103,23 @@ interface IDemoReqRes {
|
|||||||
tap.test('ReactionRequest and ReactionResponse should work', async () => {
|
tap.test('ReactionRequest and ReactionResponse should work', async () => {
|
||||||
const reactionResponse = new smartuniverse.ReactionResponse<IDemoReqRes>({
|
const reactionResponse = new smartuniverse.ReactionResponse<IDemoReqRes>({
|
||||||
channels: [testUniverse.getChannel(testChannelData.channelName)],
|
channels: [testUniverse.getChannel(testChannelData.channelName)],
|
||||||
funcDef: async reqData => {
|
funcDef: async (reqData) => {
|
||||||
console.log(reqData);
|
console.log(reqData);
|
||||||
return {
|
return {
|
||||||
hereso: 'Hello there'
|
hereso: 'Hello there',
|
||||||
};
|
};
|
||||||
},
|
},
|
||||||
method: 'demo'
|
method: 'demo',
|
||||||
});
|
});
|
||||||
const reactionRequest = new smartuniverse.ReactionRequest<IDemoReqRes>({
|
const reactionRequest = new smartuniverse.ReactionRequest<IDemoReqRes>({
|
||||||
method: 'demo'
|
method: 'demo',
|
||||||
});
|
|
||||||
const reactionResult = await reactionRequest.fire([testClientUniverse2.getChannel(testChannelData.channelName)], {
|
|
||||||
wowso: 'wowza'
|
|
||||||
});
|
});
|
||||||
|
const reactionResult = await reactionRequest.fire(
|
||||||
|
[testClientUniverse2.getChannel(testChannelData.channelName)],
|
||||||
|
{
|
||||||
|
wowso: 'wowza',
|
||||||
|
}
|
||||||
|
);
|
||||||
const result = await reactionResult.getFirstResult();
|
const result = await reactionResult.getFirstResult();
|
||||||
console.log(result);
|
console.log(result);
|
||||||
});
|
});
|
||||||
|
10
ts/index.ts
10
ts/index.ts
@ -1,7 +1,7 @@
|
|||||||
// Client classes
|
// Client classes
|
||||||
export * from './smartuniverse.classes.clientuniverse';
|
export * from './smartuniverse.classes.client.universe';
|
||||||
export * from './smartuniverse.classes.clientuniversechannel';
|
export * from './smartuniverse.classes.client.universechannel';
|
||||||
export * from './smartuniverse.classes.clientuniversemessage';
|
export * from './smartuniverse.classes.client.universemessage';
|
||||||
|
|
||||||
// Server classes
|
// Server classes
|
||||||
export * from './smartuniverse.classes.universe';
|
export * from './smartuniverse.classes.universe';
|
||||||
@ -10,7 +10,7 @@ export * from './smartuniverse.classes.universechannel';
|
|||||||
export * from './smartuniverse.classes.universemessage';
|
export * from './smartuniverse.classes.universemessage';
|
||||||
|
|
||||||
// Reaction Response
|
// Reaction Response
|
||||||
export * from './smartuniverse.classes.reactionrequest';
|
export * from './smartuniverse.classes.event.reactionrequest';
|
||||||
export * from './smartuniverse.classes.reactionresponse';
|
export * from './smartuniverse.classes.event.reactionresponse';
|
||||||
|
|
||||||
export * from './interfaces';
|
export * from './interfaces';
|
||||||
|
@ -1,10 +0,0 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
|
||||||
|
|
||||||
/**
|
|
||||||
* broadcasts an event to multiple channels
|
|
||||||
*/
|
|
||||||
export class BroadcastEvent<T> {
|
|
||||||
fire() {
|
|
||||||
|
|
||||||
}
|
|
||||||
};
|
|
@ -1,5 +0,0 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
|
||||||
|
|
||||||
export class BroadcastSUbscription {
|
|
||||||
|
|
||||||
}
|
|
@ -1,17 +1,18 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
import * as plugins from './smartuniverse.plugins';
|
||||||
|
|
||||||
import { Objectmap } from '@pushrocks/lik';
|
|
||||||
import { Observable } from 'rxjs';
|
import { Observable } from 'rxjs';
|
||||||
import { Smartsocket, SmartsocketClient } from '@pushrocks/smartsocket';
|
import { Smartsocket, SmartsocketClient } from '@pushrocks/smartsocket';
|
||||||
import * as url from 'url';
|
import * as url from 'url';
|
||||||
|
|
||||||
import * as interfaces from './interfaces';
|
import * as interfaces from './interfaces';
|
||||||
|
|
||||||
import { ClientUniverseChannel, ClientUniverseMessage } from './';
|
import { ClientUniverseChannel, ClientUniverseMessage } from '.';
|
||||||
import { ClientUniverseCache } from './smartuniverse.classes.clientuniversecache';
|
import { ClientUniverseCache } from './smartuniverse.classes.client.universecache';
|
||||||
|
import { logger } from './smartuniverse.logging';
|
||||||
|
|
||||||
export interface IClientOptions {
|
export interface IClientOptions {
|
||||||
serverAddress: string;
|
serverAddress: string;
|
||||||
|
autoReconnect: boolean;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -24,6 +25,8 @@ export class ClientUniverse {
|
|||||||
public messageRxjsSubject = new plugins.smartrx.rxjs.Subject<ClientUniverseMessage<any>>();
|
public messageRxjsSubject = new plugins.smartrx.rxjs.Subject<ClientUniverseMessage<any>>();
|
||||||
public clientUniverseCache = new ClientUniverseCache();
|
public clientUniverseCache = new ClientUniverseCache();
|
||||||
|
|
||||||
|
public autoReconnectStatus: 'on' | 'off' = 'off';
|
||||||
|
|
||||||
constructor(optionsArg: IClientOptions) {
|
constructor(optionsArg: IClientOptions) {
|
||||||
this.options = optionsArg;
|
this.options = optionsArg;
|
||||||
}
|
}
|
||||||
@ -54,7 +57,7 @@ export class ClientUniverse {
|
|||||||
* @param passphraseArg
|
* @param passphraseArg
|
||||||
*/
|
*/
|
||||||
public getChannel(channelName: string): ClientUniverseChannel {
|
public getChannel(channelName: string): ClientUniverseChannel {
|
||||||
const clientUniverseChannel = this.clientUniverseCache.channelMap.find(channel => {
|
const clientUniverseChannel = this.clientUniverseCache.channelMap.find((channel) => {
|
||||||
return channel.name === channelName;
|
return channel.name === channelName;
|
||||||
});
|
});
|
||||||
return clientUniverseChannel;
|
return clientUniverseChannel;
|
||||||
@ -66,17 +69,21 @@ export class ClientUniverse {
|
|||||||
*/
|
*/
|
||||||
public removeChannel(channelNameArg, notifyServer = true) {
|
public removeChannel(channelNameArg, notifyServer = true) {
|
||||||
const clientUniverseChannel = this.clientUniverseCache.channelMap.findOneAndRemove(
|
const clientUniverseChannel = this.clientUniverseCache.channelMap.findOneAndRemove(
|
||||||
channelItemArg => {
|
(channelItemArg) => {
|
||||||
return channelItemArg.name === channelNameArg;
|
return channelItemArg.name === channelNameArg;
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
public async start() {
|
public async start() {
|
||||||
|
if (this.options.autoReconnect) {
|
||||||
|
this.autoReconnectStatus = 'on';
|
||||||
|
}
|
||||||
await this.checkConnection();
|
await this.checkConnection();
|
||||||
}
|
}
|
||||||
|
|
||||||
public async stop() {
|
public async stop() {
|
||||||
|
this.autoReconnectStatus = 'off';
|
||||||
await this.disconnect('triggered');
|
await this.disconnect('triggered');
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -84,7 +91,7 @@ export class ClientUniverse {
|
|||||||
* checks the connection towards a universe server
|
* checks the connection towards a universe server
|
||||||
* since password validation is done through other means, a connection should always be possible
|
* since password validation is done through other means, a connection should always be possible
|
||||||
*/
|
*/
|
||||||
public async checkConnection(): Promise<void> {
|
private async checkConnection(): Promise<void> {
|
||||||
if (!this.smartsocketClient) {
|
if (!this.smartsocketClient) {
|
||||||
const parsedURL = url.parse(this.options.serverAddress);
|
const parsedURL = url.parse(this.options.serverAddress);
|
||||||
const socketConfig: plugins.smartsocket.ISmartsocketClientOptions = {
|
const socketConfig: plugins.smartsocket.ISmartsocketClientOptions = {
|
||||||
@ -92,12 +99,12 @@ export class ClientUniverse {
|
|||||||
password: 'UniverseClient',
|
password: 'UniverseClient',
|
||||||
port: parseInt(parsedURL.port, 10),
|
port: parseInt(parsedURL.port, 10),
|
||||||
role: 'UniverseClient',
|
role: 'UniverseClient',
|
||||||
url: parsedURL.protocol + '//' + parsedURL.hostname
|
url: parsedURL.protocol + '//' + parsedURL.hostname,
|
||||||
};
|
};
|
||||||
this.smartsocketClient = new SmartsocketClient(socketConfig);
|
this.smartsocketClient = new SmartsocketClient(socketConfig);
|
||||||
|
|
||||||
this.smartsocketClient.eventSubject.subscribe(async eventArg => {
|
this.smartsocketClient.eventSubject.subscribe(async (eventArg) => {
|
||||||
switch(eventArg) {
|
switch (eventArg) {
|
||||||
case 'disconnected':
|
case 'disconnected':
|
||||||
this.disconnect('upstreamEvent');
|
this.disconnect('upstreamEvent');
|
||||||
}
|
}
|
||||||
@ -112,14 +119,14 @@ export class ClientUniverse {
|
|||||||
funcName: 'unsubscribe',
|
funcName: 'unsubscribe',
|
||||||
allowedRoles: [],
|
allowedRoles: [],
|
||||||
funcDef: async (dataArg: interfaces.IServerUnsubscribeActionPayload) => {
|
funcDef: async (dataArg: interfaces.IServerUnsubscribeActionPayload) => {
|
||||||
const channel = this.clientUniverseCache.channelMap.find(channelArg => {
|
const channel = this.clientUniverseCache.channelMap.find((channelArg) => {
|
||||||
return channelArg.name === dataArg.name;
|
return channelArg.name === dataArg.name;
|
||||||
});
|
});
|
||||||
if (channel) {
|
if (channel) {
|
||||||
channel.unsubscribe();
|
channel.unsubscribe();
|
||||||
}
|
}
|
||||||
return {};
|
return {};
|
||||||
}
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -130,8 +137,8 @@ export class ClientUniverse {
|
|||||||
>({
|
>({
|
||||||
funcName: 'processMessage',
|
funcName: 'processMessage',
|
||||||
allowedRoles: [],
|
allowedRoles: [],
|
||||||
funcDef: async messageDescriptorArg => {
|
funcDef: async (messageDescriptorArg) => {
|
||||||
plugins.smartlog.defaultLogger.log('info', 'Got message from server');
|
logger.log('info', 'Got message from server');
|
||||||
const clientUniverseMessage = ClientUniverseMessage.createMessageFromMessageDescriptor(
|
const clientUniverseMessage = ClientUniverseMessage.createMessageFromMessageDescriptor(
|
||||||
messageDescriptorArg
|
messageDescriptorArg
|
||||||
);
|
);
|
||||||
@ -142,14 +149,14 @@ export class ClientUniverse {
|
|||||||
if (targetChannel) {
|
if (targetChannel) {
|
||||||
await targetChannel.emitMessageLocally(clientUniverseMessage);
|
await targetChannel.emitMessageLocally(clientUniverseMessage);
|
||||||
return {
|
return {
|
||||||
messageStatus: 'ok'
|
messageStatus: 'ok',
|
||||||
};
|
};
|
||||||
} else {
|
} else {
|
||||||
return {
|
return {
|
||||||
messageStatus: 'channel not found'
|
messageStatus: 'channel not found',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
}
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
// add functions
|
// add functions
|
||||||
@ -157,21 +164,32 @@ export class ClientUniverse {
|
|||||||
this.smartsocketClient.addSocketFunction(socketFunctionProcessMessage);
|
this.smartsocketClient.addSocketFunction(socketFunctionProcessMessage);
|
||||||
|
|
||||||
await this.smartsocketClient.connect();
|
await this.smartsocketClient.connect();
|
||||||
plugins.smartlog.defaultLogger.log('info', 'universe client connected successfully');
|
logger.log('info', 'universe client connected successfully');
|
||||||
await this.clientUniverseCache.channelMap.forEach(async clientUniverseChannelArg => {
|
await this.clientUniverseCache.channelMap.forEach(async (clientUniverseChannelArg) => {
|
||||||
await clientUniverseChannelArg.populateSubscriptionToServer();
|
await clientUniverseChannelArg.populateSubscriptionToServer();
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public async disconnect(reason: 'upstreamEvent' | 'triggered' = 'triggered', tryReconnect = false) {
|
private async disconnect(
|
||||||
if ('triggered') {
|
reason: 'upstreamEvent' | 'triggered' = 'triggered',
|
||||||
this.smartsocketClient.disconnect();
|
tryReconnect = false
|
||||||
|
) {
|
||||||
|
const instructDisconnect = async () => {
|
||||||
|
if (this.smartsocketClient) {
|
||||||
|
const smartsocketToDisconnect = this.smartsocketClient;
|
||||||
|
this.smartsocketClient = null; // making sure the upstreamEvent does not interfere
|
||||||
|
await smartsocketToDisconnect.disconnect();
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
if (reason === 'triggered' && this.smartsocketClient) {
|
||||||
|
await instructDisconnect();
|
||||||
}
|
}
|
||||||
this.smartsocketClient = null;
|
if (this.autoReconnectStatus === 'on' && reason === 'upstreamEvent') {
|
||||||
if (tryReconnect) {
|
await instructDisconnect();
|
||||||
await plugins.smartdelay.delayForRandom(5000, 20000);
|
await plugins.smartdelay.delayForRandom(5000, 20000);
|
||||||
this.checkConnection();
|
await this.checkConnection();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -1,5 +1,5 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
import * as plugins from './smartuniverse.plugins';
|
||||||
import { ClientUniverseChannel } from './smartuniverse.classes.clientuniversechannel';
|
import { ClientUniverseChannel } from './smartuniverse.classes.client.universechannel';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* a cache for clients
|
* a cache for clients
|
||||||
@ -7,5 +7,5 @@ import { ClientUniverseChannel } from './smartuniverse.classes.clientuniversecha
|
|||||||
* good for deduplication in mesh environments
|
* good for deduplication in mesh environments
|
||||||
*/
|
*/
|
||||||
export class ClientUniverseCache {
|
export class ClientUniverseCache {
|
||||||
public channelMap = new plugins.lik.Objectmap<ClientUniverseChannel>();
|
public channelMap = new plugins.lik.ObjectMap<ClientUniverseChannel>();
|
||||||
}
|
}
|
@ -1,10 +1,10 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
import * as plugins from './smartuniverse.plugins';
|
||||||
import * as interfaces from './interfaces';
|
import * as interfaces from './interfaces';
|
||||||
|
|
||||||
import { ClientUniverse } from './';
|
import { ClientUniverse } from '.';
|
||||||
import { ClientUniverseMessage } from './smartuniverse.classes.clientuniversemessage';
|
import { ClientUniverseMessage } from './smartuniverse.classes.client.universemessage';
|
||||||
import { ReactionRequest } from './smartuniverse.classes.reactionrequest';
|
import { ReactionRequest } from './smartuniverse.classes.event.reactionrequest';
|
||||||
import { ReactionResponse } from './smartuniverse.classes.reactionresponse';
|
import { ReactionResponse } from './smartuniverse.classes.event.reactionresponse';
|
||||||
|
|
||||||
export class ClientUniverseChannel implements interfaces.IUniverseChannel {
|
export class ClientUniverseChannel implements interfaces.IUniverseChannel {
|
||||||
// ======
|
// ======
|
||||||
@ -54,12 +54,11 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
|
|||||||
* tells the universe about this instances interest into a channel
|
* tells the universe about this instances interest into a channel
|
||||||
*/
|
*/
|
||||||
public subscribe(observingFunctionArg: (messageArg: ClientUniverseMessage<any>) => void) {
|
public subscribe(observingFunctionArg: (messageArg: ClientUniverseMessage<any>) => void) {
|
||||||
|
|
||||||
return this.subject.subscribe(
|
return this.subject.subscribe(
|
||||||
messageArg => {
|
(messageArg) => {
|
||||||
observingFunctionArg(messageArg);
|
observingFunctionArg(messageArg);
|
||||||
},
|
},
|
||||||
error => console.log(error)
|
(error) => console.log(error)
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -74,7 +73,7 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
|
|||||||
interfaces.ISocketRequest_SubscribeChannel
|
interfaces.ISocketRequest_SubscribeChannel
|
||||||
>('subscribeChannel', {
|
>('subscribeChannel', {
|
||||||
name: this.name,
|
name: this.name,
|
||||||
passphrase: this.passphrase
|
passphrase: this.passphrase,
|
||||||
});
|
});
|
||||||
this.status = response.subscriptionStatus;
|
this.status = response.subscriptionStatus;
|
||||||
}
|
}
|
||||||
@ -88,15 +87,15 @@ export class ClientUniverseChannel implements interfaces.IUniverseChannel {
|
|||||||
* sends a message towards the server
|
* sends a message towards the server
|
||||||
* @param messageArg
|
* @param messageArg
|
||||||
*/
|
*/
|
||||||
public async sendMessage(messageArg: interfaces.IMessageCreator) {
|
public async postMessage(messageArg: interfaces.IMessageCreator) {
|
||||||
await this.clientUniverseRef.checkConnection();
|
await this.clientUniverseRef.start(); // its ok to call this multiple times
|
||||||
const universeMessageToSend: interfaces.IUniverseMessage = {
|
const universeMessageToSend: interfaces.IUniverseMessage = {
|
||||||
id: plugins.smartunique.shortId(),
|
id: plugins.smartunique.shortId(),
|
||||||
timestamp: Date.now(),
|
timestamp: Date.now(),
|
||||||
passphrase: this.passphrase,
|
passphrase: this.passphrase,
|
||||||
targetChannelName: this.name,
|
targetChannelName: this.name,
|
||||||
messageText: messageArg.messageText,
|
messageText: messageArg.messageText,
|
||||||
payload: messageArg.payload
|
payload: messageArg.payload,
|
||||||
};
|
};
|
||||||
await this.clientUniverseRef.smartsocketClient.serverCall(
|
await this.clientUniverseRef.smartsocketClient.serverCall(
|
||||||
'processMessage',
|
'processMessage',
|
17
ts/smartuniverse.classes.event.broadcastevent.ts
Normal file
17
ts/smartuniverse.classes.event.broadcastevent.ts
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
import * as plugins from './smartuniverse.plugins';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* broadcasts an event to multiple channels
|
||||||
|
* 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']) {}
|
||||||
|
|
||||||
|
public subscribe(funcArg: (nextArg: T['payload']) => void): plugins.smartrx.rxjs.Subscription {
|
||||||
|
return this.eventSubject.subscribe(funcArg);
|
||||||
|
}
|
||||||
|
}
|
@ -1,11 +1,13 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
import * as plugins from './smartuniverse.plugins';
|
||||||
import { UniverseChannel } from './smartuniverse.classes.universechannel';
|
import { UniverseChannel } from './smartuniverse.classes.universechannel';
|
||||||
import { ClientUniverseChannel } from './smartuniverse.classes.clientuniversechannel';
|
import { ClientUniverseChannel } from './smartuniverse.classes.client.universechannel';
|
||||||
import { ReactionResult } from './smartuniverse.classes.reactionresult';
|
import { ReactionResult } from './smartuniverse.classes.event.reactionresult';
|
||||||
import { UniverseMessage } from './smartuniverse.classes.universemessage';
|
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> {
|
export interface IReactionRequestConstructorOptions<
|
||||||
|
T extends plugins.typedrequestInterfaces.ITypedRequest
|
||||||
|
> {
|
||||||
method: T['method'];
|
method: T['method'];
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -15,9 +17,9 @@ export interface ICombinatorPayload<T extends plugins.typedrequestInterfaces.ITy
|
|||||||
*/
|
*/
|
||||||
id: string;
|
id: string;
|
||||||
typedRequestPayload: {
|
typedRequestPayload: {
|
||||||
method: T['method'],
|
method: T['method'];
|
||||||
request : T['request'],
|
request: T['request'];
|
||||||
response: T['response']
|
response: T['response'];
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -28,35 +30,50 @@ export class ReactionRequest<T extends plugins.typedrequestInterfaces.ITypedRequ
|
|||||||
this.method = optionsArg.method;
|
this.method = optionsArg.method;
|
||||||
}
|
}
|
||||||
|
|
||||||
public async fire(channelsArg: Array<UniverseChannel | ClientUniverseChannel>, requestDataArg: T['request'], timeoutMillisArg=5000) {
|
public async fire(
|
||||||
const subscriptionMap = new plugins.lik.Objectmap<plugins.smartrx.rxjs.Subscription>();
|
channelsArg: Array<UniverseChannel | ClientUniverseChannel>,
|
||||||
|
requestDataArg: T['request'],
|
||||||
|
timeoutMillisArg = 5000
|
||||||
|
) {
|
||||||
|
const subscriptionMap = new plugins.lik.ObjectMap<plugins.smartrx.rxjs.Subscription>();
|
||||||
const reactionResult = new ReactionResult<T>();
|
const reactionResult = new ReactionResult<T>();
|
||||||
const requestId = plugins.smartunique.shortId();
|
const requestId = plugins.smartunique.shortId();
|
||||||
for (const channel of channelsArg) {
|
for (const channel of channelsArg) {
|
||||||
subscriptionMap.add(channel.subscribe((messageArg: UniverseMessage<ICombinatorPayload<T>> | ClientUniverseMessage<ICombinatorPayload<T>>) => {
|
subscriptionMap.add(
|
||||||
if (messageArg.messageText === 'reactionResponse' && messageArg.payload.typedRequestPayload.method === this.method) {
|
channel.subscribe(
|
||||||
const payload: ICombinatorPayload<T> = messageArg.payload;
|
(
|
||||||
if (payload.id !== requestId) {
|
messageArg:
|
||||||
return;
|
| UniverseMessage<ICombinatorPayload<T>>
|
||||||
|
| ClientUniverseMessage<ICombinatorPayload<T>>
|
||||||
|
) => {
|
||||||
|
if (
|
||||||
|
messageArg.messageText === 'reactionResponse' &&
|
||||||
|
messageArg.payload.typedRequestPayload.method === this.method
|
||||||
|
) {
|
||||||
|
const payload: ICombinatorPayload<T> = messageArg.payload;
|
||||||
|
if (payload.id !== requestId) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
reactionResult.pushReactionResponse(payload.typedRequestPayload.response);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
reactionResult.pushReactionResponse(payload.typedRequestPayload.response);
|
)
|
||||||
}
|
);
|
||||||
}));
|
|
||||||
const payload: ICombinatorPayload<T> = {
|
const payload: ICombinatorPayload<T> = {
|
||||||
id: requestId,
|
id: requestId,
|
||||||
typedRequestPayload: {
|
typedRequestPayload: {
|
||||||
method: this.method,
|
method: this.method,
|
||||||
request: requestDataArg,
|
request: requestDataArg,
|
||||||
response: null
|
response: null,
|
||||||
}
|
},
|
||||||
};
|
};
|
||||||
channel.sendMessage({
|
channel.postMessage({
|
||||||
messageText: 'reactionRequest',
|
messageText: 'reactionRequest',
|
||||||
payload
|
payload,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
plugins.smartdelay.delayFor(timeoutMillisArg).then(async () => {
|
plugins.smartdelay.delayFor(timeoutMillisArg).then(async () => {
|
||||||
await subscriptionMap.forEach(subscriptionArg => {
|
await subscriptionMap.forEach((subscriptionArg) => {
|
||||||
subscriptionArg.unsubscribe();
|
subscriptionArg.unsubscribe();
|
||||||
});
|
});
|
||||||
reactionResult.complete();
|
reactionResult.complete();
|
@ -1,12 +1,14 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
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 { 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 { 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']) => Promise<T['response']>;
|
export type TReactionResponseFuncDef<T extends plugins.typedrequestInterfaces.ITypedRequest> = (
|
||||||
|
dataArg: T['request']
|
||||||
|
) => Promise<T['response']>;
|
||||||
|
|
||||||
export interface IReactionResponseConstructorOptions<
|
export interface IReactionResponseConstructorOptions<
|
||||||
T extends plugins.typedrequestInterfaces.ITypedRequest
|
T extends plugins.typedrequestInterfaces.ITypedRequest
|
||||||
@ -18,7 +20,7 @@ export interface IReactionResponseConstructorOptions<
|
|||||||
|
|
||||||
export class ReactionResponse<T extends plugins.typedrequestInterfaces.ITypedRequest> {
|
export class ReactionResponse<T extends plugins.typedrequestInterfaces.ITypedRequest> {
|
||||||
public method: T['method'];
|
public method: T['method'];
|
||||||
public channels = new plugins.lik.Objectmap<UniverseChannel | ClientUniverseChannel>();
|
public channels = new plugins.lik.ObjectMap<UniverseChannel | ClientUniverseChannel>();
|
||||||
public funcDef: TReactionResponseFuncDef<T>;
|
public funcDef: TReactionResponseFuncDef<T>;
|
||||||
|
|
||||||
constructor(optionsArg: IReactionResponseConstructorOptions<T>) {
|
constructor(optionsArg: IReactionResponseConstructorOptions<T>) {
|
||||||
@ -26,7 +28,7 @@ export class ReactionResponse<T extends plugins.typedrequestInterfaces.ITypedReq
|
|||||||
this.channels.addArray(optionsArg.channels);
|
this.channels.addArray(optionsArg.channels);
|
||||||
this.funcDef = optionsArg.funcDef;
|
this.funcDef = optionsArg.funcDef;
|
||||||
for (const channel of this.channels.getArray()) {
|
for (const channel of this.channels.getArray()) {
|
||||||
channel.subscribe(messageArg => {
|
channel.subscribe((messageArg) => {
|
||||||
this.processMessageForReaction(channel, messageArg);
|
this.processMessageForReaction(channel, messageArg);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@ -42,17 +44,19 @@ export class ReactionResponse<T extends plugins.typedrequestInterfaces.ITypedReq
|
|||||||
messageArg.messageText === 'reactionRequest' &&
|
messageArg.messageText === 'reactionRequest' &&
|
||||||
messageArg.payload.typedRequestPayload.method === this.method
|
messageArg.payload.typedRequestPayload.method === this.method
|
||||||
) {
|
) {
|
||||||
const response: T['response'] = await this.funcDef(messageArg.payload.typedRequestPayload.request);
|
const response: T['response'] = await this.funcDef(
|
||||||
|
messageArg.payload.typedRequestPayload.request
|
||||||
|
);
|
||||||
const payload: ICombinatorPayload<T> = {
|
const payload: ICombinatorPayload<T> = {
|
||||||
...messageArg.payload,
|
...messageArg.payload,
|
||||||
typedRequestPayload: {
|
typedRequestPayload: {
|
||||||
...messageArg.payload.typedRequestPayload,
|
...messageArg.payload.typedRequestPayload,
|
||||||
response
|
response,
|
||||||
}
|
},
|
||||||
};
|
};
|
||||||
channelArg.sendMessage({
|
channelArg.postMessage({
|
||||||
messageText: 'reactionResponse',
|
messageText: 'reactionResponse',
|
||||||
payload
|
payload,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -1,13 +1,13 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
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> {
|
export class ReactionResult<T extends plugins.typedrequestInterfaces.ITypedRequest> {
|
||||||
private resultReplaySubject = new plugins.smartrx.rxjs.ReplaySubject<T['response']>();
|
private resultReplaySubject = new plugins.smartrx.rxjs.ReplaySubject<T['response']>();
|
||||||
private endResult: Array<T['response']> = [];
|
private endResult: Array<T['response']> = [];
|
||||||
private completeDeferred = plugins.smartpromise.defer<Array<T['response']>>();
|
private completeDeferred = plugins.smartpromise.defer<Array<T['response']>>();
|
||||||
|
|
||||||
constructor () {
|
constructor() {
|
||||||
this.resultSubscribe(responseArg => {
|
this.resultSubscribe((responseArg) => {
|
||||||
this.endResult.push(responseArg);
|
this.endResult.push(responseArg);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@ -29,7 +29,7 @@ export class ReactionResult<T extends plugins.typedrequestInterfaces.ITypedReque
|
|||||||
*/
|
*/
|
||||||
public async getFirstResult() {
|
public async getFirstResult() {
|
||||||
const done = plugins.smartpromise.defer<T['response']>();
|
const done = plugins.smartpromise.defer<T['response']>();
|
||||||
const subscription = this.resultReplaySubject.subscribe(result => {
|
const subscription = this.resultReplaySubject.subscribe((result) => {
|
||||||
done.resolve(result);
|
done.resolve(result);
|
||||||
subscription.unsubscribe();
|
subscription.unsubscribe();
|
||||||
});
|
});
|
@ -1,4 +1,5 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
import * as plugins from './smartuniverse.plugins';
|
||||||
|
import * as pluginsTyped from './smartuniverse.pluginstyped';
|
||||||
|
|
||||||
import { Handler, Route, Server } from '@pushrocks/smartexpress';
|
import { Handler, Route, Server } from '@pushrocks/smartexpress';
|
||||||
import { UniverseCache, UniverseChannel, UniverseMessage } from './';
|
import { UniverseCache, UniverseChannel, UniverseMessage } from './';
|
||||||
@ -7,10 +8,11 @@ import * as paths from './smartuniverse.paths';
|
|||||||
|
|
||||||
import * as interfaces from './interfaces';
|
import * as interfaces from './interfaces';
|
||||||
import { UniverseConnection } from './smartuniverse.classes.universeconnection';
|
import { UniverseConnection } from './smartuniverse.classes.universeconnection';
|
||||||
|
import { logger } from './smartuniverse.logging';
|
||||||
|
|
||||||
export interface ISmartUniverseConstructorOptions {
|
export interface ISmartUniverseConstructorOptions {
|
||||||
messageExpiryInMilliseconds: number;
|
messageExpiryInMilliseconds: number;
|
||||||
externalServer?: plugins.smartexpress.Server;
|
externalServer?: pluginsTyped.smartexpress.Server;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -26,7 +28,7 @@ export class Universe {
|
|||||||
/**
|
/**
|
||||||
* the smartexpress server used
|
* the smartexpress server used
|
||||||
*/
|
*/
|
||||||
private smartexpressServer: plugins.smartexpress.Server;
|
private smartexpressServer: pluginsTyped.smartexpress.Server;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* the smartsocket used
|
* the smartsocket used
|
||||||
@ -69,7 +71,7 @@ export class Universe {
|
|||||||
* returns a channel
|
* returns a channel
|
||||||
*/
|
*/
|
||||||
public getChannel(channelNameArg: string) {
|
public getChannel(channelNameArg: string) {
|
||||||
return this.universeCache.channelMap.find(channelArg => {
|
return this.universeCache.channelMap.find((channelArg) => {
|
||||||
return channelArg.name === channelNameArg;
|
return channelArg.name === channelNameArg;
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@ -78,28 +80,21 @@ export class Universe {
|
|||||||
* initiates a server
|
* initiates a server
|
||||||
*/
|
*/
|
||||||
public async start(portArg: number) {
|
public async start(portArg: number) {
|
||||||
// lets create the base smartexpress server
|
|
||||||
if (!this.options.externalServer) {
|
|
||||||
this.smartexpressServer = new plugins.smartexpress.Server({
|
|
||||||
cors: true,
|
|
||||||
defaultAnswer: async () => {
|
|
||||||
return `smartuniverse server ${this.getUniverseVersion()}`;
|
|
||||||
},
|
|
||||||
forceSsl: false,
|
|
||||||
port: portArg
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
console.log('Universe is using externally supplied server');
|
|
||||||
this.smartexpressServer = this.options.externalServer;
|
|
||||||
}
|
|
||||||
|
|
||||||
// add websocket upgrade
|
// add websocket upgrade
|
||||||
this.smartsocket = new plugins.smartsocket.Smartsocket({});
|
this.smartsocket = new plugins.smartsocket.Smartsocket({
|
||||||
|
port: portArg
|
||||||
|
});
|
||||||
|
|
||||||
|
// lets create the base smartexpress server
|
||||||
|
if (this.options.externalServer) {
|
||||||
|
console.log('Universe is using externally supplied server');
|
||||||
|
this.smartsocket.setExternalServer('smartexpress' ,this.options.externalServer);
|
||||||
|
}
|
||||||
|
|
||||||
// add a role for the clients
|
// add a role for the clients
|
||||||
const ClientRole = new plugins.smartsocket.SocketRole({
|
const ClientRole = new plugins.smartsocket.SocketRole({
|
||||||
name: 'UniverseClient',
|
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
|
// add the role to smartsocket
|
||||||
@ -114,13 +109,13 @@ export class Universe {
|
|||||||
const universeConnection = new UniverseConnection({
|
const universeConnection = new UniverseConnection({
|
||||||
universe: this,
|
universe: this,
|
||||||
socketConnection: socketConnectionArg,
|
socketConnection: socketConnectionArg,
|
||||||
authenticationRequests: [dataArg]
|
authenticationRequests: [dataArg],
|
||||||
});
|
});
|
||||||
await UniverseConnection.addConnectionToCache(this, universeConnection);
|
await UniverseConnection.addConnectionToCache(this, universeConnection);
|
||||||
return {
|
return {
|
||||||
subscriptionStatus: 'subscribed'
|
subscriptionStatus: 'subscribed',
|
||||||
};
|
};
|
||||||
}
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
const socketFunctionProcessMessage = new plugins.smartsocket.SocketFunction({
|
const socketFunctionProcessMessage = new plugins.smartsocket.SocketFunction({
|
||||||
@ -132,17 +127,11 @@ export class Universe {
|
|||||||
socketConnectionArg
|
socketConnectionArg
|
||||||
);
|
);
|
||||||
if (universeConnection) {
|
if (universeConnection) {
|
||||||
plugins.smartlog.defaultLogger.log(
|
logger.log('ok', 'found UniverseConnection for socket for incoming message');
|
||||||
'ok',
|
|
||||||
'found UniverseConnection for socket for incoming message'
|
|
||||||
);
|
|
||||||
} else {
|
} else {
|
||||||
plugins.smartlog.defaultLogger.log(
|
logger.log('warn', 'found no Authorized channel for incoming message');
|
||||||
'warn',
|
|
||||||
'found no Authorized channel for incoming message'
|
|
||||||
);
|
|
||||||
return {
|
return {
|
||||||
error: 'You need to authenticate for a channel'
|
error: 'You need to authenticate for a channel',
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
const unauthenticatedMessage = UniverseMessage.createMessageFromPayload(
|
const unauthenticatedMessage = UniverseMessage.createMessageFromPayload(
|
||||||
@ -157,22 +146,16 @@ export class Universe {
|
|||||||
const authenticatedMessage = unauthenticatedMessage;
|
const authenticatedMessage = unauthenticatedMessage;
|
||||||
await this.universeCache.addMessage(authenticatedMessage);
|
await this.universeCache.addMessage(authenticatedMessage);
|
||||||
}
|
}
|
||||||
}
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
// add socket functions
|
// add socket functions
|
||||||
this.smartsocket.addSocketFunction(socketFunctionSubscription);
|
this.smartsocket.addSocketFunction(socketFunctionSubscription);
|
||||||
this.smartsocket.addSocketFunction(socketFunctionProcessMessage);
|
this.smartsocket.addSocketFunction(socketFunctionProcessMessage);
|
||||||
|
|
||||||
// start the server
|
|
||||||
if (!this.options.externalServer) {
|
|
||||||
await this.smartexpressServer.start();
|
|
||||||
}
|
|
||||||
|
|
||||||
// add smartsocket to the running smartexpress app
|
// add smartsocket to the running smartexpress app
|
||||||
await this.smartsocket.setExternalServer('smartexpress', this.smartexpressServer);
|
|
||||||
await this.smartsocket.start();
|
await this.smartsocket.start();
|
||||||
plugins.smartlog.defaultLogger.log('success', 'started universe');
|
logger.log('success', 'started universe');
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -180,8 +163,5 @@ export class Universe {
|
|||||||
*/
|
*/
|
||||||
public async stopServer() {
|
public async stopServer() {
|
||||||
await this.smartsocket.stop();
|
await this.smartsocket.stop();
|
||||||
if (!this.options.externalServer) {
|
|
||||||
await this.smartexpressServer.stop();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -3,11 +3,10 @@ import * as plugins from './smartuniverse.plugins';
|
|||||||
import { UniverseChannel } from './smartuniverse.classes.universechannel';
|
import { UniverseChannel } from './smartuniverse.classes.universechannel';
|
||||||
import { UniverseMessage } from './smartuniverse.classes.universemessage';
|
import { UniverseMessage } from './smartuniverse.classes.universemessage';
|
||||||
|
|
||||||
import { Objectmap } from '@pushrocks/lik';
|
import { ObjectMap } from '@pushrocks/lik';
|
||||||
|
|
||||||
import { Observable, from } from 'rxjs';
|
import { Observable, from } from 'rxjs';
|
||||||
import { filter } from 'rxjs/operators';
|
import { filter } from 'rxjs/operators';
|
||||||
import { rxjs } from '@pushrocks/smartrx';
|
|
||||||
import { UniverseConnection } from './smartuniverse.classes.universeconnection';
|
import { UniverseConnection } from './smartuniverse.classes.universeconnection';
|
||||||
import { Universe } from './smartuniverse.classes.universe';
|
import { Universe } from './smartuniverse.classes.universe';
|
||||||
|
|
||||||
@ -24,17 +23,17 @@ export class UniverseCache {
|
|||||||
/**
|
/**
|
||||||
* stores messages for this instance
|
* stores messages for this instance
|
||||||
*/
|
*/
|
||||||
public messageMap = new Objectmap<UniverseMessage<any>>();
|
public messageMap = new ObjectMap<UniverseMessage<any>>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* stores the channels that are available within the universe
|
* stores the channels that are available within the universe
|
||||||
*/
|
*/
|
||||||
public channelMap = new Objectmap<UniverseChannel>();
|
public channelMap = new ObjectMap<UniverseChannel>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* stores all connections
|
* stores all connections
|
||||||
*/
|
*/
|
||||||
public connectionMap = new plugins.lik.Objectmap<UniverseConnection>();
|
public connectionMap = new plugins.lik.ObjectMap<UniverseConnection>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* allows messages to be processed in a blacklist mode for further analysis
|
* allows messages to be processed in a blacklist mode for further analysis
|
||||||
@ -58,7 +57,7 @@ export class UniverseCache {
|
|||||||
messageArg.setUniverseCache(this);
|
messageArg.setUniverseCache(this);
|
||||||
UniverseChannel.authorizeAMessageForAChannel(this, messageArg);
|
UniverseChannel.authorizeAMessageForAChannel(this, messageArg);
|
||||||
this.messageMap.add(messageArg);
|
this.messageMap.add(messageArg);
|
||||||
messageArg.universeChannelList.forEach(universeChannel => {
|
messageArg.universeChannelList.forEach((universeChannel) => {
|
||||||
universeChannel.push(messageArg);
|
universeChannel.push(messageArg);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@ -71,7 +70,7 @@ export class UniverseCache {
|
|||||||
channelName?: string
|
channelName?: string
|
||||||
): Observable<UniverseMessage<any>> {
|
): Observable<UniverseMessage<any>> {
|
||||||
const messageObservable = from(this.messageMap.getArray()).pipe(
|
const messageObservable = from(this.messageMap.getArray()).pipe(
|
||||||
filter(messageArg => {
|
filter((messageArg) => {
|
||||||
return messageArg.smartTimestamp.isYoungerThanMilliSeconds(this.destructionTime);
|
return messageArg.smartTimestamp.isYoungerThanMilliSeconds(this.destructionTime);
|
||||||
})
|
})
|
||||||
);
|
);
|
||||||
|
@ -5,6 +5,7 @@ import { UniverseCache } from './smartuniverse.classes.universecache';
|
|||||||
import { UniverseMessage } from './smartuniverse.classes.universemessage';
|
import { UniverseMessage } from './smartuniverse.classes.universemessage';
|
||||||
import { UniverseConnection } from './smartuniverse.classes.universeconnection';
|
import { UniverseConnection } from './smartuniverse.classes.universeconnection';
|
||||||
import { Universe } from './smartuniverse.classes.universe';
|
import { Universe } from './smartuniverse.classes.universe';
|
||||||
|
import { logger } from './smartuniverse.logging';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* enables messages to stay within a certain scope.
|
* enables messages to stay within a certain scope.
|
||||||
@ -33,7 +34,7 @@ export class UniverseChannel {
|
|||||||
* returns boolean wether certain channel exists
|
* returns boolean wether certain channel exists
|
||||||
*/
|
*/
|
||||||
public static async doesChannelExists(universeCacheArg: UniverseCache, channelNameArg: string) {
|
public static async doesChannelExists(universeCacheArg: UniverseCache, channelNameArg: string) {
|
||||||
const channel = universeCacheArg.channelMap.find(channelArg => {
|
const channel = universeCacheArg.channelMap.find((channelArg) => {
|
||||||
return channelArg.name === channelNameArg;
|
return channelArg.name === channelNameArg;
|
||||||
});
|
});
|
||||||
if (channel) {
|
if (channel) {
|
||||||
@ -54,25 +55,25 @@ export class UniverseChannel {
|
|||||||
universeCacheArg: UniverseCache,
|
universeCacheArg: UniverseCache,
|
||||||
universeMessageArg: UniverseMessage<any>
|
universeMessageArg: UniverseMessage<any>
|
||||||
): UniverseChannel {
|
): UniverseChannel {
|
||||||
const foundChannel = universeCacheArg.channelMap.find(universeChannel => {
|
const foundChannel = universeCacheArg.channelMap.find((universeChannel) => {
|
||||||
const result = universeChannel.authenticate(universeMessageArg);
|
const result = universeChannel.authenticate(universeMessageArg);
|
||||||
return result;
|
return result;
|
||||||
});
|
});
|
||||||
if (foundChannel) {
|
if (foundChannel) {
|
||||||
universeMessageArg.authenticated = true;
|
universeMessageArg.authenticated = true;
|
||||||
universeMessageArg.universeChannelList.add(foundChannel);
|
universeMessageArg.universeChannelList.add(foundChannel);
|
||||||
plugins.smartlog.defaultLogger.log('ok', 'message authorized');
|
logger.log('ok', 'message authorized');
|
||||||
return foundChannel;
|
return foundChannel;
|
||||||
} else {
|
} else {
|
||||||
universeMessageArg.authenticated = false;
|
universeMessageArg.authenticated = false;
|
||||||
universeMessageArg.universeChannelList.add(universeCacheArg.blackListChannel);
|
universeMessageArg.universeChannelList.add(universeCacheArg.blackListChannel);
|
||||||
plugins.smartlog.defaultLogger.log('warn', 'message not valid');
|
logger.log('warn', 'message not valid');
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static getUniverseChannelByName(universeRef: Universe, universeChannelName: string) {
|
public static getUniverseChannelByName(universeRef: Universe, universeChannelName: string) {
|
||||||
return universeRef.universeCache.channelMap.find(channelArg => {
|
return universeRef.universeCache.channelMap.find((channelArg) => {
|
||||||
return channelArg.name === universeChannelName;
|
return channelArg.name === universeChannelName;
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@ -117,7 +118,7 @@ export class UniverseChannel {
|
|||||||
public async push(messageArg: UniverseMessage<any>) {
|
public async push(messageArg: UniverseMessage<any>) {
|
||||||
this.subject.next(messageArg);
|
this.subject.next(messageArg);
|
||||||
const universeConnectionsWithChannelAccess: UniverseConnection[] = [];
|
const universeConnectionsWithChannelAccess: UniverseConnection[] = [];
|
||||||
await this.universeRef.universeCache.connectionMap.forEach(async socketConnection => {
|
await this.universeRef.universeCache.connectionMap.forEach(async (socketConnection) => {
|
||||||
if (socketConnection.authenticatedChannels.includes(this)) {
|
if (socketConnection.authenticatedChannels.includes(this)) {
|
||||||
universeConnectionsWithChannelAccess.push(socketConnection);
|
universeConnectionsWithChannelAccess.push(socketConnection);
|
||||||
}
|
}
|
||||||
@ -131,7 +132,7 @@ export class UniverseChannel {
|
|||||||
passphrase: messageArg.passphrase,
|
passphrase: messageArg.passphrase,
|
||||||
targetChannelName: this.name,
|
targetChannelName: this.name,
|
||||||
messageText: messageArg.messageText,
|
messageText: messageArg.messageText,
|
||||||
payload: messageArg.payload
|
payload: messageArg.payload,
|
||||||
};
|
};
|
||||||
smartsocket.clientCall(
|
smartsocket.clientCall(
|
||||||
'processMessage',
|
'processMessage',
|
||||||
@ -144,24 +145,24 @@ export class UniverseChannel {
|
|||||||
// functions to interact with a channel locally
|
// functions to interact with a channel locally
|
||||||
public subscribe(observingFunctionArg: (messageArg: UniverseMessage<any>) => void) {
|
public subscribe(observingFunctionArg: (messageArg: UniverseMessage<any>) => void) {
|
||||||
return this.subject.subscribe(
|
return this.subject.subscribe(
|
||||||
messageArg => {
|
(messageArg) => {
|
||||||
observingFunctionArg(messageArg);
|
observingFunctionArg(messageArg);
|
||||||
},
|
},
|
||||||
error => console.log(error)
|
(error) => console.log(error)
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* sends a message to the channel
|
* sends a message to the channel
|
||||||
*/
|
*/
|
||||||
public async sendMessage(messageDescriptor: interfaces.IMessageCreator) {
|
public async postMessage(messageDescriptor: interfaces.IMessageCreator) {
|
||||||
const messageToSend = new UniverseMessage({
|
const messageToSend = new UniverseMessage({
|
||||||
id: plugins.smartunique.shortId(),
|
id: plugins.smartunique.shortId(),
|
||||||
messageText: messageDescriptor.messageText,
|
messageText: messageDescriptor.messageText,
|
||||||
payload: messageDescriptor.payload,
|
payload: messageDescriptor.payload,
|
||||||
targetChannelName: this.name,
|
targetChannelName: this.name,
|
||||||
passphrase: this.passphrase,
|
passphrase: this.passphrase,
|
||||||
timestamp: Date.now()
|
timestamp: Date.now(),
|
||||||
});
|
});
|
||||||
this.universeRef.universeCache.addMessage(messageToSend);
|
this.universeRef.universeCache.addMessage(messageToSend);
|
||||||
}
|
}
|
||||||
|
@ -37,7 +37,7 @@ export class UniverseConnection {
|
|||||||
universeConnectionArg: UniverseConnection
|
universeConnectionArg: UniverseConnection
|
||||||
): Promise<UniverseConnection> {
|
): Promise<UniverseConnection> {
|
||||||
let connectionToReturn: UniverseConnection;
|
let connectionToReturn: UniverseConnection;
|
||||||
universeCache.connectionMap.forEach(async existingConnection => {
|
universeCache.connectionMap.forEach(async (existingConnection) => {
|
||||||
if (existingConnection.socketConnection === universeConnectionArg.socketConnection) {
|
if (existingConnection.socketConnection === universeConnectionArg.socketConnection) {
|
||||||
connectionToReturn = await this.mergeUniverseConnections(
|
connectionToReturn = await this.mergeUniverseConnections(
|
||||||
existingConnection,
|
existingConnection,
|
||||||
@ -87,7 +87,7 @@ export class UniverseConnection {
|
|||||||
universeCache: UniverseCache,
|
universeCache: UniverseCache,
|
||||||
socketConnectionArg: plugins.smartsocket.SocketConnection
|
socketConnectionArg: plugins.smartsocket.SocketConnection
|
||||||
): UniverseConnection {
|
): UniverseConnection {
|
||||||
const universeConnection = universeCache.connectionMap.find(universeConnectionArg => {
|
const universeConnection = universeCache.connectionMap.find((universeConnectionArg) => {
|
||||||
return universeConnectionArg.socketConnection === socketConnectionArg;
|
return universeConnectionArg.socketConnection === socketConnectionArg;
|
||||||
});
|
});
|
||||||
return universeConnection;
|
return universeConnection;
|
||||||
@ -121,9 +121,10 @@ export class UniverseConnection {
|
|||||||
socketConnection: plugins.smartsocket.SocketConnection;
|
socketConnection: plugins.smartsocket.SocketConnection;
|
||||||
authenticationRequests: Array<interfaces.ISocketRequest_SubscribeChannel['request']>;
|
authenticationRequests: Array<interfaces.ISocketRequest_SubscribeChannel['request']>;
|
||||||
}) {
|
}) {
|
||||||
|
this.universeRef = optionsArg.universe;
|
||||||
this.authenticationRequests = optionsArg.authenticationRequests;
|
this.authenticationRequests = optionsArg.authenticationRequests;
|
||||||
this.socketConnection = optionsArg.socketConnection;
|
this.socketConnection = optionsArg.socketConnection;
|
||||||
this.socketConnection.eventSubject.subscribe(async eventArg => {
|
this.socketConnection.eventSubject.subscribe(async (eventArg) => {
|
||||||
switch (eventArg) {
|
switch (eventArg) {
|
||||||
case 'disconnected':
|
case 'disconnected':
|
||||||
await this.disconnect('upstreamevent');
|
await this.disconnect('upstreamevent');
|
||||||
|
@ -1,13 +1,12 @@
|
|||||||
import * as plugins from './smartuniverse.plugins';
|
import * as plugins from './smartuniverse.plugins';
|
||||||
import * as interfaces from './interfaces';
|
import * as interfaces from './interfaces';
|
||||||
|
|
||||||
import { Objectmap } from '@pushrocks/lik';
|
|
||||||
|
|
||||||
import { Timer, TimeStamp } from '@pushrocks/smarttime';
|
import { Timer, TimeStamp } from '@pushrocks/smarttime';
|
||||||
import { Universe } from './smartuniverse.classes.universe';
|
import { Universe } from './smartuniverse.classes.universe';
|
||||||
import { UniverseChannel } from './smartuniverse.classes.universechannel';
|
import { UniverseChannel } from './smartuniverse.classes.universechannel';
|
||||||
import { UniverseCache } from './smartuniverse.classes.universecache';
|
import { UniverseCache } from './smartuniverse.classes.universecache';
|
||||||
import { SocketConnection } from '@pushrocks/smartsocket';
|
import { SocketConnection } from '@pushrocks/smartsocket';
|
||||||
|
import { logger } from './smartuniverse.logging';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* represents a message within a universe
|
* represents a message within a universe
|
||||||
@ -40,7 +39,7 @@ export class UniverseMessage<T> implements interfaces.IUniverseMessage {
|
|||||||
/**
|
/**
|
||||||
* enables unprotected grouping of messages for efficiency purposes.
|
* enables unprotected grouping of messages for efficiency purposes.
|
||||||
*/
|
*/
|
||||||
public universeChannelList = new Objectmap<UniverseChannel>();
|
public universeChannelList = new plugins.lik.ObjectMap<UniverseChannel>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* wether the message is authenticated
|
* wether the message is authenticated
|
||||||
@ -78,12 +77,14 @@ export class UniverseMessage<T> implements interfaces.IUniverseMessage {
|
|||||||
this.destructionTimer = new Timer(selfdestructAfterArg);
|
this.destructionTimer = new Timer(selfdestructAfterArg);
|
||||||
this.destructionTimer.start();
|
this.destructionTimer.start();
|
||||||
// set up self destruction by removing this from the parent messageCache
|
// set up self destruction by removing this from the parent messageCache
|
||||||
this.destructionTimer.completed.then(async () => {
|
this.destructionTimer.completed
|
||||||
this.universeCache.messageMap.remove(this);
|
.then(async () => {
|
||||||
}).catch(err => {
|
this.universeCache.messageMap.remove(this);
|
||||||
console.log(err);
|
})
|
||||||
console.log(this);
|
.catch((err) => {
|
||||||
});
|
console.log(err);
|
||||||
|
console.log(this);
|
||||||
|
});
|
||||||
} else {
|
} else {
|
||||||
plugins.smartdelay.delayFor(1000).then(() => {
|
plugins.smartdelay.delayFor(1000).then(() => {
|
||||||
if (!this.destructionTimer) {
|
if (!this.destructionTimer) {
|
||||||
@ -97,6 +98,6 @@ export class UniverseMessage<T> implements interfaces.IUniverseMessage {
|
|||||||
* handles bad messages for further analysis
|
* handles bad messages for further analysis
|
||||||
*/
|
*/
|
||||||
public handleAsBadMessage() {
|
public handleAsBadMessage() {
|
||||||
plugins.smartlog.defaultLogger.log('warn', 'received a bad message');
|
logger.log('warn', 'received a bad message');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
2
ts/smartuniverse.logging.ts
Normal file
2
ts/smartuniverse.logging.ts
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
import * as plugins from './smartuniverse.plugins';
|
||||||
|
export const logger = new plugins.smartlog.ConsoleLog();
|
@ -6,15 +6,12 @@ export { path };
|
|||||||
// apiglobal scope
|
// apiglobal scope
|
||||||
import * as typedrequestInterfaces from '@apiglobal/typedrequest-interfaces';
|
import * as typedrequestInterfaces from '@apiglobal/typedrequest-interfaces';
|
||||||
|
|
||||||
export {
|
export { typedrequestInterfaces };
|
||||||
typedrequestInterfaces
|
|
||||||
};
|
|
||||||
|
|
||||||
// pushrocks scope
|
// pushrocks scope
|
||||||
import * as lik from '@pushrocks/lik';
|
import * as lik from '@pushrocks/lik';
|
||||||
import * as smarthash from '@pushrocks/smarthash';
|
import * as smarthash from '@pushrocks/smarthash';
|
||||||
import * as smartdelay from '@pushrocks/smartdelay';
|
import * as smartdelay from '@pushrocks/smartdelay';
|
||||||
import * as smartexpress from '@pushrocks/smartexpress';
|
|
||||||
import * as smartfile from '@pushrocks/smartfile';
|
import * as smartfile from '@pushrocks/smartfile';
|
||||||
import * as smartlog from '@pushrocks/smartlog';
|
import * as smartlog from '@pushrocks/smartlog';
|
||||||
import * as smartpromise from '@pushrocks/smartpromise';
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
@ -28,7 +25,6 @@ export {
|
|||||||
lik,
|
lik,
|
||||||
smarthash,
|
smarthash,
|
||||||
smartdelay,
|
smartdelay,
|
||||||
smartexpress,
|
|
||||||
smartfile,
|
smartfile,
|
||||||
smartlog,
|
smartlog,
|
||||||
smartpromise,
|
smartpromise,
|
||||||
@ -36,5 +32,5 @@ export {
|
|||||||
smartrequest,
|
smartrequest,
|
||||||
smartsocket,
|
smartsocket,
|
||||||
smarttime,
|
smarttime,
|
||||||
smartunique
|
smartunique,
|
||||||
};
|
};
|
||||||
|
5
ts/smartuniverse.pluginstyped.ts
Normal file
5
ts/smartuniverse.pluginstyped.ts
Normal file
@ -0,0 +1,5 @@
|
|||||||
|
import type * as smartexpress from '@pushrocks/smartexpress';
|
||||||
|
|
||||||
|
export {
|
||||||
|
smartexpress
|
||||||
|
};
|
Reference in New Issue
Block a user