test(reactive-rpc): 💍 move Reactive RPC E2E tests under the /src/reactive-rpc folder

Author: streamich

package.json

@@ -53,8 +53,8 @@
     "test:cli:pointer": "./bin/json-pointer-test.js ./bin/json-pointer.js",
     "test:cli:patch": "./bin/json-patch-test.js ./bin/json-patch.js",
     "test:cli:pack": "./bin/json-pack-test.js ./bin/json-pack.js",
-    "test:reactive-rpc": "node -r ts-node/register/transpile-only src/__tests__/reactive-rpc/run.ts",
-    "test:reactive-rpc:jest": "TEST_E2E=1 jest --maxWorkers 1 --no-cache src/__tests__/reactive-rpc/",
+    "test:reactive-rpc": "node -r ts-node/register/transpile-only src/reactive-rpc/__tests__/e2e/run.ts",
+    "test:reactive-rpc:jest": "TEST_E2E=1 jest --maxWorkers 1 --no-cache src/reactive-rpc/__tests__/e2e/",
     "demo:json-patch": "ts-node src/json-patch/__demos__/json-patch.ts",
     "demo:json-pointer": "ts-node src/json-pointer/__demos__/json-pointer.ts",
     "demo:reactive-rpc:server": "ts-node src/reactive-rpc/__demos__/server.ts",

src/__tests__/reactive-rpc/README.md renamed to src/reactive-rpc/__tests__/e2e/README.md

@@ -22,5 +22,5 @@ yarn test:reactive-rpc:jest
 To run a specific test suite use this command:
 
 ```
-TEST_E2E=1 npx jest --no-cache src/__tests__/reactive-rpc/uws/http/rx-rpc/FetchRpcClient.spec.ts
+TEST_E2E=1 npx jest --no-cache src/reactive-rpc/__tests__/e2e/uws/ws/RpcPersistentClient.spec.ts
 ```

src/__tests__/reactive-rpc/run.ts renamed to src/reactive-rpc/__tests__/e2e/run.ts

@@ -1,5 +1,5 @@
 import {spawn} from 'child_process';
