Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 37e1ee7970 | |||
| bd0bb3acf5 | |||
| f60497474e | |||
| 1d84cefa84 |
2
package-lock.json
generated
2
package-lock.json
generated
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartuniverse",
|
"name": "@pushrocks/smartuniverse",
|
||||||
"version": "1.0.68",
|
"version": "1.0.70",
|
||||||
"lockfileVersion": 1,
|
"lockfileVersion": 1,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartuniverse",
|
"name": "@pushrocks/smartuniverse",
|
||||||
"version": "1.0.68",
|
"version": "1.0.70",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "messaging service for your micro services",
|
"description": "messaging service for your micro services",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
|
|||||||
@@ -88,7 +88,7 @@ export class ClientUniverse {
|
|||||||
if (!this.smartsocketClient && !this.observableIntake) {
|
if (!this.smartsocketClient && !this.observableIntake) {
|
||||||
const parsedURL = url.parse(this.options.serverAddress);
|
const parsedURL = url.parse(this.options.serverAddress);
|
||||||
const socketConfig: plugins.smartsocket.ISmartsocketClientOptions = {
|
const socketConfig: plugins.smartsocket.ISmartsocketClientOptions = {
|
||||||
alias: process.env.SOCKET_ALIAS || 'someclient',
|
alias: 'universeclient',
|
||||||
password: 'UniverseClient',
|
password: 'UniverseClient',
|
||||||
port: parseInt(parsedURL.port, 10),
|
port: parseInt(parsedURL.port, 10),
|
||||||
role: 'UniverseClient',
|
role: 'UniverseClient',
|
||||||
|
|||||||
@@ -160,12 +160,13 @@ export class Universe {
|
|||||||
this.smartsocket.addSocketFunction(socketFunctionSubscription);
|
this.smartsocket.addSocketFunction(socketFunctionSubscription);
|
||||||
this.smartsocket.addSocketFunction(socketFunctionProcessMessage);
|
this.smartsocket.addSocketFunction(socketFunctionProcessMessage);
|
||||||
|
|
||||||
// add smartsocket to the running smartexpress app
|
// start the server
|
||||||
await this.smartsocket.setExternalServer('smartexpress', this.smartexpressServer);
|
|
||||||
// start everything
|
|
||||||
if (!this.options.externalServer) {
|
if (!this.options.externalServer) {
|
||||||
await this.smartexpressServer.start();
|
await this.smartexpressServer.start();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 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');
|
plugins.smartlog.defaultLogger.log('success', 'started universe');
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user