Method Validate

internal/store/types.go:1422–1472

Validate ensures the persisted network message is complete and internally consistent.

()

// Validate ensures the persisted network message is complete and internally consistent.
func (e NetworkConversationMessage) Validate() error {
	if err := requireField(e.MessageID, "network message id"); err != nil {
		return err
	}
	if err := (NetworkChannelRef{WorkspaceID: e.WorkspaceID, Channel: e.Channel}).Validate(); err != nil {
		return err
	}
	if err := requireField(e.Direction, "network message direction"); err != nil {
		return err
	}
	direction := strings.TrimSpace(e.Direction)
	if direction != e.Direction {
		return fmt.Errorf("store: unsupported network message direction %q", e.Direction)
	}
	switch direction {
	case typesSentKey, "received":
	default:
		return fmt.Errorf("store: unsupported network message direction %q", e.Direction)
	}
	if err := requireField(e.PeerFrom, "network message peer_from"); err != nil {
		return err
	}
	if err := requireField(e.Kind, "network message kind"); err != nil {
		return err
	}
	if err := validateNetworkMessageKind(e.Kind); err != nil {
		return err
	}
	if err := e.validateConversationFields(); err != nil {
		return err
	}
	if _, err := NormalizeNetworkPeerIDs(e.Mentions, "network message mentions"); err != nil {
		return err
	}
	if len(e.Body) == 0 {
		return fmt.Errorf("store: network message body is required")
	}
	if !json.Valid(e.Body) {
		return fmt.Errorf("store: network message body must be valid JSON")
	}
	if networkRawJSONContainsClaimToken(e.Body) {
		return fmt.Errorf("store: network message body contains raw claim_token material")
	}
	if err := validateNetworkMessageExtJSON(e.ExtJSON); err != nil {
		return err
	}
	if networkConversationMessageContainsRawClaimToken(e) {
		return fmt.Errorf("store: network message entry contains raw claim_token material")
	}
	return nil
}

func validateNetworkMessageExtJSON(raw json.RawMessage) error {
	trimmed := strings.TrimSpace(string(raw))