-import {Defer} from '../../util/Defer';
+import {Defer} from '../../../util/Defer';
 
 const startServer = async () => {
   const started = new Defer<void>();
@@ -59,11 +59,9 @@ const runTests = async () => {
     const server = await startServer();
     await server.started;
     let exitCode = 0;
-    for (let i = 0; i < 3; i++) {
-      const jest = await runTests();
-      exitCode = await jest.exitCode;
-      if (exitCode !== 0) throw exitCode;
-    }
+    const jest = await runTests();
+    exitCode = await jest.exitCode;
+    if (exitCode !== 0) throw exitCode;
     process.exit(exitCode);
   } catch (error) {
     // tslint:disable-next-line no-console

src/__tests__/reactive-rpc/uws/http/FetchRpcClient.spec.ts renamed to src/reactive-rpc/__tests__/e2e/uws/http/FetchRpcClient.spec.ts

@@ -2,14 +2,14 @@
  * @jest-environment node
  */
 
-import {ApiTestSetup, runApiTests} from '../../../../reactive-rpc/common/rpc/__tests__/runApiTests';
-import {RpcCodecs} from '../../../../reactive-rpc/common/codec/RpcCodecs';
-import {RpcMessageCodecs} from '../../../../reactive-rpc/common/codec/RpcMessageCodecs';
-import {Writer} from '../../../../util/buffers/Writer';
-import {Codecs} from '../../../../json-pack/codecs/Codecs';
-import {RpcMessageCodec} from '../../../../reactive-rpc/common/codec/types';
-import {JsonValueCodec} from '../../../../json-pack/codecs/types';
-import {FetchRpcClient} from '../../../../reactive-rpc/common/rpc/client/FetchRpcClient';
+import {ApiTestSetup, runApiTests} from '../../../../common/rpc/__tests__/runApiTests';
+import {RpcCodecs} from '../../../../common/codec/RpcCodecs';
+import {RpcMessageCodecs} from '../../../../common/codec/RpcMessageCodecs';
+import {Writer} from '../../../../../util/buffers/Writer';
+import {Codecs} from '../../../../../json-pack/codecs/Codecs';
+import {RpcMessageCodec} from '../../../../common/codec/types';
+import {JsonValueCodec} from '../../../../../json-pack/codecs/types';
+import {FetchRpcClient} from '../../../../common/rpc/client/FetchRpcClient';
 
 if (process.env.TEST_E2E) {
   const codecs = new RpcCodecs(new Codecs(new Writer()), new RpcMessageCodecs());

src/__tests__/reactive-rpc/uws/http/StreamingRpcClient.spec.ts renamed to src/reactive-rpc/__tests__/e2e/uws/http/StreamingRpcClient.spec.ts

@@ -2,14 +2,14 @@
  * @jest-environment node
  */
 
-import {ApiTestSetup, runApiTests} from '../../../../reactive-rpc/common/rpc/__tests__/runApiTests';
-import {StreamingRpcClient} from '../../../../reactive-rpc/common';
-import {RpcCodecs} from '../../../../reactive-rpc/common/codec/RpcCodecs';
-import {RpcMessageCodecs} from '../../../../reactive-rpc/common/codec/RpcMessageCodecs';
-import {Writer} from '../../../../util/buffers/Writer';
-import {Codecs} from '../../../../json-pack/codecs/Codecs';
-import {RpcMessageCodec} from '../../../../reactive-rpc/common/codec/types';
-import {JsonValueCodec} from '../../../../json-pack/codecs/types';
+import {ApiTestSetup, runApiTests} from '../../../../common/rpc/__tests__/runApiTests';
+import {StreamingRpcClient} from '../../../../common';
+import {RpcCodecs} from '../../../../common/codec/RpcCodecs';
+import {RpcMessageCodecs} from '../../../../common/codec/RpcMessageCodecs';
+import {Writer} from '../../../../../util/buffers/Writer';
+import {Codecs} from '../../../../../json-pack/codecs/Codecs';
+import {RpcMessageCodec} from '../../../../common/codec/types';
+import {JsonValueCodec} from '../../../../../json-pack/codecs/types';
 
 if (process.env.TEST_E2E) {
   const codecs = new RpcCodecs(new Codecs(new Writer()), new RpcMessageCodecs());

src/__tests__/reactive-rpc/uws/ws/RpcPersistentClient.spec.ts renamed to src/reactive-rpc/__tests__/e2e/uws/ws/RpcPersistentClient.spec.ts

@@ -2,16 +2,16 @@
  * @jest-environment node
  */
 
-import {ApiTestSetup, runApiTests} from '../../../../reactive-rpc/common/rpc/__tests__/runApiTests';
+import {ApiTestSetup, runApiTests} from '../../../../common/rpc/__tests__/runApiTests';
 import WebSocket from 'ws';
-import {RpcCodecs} from '../../../../reactive-rpc/common/codec/RpcCodecs';
-import {RpcMessageCodecs} from '../../../../reactive-rpc/common/codec/RpcMessageCodecs';
-import {Writer} from '../../../../util/buffers/Writer';
-import {Codecs} from '../../../../json-pack/codecs/Codecs';
-import {RpcMessageCodec} from '../../../../reactive-rpc/common/codec/types';
-import {JsonValueCodec} from '../../../../json-pack/codecs/types';
-import {RpcCodec} from '../../../../reactive-rpc/common/codec/RpcCodec';
-import {RpcPersistentClient, WebSocketChannel} from '../../../../reactive-rpc/common';
+import {RpcCodecs} from '../../../../common/codec/RpcCodecs';
+import {RpcMessageCodecs} from '../../../../common/codec/RpcMessageCodecs';
+import {Writer} from '../../../../../util/buffers/Writer';
+import {Codecs} from '../../../../../json-pack/codecs/Codecs';
+import {RpcMessageCodec} from '../../../../common/codec/types';
+import {JsonValueCodec} from '../../../../../json-pack/codecs/types';
+import {RpcCodec} from '../../../../common/codec/RpcCodec';
+import {RpcPersistentClient, WebSocketChannel} from '../../../../common';
 
 if (process.env.TEST_E2E) {
   const codecs = new RpcCodecs(new Codecs(new Writer()), new RpcMessageCodecs());