remove lowercasing for MCP transport name

Author: betegon

packages/core/src/integrations/mcp-server/attributeExtraction.ts

@@ -48,13 +48,13 @@ export function getTransportTypes(transport: MCPTransport): { mcpTransport: stri
   if (!transport?.constructor) {
     return { mcpTransport: 'unknown', networkTransport: 'unknown' };
   }
-  const transportName =
-    typeof transport.constructor?.name === 'string' ? transport.constructor.name.toLowerCase() : 'unknown';
+  const transportName = typeof transport.constructor?.name === 'string' ? transport.constructor.name : 'unknown';
   let networkTransport = 'unknown';
 
-  if (transportName.includes('stdio')) {
+  const lowerTransportName = transportName.toLowerCase();
+  if (lowerTransportName.includes('stdio')) {
     networkTransport = 'pipe';
-  } else if (transportName.includes('http') || transportName.includes('sse')) {
+  } else if (lowerTransportName.includes('http') || lowerTransportName.includes('sse')) {
     networkTransport = 'tcp';
   }
 

packages/core/test/lib/integrations/mcp-server/semanticConventions.test.ts

@@ -61,7 +61,7 @@ describe('MCP Server Semantic Conventions', () => {
           'mcp.session.id': 'test-session-123',
           'client.address': '192.168.1.100',
           'client.port': 54321,
-          'mcp.transport': 'streamablehttpservertransport',
+          'mcp.transport': 'StreamableHTTPServerTransport',
           'network.transport': 'tcp',
           'network.protocol.version': '2.0',
           'mcp.request.argument.location': '"Seattle, WA"',
@@ -93,7 +93,7 @@ describe('MCP Server Semantic Conventions', () => {
           'mcp.resource.uri': 'file:///docs/api.md',
           'mcp.request.id': 'req-2',
           'mcp.session.id': 'test-session-123',
-          'mcp.transport': 'streamablehttpservertransport',
+          'mcp.transport': 'StreamableHTTPServerTransport',
           'network.transport': 'tcp',
           'network.protocol.version': '2.0',
           'mcp.request.argument.uri': '"file:///docs/api.md"',
@@ -125,7 +125,7 @@ describe('MCP Server Semantic Conventions', () => {
           'mcp.prompt.name': 'analyze-code',
           'mcp.request.id': 'req-3',
           'mcp.session.id': 'test-session-123',
-          'mcp.transport': 'streamablehttpservertransport',
+          'mcp.transport': 'StreamableHTTPServerTransport',
           'network.transport': 'tcp',
           'network.protocol.version': '2.0',
           'mcp.request.argument.name': '"analyze-code"',
@@ -154,7 +154,7 @@ describe('MCP Server Semantic Conventions', () => {
           attributes: {
             'mcp.method.name': 'notifications/tools/list_changed',
             'mcp.session.id': 'test-session-123',
-            'mcp.transport': 'streamablehttpservertransport',
+            'mcp.transport': 'StreamableHTTPServerTransport',
             'network.transport': 'tcp',
             'network.protocol.version': '2.0',
             'sentry.op': 'mcp.notification.client_to_server',
@@ -193,7 +193,7 @@ describe('MCP Server Semantic Conventions', () => {
             'mcp.request.id': 'req-4',
             'mcp.session.id': 'test-session-123',
             // Transport attributes
-            'mcp.transport': 'streamablehttpservertransport',
+            'mcp.transport': 'StreamableHTTPServerTransport',
             'network.transport': 'tcp',
             'network.protocol.version': '2.0',
             // Sentry-specific
@@ -227,7 +227,7 @@ describe('MCP Server Semantic Conventions', () => {
           attributes: {
             'mcp.method.name': 'notifications/message',
             'mcp.session.id': 'test-session-123',
-            'mcp.transport': 'streamablehttpservertransport',
+            'mcp.transport': 'StreamableHTTPServerTransport',
             'network.transport': 'tcp',
             'network.protocol.version': '2.0',
             'mcp.logging.level': 'info',

packages/core/test/lib/integrations/mcp-server/transportInstrumentation.test.ts

@@ -216,7 +216,7 @@ describe('MCP Server Transport Instrumentation', () => {
           'mcp.tool.name': 'process-file',
           'mcp.request.id': 'req-stdio-1',
           'mcp.session.id': 'stdio-session-456',
-          'mcp.transport': 'stdioservertransport',
+          'mcp.transport': 'StdioServerTransport',
           'network.transport': 'pipe', // Should be pipe, not tcp
           'network.protocol.version': '2.0',
           'mcp.request.argument.path': '"/tmp/data.txt"',
@@ -247,7 +247,7 @@ describe('MCP Server Transport Instrumentation', () => {
           attributes: expect.objectContaining({
             'mcp.method.name': 'notifications/message',
             'mcp.session.id': 'stdio-session-456',
-            'mcp.transport': 'stdioservertransport',
+            'mcp.transport': 'StdioServerTransport',
             'network.transport': 'pipe',
             'mcp.logging.level': 'debug',
             'mcp.logging.message': 'Processing stdin input',
@@ -288,7 +288,7 @@ describe('MCP Server Transport Instrumentation', () => {
           attributes: expect.objectContaining({
             'mcp.method.name': 'resources/read',
             'mcp.resource.uri': 'https://api.example.com/data',
-            'mcp.transport': 'sseservertransport',
+            'mcp.transport': 'SSEServerTransport',
             'network.transport': 'tcp',
             'mcp.session.id': 'sse-session-789',
           }),
@@ -363,7 +363,7 @@ describe('MCP Server Transport Instrumentation', () => {
           'mcp.session.id': 'test-session-direct',
           'client.address': '127.0.0.1',
           'client.port': 8080,
-          'mcp.transport': 'streamablehttpservertransport',
+          'mcp.transport': 'StreamableHTTPServerTransport',
           'network.transport': 'tcp',
           'network.protocol.version': '2.0',
           'mcp.request.argument.input': '"test"',
@@ -508,23 +508,23 @@ describe('MCP Server Transport Instrumentation', () => {
       const transport = createMockTransport();
       const result = getTransportTypes(transport);
 
-      expect(result.mcpTransport).toBe('streamablehttpservertransport');
+      expect(result.mcpTransport).toBe('StreamableHTTPServerTransport');
       expect(result.networkTransport).toBe('tcp');
     });
 
     it('extracts stdio transport and maps to pipe network', () => {
       const transport = createMockStdioTransport();
       const result = getTransportTypes(transport);
 
-      expect(result.mcpTransport).toBe('stdioservertransport');
+      expect(result.mcpTransport).toBe('StdioServerTransport');
       expect(result.networkTransport).toBe('pipe');
     });
 
     it('extracts SSE transport name', () => {
       const transport = createMockSseTransport();
       const result = getTransportTypes(transport);
 
-      expect(result.mcpTransport).toBe('sseservertransport');
+      expect(result.mcpTransport).toBe('SSEServerTransport');
       expect(result.networkTransport).toBe('tcp');
     });
 
@@ -556,7 +556,7 @@ describe('MCP Server Transport Instrumentation', () => {
       };
       const result = getTransportTypes(transport);
 
-      expect(result.mcpTransport).toBe('customtransport');
+      expect(result.mcpTransport).toBe('CustomTransport');
       expect(result.networkTransport).toBe('unknown');
     });
   });