Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
f27b9f8143 | |||
38058aba57 | |||
ba38dae64f | |||
69e862a6cf | |||
4562ac355b | |||
b029dc191e | |||
2640275d04 | |||
7bbcc91300 |
@ -13,31 +13,24 @@ stages:
|
|||||||
- metadata
|
- metadata
|
||||||
|
|
||||||
before_script:
|
before_script:
|
||||||
- npm install -g @shipzone/npmci
|
- pnpm install -g pnpm
|
||||||
|
- pnpm install -g @shipzone/npmci
|
||||||
|
- npmci npm prepare
|
||||||
|
|
||||||
# ====================
|
# ====================
|
||||||
# security stage
|
# security stage
|
||||||
# ====================
|
# ====================
|
||||||
mirror:
|
# ====================
|
||||||
stage: security
|
# security stage
|
||||||
script:
|
# ====================
|
||||||
- npmci git mirror
|
|
||||||
only:
|
|
||||||
- tags
|
|
||||||
tags:
|
|
||||||
- lossless
|
|
||||||
- docker
|
|
||||||
- notpriv
|
|
||||||
|
|
||||||
auditProductionDependencies:
|
auditProductionDependencies:
|
||||||
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci command npm config set registry https://registry.npmjs.org
|
||||||
- npmci command npm install --production --ignore-scripts
|
- npmci command pnpm audit --audit-level=high --prod
|
||||||
- npmci command npm config set registry https://registry.npmjs.org
|
|
||||||
- npmci command npm audit --audit-level=high --only=prod --production
|
|
||||||
tags:
|
tags:
|
||||||
|
- lossless
|
||||||
- docker
|
- docker
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
|
||||||
@ -45,11 +38,10 @@ auditDevDependencies:
|
|||||||
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
|
||||||
- npmci command npm install --ignore-scripts
|
|
||||||
- npmci command npm config set registry https://registry.npmjs.org
|
- npmci command npm config set registry https://registry.npmjs.org
|
||||||
- npmci command npm audit --audit-level=high --only=dev
|
- npmci command pnpm audit --audit-level=high --dev
|
||||||
tags:
|
tags:
|
||||||
|
- lossless
|
||||||
- docker
|
- docker
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
|
||||||
@ -60,7 +52,6 @@ auditDevDependencies:
|
|||||||
testStable:
|
testStable:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
|
||||||
- npmci node install stable
|
- npmci node install stable
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci npm test
|
||||||
@ -71,10 +62,9 @@ testStable:
|
|||||||
testBuild:
|
testBuild:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
|
||||||
- npmci node install stable
|
- npmci node install stable
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command npm run build
|
- npmci npm build
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
@ -100,10 +90,9 @@ codequality:
|
|||||||
only:
|
only:
|
||||||
- tags
|
- tags
|
||||||
script:
|
script:
|
||||||
- npmci command npm install -g tslint typescript
|
- npmci command npm install -g typescript
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
|
|
||||||
tags:
|
tags:
|
||||||
- lossless
|
- lossless
|
||||||
- docker
|
- docker
|
||||||
@ -123,11 +112,9 @@ trigger:
|
|||||||
pages:
|
pages:
|
||||||
stage: metadata
|
stage: metadata
|
||||||
script:
|
script:
|
||||||
- npmci node install lts
|
- npmci node install stable
|
||||||
- npmci command npm install -g @gitzone/tsdoc
|
|
||||||
- npmci npm prepare
|
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command tsdoc
|
- npmci command npm run buildDocs
|
||||||
tags:
|
tags:
|
||||||
- lossless
|
- lossless
|
||||||
- docker
|
- docker
|
||||||
|
3
.vscode/settings.json
vendored
3
.vscode/settings.json
vendored
@ -22,6 +22,5 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
],
|
]
|
||||||
"typescript.tsdk": "node_modules/typescript/lib"
|
|
||||||
}
|
}
|
||||||
|
@ -1,13 +1,14 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartsocket",
|
"name": "@pushrocks/smartsocket",
|
||||||
"version": "2.0.9",
|
"version": "2.0.13",
|
||||||
"description": "easy and secure websocket communication",
|
"description": "easy and secure websocket communication",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist_ts/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "(tstest test/)",
|
"test": "(tstest test/)",
|
||||||
"build": "(tsbuild --web --allowimplicitany && tsbundle --from ./ts/index.ts --to dist_bundle/bundle.js)"
|
"build": "(tsbuild --web --allowimplicitany && tsbundle --from ./ts/index.ts --to dist_bundle/bundle.js)",
|
||||||
|
"buildDocs": "tsdoc"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@ -25,7 +26,7 @@
|
|||||||
"@pushrocks/isounique": "^1.0.5",
|
"@pushrocks/isounique": "^1.0.5",
|
||||||
"@pushrocks/lik": "^6.0.0",
|
"@pushrocks/lik": "^6.0.0",
|
||||||
"@pushrocks/smartdelay": "^2.0.13",
|
"@pushrocks/smartdelay": "^2.0.13",
|
||||||
"@pushrocks/smartenv": "^5.0.2",
|
"@pushrocks/smartenv": "^5.0.4",
|
||||||
"@pushrocks/smartexpress": "^4.0.18",
|
"@pushrocks/smartexpress": "^4.0.18",
|
||||||
"@pushrocks/smartjson": "^5.0.1",
|
"@pushrocks/smartjson": "^5.0.1",
|
||||||
"@pushrocks/smartlog": "^3.0.1",
|
"@pushrocks/smartlog": "^3.0.1",
|
||||||
@ -37,6 +38,7 @@
|
|||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@gitzone/tsbuild": "^2.1.63",
|
"@gitzone/tsbuild": "^2.1.63",
|
||||||
|
"@gitzone/tsbundle": "^2.0.7",
|
||||||
"@gitzone/tsrun": "^1.2.37",
|
"@gitzone/tsrun": "^1.2.37",
|
||||||
"@gitzone/tstest": "^1.0.72",
|
"@gitzone/tstest": "^1.0.72",
|
||||||
"@pushrocks/tapbundle": "^5.0.4",
|
"@pushrocks/tapbundle": "^5.0.4",
|
||||||
|
24
pnpm-lock.yaml
generated
24
pnpm-lock.yaml
generated
@ -3,13 +3,14 @@ lockfileVersion: 5.4
|
|||||||
specifiers:
|
specifiers:
|
||||||
'@apiglobal/typedrequest-interfaces': ^2.0.1
|
'@apiglobal/typedrequest-interfaces': ^2.0.1
|
||||||
'@gitzone/tsbuild': ^2.1.63
|
'@gitzone/tsbuild': ^2.1.63
|
||||||
|
'@gitzone/tsbundle': ^2.0.7
|
||||||
'@gitzone/tsrun': ^1.2.37
|
'@gitzone/tsrun': ^1.2.37
|
||||||
'@gitzone/tstest': ^1.0.72
|
'@gitzone/tstest': ^1.0.72
|
||||||
'@pushrocks/isohash': ^2.0.0
|
'@pushrocks/isohash': ^2.0.0
|
||||||
'@pushrocks/isounique': ^1.0.5
|
'@pushrocks/isounique': ^1.0.5
|
||||||
'@pushrocks/lik': ^6.0.0
|
'@pushrocks/lik': ^6.0.0
|
||||||
'@pushrocks/smartdelay': ^2.0.13
|
'@pushrocks/smartdelay': ^2.0.13
|
||||||
'@pushrocks/smartenv': ^5.0.2
|
'@pushrocks/smartenv': ^5.0.4
|
||||||
'@pushrocks/smartexpress': ^4.0.18
|
'@pushrocks/smartexpress': ^4.0.18
|
||||||
'@pushrocks/smartjson': ^5.0.1
|
'@pushrocks/smartjson': ^5.0.1
|
||||||
'@pushrocks/smartlog': ^3.0.1
|
'@pushrocks/smartlog': ^3.0.1
|
||||||
@ -27,7 +28,7 @@ dependencies:
|
|||||||
'@pushrocks/isounique': 1.0.5
|
'@pushrocks/isounique': 1.0.5
|
||||||
'@pushrocks/lik': 6.0.0
|
'@pushrocks/lik': 6.0.0
|
||||||
'@pushrocks/smartdelay': 2.0.13
|
'@pushrocks/smartdelay': 2.0.13
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@pushrocks/smartexpress': 4.0.22
|
'@pushrocks/smartexpress': 4.0.22
|
||||||
'@pushrocks/smartjson': 5.0.5
|
'@pushrocks/smartjson': 5.0.5
|
||||||
'@pushrocks/smartlog': 3.0.2
|
'@pushrocks/smartlog': 3.0.2
|
||||||
@ -39,6 +40,7 @@ dependencies:
|
|||||||
|
|
||||||
devDependencies:
|
devDependencies:
|
||||||
'@gitzone/tsbuild': 2.1.65
|
'@gitzone/tsbuild': 2.1.65
|
||||||
|
'@gitzone/tsbundle': 2.0.7
|
||||||
'@gitzone/tsrun': 1.2.39_@types+node@18.11.18
|
'@gitzone/tsrun': 1.2.39_@types+node@18.11.18
|
||||||
'@gitzone/tstest': 1.0.74_@types+node@18.11.18
|
'@gitzone/tstest': 1.0.74_@types+node@18.11.18
|
||||||
'@pushrocks/tapbundle': 5.0.4
|
'@pushrocks/tapbundle': 5.0.4
|
||||||
@ -328,7 +330,7 @@ packages:
|
|||||||
/@pushrocks/isohash/2.0.0:
|
/@pushrocks/isohash/2.0.0:
|
||||||
resolution: {integrity: sha512-a6Vktczk0Q39hBYTuAFqa12QNhy5GcFYhnJ5pqzpE5r3rj3FSS8HLqsoBUwB3b9YHGKYnbky9C3YNhMmFvoLPg==}
|
resolution: {integrity: sha512-a6Vktczk0Q39hBYTuAFqa12QNhy5GcFYhnJ5pqzpE5r3rj3FSS8HLqsoBUwB3b9YHGKYnbky9C3YNhMmFvoLPg==}
|
||||||
dependencies:
|
dependencies:
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@pushrocks/smarthash': 2.1.10
|
'@pushrocks/smarthash': 2.1.10
|
||||||
|
|
||||||
/@pushrocks/isounique/1.0.5:
|
/@pushrocks/isounique/1.0.5:
|
||||||
@ -408,8 +410,8 @@ packages:
|
|||||||
dependencies:
|
dependencies:
|
||||||
'@pushrocks/smartpromise': 3.1.7
|
'@pushrocks/smartpromise': 3.1.7
|
||||||
|
|
||||||
/@pushrocks/smartenv/5.0.3:
|
/@pushrocks/smartenv/5.0.4:
|
||||||
resolution: {integrity: sha512-/cgEDhOIo9LB5Vd2BVO9+QrjC38w872iy7w88UWuwz7obVILWOHl3MYMHAKFqXexuwKpQ/y/Klu2xQHtOPgi6Q==}
|
resolution: {integrity: sha512-/fVIgZ9LY0GkJQFQwTC06nqFEJhZeuJapa6SeQs3WGkGkgYeWO3DTscwxtUpZULUn7geuAFQrk+vW+lErXiksQ==}
|
||||||
dependencies:
|
dependencies:
|
||||||
'@pushrocks/smartpromise': 3.1.7
|
'@pushrocks/smartpromise': 3.1.7
|
||||||
|
|
||||||
@ -441,7 +443,7 @@ packages:
|
|||||||
'@apiglobal/typedsocket': 2.0.12
|
'@apiglobal/typedsocket': 2.0.12
|
||||||
'@pushrocks/lik': 6.0.0
|
'@pushrocks/lik': 6.0.0
|
||||||
'@pushrocks/smartdelay': 2.0.13
|
'@pushrocks/smartdelay': 2.0.13
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@pushrocks/smartfeed': 1.0.11
|
'@pushrocks/smartfeed': 1.0.11
|
||||||
'@pushrocks/smartfile': 10.0.5
|
'@pushrocks/smartfile': 10.0.5
|
||||||
'@pushrocks/smartmanifest': 1.0.8
|
'@pushrocks/smartmanifest': 1.0.8
|
||||||
@ -696,7 +698,7 @@ packages:
|
|||||||
'@pushrocks/isounique': 1.0.5
|
'@pushrocks/isounique': 1.0.5
|
||||||
'@pushrocks/lik': 6.0.0
|
'@pushrocks/lik': 6.0.0
|
||||||
'@pushrocks/smartdelay': 2.0.13
|
'@pushrocks/smartdelay': 2.0.13
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@pushrocks/smartexpress': 4.0.22
|
'@pushrocks/smartexpress': 4.0.22
|
||||||
'@pushrocks/smartjson': 5.0.5
|
'@pushrocks/smartjson': 5.0.5
|
||||||
'@pushrocks/smartlog': 3.0.2
|
'@pushrocks/smartlog': 3.0.2
|
||||||
@ -735,7 +737,7 @@ packages:
|
|||||||
resolution: {integrity: sha512-g9a/Mfj+eJAUrTDQoH3oaYegjI98WlVoSLAI8lpExQ/STlEJGO5ZdWDqgZ0HvHe+5UeWvxzCFpHifqRhMUJ+dQ==}
|
resolution: {integrity: sha512-g9a/Mfj+eJAUrTDQoH3oaYegjI98WlVoSLAI8lpExQ/STlEJGO5ZdWDqgZ0HvHe+5UeWvxzCFpHifqRhMUJ+dQ==}
|
||||||
dependencies:
|
dependencies:
|
||||||
'@pushrocks/isounique': 1.0.5
|
'@pushrocks/isounique': 1.0.5
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@types/randomatic': 3.1.3
|
'@types/randomatic': 3.1.3
|
||||||
buffer: 6.0.3
|
buffer: 6.0.3
|
||||||
crypto-random-string: 4.0.0
|
crypto-random-string: 4.0.0
|
||||||
@ -806,7 +808,7 @@ packages:
|
|||||||
dependencies:
|
dependencies:
|
||||||
'@open-wc/testing': 3.1.7
|
'@open-wc/testing': 3.1.7
|
||||||
'@pushrocks/smartdelay': 2.0.13
|
'@pushrocks/smartdelay': 2.0.13
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@pushrocks/smartexpect': 1.0.14
|
'@pushrocks/smartexpect': 1.0.14
|
||||||
'@pushrocks/smartpromise': 3.1.7
|
'@pushrocks/smartpromise': 3.1.7
|
||||||
'@pushrocks/smarttime': 3.0.50
|
'@pushrocks/smarttime': 3.0.50
|
||||||
@ -821,7 +823,7 @@ packages:
|
|||||||
dependencies:
|
dependencies:
|
||||||
'@adobe/helix-fetch': 3.1.2
|
'@adobe/helix-fetch': 3.1.2
|
||||||
'@pushrocks/smartdelay': 2.0.13
|
'@pushrocks/smartdelay': 2.0.13
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@pushrocks/smartjson': 5.0.5
|
'@pushrocks/smartjson': 5.0.5
|
||||||
'@pushrocks/smartpromise': 3.1.7
|
'@pushrocks/smartpromise': 3.1.7
|
||||||
'@pushrocks/webstore': 2.0.5
|
'@pushrocks/webstore': 2.0.5
|
||||||
@ -833,7 +835,7 @@ packages:
|
|||||||
dependencies:
|
dependencies:
|
||||||
'@apiglobal/typedrequest-interfaces': 1.0.20
|
'@apiglobal/typedrequest-interfaces': 1.0.20
|
||||||
'@pushrocks/lik': 6.0.0
|
'@pushrocks/lik': 6.0.0
|
||||||
'@pushrocks/smartenv': 5.0.3
|
'@pushrocks/smartenv': 5.0.4
|
||||||
'@pushrocks/smartjson': 5.0.5
|
'@pushrocks/smartjson': 5.0.5
|
||||||
'@pushrocks/smartpromise': 3.1.7
|
'@pushrocks/smartpromise': 3.1.7
|
||||||
'@pushrocks/smartrx': 2.0.27
|
'@pushrocks/smartrx': 2.0.27
|
||||||
|
@ -21,7 +21,6 @@ Code Style | [](htt
|
|||||||
PackagePhobia (total standalone install weight) | [](https://lossless.cloud)
|
PackagePhobia (total standalone install weight) | [](https://lossless.cloud)
|
||||||
PackagePhobia (package size on registry) | [](https://lossless.cloud)
|
PackagePhobia (package size on registry) | [](https://lossless.cloud)
|
||||||
BundlePhobia (total size when bundled) | [](https://lossless.cloud)
|
BundlePhobia (total size when bundled) | [](https://lossless.cloud)
|
||||||
Platform support | [](https://lossless.cloud) [](https://lossless.cloud)
|
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
|
||||||
@ -116,7 +115,6 @@ We are always happy for code contributions. If you are not the code contributing
|
|||||||
|
|
||||||
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)
|
## Legal
|
||||||
|
> MIT licensed | **©** [Task Venture Capital GmbH](https://task.vc)
|
||||||
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
|
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
|
||||||
|
|
||||||
[](https://maintainedby.lossless.com)
|
|
||||||
|
@ -33,7 +33,6 @@ tap.test('Should accept an smartExpressServer as server', async () => {
|
|||||||
await myseServer.start();
|
await myseServer.start();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
// class SocketFunction
|
// class SocketFunction
|
||||||
tap.test('should register a new Function', async () => {
|
tap.test('should register a new Function', async () => {
|
||||||
testSocketFunction1 = new smartsocket.SocketFunction({
|
testSocketFunction1 = new smartsocket.SocketFunction({
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@pushrocks/smartsocket',
|
name: '@pushrocks/smartsocket',
|
||||||
version: '2.0.9',
|
version: '2.0.13',
|
||||||
description: 'easy and secure websocket communication'
|
description: 'easy and secure websocket communication'
|
||||||
}
|
}
|
||||||
|
@ -47,7 +47,13 @@ export class Smartsocket {
|
|||||||
*/
|
*/
|
||||||
public async start() {
|
public async start() {
|
||||||
const socketIoModule = await this.smartenv.getSafeNodeModule('socket.io');
|
const socketIoModule = await this.smartenv.getSafeNodeModule('socket.io');
|
||||||
this.io = new socketIoModule.Server(await this.socketServer.getServerForSocketIo());
|
this.io = new socketIoModule.Server(await this.socketServer.getServerForSocketIo(), {
|
||||||
|
cors: {
|
||||||
|
allowedHeaders: '*',
|
||||||
|
methods: '*',
|
||||||
|
origin: '*',
|
||||||
|
}
|
||||||
|
});
|
||||||
await this.socketServer.start();
|
await this.socketServer.start();
|
||||||
this.io.on('connection', (socketArg) => {
|
this.io.on('connection', (socketArg) => {
|
||||||
this._handleSocketConnection(socketArg);
|
this._handleSocketConnection(socketArg);
|
||||||
@ -61,7 +67,10 @@ export class Smartsocket {
|
|||||||
await plugins.smartdelay.delayFor(1000);
|
await plugins.smartdelay.delayFor(1000);
|
||||||
this.socketConnections.forEach((socketObjectArg: SocketConnection) => {
|
this.socketConnections.forEach((socketObjectArg: SocketConnection) => {
|
||||||
if (socketObjectArg) {
|
if (socketObjectArg) {
|
||||||
logger.log('info', `disconnecting socket with >>alias ${socketObjectArg.alias} due to server stop...`);
|
logger.log(
|
||||||
|
'info',
|
||||||
|
`disconnecting socket with >>alias ${socketObjectArg.alias} due to server stop...`
|
||||||
|
);
|
||||||
socketObjectArg.disconnect();
|
socketObjectArg.disconnect();
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
@ -97,10 +97,10 @@ export class SmartsocketClient {
|
|||||||
getFunction: () => {
|
getFunction: () => {
|
||||||
const socketIoBrowserModule = (globalThis as any).io;
|
const socketIoBrowserModule = (globalThis as any).io;
|
||||||
console.log('loaded socket.io for browser');
|
console.log('loaded socket.io for browser');
|
||||||
console.log(socketIoBrowserModule);
|
|
||||||
return socketIoBrowserModule;
|
return socketIoBrowserModule;
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
console.log(socketIoClient);
|
||||||
logger.log('info', 'trying to connect...');
|
logger.log('info', 'trying to connect...');
|
||||||
const socketUrl = `${this.serverUrl}:${this.serverPort}`;
|
const socketUrl = `${this.serverUrl}:${this.serverPort}`;
|
||||||
this.socketConnection = new SocketConnection({
|
this.socketConnection = new SocketConnection({
|
||||||
|
@ -161,11 +161,10 @@ export class SocketConnection {
|
|||||||
this.socket.on('function', (dataArg: ISocketRequestDataObject<any>) => {
|
this.socket.on('function', (dataArg: ISocketRequestDataObject<any>) => {
|
||||||
// check if requested function is available to the socket's scope
|
// check if requested function is available to the socket's scope
|
||||||
// logger.log('info', 'function request received');
|
// logger.log('info', 'function request received');
|
||||||
const referencedFunction: SocketFunction<any> = this.smartsocketRef.socketFunctions.findSync(
|
const referencedFunction: SocketFunction<any> =
|
||||||
(socketFunctionArg) => {
|
this.smartsocketRef.socketFunctions.findSync((socketFunctionArg) => {
|
||||||
return socketFunctionArg.name === dataArg.funcCallData.funcName;
|
return socketFunctionArg.name === dataArg.funcCallData.funcName;
|
||||||
}
|
});
|
||||||
);
|
|
||||||
if (referencedFunction) {
|
if (referencedFunction) {
|
||||||
// logger.log('ok', 'function in access scope');
|
// logger.log('ok', 'function in access scope');
|
||||||
const localSocketRequest = new SocketRequest(this.smartsocketRef, {
|
const localSocketRequest = new SocketRequest(this.smartsocketRef, {
|
||||||
@ -197,7 +196,10 @@ export class SocketConnection {
|
|||||||
this.remoteTagStoreObservable.next(tagStoreArg);
|
this.remoteTagStoreObservable.next(tagStoreArg);
|
||||||
});
|
});
|
||||||
|
|
||||||
logger.log('info', `now listening to function requests for ${this.alias} on side ${this.side}`);
|
logger.log(
|
||||||
|
'info',
|
||||||
|
`now listening to function requests for ${this.alias} on side ${this.side}`
|
||||||
|
);
|
||||||
done.resolve(this);
|
done.resolve(this);
|
||||||
} else {
|
} else {
|
||||||
const errMessage = 'socket needs to be authenticated first';
|
const errMessage = 'socket needs to be authenticated first';
|
||||||
|
@ -10,7 +10,7 @@ import type * as smartexpress from '@pushrocks/smartexpress';
|
|||||||
export { smartexpress };
|
export { smartexpress };
|
||||||
|
|
||||||
// third party scope
|
// third party scope
|
||||||
import type { Socket as ServerSocket, Server as ServerServer} from 'socket.io';
|
import type { Socket as ServerSocket, Server as ServerServer } from 'socket.io';
|
||||||
import type { Socket as ClientSocket, connect as ClientIo } from 'socket.io-client';
|
import type { Socket as ClientSocket, connect as ClientIo } from 'socket.io-client';
|
||||||
|
|
||||||
export namespace socketIo {
|
export namespace socketIo {
|
||||||
|
Reference in New Issue
Block a user