Function envelopeFromNetworkMessage

internal/api/core/agent_channels.go:803–830

(entry store.NetworkMessageEntry)

}

func envelopeFromNetworkMessage(entry store.NetworkMessageEntry) (network.Envelope, error) {
	envelope := network.Envelope{
		Protocol:    network.ProtocolV0,
		ID:          strings.TrimSpace(entry.MessageID),
		Kind:        network.Kind(strings.TrimSpace(entry.Kind)),
		WorkspaceID: strings.TrimSpace(entry.WorkspaceID),
		Channel:     strings.TrimSpace(entry.Channel),
		From:        strings.TrimSpace(entry.PeerFrom),
		Mentions:    cloneTrimmedStrings(entry.Mentions),
		WorkID:      optionalStringPtr(entry.WorkID),
		ReplyTo:     optionalStringPtr(entry.ReplyTo),
		TraceID:     optionalStringPtr(entry.TraceID),
		CausationID: optionalStringPtr(entry.CausationID),
		TS:          entry.Timestamp.Unix(),
		Body:        cloneRawMessage(entry.Body),
	}
	ext, err := extensionMapFromNetworkMessage(entry)
	if err != nil {
		return network.Envelope{}, err
	}
	if len(ext) > 0 {
		envelope.Ext = ext
	}
	if to := strings.TrimSpace(entry.PeerTo); to != "" {
		envelope.To = &to
	}
	return envelope, nil
}

func extensionMapFromNetworkMessage(entry store.NetworkMessageEntry) (network.ExtensionMap, error) {
	trimmed := strings.TrimSpace(string(entry.ExtJSON))