( ctx context.Context, scope toolspkg.Scope, req toolspkg.CallRequest, )
| 1856 | } |
| 1857 | |
| 1858 | func (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 | |
| 1890 | func (n *daemonNativeTools) networkConversationMessages( |
| 1891 | ctx context.Context, |
nothing calls this directly
no test coverage detected