.woodpecker/.build.yml

@@ -3,7 +3,11 @@ when:
 
 steps:
   build:
-    image: oven/bun:1.1.3-slim
+    image: oven/bun:${BUN_VERSION}-slim
     commands:
       - bun install
-      - bun run build
+      - bun run build
+
+matrix:
+  BUN_VERSION:
+    - 1.1.0

.woodpecker/.lint.yml

@@ -3,7 +3,7 @@ when:
 
 steps:
   lint:
-    image: oven/bun:1.1.3-slim
+    image: oven/bun:1.0.33-slim
     commands:
       - bun install
       - bun run ci

.woodpecker/.test.yml

@@ -13,10 +13,7 @@ steps:
 matrix:
   BUN_VERSION:
     - 1.1.0
-    - 1.1.1
-    - 1.1.2
-    - 1.1.3
 
 services:
   nats:
-    image: nats:2-alpine
+    image: nats

package.json

@@ -12,7 +12,7 @@
 		"build": "tsc --project tsconfig.build.json"
 	},
 	"devDependencies": {
-		"@biomejs/biome": "1.6.4",
+		"@biomejs/biome": "1.6.3",
 		"@types/bun": "latest",
 		"typescript": "^5.0.0"
 	},
@@ -20,7 +20,7 @@
 		"typescript": "^5.0.0"
 	},
 	"dependencies": {
-		"nats": "^2.22.0",
+		"nats": "^2.19.0",
 		"zod": "^3.22.4"
 	}
 }

src/service.ts

@@ -29,7 +29,7 @@ export default class Service {
 		adaptor: string,
 		subject: string,
 		fn: RouteSubscribeTypeFn<z.infer<T>, U>,
-		schema?: T,
+		schema: T | undefined = undefined,
 	) {
 		this.adaptors[adaptor].subscribe(
 			`${this.name}.${subject}`,
@@ -64,7 +64,7 @@ export default class Service {
 				}
 
 				try {
-					const res = await fn(this, req);
+					const res = await fn(req);
 					const internalResponse = {
 						statusCode: res.statusCode,
 						data: res.data,

src/types.ts

@@ -1,8 +1,6 @@
 import type { Request, Response } from "./messages.ts";
-import type Service from "./service.ts";
 
 export type AdaptorSubscribeTypeFn = (msg: string) => Promise<string>;
 export type RouteSubscribeTypeFn<T, U> = (
-	srv: Service,
 	msg: Request<T>,
 ) => Promise<Response<U>>;

tests/service.test.ts

@@ -27,7 +27,7 @@ test("request success", async () => {
 	srv.subscribe(
 		adaptorName,
 		subject,
-		async (srv, msg) => {
+		async (msg) => {
 			return { data: msg.data, statusCode: statusCodeExpected };
 		},
 		z.string(),
@@ -54,9 +54,14 @@ test("request error", async () => {
 	const statusCodeExpected = 500;
 
 	srv.addAdaptor(adaptorName, new NatsAdaptor({ servers: [natsServer] }));
-	srv.subscribe(adaptorName, subject, async (srv, msg) => {
+	srv.subscribe(
-		throw new RequestError("request error", 500);
+		adaptorName,
-	});
+		subject,
+		async (msg) => {
+			throw new RequestError("request error", 500);
+		},
+		z.string(),
+	);
 
 	await srv.listen();
 	expect(() => {
@@ -77,7 +82,7 @@ test("request adaptor not found", async () => {
 	const statusCodeExpected = 200;
 
 	srv.addAdaptor(adaptorName, new NatsAdaptor({ servers: [natsServer] }));
-	srv.subscribe(adaptorName, subject, async (srv, msg) => {
+	srv.subscribe(adaptorName, subject, async (msg) => {
 		return { data: msg.data, statusCode: statusCodeExpected };
 	});