Method networkInbox

internal/daemon/native_tools.go:1381–1424

(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
)

}

func (n *daemonNativeTools) networkInbox(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkInboxInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	bound, err := n.nativeBoundSession(ctx, scope)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	sessionID := nativeBoundSessionID(bound, input.SessionID, req.SessionID, scope.SessionID)
	if sessionID == "" {
		return toolspkg.ToolResult{}, nativeRequiredInputError(req.ToolID, "session_id")
	}
	resolved, err := n.nativeResolvedWorkspace(
		ctx,
		req.ToolID,
		nativeBoundWorkspaceRef(bound, input.WorkspaceID),
		scope,
	)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	sessionWorkspaceID, err := nativeResolvedRegistryWorkspaceID(&resolved)
	if err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	if err := n.requireNativeSessionWorkspace(ctx, req.ToolID, sessionWorkspaceID, sessionID); err != nil {
		return toolspkg.ToolResult{}, err
	}
	messages, err := n.deps.Network.Inbox(ctx, sessionID)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	messages = nativeFilterNetworkEnvelopes(bound, messages)
	payload := core.NetworkEnvelopePayloadsFromEnvelopes(messages)
	return structuredNetworkResult(
		map[string]any{nativeToolsMessagesKey: payload},
		fmt.Sprintf("%d messages", len(payload)),
	)
}

func (n *daemonNativeTools) networkSend(
	ctx context.Context,