feat: add protocol logging UI controls and endpoint

- Add protocol logging checkbox to testing UI
- Add /api/sales/agents/:agentId/query endpoint with protocol logging support
- Export ProtocolLoggingConfig type from library
- Wire-level HTTP logs now display in debug panel when enabled

Author: EmmaLouise2018

src/lib/index.ts

@@ -157,6 +157,10 @@ export type {
 // Re-export all Zod schemas for user validation needs
 export * from './types/schemas.generated';
 
+// ====== PROTOCOL LOGGING ======
+// Protocol logging configuration
+export type { ProtocolLoggingConfig } from './protocols/mcp';
+
 // ====== AUTHENTICATION ======
 // Auth utilities for custom integrations
 export { getAuthToken, createAdCPHeaders, createMCPAuthHeaders, createAuthenticatedFetch } from './auth';

src/public/index.html

@@ -2249,6 +2249,12 @@ <h1>Ad Context Protocol Testing Framework</h1>
               📋 View All
             </button>
           </div>
+          <div style="display: flex; align-items: center; gap: 5px; padding: 8px 12px; background: rgba(255,255,255,0.1); border-radius: 6px">
+            <input type="checkbox" id="enable-protocol-logging" style="width: auto; margin: 0" />
+            <label for="enable-protocol-logging" style="margin: 0; cursor: pointer; font-size: 13px" title="Enable detailed wire-level HTTP request/response logging">
+              🔍 Protocol Logging
+            </label>
+          </div>
         </div>
       </div>
 
@@ -8362,6 +8368,23 @@ <h4>📥 Response</h4>
         }
       }
 
+      // Helper function to get protocol logging config from UI
+      function getProtocolLoggingConfig() {
+        const enabled = document.getElementById('enable-protocol-logging').checked;
+        if (!enabled) {
+          return null;
+        }
+        return {
+          enabled: true,
+          logRequests: true,
+          logResponses: true,
+          logRequestBodies: true,
+          logResponseBodies: true,
+          maxBodySize: 50000,
+          redactAuthHeaders: true,
+        };
+      }
+
       async function executeMCPTool(agent, toolName, params) {
         logEvent('info', `Executing MCP tool ${toolName} with agent: ${agent.name} (ID: ${agent.id})`);
         return await executeMCPToolBackend(agent, toolName, params);
@@ -8406,6 +8429,7 @@ <h4>📥 Response</h4>
             brandStory: params.brief || 'Test execution from ADCP Testing Suite',
             offering: null,
             agentConfig: agent,
+            protocolLogging: getProtocolLoggingConfig(),
           }),
         });
 
@@ -8486,6 +8510,7 @@ <h4>📥 Response</h4>
             brandStory: params.brief || 'Test execution from ADCP Testing Suite',
             offering: null,
             agentConfig: agent,
+            protocolLogging: getProtocolLoggingConfig(),
           }),
         });
 

src/server/server.ts

@@ -19,6 +19,7 @@ import {
   type SyncCreativesResponse,
   type CreateMediaBuyResponse,
   type MediaBuyDeliveryNotification,
+  type ProtocolLoggingConfig,
   ADCP_STATUS,
   InputRequiredError,
 } from '../lib';
@@ -127,6 +128,18 @@ const clientConfig: SingleAgentClientConfig = {
     logSchemaViolations: process.env.ADCP_LOG_SCHEMA_VIOLATIONS !== 'false', // Default: true
   },
 
+  // Protocol logging configuration - wire-level HTTP request/response logging
+  // Can be enabled via env var or dynamically per request
+  protocolLogging: {
+    enabled: process.env.ADCP_PROTOCOL_LOGGING === 'true', // Default: false
+    logRequests: true,
+    logResponses: true,
+    logRequestBodies: true,
+    logResponseBodies: true,
+    maxBodySize: 50000,
+    redactAuthHeaders: true,
+  },
+
   // Activity logging - store ALL events
   onActivity: (activity: Activity) => {
     storeEvent({
@@ -660,6 +673,89 @@ app.get('/api/sales/agents/:agentId/info', async (request, reply) => {
   }
 });
 
+// Query agent endpoint - supports protocol logging
+app.post<{
+  Params: { agentId: string };
+  Body: {
+    brandStory?: string;
+    offering?: string | null;
+    agentConfig?: AgentConfig;
+    protocolLogging?: ProtocolLoggingConfig | null;
+  };
+}>('/api/sales/agents/:agentId/query', async (request, reply) => {
+  const { agentId } = request.params;
+  const { brandStory, offering, agentConfig, protocolLogging } = request.body;
+
+  try {
+    // Create a temporary client if custom config is provided, or use the existing client with protocol logging
+    let agent;
+    let tempClient: ADCPMultiAgentClient | null = null;
+
+    if (agentConfig) {
+      // Custom agent configuration provided
+      const customAgentConfig: AgentConfig = {
+        id: agentConfig.id || agentId,
+        name: agentConfig.name || agentId,
+        agent_uri: agentConfig.agent_uri || (agentConfig as any).server_url,
+        protocol: agentConfig.protocol || 'mcp',
+        auth_token_env: agentConfig.auth_token_env,
+        requiresAuth: agentConfig.requiresAuth !== false,
+      };
+
+      // Merge protocol logging config if provided
+      const tempClientConfig: SingleAgentClientConfig = {
+        ...clientConfig,
+        ...(protocolLogging && { protocolLogging }),
+      };
+
+      tempClient = new ADCPMultiAgentClient([customAgentConfig], tempClientConfig);
+      agent = tempClient.agent(customAgentConfig.id);
+    } else {
+      // Use existing client - if protocol logging is provided, create new client with that config
+      if (protocolLogging) {
+        const agentConfigs = adcpClient.getAgentConfigs();
+        const tempClientConfig: SingleAgentClientConfig = {
+          ...clientConfig,
+          protocolLogging,
+        };
+        tempClient = new ADCPMultiAgentClient(agentConfigs, tempClientConfig);
+        agent = tempClient.agent(agentId);
+      } else {
+        agent = adcpClient.agent(agentId);
+      }
+    }
+
+    if (!agent) {
+      return reply.code(404).send({
+        success: false,
+        error: `Agent ${agentId} not found`,
+        timestamp: new Date().toISOString(),
+      });
+    }
+
+    // Call get_products by default (this is what the testing UI expects)
+    const result = await agent.getProducts({
+      brand_manifest: { name: brandStory || offering || 'Test brand' },
+      ...(brandStory && { brief: brandStory }),
+    });
+
+    return reply.send({
+      success: result.success,
+      data: result.data,
+      error: result.error,
+      debugLogs: result.debug_logs || [],
+      timestamp: new Date().toISOString(),
+    });
+  } catch (error) {
+    app.log.error(`Failed to query agent ${agentId}: ${error instanceof Error ? error.message : String(error)}`);
+    return reply.code(500).send({
+      success: false,
+      error: error instanceof Error ? error.message : 'Failed to query agent',
+      timestamp: new Date().toISOString(),
+    });
+  }
+});
+
 // Helper function to extract data from nested A2A/MCP responses
 function extractResponseData(result: any): any {
   // Check multiple possible nested structures