105 lines
3.0 KiB
TypeScript
105 lines
3.0 KiB
TypeScript
// tslint:disable-next-line:no-implicit-dependencies
|
|
import { expect, expectAsync, tap } from '@pushrocks/tapbundle';
|
|
|
|
import * as isohash from '@pushrocks/isohash';
|
|
import * as smartexpress from '@pushrocks/smartexpress';
|
|
|
|
import * as smartsocket from '../ts/index.js';
|
|
|
|
let testSmartsocket: smartsocket.Smartsocket;
|
|
let testSmartsocketClient: smartsocket.SmartsocketClient;
|
|
let testSocketFunction1: smartsocket.SocketFunction<any>;
|
|
let myseServer: smartexpress.Server;
|
|
|
|
const testConfig = {
|
|
port: 3000,
|
|
};
|
|
|
|
// class smartsocket
|
|
tap.test('should create a new smartsocket', async () => {
|
|
testSmartsocket = new smartsocket.Smartsocket({ alias: 'testserver', port: testConfig.port });
|
|
expect(testSmartsocket).toBeInstanceOf(smartsocket.Smartsocket);
|
|
});
|
|
|
|
tap.test('Should accept an smartExpressServer as server', async () => {
|
|
myseServer = new smartexpress.Server({
|
|
cors: true,
|
|
forceSsl: false,
|
|
port: testConfig.port,
|
|
});
|
|
|
|
testSmartsocket.setExternalServer('smartexpress', myseServer);
|
|
|
|
await myseServer.start();
|
|
});
|
|
|
|
|
|
// class SocketFunction
|
|
tap.test('should register a new Function', async () => {
|
|
testSocketFunction1 = new smartsocket.SocketFunction({
|
|
funcDef: async (dataArg, socketConnectionArg) => {
|
|
return dataArg;
|
|
},
|
|
funcName: 'testFunction1',
|
|
});
|
|
testSmartsocket.addSocketFunction(testSocketFunction1);
|
|
console.log(testSmartsocket.socketFunctions);
|
|
});
|
|
|
|
tap.test('should start listening when .started is called', async () => {
|
|
await testSmartsocket.start();
|
|
});
|
|
|
|
// class SmartsocketClient
|
|
tap.test('should react to a new websocket connection from client', async () => {
|
|
testSmartsocketClient = new smartsocket.SmartsocketClient({
|
|
port: testConfig.port,
|
|
url: 'http://localhost',
|
|
alias: 'testClient1',
|
|
});
|
|
testSmartsocketClient.addSocketFunction(testSocketFunction1);
|
|
await testSmartsocketClient.connect();
|
|
});
|
|
|
|
tap.test('client should disconnect and reconnect', async (tools) => {
|
|
await testSmartsocketClient.disconnect();
|
|
await tools.delayFor(100);
|
|
await testSmartsocketClient.connect();
|
|
});
|
|
|
|
tap.test('2 clients should connect in parallel', async () => {
|
|
// TODO: implement parallel test
|
|
});
|
|
|
|
tap.test('should be able to make a functionCall from client to server', async () => {
|
|
const totalCycles = 20000;
|
|
let counter = 0;
|
|
let startTime = Date.now();
|
|
while (counter < totalCycles) {
|
|
const randomString = `hello ${Math.random()}`;
|
|
const response: any = await testSmartsocketClient.serverCall('testFunction1', {
|
|
value1: randomString,
|
|
});
|
|
expect(response.value1).toEqual(randomString);
|
|
if (counter % 100 === 0) {
|
|
console.log(
|
|
`processed 100 more messages in ${Date.now() - startTime}ms. ${
|
|
totalCycles - counter
|
|
} messages to go.`
|
|
);
|
|
startTime = Date.now();
|
|
}
|
|
counter++;
|
|
}
|
|
});
|
|
|
|
tap.test('should be able to make a functionCall from server to client', async () => {});
|
|
|
|
// terminate
|
|
tap.test('should close the server', async () => {
|
|
await testSmartsocket.stop();
|
|
await myseServer.stop();
|
|
});
|
|
|
|
tap.start();
|