(env Envelope)
| 451 | } |
| 452 | |
| 453 | func validateEnvelopeReferences(env Envelope) error { |
| 454 | if err := validateOptionalIdentifierField(env.ReplyTo, "reply_to"); err != nil { |
| 455 | return err |
| 456 | } |
| 457 | if err := validateOptionalIdentifierField(env.TraceID, "trace_id"); err != nil { |
| 458 | return err |
| 459 | } |
| 460 | if err := validateOptionalIdentifierField(env.CausationID, "causation_id"); err != nil { |
| 461 | return err |
| 462 | } |
| 463 | if env.TS <= 0 { |
| 464 | return fmt.Errorf("%w: ts is required", ErrMissingField) |
| 465 | } |
| 466 | return ValidateEnvelopeConversation(env) |
| 467 | } |
| 468 | |
| 469 | func validateOptionalIdentifierField(value *string, field string) error { |
| 470 | if value != nil && *value == "" { |
no test coverage detected