fix: add more debug logging to TS e2e tests, disable streaming

Author: clareliguori

e2e_tests/typescript/src/chat_session.ts

@@ -27,7 +27,17 @@ export class ChatSession {
           logger.info(`Agent invocation completed in ${duration}ms`);
         } catch (error) {
           const duration = Date.now() - startTime;
-          logger.error(`Agent invocation failed after ${duration}ms:`, error);
+          logger.error(`Agent invocation failed after ${duration}ms: ${error}`);
+          if (error instanceof Error) {
+            logger.error(`Error name: ${error.name}`);
+            logger.error(`Error message: ${error.message}`);
+            if (error.stack) {
+              logger.error(`Error stack: ${error.stack}`);
+            }
+            if ('cause' in error && error.cause) {
+              logger.error(`Error cause: ${JSON.stringify(error.cause, null, 2)}`);
+            }
+          }
           throw error;
         }
       }

e2e_tests/typescript/src/main.ts

@@ -61,11 +61,15 @@ async function main(): Promise<void> {
   logger.info(`Loaded ${userUtterances.length} test questions`);
 
   logger.info("Initializing Bedrock model...");
+  const region = typeof config.bedrockClient.config.region === 'function'
+    ? await config.bedrockClient.config.region()
+    : config.bedrockClient.config.region;
   const model = new BedrockModel({
-    region: config.bedrockClient.config.region as string,
+    region: region as string,
     modelId: config.modelId,
+    stream: false,
   });
-  logger.info(`Using model: ${config.modelId} in region: ${config.bedrockClient.config.region}`);
+  logger.info(`Using model: ${config.modelId} in region: ${region} (streaming disabled)`);
 
   logger.info("Creating agent...");
   const agent = new Agent({
@@ -89,8 +93,15 @@ process.on("unhandledRejection", (reason, promise) => {
 
 main().catch((error) => {
   logger.error("Error in main:", error);
-  if (error.stack) {
-    logger.error("Stack trace:", error.stack);
+  if (error instanceof Error) {
+    logger.error(`Error type: ${error.constructor.name}`);
+    logger.error(`Error message: ${error.message}`);
+    if (error.stack) {
+      logger.error("Stack trace:", error.stack);
+    }
+    if ('cause' in error && error.cause) {
+      logger.error("Error cause:", JSON.stringify(error.cause, null, 2));
+    }
   }
   process.exit(1);
 });

e2e_tests/typescript/src/mcp_clients.ts

@@ -24,7 +24,7 @@ export async function createStdioClient(name: string, config: any): Promise<McpC
     args: config.args,
     env: config.env ? { ...process.env, ...config.env } : undefined,
   });
-  return new McpClient({ transport });
+  return new McpClient({ transport, applicationName: name });
 }
 
 export async function createLambdaFunctionClient(name: string, config: any): Promise<McpClient> {
@@ -34,7 +34,7 @@ export async function createLambdaFunctionClient(name: string, config: any): Pro
     functionName: config.functionName,
     regionName: config.region,
   });
-  return new McpClient({ transport });
+  return new McpClient({ transport, applicationName: name });
 }
 
 export async function createLambdaFunctionUrlClient(name: string, config: any): Promise<McpClient> {
@@ -54,7 +54,7 @@ export async function createLambdaFunctionUrlClient(name: string, config: any):
 
   logger.debug(`Lambda function URL: ${functionUrl}, region: ${region}`);
   const transport = new StreamableHTTPClientWithSigV4Transport(new URL(functionUrl), { region, service: "lambda" });
-  return new McpClient({ transport });
+  return new McpClient({ transport, applicationName: name });
 }
 
 export async function createAutomatedOAuthClient(name: string, config: any): Promise<McpClient> {
@@ -86,7 +86,7 @@ export async function createAutomatedOAuthClient(name: string, config: any): Pro
   logger.debug(`Creating OAuth transport for ${name}...`);
   const transport = await createAutomatedOAuthTransport(serverUrl, clientId, clientSecret);
 
-  return new McpClient({ transport });
+  return new McpClient({ transport, applicationName: name });
 }
 
 async function getCloudFormationOutput(stackName: string, outputKey: string, region: string): Promise<string> {

examples/chatbots/typescript/src/main.ts

@@ -44,6 +44,7 @@ async function main(): Promise<void> {
   const model = new BedrockModel({
     region: config.bedrockClient.config.region as string,
     modelId: config.modelId,
+    stream: false,
   });
 
   const agent = new Agent({