Merge pull request #1 from jsonjoy-com/e2e-testing

E2E testing

Author: streamich

.github/workflows/pr.yml

@@ -40,3 +40,17 @@ jobs:
       - run: yarn lint
       - run: yarn prettier:check
       - run: yarn typedoc
+  e2e-rx-rpc:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        node-version: [20.x]
+    steps:
+      - uses: actions/checkout@v4
+      - name: Use Node.js ${{ matrix.node-version }}
+        uses: actions/setup-node@v4
+        with:
+          node-version: ${{ matrix.node-version }}
+          cache: yarn
+      - run: yarn install --frozen-lockfile
+      - run: yarn test:e2e

.github/workflows/release.yml

@@ -23,6 +23,7 @@ jobs:
       - run: yarn prettier:check
       - run: yarn lint
       - run: yarn test:ci --ci
+      - run: yarn test:e2e
       - run: yarn build
       - name: Semantic Release
         uses: cycjimmy/semantic-release-action@v4

package.json

@@ -37,6 +37,7 @@
     "LICENSE",
     "lib/"
   ],
+  "license": "Apache-2.0",
   "scripts": {
     "prettier": "prettier --ignore-path .gitignore --write \"src/**/*.{ts,tsx,js,jsx}\"",
     "prettier:check": "prettier --ignore-path .gitignore --list-different 'src/**/*.{ts,tsx,js,jsx}'",
@@ -47,6 +48,9 @@
     "jest": "node -r ts-node/register ./node_modules/.bin/jest",
     "test": "jest --maxWorkers 7",
     "test:ci": "yarn jest --maxWorkers 3 --no-cache",
+    "test:e2e": "node -r ts-node/register/transpile-only src/__tests__/e2e/run.ts",
+    "test:e2e:jest": "TEST_E2E=1 jest --maxWorkers 1 --no-cache src/__tests__/e2e/",
+    "demo:e2e:server": "ts-node src/__demos__/server.ts",
     "coverage": "yarn test --collectCoverage",
     "typedoc": "typedoc",
     "build:pages": "rimraf gh-pages && mkdir -p gh-pages && cp -r typedocs/* gh-pages && cp -r coverage gh-pages/coverage",

src/__demos__/server.ts

@@ -1,4 +1,5 @@
 // npx ts-node src/reactive-rpc/__demos__/server.ts
+// curl localhost:9999/rpc -H 'Content-Type: rpc.rx.compact.json' -d '[1,1,"ping"]'
 
 import {App} from 'uWebSockets.js';
 import {createCaller} from '../common/rpc/__tests__/sample-api';

src/__tests__/e2e/run.ts

@@ -4,7 +4,7 @@ import {Defer} from '../../util/Defer';
 const startServer = async () => {
   const started = new Defer<void>();
   const exitCode = new Defer<number>();
-  const cp = spawn('yarn', ['demo:reactive-rpc:server'], {
+  const cp = spawn('yarn', ['demo:e2e:server'], {
     shell: true,
   });
   process.on('exit', (code) => {
@@ -16,10 +16,11 @@ const startServer = async () => {
     process.stderr.write('[server] ' + line);
   });
   cp.stderr.on('data', (data) => {
+    const msg = Buffer.isBuffer(data) ? data.toString() : String(data);
     // tslint:disable-next-line no-console
-    console.error('Could not start server');
+    console.error('Could not start server', msg);
     started.reject(data);
-    process.stderr.write('ERROR: [server] ' + String(data));
+    process.stderr.write('ERROR: [server] ' + msg);
   });
   cp.on('close', (code) => {
     exitCode.resolve(code || 0);
@@ -34,7 +35,7 @@ const startServer = async () => {
 
 const runTests = async () => {
   const exitCode = new Defer<number>();
-  const cp = spawn('yarn', ['test:reactive-rpc:jest'], {
+  const cp = spawn('yarn', ['test:e2e:jest'], {
     env: {
       ...process.env,
       TEST_E2E: '1',