AgentEventPayloadFromEvent converts an agent event into the shared raw-stream payload.
(event acp.AgentEvent)
| 445 | |
| 446 | // AgentEventPayloadFromEvent converts an agent event into the shared raw-stream payload. |
| 447 | func AgentEventPayloadFromEvent(event acp.AgentEvent) contract.AgentEventPayload { |
| 448 | return contract.AgentEventPayload{ |
| 449 | Type: event.Type, |
| 450 | SessionID: event.SessionID, |
| 451 | TurnID: event.TurnID, |
| 452 | RequestID: event.RequestID, |
| 453 | Timestamp: event.Timestamp, |
| 454 | Text: event.Text, |
| 455 | Title: event.Title, |
| 456 | ToolCallID: event.ToolCallID, |
| 457 | StopReason: event.StopReason, |
| 458 | Action: event.Action, |
| 459 | Resource: event.Resource, |
| 460 | Decision: event.Decision, |
| 461 | Error: event.Error, |
| 462 | Failure: SessionFailurePayloadFromStore(event.Failure), |
| 463 | Usage: TokenUsagePayloadFromUsage(event.Usage), |
| 464 | Runtime: runtimeActivityPayloadFromEvent(event.Runtime), |
| 465 | Raw: payloadJSONBytes(event.Raw), |
| 466 | } |
| 467 | } |
| 468 | |
| 469 | // TokenUsagePayloadFromUsage converts token usage info into the shared payload. |
| 470 | func TokenUsagePayloadFromUsage(usage *acp.TokenUsage) *contract.TokenUsagePayload { |