Method networkDirectResolve

internal/daemon/native_tools.go:1608–1656

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

}

func (n *daemonNativeTools) networkDirectResolve(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkDirectResolveInput
	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
	}
	sessionID := firstNonEmpty(input.SessionID, req.SessionID, scope.SessionID)
	if sessionID == "" {
		return toolspkg.ToolResult{}, nativeRequiredInputError(req.ToolID, "session_id")
	}
	peerID := strings.TrimSpace(input.PeerID)
	if err := network.ValidatePeerID(peerID); 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
	}
	localPeer, remotePeer, err := n.resolveNetworkDirectRoomPeers(ctx, workspaceID, channel, sessionID, peerID)
	if err != nil {
		return toolspkg.ToolResult{}, nativeNetworkToolError(req.ToolID, err)
	}
	directID, peerA, peerB, err := network.DirectRoomIdentity(workspaceID, channel, localPeer.PeerID, remotePeer.PeerID)
	if err != nil {
		return toolspkg.ToolResult{}, nativeNetworkToolError(req.ToolID, err)
	}
	now := time.Now().UTC()
	direct, err := n.deps.NetworkStore.ResolveDirectRoom(ctx, store.NetworkDirectRoomEntry{
		WorkspaceID:    workspaceID,
		Channel:        channel,
		DirectID:       directID,
		PeerA:          peerA,
		PeerB:          peerB,
		OpenedAt:       now,
		LastActivityAt: now,
	})
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	payload := core.NetworkDirectRoomPayloadFromStore(direct)
	return structuredNetworkResult(map[string]any{nativeToolsDirectKey: payload}, payload.DirectID)
}

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