reaatech · reaatech · Jun 7, 2026
diff --git a/.../repobot-tighten-type-usage-replace-lazy-any-unknown-with-true-types-issue27.md b/.../repobot-tighten-type-usage-replace-lazy-any-unknown-with-true-types-issue27.md
@@ -0,0 +1,11 @@
+---
+"@reaatech/a2a-reference-client": patch
+"@reaatech/a2a-reference-mcp-bridge": patch
+"@reaatech/a2a-reference-observability": patch
+"@reaatech/a2a-reference-persistence": patch
+"@reaatech/a2a-reference-server": patch
+---
+
+Fix: Tighten type usage: replace lazy any/unknown with true types
+
+Closes #27
diff --git a/packages/client/src/client-unit.test.ts b/packages/client/src/client-unit.test.ts
@@ -175,7 +175,7 @@ describe('A2AClient unit tests', () => {
       );
     const client = new A2AClient({ baseUrl: 'http://localhost:3000', fetchImpl: mockFetch });
 
-    const events: unknown[] = [];
+    const events: Array<Record<string, unknown>> = [];
     for await (const event of client.sendSubscribe({
       messageId: '1',
       role: 'user',
@@ -206,7 +206,7 @@ describe('A2AClient unit tests', () => {
       );
     const client = new A2AClient({ baseUrl: 'http://localhost:3000', fetchImpl: mockFetch });
 
-    const events: unknown[] = [];
+    const events: Array<Record<string, unknown>> = [];
     for await (const event of client.subscribe('t1')) {
       events.push(event);
     }
@@ -221,13 +221,15 @@ describe('A2AClient unit tests', () => {
     const read = vi.fn().mockRejectedValue(new Error('Stream error'));
     const mockBody = {
       getReader: () => ({ read, releaseLock }),
-    } as unknown as ReadableStream<Uint8Array>;
+    } as unknown as {
+      getReader: () => { read: ReturnType<typeof vi.fn>; releaseLock: ReturnType<typeof vi.fn> };
+    };
 
     const mockResponse = {
       ok: true,
       body: mockBody,
       headers: new Headers({ 'content-type': 'text/event-stream' }),
-    } as unknown as Response;
+    } as unknown as { ok: boolean; body: unknown; headers: Headers };
 
     const mockFetch = vi
       .fn()
@@ -310,7 +312,7 @@ describe('A2AClient unit tests', () => {
       ok: true,
       body: null,
       headers: new Headers({ 'content-type': 'text/event-stream' }),
-    } as unknown as Response;
+    } as unknown as { ok: boolean; body: null; headers: Headers };
 
     const mockFetch = vi
       .fn()
@@ -362,7 +364,7 @@ describe('A2AClient unit tests', () => {
       );
     const client = new A2AClient({ baseUrl: 'http://localhost:3000', fetchImpl: mockFetch });
 
-    const events: unknown[] = [];
+    const events: Array<Record<string, unknown>> = [];
     for await (const event of client.sendSubscribe({
       messageId: '1',
       role: 'user',
@@ -505,7 +507,7 @@ describe('A2AClient unit tests', () => {
       ok: true,
       body: null,
       headers: new Headers({ 'content-type': 'text/event-stream' }),
-    } as unknown as Response;
+    } as unknown as { ok: boolean; body: null; headers: Headers };
 
     const mockFetch = vi
       .fn()

diff --git a/packages/mcp-bridge/src/a2a-to-mcp.test.ts b/packages/mcp-bridge/src/a2a-to-mcp.test.ts
@@ -3,7 +3,10 @@ import type { AgentCard, Skill } from '@reaatech/a2a-reference-core';
 import { beforeEach, describe, expect, it, vi } from 'vitest';
 import { A2aAsMcpServer } from './a2a-to-mcp.js';
 
-const mockHandlers = new Map<string, (request: unknown) => Promise<unknown>>();
+const mockHandlers = new Map<
+  string,
+  (request: Record<string, unknown>) => Promise<Record<string, unknown>>
+>();
 
 // Mutable mock state for A2AClient
 const mockA2AState = vi.hoisted(() => ({
@@ -21,23 +24,19 @@ const mockA2AState = vi.hoisted(() => ({
       { url: 'http://localhost:3000', protocolBinding: 'a2a', protocolVersion: '0.3.0' },
     ],
   } as AgentCard,
-  sendMessageResult: { id: 'task-1', status: { state: 'submitted' } } as unknown,
+  sendMessageResult: { id: 'task-1', status: { state: 'submitted' } } as Record<string, unknown>,
   getTaskResult: {
     id: 'task-1',
     status: { state: 'completed' },
     artifacts: [{ name: 'result', parts: [{ kind: 'text', text: '42' }] }],
-  } as unknown,
+  } as Record<string, unknown>,
   subscribeEvents: [] as Array<unknown>,
 }));
 
 // Mutable mock state for MCP Server
 const mockServerState = vi.hoisted(() => ({
-  clientCapabilities: undefined as { sampling?: unknown } | undefined,
-  createMessageResult: {
-    model: 'test-model',
-    role: 'assistant',
-    content: { type: 'text', text: 'User input' },
-  } as unknown,
+  clientCapabilities: undefined as { sampling?: Record<string, unknown> } | undefined,
+  createMessageResult: undefined as Record<string, unknown> | Promise<never> | undefined,
 }));
 
 // Mock the A2AClient
@@ -59,15 +58,20 @@ vi.mock('@modelcontextprotocol/sdk/server/index.js', () => ({
   Server: vi.fn().mockImplementation(() => ({
     setRequestHandler: vi
       .fn()
-      .mockImplementation((schema: unknown, handler: (req: unknown) => Promise<unknown>) => {
-        const key =
-          schema === ListToolsRequestSchema
-            ? 'listTools'
-            : schema === CallToolRequestSchema
-              ? 'callTool'
-              : 'unknown';
-        mockHandlers.set(key, handler);
-      }),
+      .mockImplementation(
+        (
+          schema: unknown,
+          handler: (req: Record<string, unknown>) => Promise<Record<string, unknown>>,
+        ) => {
+          const key =
+            schema === ListToolsRequestSchema
+              ? 'listTools'
+              : schema === CallToolRequestSchema
+                ? 'callTool'
+                : 'unknown';
+          mockHandlers.set(key, handler);
+        },
+      ),
     connect: vi.fn().mockResolvedValue(undefined),
     close: vi.fn().mockResolvedValue(undefined),
     getClientCapabilities: vi.fn().mockImplementation(() => mockServerState.clientCapabilities),
@@ -155,7 +159,9 @@ describe('A2aAsMcpServer', () => {
     await server.initialize();
     const listHandler = mockHandlers.get('listTools');
     if (!listHandler) throw new Error('Missing listTools handler');
-    const result = (await listHandler({} as never)) as { tools: Array<{ inputSchema: unknown }> };
+    const result = (await listHandler({} as never)) as {
+      tools: Array<{ inputSchema: Record<string, unknown> | undefined }>;
+    };
     expect(result.tools[0].inputSchema).toEqual({
       type: 'object',
       properties: { expression: { type: 'string' } },
@@ -170,7 +176,9 @@ describe('A2aAsMcpServer', () => {
     await server.initialize();
     const listHandler = mockHandlers.get('listTools');
     if (!listHandler) throw new Error('Missing listTools handler');
-    const result = (await listHandler({} as never)) as { tools: Array<{ inputSchema: unknown }> };
+    const result = (await listHandler({} as never)) as {
+      tools: Array<{ inputSchema: Record<string, unknown> | undefined }>;
+    };
     expect(result.tools[0].inputSchema).toEqual({
       type: 'object',
       properties: {
@@ -263,7 +271,7 @@ describe('A2aAsMcpServer', () => {
       id: 'task-1',
       status: { state: 'completed' },
       artifacts: [{ name: 'result', parts: [{ kind: 'text', text: 'Hello, User' }] }],
-    } as unknown;
+    } as Record<string, unknown>;
 
     mockServerState.clientCapabilities = { sampling: {} };
 

diff --git a/packages/mcp-bridge/src/mcp-to-a2a.test.ts b/packages/mcp-bridge/src/mcp-to-a2a.test.ts
@@ -51,7 +51,7 @@ describe('McpToolAdapter', () => {
     });
 
     // Replace the internal client with our mock
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     const card = adapter.getAgentCard();
@@ -94,7 +94,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     const card = adapter.getAgentCard();
@@ -133,7 +133,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     const artifacts = await adapter.executeTask(
@@ -182,7 +182,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await adapter.executeTask(
@@ -228,7 +228,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await adapter.executeTask(
@@ -274,7 +274,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     const artifacts = await adapter.executeTask(
@@ -317,7 +317,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await expect(
@@ -360,7 +360,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await expect(
@@ -399,7 +399,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.disconnect();
     expect(mockClient.close).toHaveBeenCalled();
   });
@@ -428,7 +428,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await expect(
@@ -466,7 +466,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await expect(
@@ -503,7 +503,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     const artifacts = await adapter.executeTask(
@@ -540,7 +540,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await adapter.executeTask(
@@ -574,7 +574,7 @@ describe('McpToolAdapter', () => {
       },
     });
 
-    (adapter as unknown as Record<string, unknown>).client = mockClient;
+    (adapter as unknown as { client: typeof mockClient }).client = mockClient;
     await adapter.initialize();
 
     await adapter.executeTask(

diff --git a/packages/observability/src/telemetry.test.ts b/packages/observability/src/telemetry.test.ts
@@ -101,7 +101,10 @@ describe('setTelemetryProvider', () => {
       startSpan() {
         return new NoopSpan();
       },
-      async startActiveSpan(_name: string, ...args: unknown[]) {
+      async startActiveSpan(
+        _name: string,
+        ...args: [Record<string, unknown> | TelemetrySpan, ...unknown[]]
+      ) {
         const fn = args.length === 2 ? args[1] : args[0];
         const result = await (fn as (span: TelemetrySpan) => Promise<unknown>)(new NoopSpan());
         return result;
@@ -147,7 +150,8 @@ describe('getTracer', () => {
   });
 
   it('passes name and version to provider', () => {
-    const spy = vi.fn<(...args: unknown[]) => ReturnType<TelemetryProvider['getTracer']>>();
+    const spy =
+      vi.fn<(...args: [string?, string?]) => ReturnType<TelemetryProvider['getTracer']>>();
     const provider: TelemetryProvider = {
       getTracer: spy,
       getMeter() {
@@ -183,14 +187,17 @@ describe('getMeter', () => {
   });
 
   it('passes name and version to provider', () => {
-    const spy = vi.fn<(...args: unknown[]) => ReturnType<TelemetryProvider['getMeter']>>();
+    const spy = vi.fn<(...args: [string?, string?]) => ReturnType<TelemetryProvider['getMeter']>>();
     const provider: TelemetryProvider = {
       getTracer() {
         return {
           startSpan() {
             return new NoopSpan();
           },
-          async startActiveSpan(_name: string, ...args: unknown[]) {
+          async startActiveSpan(
+            _name: string,
+            ...args: [Record<string, unknown> | TelemetrySpan, ...unknown[]]
+          ) {
             const fn = args.length === 2 ? args[1] : args[0];
             return (fn as (span: TelemetrySpan) => Promise<unknown>)(new NoopSpan());
           },
@@ -300,7 +307,11 @@ describe('withTaskSpan', () => {
 
   it('includes task attributes in the span options', async () => {
     const startActiveSpanSpy = vi.fn(
-      async (_name: string, _options: unknown, fn: (span: TelemetrySpan) => Promise<unknown>) => {
+      async (
+        _name: string,
+        _options: Record<string, unknown>,
+        fn: (span: TelemetrySpan) => Promise<unknown>,
+      ) => {
         return fn(new NoopSpan());
       },
     );