MCPcopy Create free account
hub / github.com/compozy/agh / networkUnmute

Method networkUnmute

internal/daemon/native_tools.go:1858–1888  ·  view source on GitHub ↗
(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
)

Source from the content-addressed store, hash-verified

1856}
1857
1858func (n *daemonNativeTools) networkUnmute(
1859 ctx context.Context,
1860 scope toolspkg.Scope,
1861 req toolspkg.CallRequest,
1862) (toolspkg.ToolResult, error) {
1863 var input networkSubscriptionDeleteInput
1864 if err := decodeNativeInput(req, &input); err != nil {
1865 return toolspkg.ToolResult{}, err
1866 }
1867 channel, err := nativeNetworkChannel(req.ToolID, input.Channel)
1868 if err != nil {
1869 return toolspkg.ToolResult{}, err
1870 }
1871 workspaceID, err := n.nativeNetworkWorkspaceID(ctx, req.ToolID, input.WorkspaceID, scope)
1872 if err != nil {
1873 return toolspkg.ToolResult{}, err
1874 }
1875 ref := store.NetworkSubscriptionRef{
1876 WorkspaceID: workspaceID,
1877 Channel: channel,
1878 ThreadID: strings.TrimSpace(input.ThreadID),
1879 PeerID: strings.TrimSpace(input.PeerID),
1880 }
1881 if err := ref.Validate(); err != nil {
1882 return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
1883 }
1884 if err := n.deps.NetworkStore.DeleteNetworkSubscription(ctx, ref); err != nil {
1885 return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
1886 }
1887 return structuredNetworkResult(map[string]any{"deleted": true}, "deleted")
1888}
1889
1890func (n *daemonNativeTools) networkConversationMessages(
1891 ctx context.Context,

Callers

nothing calls this directly

Calls 7

ValidateMethod · 0.95
decodeNativeInputFunction · 0.85
nativeNetworkChannelFunction · 0.85
nativeNetworkInputErrorFunction · 0.85
structuredNetworkResultFunction · 0.85

Tested by

no test coverage detected