From 7e53ac6ca6bc7eb07ed346d66d8c16bb668e044f Mon Sep 17 00:00:00 2001 From: Alexei Boronine Date: Tue, 15 Oct 2024 23:31:24 +0300 Subject: [PATCH] Add some tests for bad network conditions --- .github/workflows/node.js.yml | 6 +- .gitignore | 1 + package-lock.json | 1691 ++++++++++++++++++++++++++++++++- package.json | 6 +- src/cli.ts | 60 +- src/h2tunnel.test.ts | 309 ++++-- src/h2tunnel.ts | 573 ++++++----- 7 files changed, 2252 insertions(+), 394 deletions(-) diff --git a/.github/workflows/node.js.yml b/.github/workflows/node.js.yml index 0c9c06b..296da15 100644 --- a/.github/workflows/node.js.yml +++ b/.github/workflows/node.js.yml @@ -17,7 +17,7 @@ jobs: strategy: matrix: - node-version: [22.x] + node-version: [20.x, 22.x] # See supported Node.js release schedule at https://nodejs.org/en/about/releases/ steps: @@ -28,5 +28,5 @@ jobs: node-version: ${{ matrix.node-version }} cache: 'npm' - run: npm ci - - run: npm run build --if-present - - run: npm test + - run: npm run build + - run: npm run coverage diff --git a/.gitignore b/.gitignore index fa0f365..88e32f2 100644 --- a/.gitignore +++ b/.gitignore @@ -1,6 +1,7 @@ /node_modules /dist /build +/coverage # npm pack output /*.tgz /*.crt diff --git a/package-lock.json b/package-lock.json index 318e413..0b19555 100644 --- a/package-lock.json +++ b/package-lock.json @@ -7,60 +7,1074 @@ "": { "name": "h2tunnel", "version": "0.1.0", + "license": "MIT", "bin": { "h2tunnel": "build/cli.js" }, "devDependencies": { "@types/node": "^22.7.5", + "c8": "^10.1.2", "prettier": "^3.3.3", "typescript": "^5.6.3" + }, + "engines": { + "node": ">=20" + } + }, + "node_modules/@bcoe/v8-coverage": { + "version": "0.2.3", + "resolved": "https://registry.npmjs.org/@bcoe/v8-coverage/-/v8-coverage-0.2.3.tgz", + "integrity": "sha512-0hYQ8SB4Db5zvZB4axdMHGwEaQjkZzFjQiN9LVYvIFB2nSUHW9tYpxWriPrWDASIxiaXax83REcLxuSdnGPZtw==", + "dev": true + }, + "node_modules/@isaacs/cliui": { + "version": "8.0.2", + "resolved": "https://registry.npmjs.org/@isaacs/cliui/-/cliui-8.0.2.tgz", + "integrity": "sha512-O8jcjabXaleOG9DQ0+ARXWZBTfnP4WNAqzuiJK7ll44AmxGKv/J2M4TPjxjY3znBCfvBXFzucm1twdyFybFqEA==", + "dev": true, + "dependencies": { + "string-width": "^5.1.2", + "string-width-cjs": "npm:string-width@^4.2.0", + "strip-ansi": "^7.0.1", + "strip-ansi-cjs": "npm:strip-ansi@^6.0.1", + "wrap-ansi": "^8.1.0", + "wrap-ansi-cjs": "npm:wrap-ansi@^7.0.0" + }, + "engines": { + "node": ">=12" + } + }, + "node_modules/@istanbuljs/schema": { + "version": "0.1.3", + "resolved": "https://registry.npmjs.org/@istanbuljs/schema/-/schema-0.1.3.tgz", + "integrity": "sha512-ZXRY4jNvVgSVQ8DL3LTcakaAtXwTVUxE81hslsyD2AtoXW/wVob10HkOJ1X/pAlcI7D+2YoZKg5do8G/w6RYgA==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/@jridgewell/resolve-uri": { + "version": "3.1.2", + "resolved": "https://registry.npmjs.org/@jridgewell/resolve-uri/-/resolve-uri-3.1.2.tgz", + "integrity": "sha512-bRISgCIjP20/tbWSPWMEi54QVPRZExkuD9lJL+UIxUKtwVJA8wW1Trb1jMs1RFXo1CBTNZ/5hpC9QvmKWdopKw==", + "dev": true, + "engines": { + "node": ">=6.0.0" + } + }, + "node_modules/@jridgewell/sourcemap-codec": { + "version": "1.5.0", + "resolved": "https://registry.npmjs.org/@jridgewell/sourcemap-codec/-/sourcemap-codec-1.5.0.tgz", + "integrity": "sha512-gv3ZRaISU3fjPAgNsriBRqGWQL6quFx04YMPW/zD8XMLsU32mhCCbfbO6KZFLjvYpCZ8zyDEgqsgf+PwPaM7GQ==", + "dev": true + }, + "node_modules/@jridgewell/trace-mapping": { + "version": "0.3.25", + "resolved": "https://registry.npmjs.org/@jridgewell/trace-mapping/-/trace-mapping-0.3.25.tgz", + "integrity": "sha512-vNk6aEwybGtawWmy/PzwnGDOjCkLWSD2wqvjGGAgOAwCGWySYXfYoxt00IJkTF+8Lb57DwOb3Aa0o9CApepiYQ==", + "dev": true, + "dependencies": { + "@jridgewell/resolve-uri": "^3.1.0", + "@jridgewell/sourcemap-codec": "^1.4.14" + } + }, + "node_modules/@pkgjs/parseargs": { + "version": "0.11.0", + "resolved": "https://registry.npmjs.org/@pkgjs/parseargs/-/parseargs-0.11.0.tgz", + "integrity": "sha512-+1VkjdD0QBLPodGrJUeqarH8VAIvQODIbwh9XpP5Syisf7YoQgsJKPNFoqqLQlu+VQ/tVSshMR6loPMn8U+dPg==", + "dev": true, + "optional": true, + "engines": { + "node": ">=14" + } + }, + "node_modules/@types/istanbul-lib-coverage": { + "version": "2.0.6", + "resolved": "https://registry.npmjs.org/@types/istanbul-lib-coverage/-/istanbul-lib-coverage-2.0.6.tgz", + "integrity": "sha512-2QF/t/auWm0lsy8XtKVPG19v3sSOQlJe/YHZgfjb/KBBHOGSV+J2q/S671rcq9uTBrLAXmZpqJiaQbMT+zNU1w==", + "dev": true + }, + "node_modules/@types/node": { + "version": "22.7.5", + "resolved": "https://registry.npmjs.org/@types/node/-/node-22.7.5.tgz", + "integrity": "sha512-jML7s2NAzMWc//QSJ1a3prpk78cOPchGvXJsC3C6R6PSMoooztvRVQEz89gmBTBY1SPMaqo5teB4uNHPdetShQ==", + "dev": true, + "dependencies": { + "undici-types": "~6.19.2" + } + }, + "node_modules/ansi-regex": { + "version": "6.1.0", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-6.1.0.tgz", + "integrity": "sha512-7HSX4QQb4CspciLpVFwyRe79O3xsIZDDLER21kERQ71oaPodF8jL725AgJMFAYbooIqolJoRLuM81SpeUkpkvA==", + "dev": true, + "engines": { + "node": ">=12" + }, + "funding": { + "url": "https://github.com/chalk/ansi-regex?sponsor=1" + } + }, + "node_modules/ansi-styles": { + "version": "6.2.1", + "resolved": "https://registry.npmjs.org/ansi-styles/-/ansi-styles-6.2.1.tgz", + "integrity": "sha512-bN798gFfQX+viw3R7yrGWRqnrN2oRkEkUjjl4JNn4E8GxxbjtG3FbrEIIY3l8/hrwUwIeCZvi4QuOTP4MErVug==", + "dev": true, + "engines": { + "node": ">=12" + }, + "funding": { + "url": "https://github.com/chalk/ansi-styles?sponsor=1" + } + }, + "node_modules/balanced-match": { + "version": "1.0.2", + "resolved": "https://registry.npmjs.org/balanced-match/-/balanced-match-1.0.2.tgz", + "integrity": "sha512-3oSeUO0TMV67hN1AmbXsK4yaqU7tjiHlbxRDZOpH0KW9+CeX4bRAaX0Anxt0tx2MrpRpWwQaPwIlISEJhYU5Pw==", + "dev": true + }, + "node_modules/brace-expansion": { + "version": "2.0.1", + "resolved": "https://registry.npmjs.org/brace-expansion/-/brace-expansion-2.0.1.tgz", + "integrity": "sha512-XnAIvQ8eM+kC6aULx6wuQiwVsnzsi9d3WxzV3FpWTGA19F621kwdbsAcFKXgKUHZWsy+mY6iL1sHTxWEFCytDA==", + "dev": true, + "dependencies": { + "balanced-match": "^1.0.0" + } + }, + "node_modules/c8": { + "version": "10.1.2", + "resolved": "https://registry.npmjs.org/c8/-/c8-10.1.2.tgz", + "integrity": "sha512-Qr6rj76eSshu5CgRYvktW0uM0CFY0yi4Fd5D0duDXO6sYinyopmftUiJVuzBQxQcwQLor7JWDVRP+dUfCmzgJw==", + "dev": true, + "dependencies": { + "@bcoe/v8-coverage": "^0.2.3", + "@istanbuljs/schema": "^0.1.3", + "find-up": "^5.0.0", + "foreground-child": "^3.1.1", + "istanbul-lib-coverage": "^3.2.0", + "istanbul-lib-report": "^3.0.1", + "istanbul-reports": "^3.1.6", + "test-exclude": "^7.0.1", + "v8-to-istanbul": "^9.0.0", + "yargs": "^17.7.2", + "yargs-parser": "^21.1.1" + }, + "bin": { + "c8": "bin/c8.js" + }, + "engines": { + "node": ">=18" + }, + "peerDependencies": { + "monocart-coverage-reports": "^2" + }, + "peerDependenciesMeta": { + "monocart-coverage-reports": { + "optional": true + } + } + }, + "node_modules/cliui": { + "version": "8.0.1", + "resolved": "https://registry.npmjs.org/cliui/-/cliui-8.0.1.tgz", + "integrity": "sha512-BSeNnyus75C4//NQ9gQt1/csTXyo/8Sb+afLAkzAptFuMsod9HFokGNudZpi/oQV73hnVK+sR+5PVRMd+Dr7YQ==", + "dev": true, + "dependencies": { + "string-width": "^4.2.0", + "strip-ansi": "^6.0.1", + "wrap-ansi": "^7.0.0" + }, + "engines": { + "node": ">=12" + } + }, + "node_modules/cliui/node_modules/ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/cliui/node_modules/ansi-styles": { + "version": "4.3.0", + "resolved": "https://registry.npmjs.org/ansi-styles/-/ansi-styles-4.3.0.tgz", + "integrity": "sha512-zbB9rCJAT1rbjiVDb2hqKFHNYLxgtk8NURxZ3IZwD3F6NtxbXZQCnnSi1Lkx+IDohdPlFp222wVALIheZJQSEg==", + "dev": true, + "dependencies": { + "color-convert": "^2.0.1" + }, + "engines": { + "node": ">=8" + }, + "funding": { + "url": "https://github.com/chalk/ansi-styles?sponsor=1" + } + }, + "node_modules/cliui/node_modules/emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "node_modules/cliui/node_modules/string-width": { + "version": "4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "dependencies": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/cliui/node_modules/strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "dependencies": { + "ansi-regex": "^5.0.1" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/cliui/node_modules/wrap-ansi": { + "version": "7.0.0", + "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-7.0.0.tgz", + "integrity": "sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==", + "dev": true, + "dependencies": { + "ansi-styles": "^4.0.0", + "string-width": "^4.1.0", + "strip-ansi": "^6.0.0" + }, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/chalk/wrap-ansi?sponsor=1" + } + }, + "node_modules/color-convert": { + "version": "2.0.1", + "resolved": "https://registry.npmjs.org/color-convert/-/color-convert-2.0.1.tgz", + "integrity": "sha512-RRECPsj7iu/xb5oKYcsFHSppFNnsj/52OVTRKb4zP5onXwVF3zVmmToNcOfGC+CRDpfK/U584fMg38ZHCaElKQ==", + "dev": true, + "dependencies": { + "color-name": "~1.1.4" + }, + "engines": { + "node": ">=7.0.0" + } + }, + "node_modules/color-name": { + "version": "1.1.4", + "resolved": "https://registry.npmjs.org/color-name/-/color-name-1.1.4.tgz", + "integrity": "sha512-dOy+3AuW3a2wNbZHIuMZpTcgjGuLU/uBL/ubcZF9OXbDo8ff4O8yVp5Bf0efS8uEoYo5q4Fx7dY9OgQGXgAsQA==", + "dev": true + }, + "node_modules/convert-source-map": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/convert-source-map/-/convert-source-map-2.0.0.tgz", + "integrity": "sha512-Kvp459HrV2FEJ1CAsi1Ku+MY3kasH19TFykTz2xWmMeq6bk2NU3XXvfJ+Q61m0xktWwt+1HSYf3JZsTms3aRJg==", + "dev": true + }, + "node_modules/cross-spawn": { + "version": "7.0.3", + "resolved": "https://registry.npmjs.org/cross-spawn/-/cross-spawn-7.0.3.tgz", + "integrity": "sha512-iRDPJKUPVEND7dHPO8rkbOnPpyDygcDFtWjpeWNCgy8WP2rXcxXL8TskReQl6OrB2G7+UJrags1q15Fudc7G6w==", + "dev": true, + "dependencies": { + "path-key": "^3.1.0", + "shebang-command": "^2.0.0", + "which": "^2.0.1" + }, + "engines": { + "node": ">= 8" + } + }, + "node_modules/eastasianwidth": { + "version": "0.2.0", + "resolved": "https://registry.npmjs.org/eastasianwidth/-/eastasianwidth-0.2.0.tgz", + "integrity": "sha512-I88TYZWc9XiYHRQ4/3c5rjjfgkjhLyW2luGIheGERbNQ6OY7yTybanSpDXZa8y7VUP9YmDcYa+eyq4ca7iLqWA==", + "dev": true + }, + "node_modules/emoji-regex": { + "version": "9.2.2", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-9.2.2.tgz", + "integrity": "sha512-L18DaJsXSUk2+42pv8mLs5jJT2hqFkFE4j21wOmgbUqsZ2hL72NsUU785g9RXgo3s0ZNgVl42TiHp3ZtOv/Vyg==", + "dev": true + }, + "node_modules/escalade": { + "version": "3.2.0", + "resolved": "https://registry.npmjs.org/escalade/-/escalade-3.2.0.tgz", + "integrity": "sha512-WUj2qlxaQtO4g6Pq5c29GTcWGDyd8itL8zTlipgECz3JesAiiOKotd8JU6otB3PACgG6xkJUyVhboMS+bje/jA==", + "dev": true, + "engines": { + "node": ">=6" + } + }, + "node_modules/find-up": { + "version": "5.0.0", + "resolved": "https://registry.npmjs.org/find-up/-/find-up-5.0.0.tgz", + "integrity": "sha512-78/PXT1wlLLDgTzDs7sjq9hzz0vXD+zn+7wypEe4fXQxCmdmqfGsEPQxmiCSQI3ajFV91bVSsvNtrJRiW6nGng==", + "dev": true, + "dependencies": { + "locate-path": "^6.0.0", + "path-exists": "^4.0.0" + }, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/foreground-child": { + "version": "3.3.0", + "resolved": "https://registry.npmjs.org/foreground-child/-/foreground-child-3.3.0.tgz", + "integrity": "sha512-Ld2g8rrAyMYFXBhEqMz8ZAHBi4J4uS1i/CxGMDnjyFWddMXLVcDp051DZfu+t7+ab7Wv6SMqpWmyFIj5UbfFvg==", + "dev": true, + "dependencies": { + "cross-spawn": "^7.0.0", + "signal-exit": "^4.0.1" + }, + "engines": { + "node": ">=14" + }, + "funding": { + "url": "https://github.com/sponsors/isaacs" + } + }, + "node_modules/get-caller-file": { + "version": "2.0.5", + "resolved": "https://registry.npmjs.org/get-caller-file/-/get-caller-file-2.0.5.tgz", + "integrity": "sha512-DyFP3BM/3YHTQOCUL/w0OZHR0lpKeGrxotcHWcqNEdnltqFwXVfhEBQ94eIo34AfQpo0rGki4cyIiftY06h2Fg==", + "dev": true, + "engines": { + "node": "6.* || 8.* || >= 10.*" + } + }, + "node_modules/glob": { + "version": "10.4.5", + "resolved": "https://registry.npmjs.org/glob/-/glob-10.4.5.tgz", + "integrity": "sha512-7Bv8RF0k6xjo7d4A/PxYLbUCfb6c+Vpd2/mB2yRDlew7Jb5hEXiCD9ibfO7wpk8i4sevK6DFny9h7EYbM3/sHg==", + "dev": true, + "dependencies": { + "foreground-child": "^3.1.0", + "jackspeak": "^3.1.2", + "minimatch": "^9.0.4", + "minipass": "^7.1.2", + "package-json-from-dist": "^1.0.0", + "path-scurry": "^1.11.1" + }, + "bin": { + "glob": "dist/esm/bin.mjs" + }, + "funding": { + "url": "https://github.com/sponsors/isaacs" + } + }, + "node_modules/has-flag": { + "version": "4.0.0", + "resolved": "https://registry.npmjs.org/has-flag/-/has-flag-4.0.0.tgz", + "integrity": "sha512-EykJT/Q1KjTWctppgIAgfSO0tKVuZUjhgMr17kqTumMl6Afv3EISleU7qZUzoXDFTAHTDC4NOoG/ZxU3EvlMPQ==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/html-escaper": { + "version": "2.0.2", + "resolved": "https://registry.npmjs.org/html-escaper/-/html-escaper-2.0.2.tgz", + "integrity": "sha512-H2iMtd0I4Mt5eYiapRdIDjp+XzelXQ0tFE4JS7YFwFevXXMmOp9myNrUvCg0D6ws8iqkRPBfKHgbwig1SmlLfg==", + "dev": true + }, + "node_modules/is-fullwidth-code-point": { + "version": "3.0.0", + "resolved": "https://registry.npmjs.org/is-fullwidth-code-point/-/is-fullwidth-code-point-3.0.0.tgz", + "integrity": "sha512-zymm5+u+sCsSWyD9qNaejV3DFvhCKclKdizYaJUuHA83RLjb7nSuGnddCHGv0hk+KY7BMAlsWeK4Ueg6EV6XQg==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/isexe": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/isexe/-/isexe-2.0.0.tgz", + "integrity": "sha512-RHxMLp9lnKHGHRng9QFhRCMbYAcVpn69smSGcq3f36xjgVVWThj4qqLbTLlq7Ssj8B+fIQ1EuCEGI2lKsyQeIw==", + "dev": true + }, + "node_modules/istanbul-lib-coverage": { + "version": "3.2.2", + "resolved": "https://registry.npmjs.org/istanbul-lib-coverage/-/istanbul-lib-coverage-3.2.2.tgz", + "integrity": "sha512-O8dpsF+r0WV/8MNRKfnmrtCWhuKjxrq2w+jpzBL5UZKTi2LeVWnWOmWRxFlesJONmc+wLAGvKQZEOanko0LFTg==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/istanbul-lib-report": { + "version": "3.0.1", + "resolved": "https://registry.npmjs.org/istanbul-lib-report/-/istanbul-lib-report-3.0.1.tgz", + "integrity": "sha512-GCfE1mtsHGOELCU8e/Z7YWzpmybrx/+dSTfLrvY8qRmaY6zXTKWn6WQIjaAFw069icm6GVMNkgu0NzI4iPZUNw==", + "dev": true, + "dependencies": { + "istanbul-lib-coverage": "^3.0.0", + "make-dir": "^4.0.0", + "supports-color": "^7.1.0" + }, + "engines": { + "node": ">=10" + } + }, + "node_modules/istanbul-reports": { + "version": "3.1.7", + "resolved": "https://registry.npmjs.org/istanbul-reports/-/istanbul-reports-3.1.7.tgz", + "integrity": "sha512-BewmUXImeuRk2YY0PVbxgKAysvhRPUQE0h5QRM++nVWyubKGV0l8qQ5op8+B2DOmwSe63Jivj0BjkPQVf8fP5g==", + "dev": true, + "dependencies": { + "html-escaper": "^2.0.0", + "istanbul-lib-report": "^3.0.0" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/jackspeak": { + "version": "3.4.3", + "resolved": "https://registry.npmjs.org/jackspeak/-/jackspeak-3.4.3.tgz", + "integrity": "sha512-OGlZQpz2yfahA/Rd1Y8Cd9SIEsqvXkLVoSw/cgwhnhFMDbsQFeZYoJJ7bIZBS9BcamUW96asq/npPWugM+RQBw==", + "dev": true, + "dependencies": { + "@isaacs/cliui": "^8.0.2" + }, + "funding": { + "url": "https://github.com/sponsors/isaacs" + }, + "optionalDependencies": { + "@pkgjs/parseargs": "^0.11.0" + } + }, + "node_modules/locate-path": { + "version": "6.0.0", + "resolved": "https://registry.npmjs.org/locate-path/-/locate-path-6.0.0.tgz", + "integrity": "sha512-iPZK6eYjbxRu3uB4/WZ3EsEIMJFMqAoopl3R+zuq0UjcAm/MO6KCweDgPfP3elTztoKP3KtnVHxTn2NHBSDVUw==", + "dev": true, + "dependencies": { + "p-locate": "^5.0.0" + }, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/lru-cache": { + "version": "10.4.3", + "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-10.4.3.tgz", + "integrity": "sha512-JNAzZcXrCt42VGLuYz0zfAzDfAvJWW6AfYlDBQyDV5DClI2m5sAmK+OIO7s59XfsRsWHp02jAJrRadPRGTt6SQ==", + "dev": true + }, + "node_modules/make-dir": { + "version": "4.0.0", + "resolved": "https://registry.npmjs.org/make-dir/-/make-dir-4.0.0.tgz", + "integrity": "sha512-hXdUTZYIVOt1Ex//jAQi+wTZZpUpwBj/0QsOzqegb3rGMMeJiSEu5xLHnYfBrRV4RH2+OCSOO95Is/7x1WJ4bw==", + "dev": true, + "dependencies": { + "semver": "^7.5.3" + }, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/minimatch": { + "version": "9.0.5", + "resolved": "https://registry.npmjs.org/minimatch/-/minimatch-9.0.5.tgz", + "integrity": "sha512-G6T0ZX48xgozx7587koeX9Ys2NYy6Gmv//P89sEte9V9whIapMNF4idKxnW2QtCcLiTWlb/wfCabAtAFWhhBow==", + "dev": true, + "dependencies": { + "brace-expansion": "^2.0.1" + }, + "engines": { + "node": ">=16 || 14 >=14.17" + }, + "funding": { + "url": "https://github.com/sponsors/isaacs" + } + }, + "node_modules/minipass": { + "version": "7.1.2", + "resolved": "https://registry.npmjs.org/minipass/-/minipass-7.1.2.tgz", + "integrity": "sha512-qOOzS1cBTWYF4BH8fVePDBOO9iptMnGUEZwNc/cMWnTV2nVLZ7VoNWEPHkYczZA0pdoA7dl6e7FL659nX9S2aw==", + "dev": true, + "engines": { + "node": ">=16 || 14 >=14.17" + } + }, + "node_modules/p-limit": { + "version": "3.1.0", + "resolved": "https://registry.npmjs.org/p-limit/-/p-limit-3.1.0.tgz", + "integrity": "sha512-TYOanM3wGwNGsZN2cVTYPArw454xnXj5qmWF1bEoAc4+cU/ol7GVh7odevjp1FNHduHc3KZMcFduxU5Xc6uJRQ==", + "dev": true, + "dependencies": { + "yocto-queue": "^0.1.0" + }, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/p-locate": { + "version": "5.0.0", + "resolved": "https://registry.npmjs.org/p-locate/-/p-locate-5.0.0.tgz", + "integrity": "sha512-LaNjtRWUBY++zB5nE/NwcaoMylSPk+S+ZHNB1TzdbMJMny6dynpAGt7X/tl/QYq3TIeE6nxHppbo2LGymrG5Pw==", + "dev": true, + "dependencies": { + "p-limit": "^3.0.2" + }, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/package-json-from-dist": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/package-json-from-dist/-/package-json-from-dist-1.0.1.tgz", + "integrity": "sha512-UEZIS3/by4OC8vL3P2dTXRETpebLI2NiI5vIrjaD/5UtrkFX/tNbwjTSRAGC/+7CAo2pIcBaRgWmcBBHcsaCIw==", + "dev": true + }, + "node_modules/path-exists": { + "version": "4.0.0", + "resolved": "https://registry.npmjs.org/path-exists/-/path-exists-4.0.0.tgz", + "integrity": "sha512-ak9Qy5Q7jYb2Wwcey5Fpvg2KoAc/ZIhLSLOSBmRmygPsGwkVVt0fZa0qrtMz+m6tJTAHfZQ8FnmB4MG4LWy7/w==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/path-key": { + "version": "3.1.1", + "resolved": "https://registry.npmjs.org/path-key/-/path-key-3.1.1.tgz", + "integrity": "sha512-ojmeN0qd+y0jszEtoY48r0Peq5dwMEkIlCOu6Q5f41lfkswXuKtYrhgoTpLnyIcHm24Uhqx+5Tqm2InSwLhE6Q==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/path-scurry": { + "version": "1.11.1", + "resolved": "https://registry.npmjs.org/path-scurry/-/path-scurry-1.11.1.tgz", + "integrity": "sha512-Xa4Nw17FS9ApQFJ9umLiJS4orGjm7ZzwUrwamcGQuHSzDyth9boKDaycYdDcZDuqYATXw4HFXgaqWTctW/v1HA==", + "dev": true, + "dependencies": { + "lru-cache": "^10.2.0", + "minipass": "^5.0.0 || ^6.0.2 || ^7.0.0" + }, + "engines": { + "node": ">=16 || 14 >=14.18" + }, + "funding": { + "url": "https://github.com/sponsors/isaacs" + } + }, + "node_modules/prettier": { + "version": "3.3.3", + "resolved": "https://registry.npmjs.org/prettier/-/prettier-3.3.3.tgz", + "integrity": "sha512-i2tDNA0O5IrMO757lfrdQZCc2jPNDVntV0m/+4whiDfWaTKfMNgR7Qz0NAeGz/nRqF4m5/6CLzbP4/liHt12Ew==", + "dev": true, + "bin": { + "prettier": "bin/prettier.cjs" + }, + "engines": { + "node": ">=14" + }, + "funding": { + "url": "https://github.com/prettier/prettier?sponsor=1" + } + }, + "node_modules/require-directory": { + "version": "2.1.1", + "resolved": "https://registry.npmjs.org/require-directory/-/require-directory-2.1.1.tgz", + "integrity": "sha512-fGxEI7+wsG9xrvdjsrlmL22OMTTiHRwAMroiEeMgq8gzoLC/PQr7RsRDSTLUg/bZAZtF+TVIkHc6/4RIKrui+Q==", + "dev": true, + "engines": { + "node": ">=0.10.0" + } + }, + "node_modules/semver": { + "version": "7.6.3", + "resolved": "https://registry.npmjs.org/semver/-/semver-7.6.3.tgz", + "integrity": "sha512-oVekP1cKtI+CTDvHWYFUcMtsK/00wmAEfyqKfNdARm8u1wNVhSgaX7A8d4UuIlUI5e84iEwOhs7ZPYRmzU9U6A==", + "dev": true, + "bin": { + "semver": "bin/semver.js" + }, + "engines": { + "node": ">=10" + } + }, + "node_modules/shebang-command": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/shebang-command/-/shebang-command-2.0.0.tgz", + "integrity": "sha512-kHxr2zZpYtdmrN1qDjrrX/Z1rR1kG8Dx+gkpK1G4eXmvXswmcE1hTWBWYUzlraYw1/yZp6YuDY77YtvbN0dmDA==", + "dev": true, + "dependencies": { + "shebang-regex": "^3.0.0" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/shebang-regex": { + "version": "3.0.0", + "resolved": "https://registry.npmjs.org/shebang-regex/-/shebang-regex-3.0.0.tgz", + "integrity": "sha512-7++dFhtcx3353uBaq8DDR4NuxBetBzC7ZQOhmTQInHEd6bSrXdiEyzCvG07Z44UYdLShWUyXt5M/yhz8ekcb1A==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/signal-exit": { + "version": "4.1.0", + "resolved": "https://registry.npmjs.org/signal-exit/-/signal-exit-4.1.0.tgz", + "integrity": "sha512-bzyZ1e88w9O1iNJbKnOlvYTrWPDl46O1bG0D3XInv+9tkPrxrN8jUUTiFlDkkmKWgn1M6CfIA13SuGqOa9Korw==", + "dev": true, + "engines": { + "node": ">=14" + }, + "funding": { + "url": "https://github.com/sponsors/isaacs" + } + }, + "node_modules/string-width": { + "version": "5.1.2", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-5.1.2.tgz", + "integrity": "sha512-HnLOCR3vjcY8beoNLtcjZ5/nxn2afmME6lhrDrebokqMap+XbeW8n9TXpPDOqdGK5qcI3oT0GKTW6wC7EMiVqA==", + "dev": true, + "dependencies": { + "eastasianwidth": "^0.2.0", + "emoji-regex": "^9.2.2", + "strip-ansi": "^7.0.1" + }, + "engines": { + "node": ">=12" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } + }, + "node_modules/string-width-cjs": { + "name": "string-width", + "version": "4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "dependencies": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/string-width-cjs/node_modules/ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/string-width-cjs/node_modules/emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "node_modules/string-width-cjs/node_modules/strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "dependencies": { + "ansi-regex": "^5.0.1" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/strip-ansi": { + "version": "7.1.0", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-7.1.0.tgz", + "integrity": "sha512-iq6eVVI64nQQTRYq2KtEg2d2uU7LElhTJwsH4YzIHZshxlgZms/wIc4VoDQTlG/IvVIrBKG06CrZnp0qv7hkcQ==", + "dev": true, + "dependencies": { + "ansi-regex": "^6.0.1" + }, + "engines": { + "node": ">=12" + }, + "funding": { + "url": "https://github.com/chalk/strip-ansi?sponsor=1" + } + }, + "node_modules/strip-ansi-cjs": { + "name": "strip-ansi", + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "dependencies": { + "ansi-regex": "^5.0.1" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/strip-ansi-cjs/node_modules/ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/supports-color": { + "version": "7.2.0", + "resolved": "https://registry.npmjs.org/supports-color/-/supports-color-7.2.0.tgz", + "integrity": "sha512-qpCAvRl9stuOHveKsn7HncJRvv501qIacKzQlO/+Lwxc9+0q2wLyv4Dfvt80/DPn2pqOBsJdDiogXGR9+OvwRw==", + "dev": true, + "dependencies": { + "has-flag": "^4.0.0" + }, + "engines": { + "node": ">=8" + } + }, + "node_modules/test-exclude": { + "version": "7.0.1", + "resolved": "https://registry.npmjs.org/test-exclude/-/test-exclude-7.0.1.tgz", + "integrity": "sha512-pFYqmTw68LXVjeWJMST4+borgQP2AyMNbg1BpZh9LbyhUeNkeaPF9gzfPGUAnSMV3qPYdWUwDIjjCLiSDOl7vg==", + "dev": true, + "dependencies": { + "@istanbuljs/schema": "^0.1.2", + "glob": "^10.4.1", + "minimatch": "^9.0.4" + }, + "engines": { + "node": ">=18" + } + }, + "node_modules/typescript": { + "version": "5.6.3", + "resolved": "https://registry.npmjs.org/typescript/-/typescript-5.6.3.tgz", + "integrity": "sha512-hjcS1mhfuyi4WW8IWtjP7brDrG2cuDZukyrYrSauoXGNgx0S7zceP07adYkJycEr56BOUTNPzbInooiN3fn1qw==", + "dev": true, + "bin": { + "tsc": "bin/tsc", + "tsserver": "bin/tsserver" + }, + "engines": { + "node": ">=14.17" + } + }, + "node_modules/undici-types": { + "version": "6.19.8", + "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-6.19.8.tgz", + "integrity": "sha512-ve2KP6f/JnbPBFyobGHuerC9g1FYGn/F8n1LWTwNxCEzd6IfqTwUQcNXgEtmmQ6DlRrC1hrSrBnCZPokRrDHjw==", + "dev": true + }, + "node_modules/v8-to-istanbul": { + "version": "9.3.0", + "resolved": "https://registry.npmjs.org/v8-to-istanbul/-/v8-to-istanbul-9.3.0.tgz", + "integrity": "sha512-kiGUalWN+rgBJ/1OHZsBtU4rXZOfj/7rKQxULKlIzwzQSvMJUUNgPwJEEh7gU6xEVxC0ahoOBvN2YI8GH6FNgA==", + "dev": true, + "dependencies": { + "@jridgewell/trace-mapping": "^0.3.12", + "@types/istanbul-lib-coverage": "^2.0.1", + "convert-source-map": "^2.0.0" + }, + "engines": { + "node": ">=10.12.0" + } + }, + "node_modules/which": { + "version": "2.0.2", + "resolved": "https://registry.npmjs.org/which/-/which-2.0.2.tgz", + "integrity": "sha512-BLI3Tl1TW3Pvl70l3yq3Y64i+awpwXqsGBYWkkqMtnbXgrMD+yj7rhW0kuEDxzJaYXGjEW5ogapKNMEKNMjibA==", + "dev": true, + "dependencies": { + "isexe": "^2.0.0" + }, + "bin": { + "node-which": "bin/node-which" + }, + "engines": { + "node": ">= 8" + } + }, + "node_modules/wrap-ansi": { + "version": "8.1.0", + "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-8.1.0.tgz", + "integrity": "sha512-si7QWI6zUMq56bESFvagtmzMdGOtoxfR+Sez11Mobfc7tm+VkUckk9bW2UeffTGVUbOksxmSw0AA2gs8g71NCQ==", + "dev": true, + "dependencies": { + "ansi-styles": "^6.1.0", + "string-width": "^5.0.1", + "strip-ansi": "^7.0.1" + }, + "engines": { + "node": ">=12" + }, + "funding": { + "url": "https://github.com/chalk/wrap-ansi?sponsor=1" + } + }, + "node_modules/wrap-ansi-cjs": { + "name": "wrap-ansi", + "version": "7.0.0", + "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-7.0.0.tgz", + "integrity": "sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==", + "dev": true, + "dependencies": { + "ansi-styles": "^4.0.0", + "string-width": "^4.1.0", + "strip-ansi": "^6.0.0" + }, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/chalk/wrap-ansi?sponsor=1" + } + }, + "node_modules/wrap-ansi-cjs/node_modules/ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/wrap-ansi-cjs/node_modules/ansi-styles": { + "version": "4.3.0", + "resolved": "https://registry.npmjs.org/ansi-styles/-/ansi-styles-4.3.0.tgz", + "integrity": "sha512-zbB9rCJAT1rbjiVDb2hqKFHNYLxgtk8NURxZ3IZwD3F6NtxbXZQCnnSi1Lkx+IDohdPlFp222wVALIheZJQSEg==", + "dev": true, + "dependencies": { + "color-convert": "^2.0.1" + }, + "engines": { + "node": ">=8" + }, + "funding": { + "url": "https://github.com/chalk/ansi-styles?sponsor=1" + } + }, + "node_modules/wrap-ansi-cjs/node_modules/emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "node_modules/wrap-ansi-cjs/node_modules/string-width": { + "version": "4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "dependencies": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" + }, + "engines": { + "node": ">=8" } }, - "node_modules/@types/node": { - "version": "22.7.5", - "resolved": "https://registry.npmjs.org/@types/node/-/node-22.7.5.tgz", - "integrity": "sha512-jML7s2NAzMWc//QSJ1a3prpk78cOPchGvXJsC3C6R6PSMoooztvRVQEz89gmBTBY1SPMaqo5teB4uNHPdetShQ==", + "node_modules/wrap-ansi-cjs/node_modules/strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", "dev": true, "dependencies": { - "undici-types": "~6.19.2" + "ansi-regex": "^5.0.1" + }, + "engines": { + "node": ">=8" } }, - "node_modules/prettier": { - "version": "3.3.3", - "resolved": "https://registry.npmjs.org/prettier/-/prettier-3.3.3.tgz", - "integrity": "sha512-i2tDNA0O5IrMO757lfrdQZCc2jPNDVntV0m/+4whiDfWaTKfMNgR7Qz0NAeGz/nRqF4m5/6CLzbP4/liHt12Ew==", + "node_modules/y18n": { + "version": "5.0.8", + "resolved": "https://registry.npmjs.org/y18n/-/y18n-5.0.8.tgz", + "integrity": "sha512-0pfFzegeDWJHJIAmTLRP2DwHjdF5s7jo9tuztdQxAhINCdvS+3nGINqPd00AphqJR/0LhANUS6/+7SCb98YOfA==", "dev": true, - "bin": { - "prettier": "bin/prettier.cjs" + "engines": { + "node": ">=10" + } + }, + "node_modules/yargs": { + "version": "17.7.2", + "resolved": "https://registry.npmjs.org/yargs/-/yargs-17.7.2.tgz", + "integrity": "sha512-7dSzzRQ++CKnNI/krKnYRV7JKKPUXMEh61soaHKg9mrWEhzFWhFnxPxGl+69cD1Ou63C13NUPCnmIcrvqCuM6w==", + "dev": true, + "dependencies": { + "cliui": "^8.0.1", + "escalade": "^3.1.1", + "get-caller-file": "^2.0.5", + "require-directory": "^2.1.1", + "string-width": "^4.2.3", + "y18n": "^5.0.5", + "yargs-parser": "^21.1.1" }, "engines": { - "node": ">=14" + "node": ">=12" + } + }, + "node_modules/yargs-parser": { + "version": "21.1.1", + "resolved": "https://registry.npmjs.org/yargs-parser/-/yargs-parser-21.1.1.tgz", + "integrity": "sha512-tVpsJW7DdjecAiFpbIB1e3qxIQsE6NoPc5/eTdrbbIC4h0LVsWhnoa3g+m2HclBIujHzsxZ4VJVA+GUuc2/LBw==", + "dev": true, + "engines": { + "node": ">=12" + } + }, + "node_modules/yargs/node_modules/ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true, + "engines": { + "node": ">=8" + } + }, + "node_modules/yargs/node_modules/emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "node_modules/yargs/node_modules/string-width": { + "version": "4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "dependencies": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" }, - "funding": { - "url": "https://github.com/prettier/prettier?sponsor=1" + "engines": { + "node": ">=8" } }, - "node_modules/typescript": { - "version": "5.6.3", - "resolved": "https://registry.npmjs.org/typescript/-/typescript-5.6.3.tgz", - "integrity": "sha512-hjcS1mhfuyi4WW8IWtjP7brDrG2cuDZukyrYrSauoXGNgx0S7zceP07adYkJycEr56BOUTNPzbInooiN3fn1qw==", + "node_modules/yargs/node_modules/strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", "dev": true, - "bin": { - "tsc": "bin/tsc", - "tsserver": "bin/tsserver" + "dependencies": { + "ansi-regex": "^5.0.1" }, "engines": { - "node": ">=14.17" + "node": ">=8" } }, - "node_modules/undici-types": { - "version": "6.19.8", - "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-6.19.8.tgz", - "integrity": "sha512-ve2KP6f/JnbPBFyobGHuerC9g1FYGn/F8n1LWTwNxCEzd6IfqTwUQcNXgEtmmQ6DlRrC1hrSrBnCZPokRrDHjw==", - "dev": true + "node_modules/yocto-queue": { + "version": "0.1.0", + "resolved": "https://registry.npmjs.org/yocto-queue/-/yocto-queue-0.1.0.tgz", + "integrity": "sha512-rVksvsnNCdJ/ohGc6xgPwyN8eheCxsiLM8mxuE/t/mOVqJewPuO1miLpTHQiRgTKCLexL4MeAFVagts7HmNZ2Q==", + "dev": true, + "engines": { + "node": ">=10" + }, + "funding": { + "url": "https://github.com/sponsors/sindresorhus" + } } }, "dependencies": { + "@bcoe/v8-coverage": { + "version": "0.2.3", + "resolved": "https://registry.npmjs.org/@bcoe/v8-coverage/-/v8-coverage-0.2.3.tgz", + "integrity": "sha512-0hYQ8SB4Db5zvZB4axdMHGwEaQjkZzFjQiN9LVYvIFB2nSUHW9tYpxWriPrWDASIxiaXax83REcLxuSdnGPZtw==", + "dev": true + }, + "@isaacs/cliui": { + "version": "8.0.2", + "resolved": "https://registry.npmjs.org/@isaacs/cliui/-/cliui-8.0.2.tgz", + "integrity": "sha512-O8jcjabXaleOG9DQ0+ARXWZBTfnP4WNAqzuiJK7ll44AmxGKv/J2M4TPjxjY3znBCfvBXFzucm1twdyFybFqEA==", + "dev": true, + "requires": { + "string-width": "^5.1.2", + "string-width-cjs": "npm:string-width@^4.2.0", + "strip-ansi": "^7.0.1", + "strip-ansi-cjs": "npm:strip-ansi@^6.0.1", + "wrap-ansi": "^8.1.0", + "wrap-ansi-cjs": "npm:wrap-ansi@^7.0.0" + } + }, + "@istanbuljs/schema": { + "version": "0.1.3", + "resolved": "https://registry.npmjs.org/@istanbuljs/schema/-/schema-0.1.3.tgz", + "integrity": "sha512-ZXRY4jNvVgSVQ8DL3LTcakaAtXwTVUxE81hslsyD2AtoXW/wVob10HkOJ1X/pAlcI7D+2YoZKg5do8G/w6RYgA==", + "dev": true + }, + "@jridgewell/resolve-uri": { + "version": "3.1.2", + "resolved": "https://registry.npmjs.org/@jridgewell/resolve-uri/-/resolve-uri-3.1.2.tgz", + "integrity": "sha512-bRISgCIjP20/tbWSPWMEi54QVPRZExkuD9lJL+UIxUKtwVJA8wW1Trb1jMs1RFXo1CBTNZ/5hpC9QvmKWdopKw==", + "dev": true + }, + "@jridgewell/sourcemap-codec": { + "version": "1.5.0", + "resolved": "https://registry.npmjs.org/@jridgewell/sourcemap-codec/-/sourcemap-codec-1.5.0.tgz", + "integrity": "sha512-gv3ZRaISU3fjPAgNsriBRqGWQL6quFx04YMPW/zD8XMLsU32mhCCbfbO6KZFLjvYpCZ8zyDEgqsgf+PwPaM7GQ==", + "dev": true + }, + "@jridgewell/trace-mapping": { + "version": "0.3.25", + "resolved": "https://registry.npmjs.org/@jridgewell/trace-mapping/-/trace-mapping-0.3.25.tgz", + "integrity": "sha512-vNk6aEwybGtawWmy/PzwnGDOjCkLWSD2wqvjGGAgOAwCGWySYXfYoxt00IJkTF+8Lb57DwOb3Aa0o9CApepiYQ==", + "dev": true, + "requires": { + "@jridgewell/resolve-uri": "^3.1.0", + "@jridgewell/sourcemap-codec": "^1.4.14" + } + }, + "@pkgjs/parseargs": { + "version": "0.11.0", + "resolved": "https://registry.npmjs.org/@pkgjs/parseargs/-/parseargs-0.11.0.tgz", + "integrity": "sha512-+1VkjdD0QBLPodGrJUeqarH8VAIvQODIbwh9XpP5Syisf7YoQgsJKPNFoqqLQlu+VQ/tVSshMR6loPMn8U+dPg==", + "dev": true, + "optional": true + }, + "@types/istanbul-lib-coverage": { + "version": "2.0.6", + "resolved": "https://registry.npmjs.org/@types/istanbul-lib-coverage/-/istanbul-lib-coverage-2.0.6.tgz", + "integrity": "sha512-2QF/t/auWm0lsy8XtKVPG19v3sSOQlJe/YHZgfjb/KBBHOGSV+J2q/S671rcq9uTBrLAXmZpqJiaQbMT+zNU1w==", + "dev": true + }, "@types/node": { "version": "22.7.5", "resolved": "https://registry.npmjs.org/@types/node/-/node-22.7.5.tgz", @@ -70,12 +1084,483 @@ "undici-types": "~6.19.2" } }, + "ansi-regex": { + "version": "6.1.0", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-6.1.0.tgz", + "integrity": "sha512-7HSX4QQb4CspciLpVFwyRe79O3xsIZDDLER21kERQ71oaPodF8jL725AgJMFAYbooIqolJoRLuM81SpeUkpkvA==", + "dev": true + }, + "ansi-styles": { + "version": "6.2.1", + "resolved": "https://registry.npmjs.org/ansi-styles/-/ansi-styles-6.2.1.tgz", + "integrity": "sha512-bN798gFfQX+viw3R7yrGWRqnrN2oRkEkUjjl4JNn4E8GxxbjtG3FbrEIIY3l8/hrwUwIeCZvi4QuOTP4MErVug==", + "dev": true + }, + "balanced-match": { + "version": "1.0.2", + "resolved": "https://registry.npmjs.org/balanced-match/-/balanced-match-1.0.2.tgz", + "integrity": "sha512-3oSeUO0TMV67hN1AmbXsK4yaqU7tjiHlbxRDZOpH0KW9+CeX4bRAaX0Anxt0tx2MrpRpWwQaPwIlISEJhYU5Pw==", + "dev": true + }, + "brace-expansion": { + "version": "2.0.1", + "resolved": "https://registry.npmjs.org/brace-expansion/-/brace-expansion-2.0.1.tgz", + "integrity": "sha512-XnAIvQ8eM+kC6aULx6wuQiwVsnzsi9d3WxzV3FpWTGA19F621kwdbsAcFKXgKUHZWsy+mY6iL1sHTxWEFCytDA==", + "dev": true, + "requires": { + "balanced-match": "^1.0.0" + } + }, + "c8": { + "version": "10.1.2", + "resolved": "https://registry.npmjs.org/c8/-/c8-10.1.2.tgz", + "integrity": "sha512-Qr6rj76eSshu5CgRYvktW0uM0CFY0yi4Fd5D0duDXO6sYinyopmftUiJVuzBQxQcwQLor7JWDVRP+dUfCmzgJw==", + "dev": true, + "requires": { + "@bcoe/v8-coverage": "^0.2.3", + "@istanbuljs/schema": "^0.1.3", + "find-up": "^5.0.0", + "foreground-child": "^3.1.1", + "istanbul-lib-coverage": "^3.2.0", + "istanbul-lib-report": "^3.0.1", + "istanbul-reports": "^3.1.6", + "test-exclude": "^7.0.1", + "v8-to-istanbul": "^9.0.0", + "yargs": "^17.7.2", + "yargs-parser": "^21.1.1" + } + }, + "cliui": { + "version": "8.0.1", + "resolved": "https://registry.npmjs.org/cliui/-/cliui-8.0.1.tgz", + "integrity": "sha512-BSeNnyus75C4//NQ9gQt1/csTXyo/8Sb+afLAkzAptFuMsod9HFokGNudZpi/oQV73hnVK+sR+5PVRMd+Dr7YQ==", + "dev": true, + "requires": { + "string-width": "^4.2.0", + "strip-ansi": "^6.0.1", + "wrap-ansi": "^7.0.0" + }, + "dependencies": { + "ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true + }, + "ansi-styles": { + "version": "4.3.0", + "resolved": "https://registry.npmjs.org/ansi-styles/-/ansi-styles-4.3.0.tgz", + "integrity": "sha512-zbB9rCJAT1rbjiVDb2hqKFHNYLxgtk8NURxZ3IZwD3F6NtxbXZQCnnSi1Lkx+IDohdPlFp222wVALIheZJQSEg==", + "dev": true, + "requires": { + "color-convert": "^2.0.1" + } + }, + "emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "string-width": { + "version": "4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "requires": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" + } + }, + "strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "requires": { + "ansi-regex": "^5.0.1" + } + }, + "wrap-ansi": { + "version": "7.0.0", + "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-7.0.0.tgz", + "integrity": "sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==", + "dev": true, + "requires": { + "ansi-styles": "^4.0.0", + "string-width": "^4.1.0", + "strip-ansi": "^6.0.0" + } + } + } + }, + "color-convert": { + "version": "2.0.1", + "resolved": "https://registry.npmjs.org/color-convert/-/color-convert-2.0.1.tgz", + "integrity": "sha512-RRECPsj7iu/xb5oKYcsFHSppFNnsj/52OVTRKb4zP5onXwVF3zVmmToNcOfGC+CRDpfK/U584fMg38ZHCaElKQ==", + "dev": true, + "requires": { + "color-name": "~1.1.4" + } + }, + "color-name": { + "version": "1.1.4", + "resolved": "https://registry.npmjs.org/color-name/-/color-name-1.1.4.tgz", + "integrity": "sha512-dOy+3AuW3a2wNbZHIuMZpTcgjGuLU/uBL/ubcZF9OXbDo8ff4O8yVp5Bf0efS8uEoYo5q4Fx7dY9OgQGXgAsQA==", + "dev": true + }, + "convert-source-map": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/convert-source-map/-/convert-source-map-2.0.0.tgz", + "integrity": "sha512-Kvp459HrV2FEJ1CAsi1Ku+MY3kasH19TFykTz2xWmMeq6bk2NU3XXvfJ+Q61m0xktWwt+1HSYf3JZsTms3aRJg==", + "dev": true + }, + "cross-spawn": { + "version": "7.0.3", + "resolved": "https://registry.npmjs.org/cross-spawn/-/cross-spawn-7.0.3.tgz", + "integrity": "sha512-iRDPJKUPVEND7dHPO8rkbOnPpyDygcDFtWjpeWNCgy8WP2rXcxXL8TskReQl6OrB2G7+UJrags1q15Fudc7G6w==", + "dev": true, + "requires": { + "path-key": "^3.1.0", + "shebang-command": "^2.0.0", + "which": "^2.0.1" + } + }, + "eastasianwidth": { + "version": "0.2.0", + "resolved": "https://registry.npmjs.org/eastasianwidth/-/eastasianwidth-0.2.0.tgz", + "integrity": "sha512-I88TYZWc9XiYHRQ4/3c5rjjfgkjhLyW2luGIheGERbNQ6OY7yTybanSpDXZa8y7VUP9YmDcYa+eyq4ca7iLqWA==", + "dev": true + }, + "emoji-regex": { + "version": "9.2.2", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-9.2.2.tgz", + "integrity": "sha512-L18DaJsXSUk2+42pv8mLs5jJT2hqFkFE4j21wOmgbUqsZ2hL72NsUU785g9RXgo3s0ZNgVl42TiHp3ZtOv/Vyg==", + "dev": true + }, + "escalade": { + "version": "3.2.0", + "resolved": "https://registry.npmjs.org/escalade/-/escalade-3.2.0.tgz", + "integrity": "sha512-WUj2qlxaQtO4g6Pq5c29GTcWGDyd8itL8zTlipgECz3JesAiiOKotd8JU6otB3PACgG6xkJUyVhboMS+bje/jA==", + "dev": true + }, + "find-up": { + "version": "5.0.0", + "resolved": "https://registry.npmjs.org/find-up/-/find-up-5.0.0.tgz", + "integrity": "sha512-78/PXT1wlLLDgTzDs7sjq9hzz0vXD+zn+7wypEe4fXQxCmdmqfGsEPQxmiCSQI3ajFV91bVSsvNtrJRiW6nGng==", + "dev": true, + "requires": { + "locate-path": "^6.0.0", + "path-exists": "^4.0.0" + } + }, + "foreground-child": { + "version": "3.3.0", + "resolved": "https://registry.npmjs.org/foreground-child/-/foreground-child-3.3.0.tgz", + "integrity": "sha512-Ld2g8rrAyMYFXBhEqMz8ZAHBi4J4uS1i/CxGMDnjyFWddMXLVcDp051DZfu+t7+ab7Wv6SMqpWmyFIj5UbfFvg==", + "dev": true, + "requires": { + "cross-spawn": "^7.0.0", + "signal-exit": "^4.0.1" + } + }, + "get-caller-file": { + "version": "2.0.5", + "resolved": "https://registry.npmjs.org/get-caller-file/-/get-caller-file-2.0.5.tgz", + "integrity": "sha512-DyFP3BM/3YHTQOCUL/w0OZHR0lpKeGrxotcHWcqNEdnltqFwXVfhEBQ94eIo34AfQpo0rGki4cyIiftY06h2Fg==", + "dev": true + }, + "glob": { + "version": "10.4.5", + "resolved": "https://registry.npmjs.org/glob/-/glob-10.4.5.tgz", + "integrity": "sha512-7Bv8RF0k6xjo7d4A/PxYLbUCfb6c+Vpd2/mB2yRDlew7Jb5hEXiCD9ibfO7wpk8i4sevK6DFny9h7EYbM3/sHg==", + "dev": true, + "requires": { + "foreground-child": "^3.1.0", + "jackspeak": "^3.1.2", + "minimatch": "^9.0.4", + "minipass": "^7.1.2", + "package-json-from-dist": "^1.0.0", + "path-scurry": "^1.11.1" + } + }, + "has-flag": { + "version": "4.0.0", + "resolved": "https://registry.npmjs.org/has-flag/-/has-flag-4.0.0.tgz", + "integrity": "sha512-EykJT/Q1KjTWctppgIAgfSO0tKVuZUjhgMr17kqTumMl6Afv3EISleU7qZUzoXDFTAHTDC4NOoG/ZxU3EvlMPQ==", + "dev": true + }, + "html-escaper": { + "version": "2.0.2", + "resolved": "https://registry.npmjs.org/html-escaper/-/html-escaper-2.0.2.tgz", + "integrity": "sha512-H2iMtd0I4Mt5eYiapRdIDjp+XzelXQ0tFE4JS7YFwFevXXMmOp9myNrUvCg0D6ws8iqkRPBfKHgbwig1SmlLfg==", + "dev": true + }, + "is-fullwidth-code-point": { + "version": "3.0.0", + "resolved": "https://registry.npmjs.org/is-fullwidth-code-point/-/is-fullwidth-code-point-3.0.0.tgz", + "integrity": "sha512-zymm5+u+sCsSWyD9qNaejV3DFvhCKclKdizYaJUuHA83RLjb7nSuGnddCHGv0hk+KY7BMAlsWeK4Ueg6EV6XQg==", + "dev": true + }, + "isexe": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/isexe/-/isexe-2.0.0.tgz", + "integrity": "sha512-RHxMLp9lnKHGHRng9QFhRCMbYAcVpn69smSGcq3f36xjgVVWThj4qqLbTLlq7Ssj8B+fIQ1EuCEGI2lKsyQeIw==", + "dev": true + }, + "istanbul-lib-coverage": { + "version": "3.2.2", + "resolved": "https://registry.npmjs.org/istanbul-lib-coverage/-/istanbul-lib-coverage-3.2.2.tgz", + "integrity": "sha512-O8dpsF+r0WV/8MNRKfnmrtCWhuKjxrq2w+jpzBL5UZKTi2LeVWnWOmWRxFlesJONmc+wLAGvKQZEOanko0LFTg==", + "dev": true + }, + "istanbul-lib-report": { + "version": "3.0.1", + "resolved": "https://registry.npmjs.org/istanbul-lib-report/-/istanbul-lib-report-3.0.1.tgz", + "integrity": "sha512-GCfE1mtsHGOELCU8e/Z7YWzpmybrx/+dSTfLrvY8qRmaY6zXTKWn6WQIjaAFw069icm6GVMNkgu0NzI4iPZUNw==", + "dev": true, + "requires": { + "istanbul-lib-coverage": "^3.0.0", + "make-dir": "^4.0.0", + "supports-color": "^7.1.0" + } + }, + "istanbul-reports": { + "version": "3.1.7", + "resolved": "https://registry.npmjs.org/istanbul-reports/-/istanbul-reports-3.1.7.tgz", + "integrity": "sha512-BewmUXImeuRk2YY0PVbxgKAysvhRPUQE0h5QRM++nVWyubKGV0l8qQ5op8+B2DOmwSe63Jivj0BjkPQVf8fP5g==", + "dev": true, + "requires": { + "html-escaper": "^2.0.0", + "istanbul-lib-report": "^3.0.0" + } + }, + "jackspeak": { + "version": "3.4.3", + "resolved": "https://registry.npmjs.org/jackspeak/-/jackspeak-3.4.3.tgz", + "integrity": "sha512-OGlZQpz2yfahA/Rd1Y8Cd9SIEsqvXkLVoSw/cgwhnhFMDbsQFeZYoJJ7bIZBS9BcamUW96asq/npPWugM+RQBw==", + "dev": true, + "requires": { + "@isaacs/cliui": "^8.0.2", + "@pkgjs/parseargs": "^0.11.0" + } + }, + "locate-path": { + "version": "6.0.0", + "resolved": "https://registry.npmjs.org/locate-path/-/locate-path-6.0.0.tgz", + "integrity": "sha512-iPZK6eYjbxRu3uB4/WZ3EsEIMJFMqAoopl3R+zuq0UjcAm/MO6KCweDgPfP3elTztoKP3KtnVHxTn2NHBSDVUw==", + "dev": true, + "requires": { + "p-locate": "^5.0.0" + } + }, + "lru-cache": { + "version": "10.4.3", + "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-10.4.3.tgz", + "integrity": "sha512-JNAzZcXrCt42VGLuYz0zfAzDfAvJWW6AfYlDBQyDV5DClI2m5sAmK+OIO7s59XfsRsWHp02jAJrRadPRGTt6SQ==", + "dev": true + }, + "make-dir": { + "version": "4.0.0", + "resolved": "https://registry.npmjs.org/make-dir/-/make-dir-4.0.0.tgz", + "integrity": "sha512-hXdUTZYIVOt1Ex//jAQi+wTZZpUpwBj/0QsOzqegb3rGMMeJiSEu5xLHnYfBrRV4RH2+OCSOO95Is/7x1WJ4bw==", + "dev": true, + "requires": { + "semver": "^7.5.3" + } + }, + "minimatch": { + "version": "9.0.5", + "resolved": "https://registry.npmjs.org/minimatch/-/minimatch-9.0.5.tgz", + "integrity": "sha512-G6T0ZX48xgozx7587koeX9Ys2NYy6Gmv//P89sEte9V9whIapMNF4idKxnW2QtCcLiTWlb/wfCabAtAFWhhBow==", + "dev": true, + "requires": { + "brace-expansion": "^2.0.1" + } + }, + "minipass": { + "version": "7.1.2", + "resolved": "https://registry.npmjs.org/minipass/-/minipass-7.1.2.tgz", + "integrity": "sha512-qOOzS1cBTWYF4BH8fVePDBOO9iptMnGUEZwNc/cMWnTV2nVLZ7VoNWEPHkYczZA0pdoA7dl6e7FL659nX9S2aw==", + "dev": true + }, + "p-limit": { + "version": "3.1.0", + "resolved": "https://registry.npmjs.org/p-limit/-/p-limit-3.1.0.tgz", + "integrity": "sha512-TYOanM3wGwNGsZN2cVTYPArw454xnXj5qmWF1bEoAc4+cU/ol7GVh7odevjp1FNHduHc3KZMcFduxU5Xc6uJRQ==", + "dev": true, + "requires": { + "yocto-queue": "^0.1.0" + } + }, + "p-locate": { + "version": "5.0.0", + "resolved": "https://registry.npmjs.org/p-locate/-/p-locate-5.0.0.tgz", + "integrity": "sha512-LaNjtRWUBY++zB5nE/NwcaoMylSPk+S+ZHNB1TzdbMJMny6dynpAGt7X/tl/QYq3TIeE6nxHppbo2LGymrG5Pw==", + "dev": true, + "requires": { + "p-limit": "^3.0.2" + } + }, + "package-json-from-dist": { + "version": "1.0.1", + "resolved": "https://registry.npmjs.org/package-json-from-dist/-/package-json-from-dist-1.0.1.tgz", + "integrity": "sha512-UEZIS3/by4OC8vL3P2dTXRETpebLI2NiI5vIrjaD/5UtrkFX/tNbwjTSRAGC/+7CAo2pIcBaRgWmcBBHcsaCIw==", + "dev": true + }, + "path-exists": { + "version": "4.0.0", + "resolved": "https://registry.npmjs.org/path-exists/-/path-exists-4.0.0.tgz", + "integrity": "sha512-ak9Qy5Q7jYb2Wwcey5Fpvg2KoAc/ZIhLSLOSBmRmygPsGwkVVt0fZa0qrtMz+m6tJTAHfZQ8FnmB4MG4LWy7/w==", + "dev": true + }, + "path-key": { + "version": "3.1.1", + "resolved": "https://registry.npmjs.org/path-key/-/path-key-3.1.1.tgz", + "integrity": "sha512-ojmeN0qd+y0jszEtoY48r0Peq5dwMEkIlCOu6Q5f41lfkswXuKtYrhgoTpLnyIcHm24Uhqx+5Tqm2InSwLhE6Q==", + "dev": true + }, + "path-scurry": { + "version": "1.11.1", + "resolved": "https://registry.npmjs.org/path-scurry/-/path-scurry-1.11.1.tgz", + "integrity": "sha512-Xa4Nw17FS9ApQFJ9umLiJS4orGjm7ZzwUrwamcGQuHSzDyth9boKDaycYdDcZDuqYATXw4HFXgaqWTctW/v1HA==", + "dev": true, + "requires": { + "lru-cache": "^10.2.0", + "minipass": "^5.0.0 || ^6.0.2 || ^7.0.0" + } + }, "prettier": { "version": "3.3.3", "resolved": "https://registry.npmjs.org/prettier/-/prettier-3.3.3.tgz", "integrity": "sha512-i2tDNA0O5IrMO757lfrdQZCc2jPNDVntV0m/+4whiDfWaTKfMNgR7Qz0NAeGz/nRqF4m5/6CLzbP4/liHt12Ew==", "dev": true }, + "require-directory": { + "version": "2.1.1", + "resolved": "https://registry.npmjs.org/require-directory/-/require-directory-2.1.1.tgz", + "integrity": "sha512-fGxEI7+wsG9xrvdjsrlmL22OMTTiHRwAMroiEeMgq8gzoLC/PQr7RsRDSTLUg/bZAZtF+TVIkHc6/4RIKrui+Q==", + "dev": true + }, + "semver": { + "version": "7.6.3", + "resolved": "https://registry.npmjs.org/semver/-/semver-7.6.3.tgz", + "integrity": "sha512-oVekP1cKtI+CTDvHWYFUcMtsK/00wmAEfyqKfNdARm8u1wNVhSgaX7A8d4UuIlUI5e84iEwOhs7ZPYRmzU9U6A==", + "dev": true + }, + "shebang-command": { + "version": "2.0.0", + "resolved": "https://registry.npmjs.org/shebang-command/-/shebang-command-2.0.0.tgz", + "integrity": "sha512-kHxr2zZpYtdmrN1qDjrrX/Z1rR1kG8Dx+gkpK1G4eXmvXswmcE1hTWBWYUzlraYw1/yZp6YuDY77YtvbN0dmDA==", + "dev": true, + "requires": { + "shebang-regex": "^3.0.0" + } + }, + "shebang-regex": { + "version": "3.0.0", + "resolved": "https://registry.npmjs.org/shebang-regex/-/shebang-regex-3.0.0.tgz", + "integrity": "sha512-7++dFhtcx3353uBaq8DDR4NuxBetBzC7ZQOhmTQInHEd6bSrXdiEyzCvG07Z44UYdLShWUyXt5M/yhz8ekcb1A==", + "dev": true + }, + "signal-exit": { + "version": "4.1.0", + "resolved": "https://registry.npmjs.org/signal-exit/-/signal-exit-4.1.0.tgz", + "integrity": "sha512-bzyZ1e88w9O1iNJbKnOlvYTrWPDl46O1bG0D3XInv+9tkPrxrN8jUUTiFlDkkmKWgn1M6CfIA13SuGqOa9Korw==", + "dev": true + }, + "string-width": { + "version": "5.1.2", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-5.1.2.tgz", + "integrity": "sha512-HnLOCR3vjcY8beoNLtcjZ5/nxn2afmME6lhrDrebokqMap+XbeW8n9TXpPDOqdGK5qcI3oT0GKTW6wC7EMiVqA==", + "dev": true, + "requires": { + "eastasianwidth": "^0.2.0", + "emoji-regex": "^9.2.2", + "strip-ansi": "^7.0.1" + } + }, + "string-width-cjs": { + "version": "npm:string-width@4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "requires": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" + }, + "dependencies": { + "ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true + }, + "emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "requires": { + "ansi-regex": "^5.0.1" + } + } + } + }, + "strip-ansi": { + "version": "7.1.0", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-7.1.0.tgz", + "integrity": "sha512-iq6eVVI64nQQTRYq2KtEg2d2uU7LElhTJwsH4YzIHZshxlgZms/wIc4VoDQTlG/IvVIrBKG06CrZnp0qv7hkcQ==", + "dev": true, + "requires": { + "ansi-regex": "^6.0.1" + } + }, + "strip-ansi-cjs": { + "version": "npm:strip-ansi@6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "requires": { + "ansi-regex": "^5.0.1" + }, + "dependencies": { + "ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true + } + } + }, + "supports-color": { + "version": "7.2.0", + "resolved": "https://registry.npmjs.org/supports-color/-/supports-color-7.2.0.tgz", + "integrity": "sha512-qpCAvRl9stuOHveKsn7HncJRvv501qIacKzQlO/+Lwxc9+0q2wLyv4Dfvt80/DPn2pqOBsJdDiogXGR9+OvwRw==", + "dev": true, + "requires": { + "has-flag": "^4.0.0" + } + }, + "test-exclude": { + "version": "7.0.1", + "resolved": "https://registry.npmjs.org/test-exclude/-/test-exclude-7.0.1.tgz", + "integrity": "sha512-pFYqmTw68LXVjeWJMST4+borgQP2AyMNbg1BpZh9LbyhUeNkeaPF9gzfPGUAnSMV3qPYdWUwDIjjCLiSDOl7vg==", + "dev": true, + "requires": { + "@istanbuljs/schema": "^0.1.2", + "glob": "^10.4.1", + "minimatch": "^9.0.4" + } + }, "typescript": { "version": "5.6.3", "resolved": "https://registry.npmjs.org/typescript/-/typescript-5.6.3.tgz", @@ -87,6 +1572,158 @@ "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-6.19.8.tgz", "integrity": "sha512-ve2KP6f/JnbPBFyobGHuerC9g1FYGn/F8n1LWTwNxCEzd6IfqTwUQcNXgEtmmQ6DlRrC1hrSrBnCZPokRrDHjw==", "dev": true + }, + "v8-to-istanbul": { + "version": "9.3.0", + "resolved": "https://registry.npmjs.org/v8-to-istanbul/-/v8-to-istanbul-9.3.0.tgz", + "integrity": "sha512-kiGUalWN+rgBJ/1OHZsBtU4rXZOfj/7rKQxULKlIzwzQSvMJUUNgPwJEEh7gU6xEVxC0ahoOBvN2YI8GH6FNgA==", + "dev": true, + "requires": { + "@jridgewell/trace-mapping": "^0.3.12", + "@types/istanbul-lib-coverage": "^2.0.1", + "convert-source-map": "^2.0.0" + } + }, + "which": { + "version": "2.0.2", + "resolved": "https://registry.npmjs.org/which/-/which-2.0.2.tgz", + "integrity": "sha512-BLI3Tl1TW3Pvl70l3yq3Y64i+awpwXqsGBYWkkqMtnbXgrMD+yj7rhW0kuEDxzJaYXGjEW5ogapKNMEKNMjibA==", + "dev": true, + "requires": { + "isexe": "^2.0.0" + } + }, + "wrap-ansi": { + "version": "8.1.0", + "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-8.1.0.tgz", + "integrity": "sha512-si7QWI6zUMq56bESFvagtmzMdGOtoxfR+Sez11Mobfc7tm+VkUckk9bW2UeffTGVUbOksxmSw0AA2gs8g71NCQ==", + "dev": true, + "requires": { + "ansi-styles": "^6.1.0", + "string-width": "^5.0.1", + "strip-ansi": "^7.0.1" + } + }, + "wrap-ansi-cjs": { + "version": "npm:wrap-ansi@7.0.0", + "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-7.0.0.tgz", + "integrity": "sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==", + "dev": true, + "requires": { + "ansi-styles": "^4.0.0", + "string-width": "^4.1.0", + "strip-ansi": "^6.0.0" + }, + "dependencies": { + "ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true + }, + "ansi-styles": { + "version": "4.3.0", + "resolved": "https://registry.npmjs.org/ansi-styles/-/ansi-styles-4.3.0.tgz", + "integrity": "sha512-zbB9rCJAT1rbjiVDb2hqKFHNYLxgtk8NURxZ3IZwD3F6NtxbXZQCnnSi1Lkx+IDohdPlFp222wVALIheZJQSEg==", + "dev": true, + "requires": { + "color-convert": "^2.0.1" + } + }, + "emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "string-width": { + "version": "4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "requires": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" + } + }, + "strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "requires": { + "ansi-regex": "^5.0.1" + } + } + } + }, + "y18n": { + "version": "5.0.8", + "resolved": "https://registry.npmjs.org/y18n/-/y18n-5.0.8.tgz", + "integrity": "sha512-0pfFzegeDWJHJIAmTLRP2DwHjdF5s7jo9tuztdQxAhINCdvS+3nGINqPd00AphqJR/0LhANUS6/+7SCb98YOfA==", + "dev": true + }, + "yargs": { + "version": "17.7.2", + "resolved": "https://registry.npmjs.org/yargs/-/yargs-17.7.2.tgz", + "integrity": "sha512-7dSzzRQ++CKnNI/krKnYRV7JKKPUXMEh61soaHKg9mrWEhzFWhFnxPxGl+69cD1Ou63C13NUPCnmIcrvqCuM6w==", + "dev": true, + "requires": { + "cliui": "^8.0.1", + "escalade": "^3.1.1", + "get-caller-file": "^2.0.5", + "require-directory": "^2.1.1", + "string-width": "^4.2.3", + "y18n": "^5.0.5", + "yargs-parser": "^21.1.1" + }, + "dependencies": { + "ansi-regex": { + "version": "5.0.1", + "resolved": "https://registry.npmjs.org/ansi-regex/-/ansi-regex-5.0.1.tgz", + "integrity": "sha512-quJQXlTSUGL2LH9SUXo8VwsY4soanhgo6LNSm84E1LBcE8s3O0wpdiRzyR9z/ZZJMlMWv37qOOb9pdJlMUEKFQ==", + "dev": true + }, + "emoji-regex": { + "version": "8.0.0", + "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz", + "integrity": "sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==", + "dev": true + }, + "string-width": { + "version": "4.2.3", + "resolved": "https://registry.npmjs.org/string-width/-/string-width-4.2.3.tgz", + "integrity": "sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==", + "dev": true, + "requires": { + "emoji-regex": "^8.0.0", + "is-fullwidth-code-point": "^3.0.0", + "strip-ansi": "^6.0.1" + } + }, + "strip-ansi": { + "version": "6.0.1", + "resolved": "https://registry.npmjs.org/strip-ansi/-/strip-ansi-6.0.1.tgz", + "integrity": "sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==", + "dev": true, + "requires": { + "ansi-regex": "^5.0.1" + } + } + } + }, + "yargs-parser": { + "version": "21.1.1", + "resolved": "https://registry.npmjs.org/yargs-parser/-/yargs-parser-21.1.1.tgz", + "integrity": "sha512-tVpsJW7DdjecAiFpbIB1e3qxIQsE6NoPc5/eTdrbbIC4h0LVsWhnoa3g+m2HclBIujHzsxZ4VJVA+GUuc2/LBw==", + "dev": true + }, + "yocto-queue": { + "version": "0.1.0", + "resolved": "https://registry.npmjs.org/yocto-queue/-/yocto-queue-0.1.0.tgz", + "integrity": "sha512-rVksvsnNCdJ/ohGc6xgPwyN8eheCxsiLM8mxuE/t/mOVqJewPuO1miLpTHQiRgTKCLexL4MeAFVagts7HmNZ2Q==", + "dev": true } } } diff --git a/package.json b/package.json index e09e20a..f14732b 100644 --- a/package.json +++ b/package.json @@ -12,7 +12,8 @@ "devDependencies": { "@types/node": "^22.7.5", "typescript": "^5.6.3", - "prettier": "^3.3.3" + "prettier": "^3.3.3", + "c8": "^10.1.2" }, "repository": { "type": "git", @@ -39,7 +40,8 @@ "scripts": { "format": "npx prettier --write .", "build": "npx tsc", - "test": "npx tsc && node --enable-source-maps --experimental-test-coverage --test build/h2tunnel.test.js" + "test": "npx tsc && node --enable-source-maps --experimental-test-coverage --test build/h2tunnel.test.js", + "coverage": "npx tsc && c8 --reporter html node build/h2tunnel.test.js" }, "engines": { "node": ">=20" diff --git a/src/cli.ts b/src/cli.ts index deac9f7..0ba031c 100644 --- a/src/cli.ts +++ b/src/cli.ts @@ -1,6 +1,6 @@ #!/usr/bin/env node import { parseArgs } from "node:util"; -import { TunnelClient, TunnelServer } from "./h2tunnel.js"; +import { AbstractTunnel, TunnelClient, TunnelServer } from "./h2tunnel.js"; import * as fs from "node:fs"; const { positionals, values } = parseArgs({ @@ -92,32 +92,36 @@ server options: --${"mux-listen-port" satisfies Param} Port for the HTTP2 server to listen on `; -const command = positionals[0]; -if (command === "client") { - const client = new TunnelClient({ - tunnelHost: getString("tunnel-host"), - tunnelPort: getInt("tunnel-port"), - key: fs.readFileSync(getString("key"), "utf8"), - cert: fs.readFileSync(getString("crt"), "utf8"), - localHttpPort: getInt("local-http-port"), - demuxListenPort: getInt("demux-listen-port"), - }); - process.on("SIGINT", () => client.stop()); - process.on("SIGTERM", () => client.stop()); - client.start(); -} else if (command === "server") { - const server = new TunnelServer({ - tunnelListenIp: getString("tunnel-listen-ip"), - tunnelListenPort: getInt("tunnel-listen-port"), - key: fs.readFileSync(getString("key"), "utf8"), - cert: fs.readFileSync(getString("crt"), "utf8"), - proxyListenPort: getInt("proxy-listen-port"), - proxyListenIp: getString("proxy-listen-ip"), - muxListenPort: getInt("mux-listen-port"), - }); - process.on("SIGINT", () => server.stop()); - process.on("SIGTERM", () => server.stop()); - server.start(); -} else { +if (positionals.length === 0) { process.stdout.write(HELP_TEXT); +} else { + const command = positionals[0]; + let tunnel: AbstractTunnel; + if (command === "client") { + tunnel = new TunnelClient({ + tunnelHost: getString("tunnel-host"), + tunnelPort: getInt("tunnel-port"), + key: fs.readFileSync(getString("key"), "utf8"), + cert: fs.readFileSync(getString("crt"), "utf8"), + localHttpPort: getInt("local-http-port"), + demuxListenPort: getInt("demux-listen-port"), + }); + } else if (command === "server") { + tunnel = new TunnelServer({ + tunnelListenIp: getString("tunnel-listen-ip"), + tunnelListenPort: getInt("tunnel-listen-port"), + key: fs.readFileSync(getString("key"), "utf8"), + cert: fs.readFileSync(getString("crt"), "utf8"), + proxyListenPort: getInt("proxy-listen-port"), + proxyListenIp: getString("proxy-listen-ip"), + muxListenPort: getInt("mux-listen-port"), + }); + } else { + throw new Error(`Unknown command: ${command}`); + } + + process.on("SIGINT", () => tunnel.abortController.abort()); + process.on("SIGTERM", () => tunnel.abortController.abort()); + tunnel.start(); + await tunnel.waitUntilState("stopped"); } diff --git a/src/h2tunnel.test.ts b/src/h2tunnel.test.ts index dd009a1..f390d83 100644 --- a/src/h2tunnel.test.ts +++ b/src/h2tunnel.test.ts @@ -7,7 +7,7 @@ import { TunnelServer, } from "./h2tunnel.js"; import * as assert from "node:assert"; -import { Readable } from "node:stream"; +import net from "node:net"; // localhost HTTP1 server "python3 -m http.server" const LOCAL_HTTP_PORT = 14000; @@ -18,12 +18,11 @@ const DEMUX_PORT = 14003; const REMOTE_HTTP_PORT = 14004; // remote TLS server for establishing a tunnel const TUNNEL_PORT = 14005; +// In order to simulate a bad network, we host a proxy TCP server on this port +const TUNNEL_PROXY_PORT = 14007; // remote HTTPS server that is piped through the tunnel to localhost const MUX_PORT = 14006; -// https://stackoverflow.com/a/41366949/212584 -// openssl req -x509 -newkey ec -pkeyopt ec_paramgen_curve:secp384r1 -days 3650 -nodes -keyout example.com.key -out example.com.crt -subj "/CN=example.com" -addext "subjectAltName=DNS:example.com,DNS:*.example.com,IP:10.0.0.1" - const CLIENT_KEY = `-----BEGIN PRIVATE KEY----- MIG2AgEAMBAGByqGSM49AgEGBSuBBAAiBIGeMIGbAgEBBDCDzcLnOqzvCrnUyd4P 1QcIG/Xi/VPpA5dVIwPVkutr9y/wZo3aJsYUX5xExQMsEeihZANiAAQfSPquV3P/ @@ -45,50 +44,42 @@ JN+yjDEXE/TgT+bxgfcCMFFZkqT7GYLc18lW6sv6GZvhzFPV8eTePa2xwVyBgaca 93vJMc5HXDLt7XPK+Iz90g== -----END CERTIFICATE-----`; -const getLogger = (colorCode: number) => (line: object) => - process.stdout.write(`\x1b[${colorCode}m${JSON.stringify(line)}\x1b[0m\n`); - -export async function streamToText( - stream: ReadableStream, -): Promise { - const reader = stream.getReader(); - const arrs: Uint8Array[] = []; - while (true) { - const chunk = await reader.read(); - if (chunk.done) { - return new Blob(arrs).text(); - } - arrs.push(chunk.value); - } -} +const getLogger = (name: string, colorCode: number) => (line: object) => + process.stdout.write( + `${name.padEnd(10)} \x1b[${colorCode}m${JSON.stringify(line)}\x1b[0m\n`, + ); async function sleep(ms: number) { return new Promise((resolve) => setTimeout(resolve, ms)); } -async function createDummyHttpServer(): Promise<() => Promise> { - const logger = getLogger(35); - const dummyServerHttp1 = http.createServer(async (request, response) => { +/** + * Waits 100 ms before sending a 200, then pipes request into response + */ +async function createEchoHttpServer(): Promise<() => Promise> { + const logger = getLogger("localhost", 35); + const dummyServerHttp1 = http.createServer((request, response) => { logger({ dummyServerRequest: { method: request.method, path: request.url }, }); - const xIncrement = request.headers["x-increment"] as string; - const reqBody = await streamToText(Readable.toWeb(request)); - const body = String(Number(reqBody) + 1); - const headerResp = String(Number(xIncrement) + 1); - const headers = { - "Content-Type": "text/plain", - "x-incremented": headerResp, - }; - await sleep(100); - const statusCode = 200; - response.writeHead(statusCode, headers); - response.end(body); - logger({ - dummyServerSentResponse: statusCode, - body, - headers, - }); + const t = setTimeout(() => { + const xIncrement = request.headers["x-increment"] as string; + const headerResp = String(Number(xIncrement) + 1); + const headers = { + "Content-Type": "text/plain", + "x-incremented": headerResp, + }; + const statusCode = 200; + response.writeHead(statusCode, headers); + request.pipe(response); + logger({ + dummyServerSentResponse: statusCode, + headers, + method: request.method, + path: request.url, + }); + }, 100); + request.on("close", () => clearTimeout(t)); }); dummyServerHttp1.listen(LOCAL_HTTP_PORT); await new Promise((resolve) => dummyServerHttp1.on("listening", resolve)); @@ -96,8 +87,57 @@ async function createDummyHttpServer(): Promise<() => Promise> { new Promise((resolve) => dummyServerHttp1.close(() => resolve())); } +class NetworkEmulator { + socket: net.Socket | null = null; + constructor( + public scenario: "good" | "garbage-to-client" | "garbage-to-server", + readonly server = net.createServer(), + readonly logger = getLogger("network", 31), + readonly abortController = new AbortController(), + ) {} + async startAndWaitUntilReady() { + return new Promise((resolve) => { + this.server.on("connection", (socket: net.Socket) => { + if (this.socket) { + // We have discovered that when not TLS client errors out, it leaves the TCP server hanging. This is why + // we cannot rely on 'maxConnections' to enforce a single connection. + this.logger({ socket: "destroying" }); + this.socket.destroy(); + } + this.socket = socket; + this.socket.on("error", (err) => this.logger({ socket: "error", err })); + this.socket.on("close", () => this.logger({ socket: "close" })); + this.logger({ server: "connection", scenario: this.scenario }); + if (this.scenario === "good") { + const targetSocket = net.createConnection({ + host: "127.0.0.1", + port: TUNNEL_PORT, + }); + this.socket.pipe(targetSocket); + targetSocket.pipe(this.socket); + } else if (this.scenario === "garbage-to-client") { + this.socket.write("bad TLS handshake"); + } else if (this.scenario === "garbage-to-server") { + const targetSocket = net.createConnection({ + host: "127.0.0.1", + port: TUNNEL_PORT, + }); + targetSocket.write("bad TLS handshake"); + this.socket.on("close", () => targetSocket.end()); + } + }); + this.server.on("listening", () => resolve()); + this.server.listen(TUNNEL_PROXY_PORT, "127.0.0.1"); + }); + } + async stopAndWaitUntilClosed() { + this.socket?.destroy(); + await new Promise((resolve) => this.server.close(() => resolve())); + } +} + const serverOptions: ServerOptions = { - logger: getLogger(32), + logger: getLogger("server", 32), tunnelListenIp: "127.0.0.1", tunnelListenPort: TUNNEL_PORT, key: CLIENT_KEY, @@ -108,7 +148,7 @@ const serverOptions: ServerOptions = { }; const clientOptions: ClientOptions = { - logger: getLogger(33), + logger: getLogger("client", 33), tunnelHost: "localhost", tunnelPort: TUNNEL_PORT, key: CLIENT_KEY, @@ -118,80 +158,205 @@ const clientOptions: ClientOptions = { tunnelRestartTimeout: 500, }; -async function expect503() { - const resp = await fetch(`http://localhost:${REMOTE_HTTP_PORT}`, { +// Send one byte per 50 ms and confirms echo server returns same data back +async function makeRequest( + expect: 200 | 503 | "ECONN", + numBytes: number, + name: string = "", +) { + const { readable, writable } = new TransformStream(); + const writer = writable.getWriter(); + const url = `http://localhost:${REMOTE_HTTP_PORT}/${expect}/${name}`; + console.log("making request", url); + const respPromise = fetch(url, { method: "post", - body: "1", + body: readable, headers: { "x-increment": "2" }, + duplex: "half", }); - assert.strictEqual(resp.status, 503); + // Send first byte immediately + try { + await writer.write("1"); + for (let i = 1; i < numBytes; i++) { + await writer.write("1"); + await sleep(50); + } + await writer.close(); + } catch (e) { + assert.strictEqual(expect, "ECONN"); + return; + } + + let resp: Response; + try { + resp = await respPromise; + } catch (e) { + assert.strictEqual(expect, "ECONN"); + return; + } + if (expect === 200) { + const body = await resp.text(); + assert.strictEqual(resp.status, 200); + assert.strictEqual(body.length, numBytes); + assert.strictEqual(resp.headers.get("x-incremented"), "3"); + } else if (expect === 503) { + if (resp.status === 200) { + console.log(8); + } + assert.strictEqual(resp.status, 503); + } } -async function expect200() { - const resp = await fetch(`http://localhost:${REMOTE_HTTP_PORT}`, { - method: "post", - body: "1", - headers: { "x-increment": "2" }, - }); - const body = await resp.text(); - assert.strictEqual(resp.status, 200); - assert.strictEqual(body, "2"); - assert.strictEqual(resp.headers.get("x-incremented"), "3"); +async function expect200(numBytes: number, name: string = "") { + await makeRequest(200, numBytes, name); +} + +async function expect503(numBytes: number, name: string = "") { + await makeRequest(503, numBytes, name); } +// async function withHappyPath( +// func: (opts: { client: TunnelClient; server: TunnelServer }) => Promise, +// ): Promise { +// const stopDummyServer = await createEchoHttpServer(); +// const server = new TunnelServer(serverOptions); +// const client = new TunnelClient(clientOptions); +// await func({ client, server }); +// await client.stop(); +// await server.stop(); +// await stopDummyServer(); +// } + test("happy-path", async () => { - const stopDummyServer = await createDummyHttpServer(); + const stopDummyServer = await createEchoHttpServer(); const server = new TunnelServer(serverOptions); const client = new TunnelClient(clientOptions); server.start(); // Make a request too early - await expect503(); + await expect503(1, "server-not-started"); await server.waitUntilListening(); client.start(); // Make a request too early - await expect503(); + await expect503(1, "server-started-but-client-not-started"); // Wait until client is connected and test 200 await client.waitUntilConnected(); - assert.strictEqual(server.state, "connected"); - await expect200(); + assert.strictEqual(server.iter(), "connected"); + // Make two simultaneous slow requests + await Promise.all([ + expect200(4, "long-request-1"), + expect200(4, "long-request-2"), + ]); // Restart server while client is running await server.stop(); server.start(); + await expect503(1); await server.waitUntilListening(); - await expect503(); // Make sure client reconnected and request succeeds + await expect503(1); await client.waitUntilConnected(); - assert.strictEqual(server.state, "connected"); + assert.strictEqual(server.iter(), "connected"); await server.waitUntilConnected(); - await expect200(); + await expect200(1); // Restart client while server is running await client.stop(); client.start(); - // Make a request too early - await expect503(); - // Wait until client reconnected and make a request + await expect503(1); + await client.waitUntilConnected(); - await expect200(); + await expect200(1); - // Break tunnel - client.tunnelSocket!.destroy(); - await expect503(); + // Break tunnel while no requests are taking place + client.tunnel!.socket.destroy(); + await sleep(10); + await expect503(1); // Wait until client reconnected and make a request await client.waitUntilConnected(); - await expect200(); + await expect200(1); + + // Break tunnel during a request but before response headers could be sent + const promise1 = expect503(1, "break-tunnel-before-reponse-headers-sent"); + await sleep(10); + client.tunnel!.socket.destroy(); + await sleep(10); + await promise1; + + // Break tunnel during a request but after response headers were already sent + await client.waitUntilConnected(); + const promise2 = makeRequest("ECONN", 4); + await sleep(110); + client.tunnel!.socket.destroy(); + await sleep(10); + await promise2; + + await client.stop(); + await server.stop(); + await stopDummyServer(); +}); + +test("garbage-to-client", async () => { + const stopDummyServer = await createEchoHttpServer(); + const network = new NetworkEmulator("garbage-to-client"); + await network.startAndWaitUntilReady(); + const server = new TunnelServer(serverOptions); + const client = new TunnelClient({ + ...clientOptions, + tunnelPort: TUNNEL_PROXY_PORT, + }); + server.start(); + client.start(); + + // Still no connection after a second + await sleep(1000); + await expect503(1); + assert.strictEqual(client.iter(), "starting"); + + // Let the network recover and make a successful connection + network.scenario = "good"; + await client.waitUntilConnected(); + await expect200(1); + + await client.stop(); + await server.stop(); + await network.stopAndWaitUntilClosed(); + await stopDummyServer(); +}); + +test("garbage-to-server", async () => { + const stopDummyServer = await createEchoHttpServer(); + const badNetwork = new NetworkEmulator("garbage-to-server"); + await badNetwork.startAndWaitUntilReady(); + const server = new TunnelServer(serverOptions); + const client = new TunnelClient({ + ...clientOptions, + tunnelPort: TUNNEL_PROXY_PORT, + }); + server.start(); + client.start(); + + // Still no connection after a second + await sleep(1000); + await expect503(1); + assert.strictEqual(client.iter(), "starting"); + + // Let the network recover and make a successful connection + badNetwork.socket!.destroy(); + badNetwork.scenario = "good"; + await client.waitUntilConnected(); + await expect200(1); await client.stop(); await server.stop(); + await badNetwork.stopAndWaitUntilClosed(); await stopDummyServer(); }); diff --git a/src/h2tunnel.ts b/src/h2tunnel.ts index 658eae7..f85ff56 100644 --- a/src/h2tunnel.ts +++ b/src/h2tunnel.ts @@ -62,55 +62,56 @@ function pruneHttp1Headers(headers: http.IncomingHttpHeaders) { return headersCopy; } -abstract class AbstractTunnel extends events.EventEmitter< +export abstract class AbstractTunnel extends events.EventEmitter< Record > { abortController: AbortController; - abstract readonly tool: "server" | "client"; - abstract iter(): void; - abstract get state(): TunnelState; - constructor(readonly logger?: (line: object) => void) { + abstract iter(): TunnelState; + constructor( + readonly log: (line: object) => void = (line) => + process.stdout.write(JSON.stringify(line) + "\n"), + ) { super(); } - log(line: object) { - line = { h2tunnel: this.tool, ...line }; - if (this.logger) { - this.logger(line); - } else { - process.stdout.write(JSON.stringify(line) + "\n"); - } + updateHook() { + const state = this.iter(); + this.log({ state }); + this.emit(state); } start() { - if (this.state !== "stopped") { - throw new Error("Already running"); - } this.log({ starting: true, pid: process.pid }); this.abortController = new AbortController(); this.abortController.signal.addEventListener("abort", () => { this.log({ aborting: true }); - this.iter(); + this.updateHook(); }); - this.iter(); + this.updateHook(); } linkSockets(remoteSideSocket: net.Socket, localSideSocket: net.Socket) { - const spyToLocal = new stream.PassThrough(); - const spyToRemote = new stream.PassThrough(); - spyToLocal.on("data", (chunk: Buffer) => { + const spyReceive = new stream.PassThrough(); + const spySend = new stream.PassThrough(); + spyReceive.on("data", (chunk: Buffer) => { this.log({ receivedBytes: chunk.length }); }); - spyToRemote.on("data", (chunk: Buffer) => { + spySend.on("data", (chunk: Buffer) => { this.log({ sentBytes: chunk.length }); }); - remoteSideSocket.pipe(spyToLocal).pipe(localSideSocket); - localSideSocket.pipe(spyToRemote).pipe(remoteSideSocket); + remoteSideSocket.pipe(spyReceive).pipe(localSideSocket); + localSideSocket.pipe(spySend).pipe(remoteSideSocket); this.log({ socketsLinked: true }); } + unlinkSockets(remoteSideSocket: net.Socket, localSideSocket: net.Socket) { + remoteSideSocket.unpipe(localSideSocket); + localSideSocket.unpipe(remoteSideSocket); + this.log({ socketsUnlinked: true }); + } + async waitUntilState(state: TunnelState): Promise { - if (this.state !== state) { + if (this.iter() !== state) { await new Promise((resolve) => this.once(state, resolve)); } } @@ -119,10 +120,6 @@ abstract class AbstractTunnel extends events.EventEmitter< await this.waitUntilState("connected"); } - async waitUntilListening() { - await this.waitUntilState("listening"); - } - async stop() { this.abortController.abort(); await this.waitUntilState("stopped"); @@ -130,23 +127,27 @@ abstract class AbstractTunnel extends events.EventEmitter< } export class TunnelServer extends AbstractTunnel { - tool = "server" as const; tunnelSocket: tls.TLSSocket | null = null; + tunnelSocketClosing = false; muxSession: http2.ClientHttp2Session | null = null; + muxSessionClosing = false; muxSessionConnected: boolean = false; tunnelServer: tls.Server | null = null; + tunnelServerClosing = false; httpServer: http.Server | null = null; + httpServerClosing = false; muxServer: net.Server | null = null; + muxServerClosing = false; muxServerListening = false; // muxServer.listening is not reliable muxSocket: net.Socket | null = null; constructor(readonly options: ServerOptions) { super(options.logger); - this.abortController = new AbortController(); } startHttpServer() { this.log({ httpServer: "starting" }); + this.httpServerClosing = false; this.httpServer = http.createServer( (req: http.IncomingMessage, res: http.ServerResponse) => { if ( @@ -169,6 +170,17 @@ export class TunnelServer extends AbstractTunnel { }, { signal: this.abortController.signal }, ); + this.muxSession.once("close", () => { + if (!res.writableEnded) { + this.log({ muxSession: "close", resHeadersSent: res.headersSent }); + if (res.headersSent) { + res.destroy(); + } else { + res.writeHead(503); + res.end(); + } + } + }); req.pipe(stream); stream.on("error", () => { res.writeHead(503); @@ -181,7 +193,12 @@ export class TunnelServer extends AbstractTunnel { ); const headers = pruneHttp2Headers(http2Headers); this.log({ - sendingHttp1Response: { status: status, headers }, + sendingHttp1Response: { + method: req.method, + path: req.url, + status: status, + headers, + }, }); res.writeHead(status, headers); stream.pipe(res); @@ -190,22 +207,24 @@ export class TunnelServer extends AbstractTunnel { ); this.httpServer.on("listening", () => { this.log({ httpServer: "listening" }); - this.iter(); + this.updateHook(); }); this.httpServer.on("close", () => { this.log({ httpServer: "close" }); + this.httpServerClosing = false; this.httpServer = null; - this.iter(); + this.updateHook(); }); this.httpServer.listen( this.options.proxyListenPort, this.options.proxyListenIp, ); - this.iter(); + this.updateHook(); } startTunnelServer() { this.log({ tunnelServer: "starting" }); + this.tunnelServerClosing = false; this.tunnelServer = tls.createServer({ key: this.options.key, cert: this.options.cert, @@ -214,59 +233,62 @@ export class TunnelServer extends AbstractTunnel { // This is necessary only if the client uses a self-signed certificate. ca: [this.options.cert], }); + this.tunnelServer.maxConnections = 1; + this.tunnelServer.on("drop", (options) => { + this.log({ tunnelServer: "drop", options }); + }); this.tunnelServer.on("close", () => { this.log({ tunnelServer: "close" }); this.tunnelServer = null; - this.iter(); + this.updateHook(); }); this.tunnelServer.on("error", (err) => { this.log({ tunnelServer: "error", err }); }); - this.tunnelServer.on( - "secureConnection", - (newTunnelSocket: tls.TLSSocket) => { - this.log({ - tunnelServer: "secureConnection", - socket: Object.fromEntries( - SOCKET_PROPS.map((k) => [k, newTunnelSocket[k]]), - ), + this.tunnelServer.on("tlsClientError", (err) => { + this.log({ tunnelServer: "tlsClientError", err }); + }); + this.tunnelServer.on("secureConnection", (socket: tls.TLSSocket) => { + this.log({ + tunnelServer: "secureConnection", + socket: Object.fromEntries(SOCKET_PROPS.map((k) => [k, socket[k]])), + }); + if (!this.abortController.signal.aborted) { + this.tunnelSocketClosing = false; + this.tunnelSocket = socket; + this.tunnelSocket.on("error", (err) => { + this.log({ tunnelSocket: "error", err }); }); - if (!this.abortController.signal.aborted) { - this.tunnelSocket = newTunnelSocket; - this.tunnelSocket.on("error", (err) => { - this.log({ tunnelSocket: "error", err }); - }); - this.tunnelSocket.on("close", () => { - this.log({ tunnelSocket: "close" }); - this.tunnelSocket = null; - this.muxSocket?.end(); - this.iter(); - }); - this.iter(); - } - }, - ); + this.tunnelSocket.on("close", () => { + this.log({ tunnelSocket: "close" }); + this.tunnelSocket = null; + this.updateHook(); + }); + this.updateHook(); + } + }); this.tunnelServer.listen( this.options.tunnelListenPort, this.options.tunnelListenIp, - () => this.iter(), + () => this.updateHook(), ); - this.iter(); } startMuxServer() { this.log({ muxServer: "starting" }); + this.muxServerClosing = false; this.muxServer = net.createServer(); this.muxServer.maxConnections = 1; this.muxServer.on("connection", (socket: net.Socket) => { this.log({ muxServer: "connection" }); if (!this.tunnelSocket) { this.log({ muxServerRejectConnectionBecauseTunnelIsClosed: true }); - socket.end(); + // TODO: Close gracefully + socket.destroy(); } else { this.muxSocket = socket; this.linkSockets(this.tunnelSocket, this.muxSocket); - this.iter(); + this.updateHook(); } }); this.muxServer.on("drop", (options) => { @@ -275,7 +297,7 @@ export class TunnelServer extends AbstractTunnel { this.muxServer.on("listening", () => { this.log({ muxServer: "listening" }); this.muxServerListening = true; - this.iter(); + this.updateHook(); }); this.muxServer.on("error", (err) => { this.log({ muxServer: "error", err }); @@ -284,36 +306,14 @@ export class TunnelServer extends AbstractTunnel { this.log({ muxServer: "close" }); this.muxServer = null; this.muxServerListening = false; - this.iter(); + this.updateHook(); }); this.muxServer.listen(this.options.muxListenPort); } - get state(): TunnelState { - if ( - !this.muxSession && - !this.httpServer && - !this.muxServer && - !this.tunnelServer - ) { - return "stopped"; - } else if (this.abortController.signal.aborted) { - return "stopping"; - } else if (this.muxSession) { - return "connected"; - } else if ( - this.tunnelServer?.listening && - this.muxServerListening && - this.httpServer?.listening - ) { - return "listening"; - } else { - return "starting"; - } - } - startMuxSession() { this.log({ muxSession: "starting" }); + this.muxSessionClosing = false; this.muxSession = http2.connect( `https://localhost:${this.options.muxListenPort}`, { @@ -325,75 +325,113 @@ export class TunnelServer extends AbstractTunnel { }, ); this.muxSession.on("connect", () => { - this.log({ muxSession: "connected" }); + this.log({ muxSession: "connect" }); this.muxSessionConnected = true; - this.iter(); + this.updateHook(); }); this.muxSession.on("close", () => { - this.log({ muxSession: "closed" }); + this.log({ muxSession: "close" }); this.muxSession = null; this.muxSessionConnected = false; - this.iter(); + this.updateHook(); }); this.muxSession.on("error", (err) => { this.log({ muxSession: "error", err }); }); - this.iter(); } iter() { - if (this.abortController.signal.aborted) { - if (this.httpServer) { - this.httpServer.close(); - } else if (this.muxSession) { - this.muxSession.close(); - } else if (this.muxServer) { - this.muxServer.close(); - } else if (this.tunnelSocket) { - this.tunnelSocket.end(); - } else if (this.tunnelServer) { - this.tunnelServer.close(); - } - } else { - if (!this.tunnelServer) { - this.startTunnelServer(); - } else if (!this.muxServer) { - this.startMuxServer(); - } else if (!this.httpServer) { - this.startHttpServer(); - } else if ( - this.muxServerListening && - this.tunnelSocket && - !this.muxSession - ) { - this.startMuxSession(); + while (true) { + if (this.abortController.signal.aborted) { + if (this.httpServer && !this.httpServerClosing) { + this.httpServerClosing = true; + this.httpServer.close(); + } else if (this.muxSession && !this.muxSessionClosing) { + this.muxSessionClosing = true; + this.muxSession.close(); + } else if (this.muxServer && !this.muxServerClosing) { + if (this.muxServer.listening) { + this.muxServerClosing = true; + this.muxServer.close(); + } else { + this.muxServer = null; + } + } else if (this.tunnelSocket && !this.tunnelSocketClosing) { + this.tunnelSocketClosing = true; + this.tunnelSocket.end(); + } else if (this.tunnelServer && !this.tunnelServerClosing) { + this.tunnelServerClosing = true; + this.tunnelServer.close(); + } else if ( + !this.muxSession && + !this.httpServer && + !this.muxServer && + !this.tunnelServer + ) { + return "stopped"; + } else { + return "stopping"; + } + } else { + if (!this.tunnelServer) { + this.startTunnelServer(); + } else if (!this.muxServer) { + this.startMuxServer(); + } else if (!this.httpServer) { + this.startHttpServer(); + } else if ( + !this.httpServer.listening || + !this.tunnelServer.listening || + !this.muxServer.listening + ) { + // Wait until everything is listening + return "starting"; + } else if (!this.tunnelSocket) { + // Nothing else to do until we have a tunnel socket + return "listening"; + } else if (!this.muxSession) { + this.startMuxSession(); + } else if (this.muxSessionConnected) { + return "connected"; + } else { + return "listening"; + } } } - this.emit(this.state); + } + + async waitUntilListening() { + await this.waitUntilState("listening"); } } export class TunnelClient extends AbstractTunnel { - tool = "client" as const; - demuxServer: http2.Http2SecureServer | null = null; + demux: null | { + server: http2.Http2SecureServer; + closing: boolean; + }; demuxSession: http2.ServerHttp2Session | null = null; - tunnelSocket: tls.TLSSocket | null = null; - tunnelSocketConnected = false; + demuxSessionClosing = false; + tunnel: null | { + socket: tls.TLSSocket; + state: "connecting" | "connected" | "closing"; + }; // The tunnel will not restart as long as this property is not null tunnelSocketRestartTimeout: NodeJS.Timeout | null = null; - reverseSocket: net.Socket | null = null; - reverseSocketConnected = false; + reverse: null | { + socket: net.Socket; + state: "connecting" | "connected" | "closing"; + }; socketsLinked = false; constructor(readonly options: ClientOptions) { super(options.logger); - this.abortController = new AbortController(); } startTunnel() { this.log({ tunnelSocket: "starting" }); this.tunnelSocketRestartTimeout = null; - this.tunnelSocket = tls.connect({ + const socket = tls.connect({ host: this.options.tunnelHost, port: this.options.tunnelPort, // Necessary only if the server requires client certificate authentication. @@ -404,18 +442,17 @@ export class TunnelClient extends AbstractTunnel { // Necessary only if the server's cert isn't for "localhost". checkServerIdentity: () => undefined, }); - this.tunnelSocket.on("secureConnect", () => { + socket.on("secureConnect", () => { this.log({ tunnelSocket: "secureConnect" }); - this.tunnelSocketConnected = true; - this.iter(); + this.tunnel = { socket: socket, state: "connected" }; + this.updateHook(); }); - this.tunnelSocket.on("error", (err) => { + socket.on("error", (err) => { this.log({ tunnelSocket: "error", err }); }); - this.tunnelSocket.on("close", () => { + socket.on("close", () => { this.log({ tunnelSocket: "close" }); - this.tunnelSocket = null; - this.tunnelSocketConnected = false; + this.tunnel = null; this.socketsLinked = false; // This session doesn't detect a broken tunnel, it needs to be terminated manually this.demuxSession?.close(); @@ -425,33 +462,90 @@ export class TunnelClient extends AbstractTunnel { this.log({ tunnelSocketWillRestart: timeout }); this.tunnelSocketRestartTimeout = setTimeout(() => { this.tunnelSocketRestartTimeout = null; - this.iter(); + this.updateHook(); }, timeout); } - this.iter(); + this.updateHook(); }); + this.tunnel = { socket: socket, state: "connecting" }; } startReverseSocket() { - this.reverseSocket = net.createConnection({ + const socket = net.createConnection({ host: "localhost", port: this.options.demuxListenPort, }); - this.reverseSocket.on("close", () => { - this.log({ reverseSocketClose: true }); - this.reverseSocket = null; - this.reverseSocketConnected = false; + socket.on("error", (err) => { + this.log({ reverseSocket: "error", err }); + }); + socket.on("close", () => { + this.log({ reverseSocket: "close" }); + this.reverse = null; this.socketsLinked = false; - this.iter(); + this.updateHook(); + }); + socket.on("connect", () => { + this.log({ reverseSocket: "connect" }); + this.reverse = { socket, state: "connected" }; + this.updateHook(); + }); + this.reverse = { socket, state: "connecting" }; + } + + receiveHttp2Request( + stream: http2.ServerHttp2Stream, + headers: http2.IncomingHttpHeaders, + ) { + const method = headers[http2.constants.HTTP2_HEADER_METHOD] as string; + const path = headers[http2.constants.HTTP2_HEADER_PATH] as string; + this.log({ receivingHttp2Request: { method, path } }); + const req = http.request({ + hostname: "localhost", + port: this.options.localHttpPort, + path: path, + method: method, + headers: pruneHttp2Headers(headers), + signal: this.abortController.signal, + }); + req.on("response", (res: http.IncomingMessage) => { + const headers = pruneHttp1Headers(res.headers); + this.log({ + sendingHttp2Response: { status: res.statusCode, headers }, + }); + stream.respond({ + [http2.constants.HTTP2_HEADER_STATUS]: res.statusCode, + ...headers, + }); + res.pipe(stream); }); - this.reverseSocket.on("connect", () => { - this.reverseSocketConnected = true; - this.iter(); + req.on("error", (e) => { + this.log({ http1ReqError: e }); + stream.destroy(); }); + stream.pipe(req); + } + + receiveDemuxSession(session: http2.ServerHttp2Session) { + this.demuxSession = session; + this.demuxSessionClosing = false; + this.demuxSession.on("error", (err) => { + this.log({ demuxSession: "error", err }); + this.demuxSession = null; + this.updateHook(); + }); + this.demuxSession.on("close", () => { + this.log({ demuxSession: "close" }); + this.demuxSession = null; + this.updateHook(); + }); + this.demuxSession.on("stream", (stream, headers) => + this.receiveHttp2Request(stream, headers), + ); + this.updateHook(); } startDemuxServer() { - this.demuxServer = http2.createSecureServer({ + const server = http2.createSecureServer({ key: this.options.key, cert: this.options.cert, // This is necessary only if using client certificate authentication. @@ -459,138 +553,93 @@ export class TunnelClient extends AbstractTunnel { // This is necessary only if the client uses a self-signed certificate. ca: [this.options.cert], }); - this.demuxServer.on("close", () => { - this.demuxServer = null; - this.iter(); + server.on("close", () => { + this.demux = null; + this.updateHook(); }); - this.demuxServer.on("timeout", () => { + server.on("timeout", () => { this.log({ demuxServer: "timeout" }); }); - this.demuxServer.on("sessionError", (err) => { + server.on("sessionError", (err) => { this.log({ demuxServer: "sessionError", err }); }); - this.demuxServer.on("clientError", (err) => { + server.on("clientError", (err) => { this.log({ demuxServer: "clientError", err }); }); - this.demuxServer.on("unknownProtocol", () => { + server.on("unknownProtocol", () => { this.log({ demuxServer: "unknownProtocol" }); }); - this.demuxServer.on("session", (session: http2.ServerHttp2Session) => { - this.demuxSession = session; - this.demuxSession.on("error", (err) => { - this.log({ demuxSession: "error", err }); - this.demuxSession = null; - this.iter(); - }); - this.demuxSession.on("close", () => { - this.log({ demuxSession: "close" }); - this.demuxSession = null; - this.iter(); - }); - this.demuxSession.on( - "stream", - async ( - stream: http2.ServerHttp2Stream, - headers: http2.IncomingHttpHeaders, - ) => { - const method = headers[http2.constants.HTTP2_HEADER_METHOD] as string; - const path = headers[http2.constants.HTTP2_HEADER_PATH] as string; - this.log({ receivingHttp2Request: { method, path } }); - const req = http.request( - { - hostname: "localhost", - port: this.options.localHttpPort, - path: path, - method: method, - headers: pruneHttp2Headers(headers), - signal: this.abortController.signal, - }, - (res: http.IncomingMessage) => { - const headers = pruneHttp1Headers(res.headers); - this.log({ - sendingHttp2Response: { status: res.statusCode, headers }, - }); - stream.respond({ - [http2.constants.HTTP2_HEADER_STATUS]: res.statusCode, - ...headers, - }); - res.pipe(stream); - }, - ); - req.on("error", (e) => { - this.log({ http1ReqError: e }); - }); - stream.pipe(req); - }, - ); - this.iter(); - }); - this.demuxServer.on("listening", () => { + server.on("session", (session) => this.receiveDemuxSession(session)); + server.on("listening", () => { this.log({ demuxServer: "listening" }); - this.iter(); + this.updateHook(); }); - this.demuxServer.listen(this.options.demuxListenPort); - this.iter(); - } - - get state(): TunnelState { - if (!this.tunnelSocket && !this.reverseSocket) { - return "stopped"; - } else if (this.abortController.signal.aborted) { - return "stopping"; - } else if (this.socketsLinked && this.demuxSession) { - return "connected"; - } else if (this.demuxServer?.listening) { - return "listening"; - } else { - return "starting"; - } + server.listen(this.options.demuxListenPort); + this.demux = { server, closing: false }; } iter() { - if (this.abortController.signal.aborted) { - if (this.tunnelSocketRestartTimeout) { - clearTimeout(this.tunnelSocketRestartTimeout); - this.tunnelSocketRestartTimeout = null; - } else if (this.reverseSocket) { - this.reverseSocket.end(); - } else if (this.tunnelSocket) { - this.tunnelSocket.end(); - } else if (this.demuxSession) { - this.demuxSession.close(); - } else if (this.demuxServer) { - this.demuxServer.close(); - } - } else { - if (!this.demuxServer) { - this.startDemuxServer(); - this.iter(); - return; - } - if (this.demuxServer.listening && !this.reverseSocket) { - this.startReverseSocket(); - this.iter(); - return; - } - if ( - this.reverseSocket && - this.reverseSocketConnected && - this.tunnelSocket && - this.tunnelSocketConnected && - !this.socketsLinked - ) { - this.linkSockets(this.tunnelSocket, this.reverseSocket); - this.socketsLinked = true; - this.iter(); - return; - } - if (!this.tunnelSocket && !this.tunnelSocketRestartTimeout) { - this.startTunnel(); - this.iter(); - return; + while (true) { + if (this.abortController.signal.aborted) { + if (this.tunnelSocketRestartTimeout) { + clearTimeout(this.tunnelSocketRestartTimeout); + this.tunnelSocketRestartTimeout = null; + } else if (this.demuxSession) { + if (!this.demuxSessionClosing) { + this.demuxSessionClosing = true; + this.demuxSession.close(); + } else { + // Do not mess around with sockets until HTTP2 session is cleanly closed + return "stopping"; + } + } else if (this.socketsLinked && this.tunnel && this.reverse) { + // Unlink sockets before closing them individually + this.unlinkSockets(this.reverse.socket, this.tunnel.socket); + this.socketsLinked = false; + } else if (this.tunnel || this.reverse) { + // Sockets are unlinked, they are safe to stop simultaneously + if (this.tunnel && this.tunnel.state !== "closing") { + this.tunnel.state = "closing"; + this.tunnel.socket.end(); + } + if (this.reverse && this.reverse.state !== "closing") { + this.reverse.state = "closing"; + this.reverse.socket.end(); + } + // Do not continue until both are stopped + return "stopping"; + } else if (this.demux) { + if (!this.demux.closing) { + this.demux.closing = true; + this.demux.server.close(); + } else { + return "stopping"; + } + } else { + return "stopped"; + } + } else { + if (!this.demux) { + this.startDemuxServer(); + } else if (!this.tunnel && !this.tunnelSocketRestartTimeout) { + this.startTunnel(); + } else if ( + !this.demux.server.listening || + !this.tunnel || + this.tunnel.state !== "connected" + ) { + return "starting"; + } else if (!this.reverse) { + this.startReverseSocket(); + } else if (this.reverse.state === "connected" && !this.socketsLinked) { + this.linkSockets(this.tunnel.socket, this.reverse.socket); + this.socketsLinked = true; + } else if (this.socketsLinked && this.demuxSession) { + return "connected"; + } else { + return "starting"; + } } } - - this.emit(this.state); } }