ICD-RxJS Part 2 migration

src/test/ACCESS_CARTA_DEFAULT.test.ts

@@ -0,0 +1,47 @@
+import { CARTA } from "carta-protobuf";
+import config from "./config.json";
+const WebSocket = require("ws");
+import { MessageController } from "./MessageController";
+
+let testServerUrl = config.serverURL0;
+let connectTimeout = config.timeout.connection;
+
+describe(`ACCESS_CARTA_DEFAULT tests: Testing connections to the backend`, () => {
+    describe(`create a Websocket connection and receive REGISTER_VIEWER_ACK`, () => {
+        let RegisterViewerAckResponse: CARTA.IRegisterViewerAck;
+        const msgController = MessageController.Instance;
+
+        test(`Receive REGISTER_VIEWER_ACK`, async () => {
+            RegisterViewerAckResponse = await msgController.connect(testServerUrl);
+        }); 
+
+        test(`REGISTER_VIEWER_ACK.message is not empty`, () => {
+            expect(RegisterViewerAckResponse.message).toBeDefined();
+        })
+
+        test(`REGISTER_VIEWER_ACK.platformStrings is not empty`, () => {
+            expect(RegisterViewerAckResponse.platformStrings).toBeDefined();
+        })
+
+        test("REGISTER_VIEWER_ACK.success = True", () => {
+            expect(RegisterViewerAckResponse.success).toBe(true);
+        });
+
+        test("REGISTER_VIEWER_ACK.session_id is not None", () => {
+            expect(RegisterViewerAckResponse.sessionId).toBeDefined();
+            console.log(`Registered session ID is ${RegisterViewerAckResponse.sessionId} @${new Date()}`);
+        });
+
+        test("REGISTER_VIEWER_ACK.user_preferences = None", () => {
+            expect(RegisterViewerAckResponse.userPreferences).toMatchObject({});
+        });
+
+        test("REGISTER_VIEWER_ACK.user_layouts = None", () => {
+            expect(RegisterViewerAckResponse.userLayouts).toMatchObject({});
+        });
+
+        afterAll(async () => {
+            await msgController.closeConnection();
+        })
+    })
+});

src/test/ACCESS_CARTA_DEFAULT_CONCURRENT.test.ts

@@ -0,0 +1,76 @@
+import { CARTA } from "carta-protobuf";
+import { BackendService } from "./MessageController-concurrent";
+import config from "./config.json";
+const WebSocket = require("ws");
+
+let testServerUrl = config.serverURL0;
+let connectTimeout = config.timeout.connection;
+let testNumber = config.repeat.concurrent
+
+let client: BackendService[] = Array(testNumber);
+let RegisterViewerAckResponse: CARTA.RegisterViewerAck[] = new Array(testNumber);
+
+describe(`ACCESS_CARTA_DEFAULT_CONCURRENT: Testing multiple concurrent connections to the backend.`, () => {
+    test(`establish ${testNumber} connections to "${testServerUrl}".`, async () => {
+        for (let i = 0; i < client.length; i++) {
+            client[i] = new BackendService;
+            RegisterViewerAckResponse[i] = await client[i].connect(testServerUrl);
+            expect(client[i].connection.readyState).toBe(WebSocket.OPEN)
+        }  
+    }, connectTimeout);
+
+    test(`assert every REGISTER_VIEWER_ACK.success is True.`, () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(item.success).toBe(true);
+        });
+    });
+
+    test(`assert every REGISTER_VIEWER_ACK.session_id is not None.`, () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(item.sessionId).toBeDefined();
+        });
+    });
+
+    test(`assert every REGISTER_VIEWER_ACK.message is not empty`, () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(item.message).toBeDefined();
+        });
+    })
+
+    test(`assert every REGISTER_VIEWER_ACK.platformStrings is not empty`, () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(item.platformStrings).toBeDefined();
+        });
+    })
+
+    test(`assert every REGISTER_VIEWER_ACK.session_id is unique.`, () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(array.filter(f => f.sessionId === item.sessionId).length).toEqual(1);
+        });
+    });
+
+    test(`assert every REGISTER_VIEWER_ACK.session_type is "CARTA.SessionType.NEW".`, () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(item.sessionType).toEqual(CARTA.SessionType.NEW);
+        });
+    });
+
+    test("assert every REGISTER_VIEWER_ACK.user_preferences = None", () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(item.userPreferences).toMatchObject({});
+        });
+    });
+
+    test("assert every REGISTER_VIEWER_ACK.user_layouts = None", () => {
+        RegisterViewerAckResponse.forEach((item, index, array) => {
+            expect(item.userLayouts).toMatchObject({});
+        });
+    });
+
+    afterAll(async () => {
+        for (let i = 0; i < client.length; i++) {
+            await client[i].closeConnection();
+        }
+    });
+
+});