Method networkChannelCreate

internal/daemon/native_create_tools.go:50–91

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

}

func (n *daemonNativeTools) networkChannelCreate(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkChannelCreateInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	channel, err := nativeNetworkChannel(req.ToolID, input.Channel)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	purpose := strings.TrimSpace(input.Purpose)
	if purpose == "" {
		return toolspkg.ToolResult{}, nativeRequiredInputError(req.ToolID, "purpose")
	}
	fanoutPolicy := store.NormalizeNetworkFanoutPolicy(input.FanoutPolicy)
	coordinatorPeerID := strings.TrimSpace(input.CoordinatorPeerID)
	if err := store.ValidateNetworkChannelFanoutConfiguration(fanoutPolicy, coordinatorPeerID); err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	workspaceID, err := n.nativeNetworkWorkspaceID(ctx, req.ToolID, input.WorkspaceID, scope)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	entry := store.NetworkChannelEntry{
		Channel:           channel,
		WorkspaceID:       workspaceID,
		Purpose:           purpose,
		FanoutPolicy:      fanoutPolicy,
		CoordinatorPeerID: coordinatorPeerID,
		CreatedBy:         strings.TrimSpace(scope.AgentName),
	}
	if err := n.deps.NetworkStore.WriteNetworkChannel(ctx, entry); err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	return structuredNetworkResult(
		nativeNetworkChannelPayload(entry),
		"channel "+channel,
	)
}

func nativeNetworkChannelPayload(entry store.NetworkChannelEntry) map[string]any {
	return map[string]any{