@@ -427,11 +427,11 @@ func (p *AICodeOtelProcessor) parseLogRecord(lr *logsv1.LogRecord, resourceAttrs
427427 event .CostUSD = getFloatFromValue (value )
428428 case "duration_ms" :
429429 event .DurationMs = getIntFromValue (value )
430- case "input_tokens" :
430+ case "input_tokens" , "input_token_count" :
431431 event .InputTokens = getIntFromValue (value )
432- case "output_tokens" :
432+ case "output_tokens" , "output_token_count" :
433433 event .OutputTokens = getIntFromValue (value )
434- case "cache_read_tokens" :
434+ case "cache_read_tokens" , "cache_token_count" , "cached_token_count" , "cachedTokenCount" :
435435 event .CacheReadTokens = getIntFromValue (value )
436436 case "cache_creation_tokens" :
437437 event .CacheCreationTokens = getIntFromValue (value )
@@ -468,17 +468,17 @@ func (p *AICodeOtelProcessor) parseLogRecord(lr *logsv1.LogRecord, resourceAttrs
468468 case "language" :
469469 event .Language = value .GetStringValue ()
470470 // Codex-specific fields
471- case "reasoning_tokens" :
471+ case "reasoning_tokens" , "reasoning_token_count" , "reasoningTokenCount" :
472472 event .ReasoningTokens = getIntFromValue (value )
473- case "provider" :
473+ case "provider" , "provider_name" , "providerName" :
474474 event .Provider = value .GetStringValue ()
475475 // Codex-specific fields for tool_decision
476476 case "call_id" , "callId" :
477477 event .CallID = value .GetStringValue ()
478478 // Codex-specific fields for sse_event
479479 case "event_kind" , "eventKind" :
480480 event .EventKind = value .GetStringValue ()
481- case "tool_tokens" , "toolTokens" :
481+ case "tool_tokens" , "toolTokens" , "tool_token_count" , "toolTokenCount" :
482482 event .ToolTokens = getIntFromValue (value )
483483 // Codex-specific fields for conversation_starts
484484 case "auth_mode" , "authMode" :
@@ -493,12 +493,20 @@ func (p *AICodeOtelProcessor) parseLogRecord(lr *logsv1.LogRecord, resourceAttrs
493493 event .SandboxPolicy = value .GetStringValue ()
494494 case "mcp_servers" , "mcpServers" :
495495 event .MCPServers = getStringArrayFromValue (value )
496- case "profile" :
496+ case "profile" , "active_profile" , "activeProfile" :
497497 event .Profile = value .GetStringValue ()
498498 case "reasoning_enabled" , "reasoningEnabled" :
499499 event .ReasoningEnabled = getBoolFromValue (value )
500+ case "reasoning_effort" , "reasoningEffort" :
501+ event .ReasoningEffort = value .GetStringValue ()
502+ case "reasoning_summary" , "reasoningSummary" :
503+ event .ReasoningSummary = value .GetStringValue ()
504+ case "max_output_tokens" , "maxOutputTokens" :
505+ event .MaxOutputTokens = getIntFromValue (value )
506+ case "auto_compact_token_limit" , "autoCompactTokenLimit" :
507+ event .AutoCompactTokenLimit = getIntFromValue (value )
500508 // Codex-specific fields for tool_result
501- case "tool_arguments" , "toolArguments" :
509+ case "tool_arguments" , "toolArguments" , "arguments" :
502510 if jsonStr := value .GetStringValue (); jsonStr != "" {
503511 var args map [string ]interface {}
504512 if err := json .Unmarshal ([]byte (jsonStr ), & args ); err == nil {
@@ -537,6 +545,10 @@ func (p *AICodeOtelProcessor) parseLogRecord(lr *logsv1.LogRecord, resourceAttrs
537545 return nil
538546 }
539547
548+ if event .SessionID == "" && event .ConversationID != "" {
549+ event .SessionID = event .ConversationID
550+ }
551+
540552 return event
541553}
542554
0 commit comments