Method networkSend

internal/daemon/native_tools.go:1426–1491

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

}

func (n *daemonNativeTools) networkSend(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkSendInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	bound, err := n.nativeBoundSession(ctx, scope)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	channel := strings.TrimSpace(input.Channel)
	if !nativeBoundSessionAllowsChannel(bound, channel) {
		return toolspkg.ToolResult{}, nativeBoundChannelDenied(req.ToolID, channel)
	}
	sessionID := nativeBoundSessionID(bound, input.SessionID, req.SessionID, scope.SessionID)
	resolved, err := n.nativeResolvedWorkspace(
		ctx,
		req.ToolID,
		nativeBoundWorkspaceRef(bound, input.WorkspaceID),
		scope,
	)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	workspaceID, err := nativeResolvedNetworkWorkspaceID(&resolved)
	if err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, 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
	}
	sendReq, err := core.NetworkSendRequestFromPayload(contract.NetworkSendRequest{
		WorkspaceID: workspaceID,
		SessionID:   sessionID,
		Channel:     channel,
		Surface:     strings.TrimSpace(input.Surface),
		ThreadID:    strings.TrimSpace(input.ThreadID),
		DirectID:    strings.TrimSpace(input.DirectID),
		Kind:        strings.TrimSpace(input.Kind),
		To:          strings.TrimSpace(input.To),
		Mentions:    cloneTrimmedStrings(input.Mentions),
		Body:        cloneJSON(input.Body),
		WorkID:      strings.TrimSpace(input.WorkID),
		ReplyTo:     strings.TrimSpace(input.ReplyTo),
		TraceID:     strings.TrimSpace(input.TraceID),
		CausationID: strings.TrimSpace(input.CausationID),
		ExpiresAt:   input.ExpiresAt,
		ID:          strings.TrimSpace(input.ID),
		Ext:         map[string]json.RawMessage(cloneExtensionMap(input.Ext)),
	})
	if err != nil {