(messages []NetworkEnvelopeRecord)
| 1730 | } |
| 1731 | |
| 1732 | func networkInboxBundle(messages []NetworkEnvelopeRecord) outputBundle { |
| 1733 | return listBundle( |
| 1734 | messages, |
| 1735 | messages, |
| 1736 | "Network Inbox", |
| 1737 | []string{ |
| 1738 | "ID", |
| 1739 | networkKindValue, |
| 1740 | networkChannelValue, |
| 1741 | networkFromValue, |
| 1742 | "To", |
| 1743 | "Reply To", |
| 1744 | "Trace", |
| 1745 | "Workflow", |
| 1746 | "Handoff", |
| 1747 | }, |
| 1748 | "network_inbox", |
| 1749 | []string{ |
| 1750 | "id", |
| 1751 | networkKindKey, |
| 1752 | networkChannelKey, |
| 1753 | "from", |
| 1754 | "to", |
| 1755 | "reply_to", |
| 1756 | "trace_id", |
| 1757 | "causation_id", |
| 1758 | "workflow_id", |
| 1759 | "handoff_version", |
| 1760 | mcpAuthExpiresAtKey, |
| 1761 | }, |
| 1762 | func(message NetworkEnvelopeRecord) []string { |
| 1763 | return []string{ |
| 1764 | stringOrDash(message.ID), |
| 1765 | stringOrDash(message.Kind), |
| 1766 | stringOrDash(message.Channel), |
| 1767 | stringOrDash(message.From), |
| 1768 | stringOrDash(optionalString(message.To)), |
| 1769 | stringOrDash(optionalString(message.ReplyTo)), |
| 1770 | stringOrDash(optionalString(message.TraceID)), |
| 1771 | stringOrDash(networkExtString(message.Ext, "agh.workflow_id")), |
| 1772 | stringOrDash(networkExtString(message.Ext, "agh.handoff_version")), |
| 1773 | } |
| 1774 | }, |
| 1775 | func(message NetworkEnvelopeRecord) []string { |
| 1776 | return []string{ |
| 1777 | message.ID, |
| 1778 | message.Kind, |
| 1779 | message.Channel, |
| 1780 | message.From, |
| 1781 | optionalString(message.To), |
| 1782 | optionalString(message.ReplyTo), |
| 1783 | optionalString(message.TraceID), |
| 1784 | optionalString(message.CausationID), |
| 1785 | networkExtString(message.Ext, "agh.workflow_id"), |
| 1786 | networkExtString(message.Ext, "agh.handoff_version"), |
| 1787 | formatUnixSeconds(message.ExpiresAt), |
| 1788 | } |
| 1789 | }, |
no test coverage detected