fix(client): accept boolean for debugLogger in pipeline functions

Pipeline functions (verifyEvents, transformChunks, parseSSEStream, etc.)
only accepted `DebugLogger | false | null`, rejecting `true`. Added
`DebugLoggerInput` type and `resolveDebugLogger()` helper so passing
`true` auto-creates a DebugLogger with all logging enabled.

Author: AlemTuzlak

sdks/typescript/packages/client/src/__tests__/debug-logger.test.ts

@@ -1,5 +1,5 @@
 import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
-import { DebugLogger, createDebugLogger } from "@/debug-logger";
+import { DebugLogger, createDebugLogger, resolveDebugLogger } from "@/debug-logger";
 import { resolveAgentDebugConfig, ResolvedAgentDebugConfig } from "@/agent/types";
 
 describe("resolveAgentDebugConfig", () => {
@@ -148,6 +148,40 @@ describe("createDebugLogger", () => {
   });
 });
 
+describe("resolveDebugLogger", () => {
+  it("returns undefined for undefined", () => {
+    expect(resolveDebugLogger(undefined)).toBeUndefined();
+  });
+
+  it("returns undefined for null", () => {
+    expect(resolveDebugLogger(null)).toBeUndefined();
+  });
+
+  it("returns undefined for false", () => {
+    expect(resolveDebugLogger(false)).toBeUndefined();
+  });
+
+  it("returns a DebugLogger instance for true", () => {
+    const logger = resolveDebugLogger(true);
+    expect(logger).toBeInstanceOf(DebugLogger);
+    expect(logger!.enabled).toBe(true);
+    expect(logger!.eventsEnabled).toBe(true);
+    expect(logger!.lifecycleEnabled).toBe(true);
+  });
+
+  it("returns the same DebugLogger instance when given one", () => {
+    const config: ResolvedAgentDebugConfig = {
+      enabled: true,
+      events: true,
+      lifecycle: false,
+      verbose: false,
+    };
+    const original = new DebugLogger(config);
+    const resolved = resolveDebugLogger(original);
+    expect(resolved).toBe(original);
+  });
+});
+
 describe("DebugLogger.event()", () => {
   let debugSpy: ReturnType<typeof vi.spyOn>;
 

sdks/typescript/packages/client/src/agent/index.ts

@@ -10,4 +10,5 @@ export type {
 } from "./types";
 export { resolveAgentDebugConfig } from "./types";
 export type { AgentSubscriber, AgentStateMutation, AgentSubscriberParams } from "./subscriber";
-export { DebugLogger, createDebugLogger } from "../debug-logger";
+export { DebugLogger, createDebugLogger, resolveDebugLogger } from "../debug-logger";
+export type { DebugLoggerInput } from "../debug-logger";

sdks/typescript/packages/client/src/apply/default.ts

@@ -48,16 +48,16 @@ import type { Observable } from "rxjs";
 import { concatMap, defaultIfEmpty, mergeAll, mergeMap } from "rxjs/operators";
 import untruncateJson from "untruncate-json";
 import { structuredClone_ } from "../utils";
-import type { DebugLogger } from "@/debug-logger";
+import { type DebugLoggerInput, resolveDebugLogger } from "@/debug-logger";
 
 export const defaultApplyEvents = (
   input: RunAgentInput,
   events$: Observable<BaseEvent>,
   agent: AbstractAgent,
   subscribers: AgentSubscriber[],
-  debugLogger?: DebugLogger | false | null,
+  debugLogger?: DebugLoggerInput,
 ): Observable<AgentStateMutation> => {
-  const log = debugLogger || undefined;
+  const log = resolveDebugLogger(debugLogger);
   let messages = structuredClone_(agent.messages);
   let state = structuredClone_(input.state);
   let currentMutation: AgentStateMutation = {};

sdks/typescript/packages/client/src/chunks/transform.ts

@@ -15,7 +15,7 @@ import {
   ReasoningMessageStartEvent,
 } from "@ag-ui/core";
 import { EventType } from "@ag-ui/core";
-import { DebugLogger } from "@/debug-logger";
+import { type DebugLoggerInput, resolveDebugLogger } from "@/debug-logger";
 
 interface TextMessageFields {
   messageId: string;
@@ -33,9 +33,9 @@ interface ReasoningMessageFields {
 }
 
 export const transformChunks =
-  (debugLogger?: DebugLogger | false | null) =>
+  (debugLogger?: DebugLoggerInput) =>
   (events$: Observable<BaseEvent>): Observable<BaseEvent> => {
-    const log = debugLogger || undefined;
+    const log = resolveDebugLogger(debugLogger);
     let textMessageFields: TextMessageFields | undefined;
     let toolCallFields: ToolCallFields | undefined;
     let reasoningMessageFields: ReasoningMessageFields | undefined;

sdks/typescript/packages/client/src/debug-logger.ts

@@ -1,4 +1,19 @@
-import { ResolvedAgentDebugConfig } from "@/agent/types";
+import { ResolvedAgentDebugConfig, resolveAgentDebugConfig } from "@/agent/types";
+
+/** Accepted input wherever a debug logger can be provided. */
+export type DebugLoggerInput = DebugLogger | boolean | null | undefined;
+
+/**
+ * Resolves a DebugLoggerInput into a DebugLogger or undefined.
+ * - `true` → creates a new DebugLogger with all logging enabled
+ * - `DebugLogger` instance → returned as-is
+ * - `false`, `null`, `undefined` → returns undefined
+ */
+export function resolveDebugLogger(input: DebugLoggerInput): DebugLogger | undefined {
+  if (input instanceof DebugLogger) return input;
+  if (input === true) return new DebugLogger(resolveAgentDebugConfig(true));
+  return undefined;
+}
 
 /**
  * Centralized debug logger for the AG-UI event pipeline.

sdks/typescript/packages/client/src/transform/http.ts

@@ -5,16 +5,16 @@ import { parseSSEStream } from "./sse";
 import { parseProtoStream } from "./proto";
 import * as proto from "@ag-ui/proto";
 import { EventType } from "@ag-ui/core";
-import { DebugLogger } from "@/debug-logger";
+import { type DebugLoggerInput, resolveDebugLogger } from "@/debug-logger";
 
 /**
  * Transforms HTTP events into BaseEvents using the appropriate format parser based on content type.
  */
 export const transformHttpEventStream = (
   source$: Observable<HttpEvent>,
-  debugLogger?: DebugLogger | false | null,
+  debugLogger?: DebugLoggerInput,
 ): Observable<BaseEvent> => {
-  const log = debugLogger || undefined;
+  const log = resolveDebugLogger(debugLogger);
   const eventSubject = new Subject<BaseEvent>();
 
   // Use ReplaySubject to buffer events until we decide on the parser

sdks/typescript/packages/client/src/transform/sse.ts

@@ -1,6 +1,6 @@
 import { Observable, Subject } from "rxjs";
 import { HttpEvent, HttpEventType } from "../run/http-request";
-import { DebugLogger } from "@/debug-logger";
+import { type DebugLoggerInput, resolveDebugLogger } from "@/debug-logger";
 
 /**
  * Parses a stream of HTTP events into a stream of JSON objects using Server-Sent Events (SSE) format.
@@ -12,9 +12,9 @@ import { DebugLogger } from "@/debug-logger";
  */
 export const parseSSEStream = (
   source$: Observable<HttpEvent>,
-  debugLogger?: DebugLogger | false | null,
+  debugLogger?: DebugLoggerInput,
 ): Observable<any> => {
-  const log = debugLogger || undefined;
+  const log = resolveDebugLogger(debugLogger);
   const jsonSubject = new Subject<any>();
   // Create TextDecoder with stream option set to true to handle split UTF-8 characters
   const decoder = new TextDecoder("utf-8", { fatal: false });

sdks/typescript/packages/client/src/verify/verify.ts

@@ -1,12 +1,12 @@
 import { BaseEvent, EventType, AGUIError } from "@ag-ui/core";
 import { Observable, throwError, of } from "rxjs";
 import { mergeMap } from "rxjs/operators";
-import { DebugLogger } from "@/debug-logger";
+import { type DebugLoggerInput, resolveDebugLogger } from "@/debug-logger";
 
 export const verifyEvents =
-  (debugLogger?: DebugLogger | false | null) =>
+  (debugLogger?: DebugLoggerInput) =>
   (source$: Observable<BaseEvent>): Observable<BaseEvent> => {
-    const log = debugLogger || undefined;
+    const log = resolveDebugLogger(debugLogger);
     // Declare variables in closure to maintain state across events
     let activeMessages = new Map<string, boolean>(); // Map of message ID -> active status
     let activeToolCalls = new Map<string, boolean>(); // Map of tool call ID -> active status