(ingress TaskIngressContext)
| 527 | } |
| 528 | |
| 529 | func networkRunMetadataValues(ingress TaskIngressContext) (map[string]string, error) { |
| 530 | workID := strings.TrimSpace(ingress.WorkID) |
| 531 | if workID == "" { |
| 532 | return nil, fmt.Errorf("%w: network work_id is required", ErrMissingField) |
| 533 | } |
| 534 | values := map[string]string{ |
| 535 | "network_workspace_id": strings.TrimSpace(ingress.WorkspaceID), |
| 536 | "network_work_id": workID, |
| 537 | "network_message_id": strings.TrimSpace(ingress.RequestID), |
| 538 | tasksNetworkChannelKey: strings.TrimSpace(ingress.Channel), |
| 539 | "network_surface": strings.TrimSpace(string(ingress.Surface)), |
| 540 | "network_reply_to": strings.TrimSpace(ingress.ReplyTo), |
| 541 | "network_trace_id": strings.TrimSpace(ingress.TraceID), |
| 542 | "network_causation_id": strings.TrimSpace(ingress.CausationID), |
| 543 | } |
| 544 | switch ingress.Surface { |
| 545 | case SurfaceThread: |
| 546 | values["network_thread_id"] = strings.TrimSpace(ingress.ThreadID) |
| 547 | case SurfaceDirect: |
| 548 | values["network_direct_id"] = strings.TrimSpace(ingress.DirectID) |
| 549 | } |
| 550 | return values, nil |
| 551 | } |
| 552 | |
| 553 | func mergeTrustedNetworkMetadata(raw json.RawMessage, values map[string]string) (json.RawMessage, error) { |
| 554 | metadata := make(map[string]any) |
no outgoing calls
no test coverage detected