fix: replace any with unknown/never in ParserMap types, format test.ts

baelter · baelter · commit c3d95c350915 · 2026-05-06T06:52:27.000+02:00
Method shorthand on AMQPParser gives bivariance, so AMQPParser&lt;unknown,
unknown&gt; accepts narrower parsers. Inference helpers use unknown/never
in the slot we discard so eslint no-explicit-any is satisfied without
disable comments.
diff --git a/src/amqp-codec-registry.ts b/src/amqp-codec-registry.ts
@@ -4,7 +4,7 @@ import { isPlainBody } from "./amqp-publisher.js"
 
 // 1. Define a type that represents a map of different Parsers
 export type ParserMap = {
-  [K: string]: AMQPParser<any, any>
+  [K: string]: AMQPParser<unknown, unknown>
 }
 
 // 2. The ParserRegistry type uses a Mapped Type to preserve the unique In/Out of each key
@@ -41,8 +41,8 @@ export function createParserRegistry<T extends ParserMap>(
   return parsers
 }
 
-export type InferParserInput<P> = P extends AMQPParser<infer TInput, any> ? TInput : never
-export type InferParserOutput<P> = P extends AMQPParser<any, infer Out> ? Out : never
+export type InferParserInput<P> = P extends AMQPParser<infer TInput, unknown> ? TInput : never
+export type InferParserOutput<P> = P extends AMQPParser<never, infer Out> ? Out : never
 
 export type CoderMap = { [K: string]: AMQPCoder }
 export type CoderRegistry<T extends CoderMap> = { readonly [K in keyof T & string]: T[K] }
@@ -213,4 +213,3 @@ export async function decodeMessage(msg: AMQPMessage, parsers: ParserMap, coders
     ;(msg as { body: unknown }).body = await decodeAndParse(parsers, coders, msg._rawBytes, msg.properties)
   }
 }
-
diff --git a/test/test.ts b/test/test.ts
@@ -810,7 +810,11 @@ test("can republish in consume block without race condition", async () => {
   await ch.basicPublish("", q.name, "x".repeat(500))
   const consumer = await ch.basicConsume(q.name, { noAck: false }, async (msg) => {
     if (msg.deliveryTag < 10000) {
-      await Promise.all([ch.basicPublish("", q.name, msg._rawBytes), ch.basicPublish("", q.name, msg._rawBytes), msg.ack()])
+      await Promise.all([
+        ch.basicPublish("", q.name, msg._rawBytes),
+        ch.basicPublish("", q.name, msg._rawBytes),
+        msg.ack(),
+      ])
     } else if (msg.deliveryTag === 10000) {
       await msg.ack()
       await consumer.cancel()

Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@ import { isPlainBody } from "./amqp-publisher.js"`
`4`	`4`
`5`	`5`	`// 1. Define a type that represents a map of different Parsers`
`6`	`6`	`export type ParserMap = {`
`7`		`- [K: string]: AMQPParser<any, any>`
	`7`	`+ [K: string]: AMQPParser<unknown, unknown>`
`8`	`8`	`}`
`9`	`9`
`10`	`10`	`// 2. The ParserRegistry type uses a Mapped Type to preserve the unique In/Out of each key`
`@@ -41,8 +41,8 @@ export function createParserRegistry<T extends ParserMap>(`
`41`	`41`	`return parsers`
`42`	`42`	`}`
`43`	`43`
`44`		`-export type InferParserInput<P> = P extends AMQPParser<infer TInput, any> ? TInput : never`
`45`		`-export type InferParserOutput<P> = P extends AMQPParser<any, infer Out> ? Out : never`
	`44`	`+export type InferParserInput<P> = P extends AMQPParser<infer TInput, unknown> ? TInput : never`
	`45`	`+export type InferParserOutput<P> = P extends AMQPParser<never, infer Out> ? Out : never`
`46`	`46`
`47`	`47`	`export type CoderMap = { [K: string]: AMQPCoder }`
`48`	`48`	`export type CoderRegistry<T extends CoderMap> = { readonly [K in keyof T & string]: T[K] }`
`@@ -213,4 +213,3 @@ export async function decodeMessage(msg: AMQPMessage, parsers: ParserMap, coders`
`213`	`213`	`;(msg as { body: unknown }).body = await decodeAndParse(parsers, coders, msg._rawBytes, msg.properties)`
`214`	`214`	`}`
`215`	`215`	`}`
`216`		`-`