Method networkDirects

internal/daemon/native_tools.go:1571–1606

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

}

func (n *daemonNativeTools) networkDirects(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkDirectsInput
	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
	}
	query := store.NetworkDirectRoomQuery{
		PeerID: strings.TrimSpace(input.PeerID),
		Limit:  input.Limit,
		After:  strings.TrimSpace(input.After),
	}
	if err := query.Validate(); 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
	}
	directs, err := n.deps.NetworkStore.ListDirectRooms(
		ctx,
		store.NetworkChannelRef{WorkspaceID: workspaceID, Channel: channel},
		query,
	)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	payload := core.NetworkDirectRoomPayloadsFromStore(directs)
	return structuredNetworkResult(map[string]any{"directs": payload}, fmt.Sprintf("%d directs", len(payload)))
}

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