rewrite to TS

Author: icebob

template/eslint.config.js

@@ -0,0 +1,33 @@
+// @ts-check
+
+import eslint from "@eslint/js";
+import tseslint from "typescript-eslint";
+import eslintPluginPrettierRecommended from "eslint-plugin-prettier/recommended";
+import globals from "globals";
+
+export default tseslint.config(
+	eslint.configs.recommended,
+	tseslint.configs.recommended,
+	eslintPluginPrettierRecommended,
+	{
+		languageOptions: {
+			globals: {
+				...globals.node
+			}
+		},
+		rules: {
+			"@/no-var": ["error"],
+			"@/no-console": ["warn"],
+			"@typescript-eslint/no-unused-vars": ["warn"],
+			"@/no-trailing-spaces": ["error"],
+			"@/no-process-exit": ["off"],
+			"@/object-curly-spacing": ["warn", "always"]
+		}
+	},
+	{
+		files: ["test/**/*.js"],
+		rules: {
+			"@/no-unused-vars": ["off"]
+		}
+	}
+);

template/eslint.config.mjs

@@ -2,7 +2,7 @@ import type { BrokerOptions, MetricRegistry, ServiceBroker } from "moleculer";
 import { Errors } from "moleculer";
 
 {{#needChannels}}
-import { Middleware as ChannelMiddleware } from "@moleculer/channels");
+import { Middleware as ChannelMiddleware } from "@moleculer/channels";
 {{#tracing}}import { Tracing as ChannelTracing } from "@moleculer/channels";{{/tracing}}
 {{/needChannels}}
 

template/jest.config.js

@@ -7,8 +7,8 @@
     "dev": "tsx ./node_modules/moleculer/bin/moleculer-runner.js --config moleculer.config.ts --hot --repl services/**/*.service.ts",
     "start": "moleculer-runner --config dist/moleculer.config.js",
     "cli": "moleculer connect {{transporter}}",
-    "ci": "jest --watch",
-    "test": "jest --coverage"{{#lint}},
+    "ci": "vitest --watch",
+    "test": "vitest --run --coverage"{{#lint}},
     "lint": "eslint",
     "lint:fix": "eslint --fix"{{/lint}}{{#docker}},
     "dc:up": "docker compose up --build -d",
@@ -21,10 +21,13 @@
   ],
   "author": "",
   "devDependencies": {
+    "@types/node": "^22.15.29",
     {{#lint}}
+		"@eslint/js": "^9.28.0",
     "eslint": "^9.28.0",
     "eslint-config-prettier": "^10.1.5",
     "eslint-plugin-prettier": "^5.4.1",
+		"typescript-eslint": "^8.33.0",
     "prettier": "^3.5.3",
     {{/lint}}
     "jest": "^29.7.0",
@@ -38,7 +41,10 @@
     {{#apiGQL}}
     "graphql-request": "^6.1.0",
     {{/apiGQL}}
-    "moleculer-repl": "^0.7.4"
+    "moleculer-repl": "^0.7.4",
+		"tsx": "^4.19.4",
+		"typescript": "^5.8.3",
+		"vitest": "^3.1.4"
   },
   "dependencies": {
     {{#apiGW}}

template/moleculer.config.ts

@@ -1,27 +1,27 @@
-import { afterAll, beforeAll, describe, expect, test } from "@jest/globals";
+import { afterAll, beforeAll, describe, it, expect, vi } from "vitest";
 
 
 process.env.PORT = 0; // Use random ports during tests
 
-const HTTPrequest = require("supertest");
+import HTTPrequest from "supertest";
 {{#apiIO}}
-const io = require("socket.io-client");
+import io from "socket.io-client";
 {{/apiIO}}
 {{#apiGQL}}
-const { request, gql } = require("graphql-request");
+import { request, gql } from "graphql-request";
 {{/apiGQL}}
 
-const { ServiceBroker } = require("moleculer");
+import { Context, ServiceBroker } from "moleculer";
 // Load service schemas
-const APISchema = require("../../services/api.service");
-const GreeterSchema = require("../../services/greeter.service");
+import APISchema from "../../../services/api.service";
+import GreeterSchema from "../../../services/greeter.service";
 {{#dbService}}
-const ProductsSchema = require("../../services/products.service");
+import ProductsSchema from "../../../services/products.service";
 {{/dbService}}
 
 describe("Test HTTP API gateway", () => {
 	let broker = new ServiceBroker({ logger: false });
-	broker.sendToChannel = jest.fn();
+	broker.sendToChannel = vi.fn();
 
 	let greeterService = broker.createService(GreeterSchema);
 	let apiService = broker.createService(APISchema);
@@ -215,7 +215,7 @@ describe("Test HTTP API gateway", () => {
 {{#apiIO}}
 describe("Test Socket.IO API gateway", () => {
 	let broker = new ServiceBroker({ logger: false });
-	broker.sendToChannel = jest.fn();
+	broker.sendToChannel = vi.fn();
 
 	let greeterService = broker.createService(GreeterSchema);
 	let apiService = broker.createService(APISchema);
@@ -406,7 +406,7 @@ describe("Test Socket.IO API gateway", () => {
 {{#apiGQL}}
 describe("Test GraphQL API gateway", () => {
 	let broker = new ServiceBroker({ logger: false });
-	broker.sendToChannel = jest.fn();
+	broker.sendToChannel = vi.fn();
 
 	let greeterService = broker.createService(GreeterSchema);
 	let apiService = broker.createService(APISchema);

template/package.json

@@ -1,4 +1,4 @@
-import { afterAll, beforeAll, describe, expect, test } from "@jest/globals";
+import { afterAll, beforeAll, describe, it, expect, vi } from "vitest";
 import { ServiceBroker } from "moleculer";
 import type { ServiceSchema } from "moleculer";
 import type { ProductEntity } from "../../services/products.service";
@@ -10,7 +10,7 @@ describe("Test 'products' service", () => {
 		const service = broker.createService(TestService);
 		service.seedDB = null; // Disable seeding
 
-		broker.sendToChannel = jest.fn();
+		broker.sendToChannel = vi.fn();
 
 		beforeAll(() => broker.start());
 		afterAll(() => broker.stop());

template/test/integration/api.spec.ts

@@ -1,7 +1,8 @@
-import { afterAll, beforeAll, describe, expect, test } from "@jest/globals";
+import { afterAll, beforeAll, describe, it, expect, vi } from "vitest";
 
-const { ServiceBroker } = require("moleculer");
-const DbMixin = require("../../../mixins/db.mixin");
+import { Context, ServiceBroker } from "moleculer";
+import type { Service, ServiceAsyncLifecycleHandler, ServiceEventHandler } from "moleculer";
+import DbMixin from "../../../mixins/db.mixin";
 
 describe("Test DB mixin", () => {
 	describe("Test schema generator", () => {
@@ -19,7 +20,7 @@ describe("Test DB mixin", () => {
 		});
 
 		it("check cache event handler", async () => {
-			jest.spyOn(broker.cacher, "clean");
+			vi.spyOn(broker.cacher, "clean");
 
 			const schema = DbMixin("my-collection");
 
@@ -37,12 +38,12 @@ describe("Test DB mixin", () => {
 				const schema = DbMixin("my-collection");
 
 				const adapterMock = {
-					count: jest.fn(async () => 10)
+					count: vi.fn(async () => 10)
 				};
-				let getAdapterMock = jest.fn(() => {
+				let getAdapterMock = vi.fn(() => {
 					return Promise.resolve(adapterMock);
 				});
-				const seedDBFn = jest.fn();
+				const seedDBFn = vi.fn();
 
 				await schema.started.call({
 					broker,
@@ -61,12 +62,12 @@ describe("Test DB mixin", () => {
 				const schema = DbMixin("my-collection");
 
 				const adapterMock = {
-					count: jest.fn(async () => 0)
+					count: vi.fn(async () => 0)
 				};
-				let getAdapterMock = jest.fn(() => {
+				let getAdapterMock = vi.fn(() => {
 					return Promise.resolve(adapterMock);
 				});
-				const seedDBFn = jest.fn();
+				const seedDBFn = vi.fn();
 
 				await schema.started.call({
 					broker,
@@ -87,7 +88,7 @@ describe("Test DB mixin", () => {
 			const schema = DbMixin("my-collection");
 
 			const ctx = {
-				broadcast: jest.fn()
+				broadcast: vi.fn()
 			};
 
 			await schema.methods.entityChanged(null, null, null, ctx);

template/test/integration/products.service.spec.ts

@@ -1,8 +1,8 @@
-import { afterAll, beforeAll, describe, expect, test } from "@jest/globals";
+import { afterAll, beforeAll, describe, it, expect, vi } from "vitest";
 
-const { ServiceBroker } = require("moleculer");
-const { ValidationError } = require("moleculer").Errors;
-const TestService = require("../../../services/greeter.service");
+import { Errors, ServiceBroker } from "moleculer";
+import type { ServiceSchema } from "moleculer";
+import TestService from "../../../services/greeter.service";
 
 describe("Test 'greeter' service", () => {
 	let broker = new ServiceBroker({ logger: false });
@@ -29,7 +29,7 @@ describe("Test 'greeter' service", () => {
 			try {
 				await broker.call("greeter.welcome");
 			} catch (err) {
-				expect(err).toBeInstanceOf(ValidationError);
+				expect(err).toBeInstanceOf(Errors.ValidationError);
 			}
 		});
 	});

template/test/unit/mixins/db.mixin.spec.ts

@@ -1,8 +1,9 @@
-import { afterAll, beforeAll, describe, expect, test } from "@jest/globals";
+import { afterAll, beforeAll, describe, it, expect, vi } from "vitest";
 
-const { ServiceBroker, Context } = require("moleculer");
-const ChannelMiddleware = require("@moleculer/channels").Middleware;
-const TestService = require("../../../services/inventory.service");
+import { Context, Errors, ServiceBroker } from "moleculer";
+import type { ServiceSchema } from "moleculer";
+import TestService from "../../../services/inventory.service";
+import { Middleware as ChannelMiddleware } from "@moleculer/channels";
 
 describe("Test 'inventory' service", () => {
 	const broker = new ServiceBroker({
@@ -16,20 +17,20 @@ describe("Test 'inventory' service", () => {
 		]
 	});
 	// Mock adapter methods
-	broker.channelAdapter.init = jest.fn();
-	broker.channelAdapter.connect = jest.fn();
-	broker.channelAdapter.disconnect = jest.fn();
-	broker.channelAdapter.subscribe = jest.fn();
-	broker.channelAdapter.unsubscribe = jest.fn();
-	broker.channelAdapter.publish = jest.fn();
+	broker.channelAdapter.init = vi.fn();
+	broker.channelAdapter.connect = vi.fn();
+	broker.channelAdapter.disconnect = vi.fn();
+	broker.channelAdapter.subscribe = vi.fn();
+	broker.channelAdapter.unsubscribe = vi.fn();
+	broker.channelAdapter.publish = vi.fn();
 
-	broker.emit = jest.fn();
+	broker.emit = vi.fn();
 
 	const service = broker.createService(TestService);
 
 	// Store the reference to the original orderProduct method
 	const ORIGINAL_ORDER_PRODUCT = service.orderProduct;
-	service.orderProduct = jest.fn();
+	service.orderProduct = vi.fn();
 
 	beforeAll(() => broker.start());
 	afterAll(() => broker.stop());
@@ -50,7 +51,7 @@ describe("Test 'inventory' service", () => {
 	});
 
 	it("should send msg to 'inventory.reserve' channel", async () => {
-		broker.sendToChannel = jest.fn();
+		broker.sendToChannel = vi.fn();
 
 		await broker.call("inventory.reserve", {
 			productId: "123",