refactor: use Node.js direct TypeScript support

Author: mrlika

bin/wt-tracker

@@ -1,3 +1,3 @@
 #!/usr/bin/env node
 
-import "../lib/run-tracker.js";
+import "../src/run-tracker.ts";

package.json

@@ -31,16 +31,15 @@
     "websockets"
   ],
   "scripts": {
-    "start": "node ./lib/run-tracker.js",
-    "start:worker-demo": "npx tsc && DEBUG=wt-tracker:tracker-worker-*,wt-tracker:multi-worker-tracker,wt-tracker:uws-tracker node ./lib/run-worker-tracker.js",
+    "start": "node ./src/run-tracker.ts",
+    "start:worker-demo": "DEBUG=wt-tracker:tracker-worker-*,wt-tracker:multi-worker-tracker,wt-tracker:uws-tracker node ./src/run-worker-tracker.ts",
     "build": "npm run lint && npm run clean && npm run compile",
-    "compile": "tsc",
+    "compile": "tsc --noEmit false",
     "lint": "eslint --flag unstable_native_nodejs_ts_config src",
     "clean": "rimraf lib",
-    "watch": "tsc --watch",
     "test": "vitest",
     "test:coverage": "vitest run --coverage",
-    "test:compile": "tsc --project tsconfig.test.json",
+    "test:compile": "tsc --project tsconfig.test.json --noEmit false",
     "test:clean": "rimraf test_dist"
   },
   "repository": {

src/build-uws-tracker.ts

@@ -1,8 +1,12 @@
-import { HttpRequest, HttpResponse } from "uWebSockets.js";
-import { debugRequest } from "./debugRequest.js";
-import { ServerItemSettings, WebSocketsAccessSettings } from "./settings.js";
-import { Tracker } from "./tracker.js";
-import { UWebSocketsTracker, UwsConnectionContext } from "./uws-tracker.js";
+import type { HttpRequest, HttpResponse } from "uWebSockets.js";
+import { debugRequest } from "./debugRequest.ts";
+import type {
+  ServerItemSettings,
+  WebSocketsAccessSettings,
+} from "./settings.ts";
+import type { Tracker } from "./tracker.ts";
+import { UWebSocketsTracker } from "./uws-tracker.ts";
+import type { UwsConnectionContext } from "./uws-tracker.ts";
 
 type BuildServerParams = {
   tracker: Tracker<UwsConnectionContext>;

src/debugRequest.ts

@@ -15,8 +15,8 @@
  */
 
 import Debug from "debug";
-import { UWebSocketsTracker } from "./uws-tracker.js";
-import { HttpRequest } from "uWebSockets.js";
+import { UWebSocketsTracker } from "./uws-tracker.ts";
+import type { HttpRequest } from "uWebSockets.js";
 
 const debugRequests = Debug("wt-tracker:uws-tracker-requests");
 const debugRequestsEnabled = debugRequests.enabled;

src/fast-tracker.ts

@@ -16,7 +16,8 @@
 
 import { threadId } from "node:worker_threads";
 import Debug from "debug";
-import { Tracker, TrackerError } from "./tracker.js";
+import type { Tracker } from "./tracker.ts";
+import { TrackerError } from "./tracker.ts";
 
 const debugSuffix = threadId ? `-${threadId}` : "";
 const debug = Debug(`wt-tracker:fast-tracker${debugSuffix}`);

src/index.ts

@@ -15,6 +15,6 @@
  * limitations under the License.
  */
 
-export * from "./uws-tracker.js";
-export * from "./fast-tracker.js";
-export * from "./tracker.js";
+export * from "./uws-tracker.ts";
+export * from "./fast-tracker.ts";
+export * from "./tracker.ts";

src/multi-worker-socket-app/index.ts

@@ -15,15 +15,15 @@
  */
 
 import { App, SSLApp } from "uWebSockets.js";
-import { Settings } from "../settings.js";
+import type { Settings } from "../settings.ts";
 import { Worker } from "node:worker_threads";
-import {
+import type {
   AppsStatsResponse,
   ServerWorkerInMessage,
   ServerWorkerOutMessage,
   WorkerDataType,
-} from "./types.js";
-import { MultiWorkerTracker } from "../multi-worker-tracker/index.js";
+} from "./types.ts";
+import { MultiWorkerTracker } from "../multi-worker-tracker/index.ts";
 
 export async function runSocketWorkersApp(settings: Settings) {
   // Create connections acceptors
@@ -85,7 +85,7 @@ export async function runSocketWorkersApp(settings: Settings) {
     // Ports between the socket worker and the tracker workers
     const trackerPorts = buildWorkerPorts();
 
-    const worker = new Worker(`${import.meta.dirname}/worker.js`, {
+    const worker = new Worker(`${import.meta.dirname}/worker.ts`, {
       workerData: {
         settings,
         trackerPorts,

src/multi-worker-socket-app/types.ts

@@ -1,4 +1,4 @@
-import { Settings } from "../settings.js";
+import type { Settings } from "../settings.ts";
 import { MessagePort } from "node:worker_threads";
 
 export type WorkerDataType = {

src/multi-worker-socket-app/worker.ts

@@ -1,10 +1,7 @@
-import { Settings } from "../settings.js";
-import { Tracker } from "../tracker.js";
-import {
-  sendMessage,
-  UWebSocketsTracker,
-  UwsConnectionContext,
-} from "../uws-tracker.js";
+import type { Settings } from "../settings.ts";
+import type { Tracker } from "../tracker.ts";
+import { sendMessage, UWebSocketsTracker } from "../uws-tracker.ts";
+import type { UwsConnectionContext } from "../uws-tracker.ts";
 import { readFileSync } from "fs";
 import { MessagePort } from "worker_threads";
 import {
@@ -13,15 +10,15 @@ import {
   parentPort,
   threadId,
 } from "node:worker_threads";
-import { MultiWorkerTracker } from "../multi-worker-tracker/index.js";
-import { buildUwsTracker } from "../build-uws-tracker.js";
-import {
+import { MultiWorkerTracker } from "../multi-worker-tracker/index.ts";
+import { buildUwsTracker } from "../build-uws-tracker.ts";
+import type {
   AppDescriptorMessage,
   AppsStatsResponse,
   ServerWorkerInMessage,
   ServerWorkerOutMessage,
   WorkerDataType,
-} from "./types.js";
+} from "./types.ts";
 
 // TODO:
 // - test what host and port workers require

src/multi-worker-tracker/index.ts

@@ -6,12 +6,13 @@ TODO:
 import os from "node:os";
 import { Worker, MessagePort, threadId } from "node:worker_threads";
 import Debug from "debug";
-import { Tracker, TrackerError } from "../tracker.js";
-import {
+import { TrackerError } from "../tracker.ts";
+import type { Tracker } from "../tracker.ts";
+import type {
   TrackerWorkerInEvent,
   TrackerWorkerOutEvent,
   WorkerDataType,
-} from "./types.js";
+} from "./types.ts";
 
 const debugSuffix = threadId ? `-${threadId}` : "";
 const debug = Debug(`wt-tracker:multi-worker-tracker${debugSuffix}`);
@@ -211,7 +212,7 @@ export class MultiWorkerTracker<
 
     for (let workerIndex = 0; workerIndex < workersCount; workerIndex++) {
       workers.push(
-        new Worker(`${import.meta.dirname}/worker.js`, {
+        new Worker(`${import.meta.dirname}/worker.ts`, {
           workerData: { settings } satisfies WorkerDataType,
         }),
       );