blanchon's picture
Update
f62f94b
<script lang="ts">
import * as Dialog from "@/components/ui/dialog";
import { Button } from "@/components/ui/button";
import * as Card from "@/components/ui/card";
import * as Alert from "@/components/ui/alert";
import { Badge } from "@/components/ui/badge";
import { toast } from "svelte-sonner";
import type { Robot } from "$lib/elements/robot/Robot.svelte.js";
import { robotManager } from "$lib/elements/robot/RobotManager.svelte.js";
import USBCalibrationPanel from "$lib/elements/robot/calibration/USBCalibrationPanel.svelte";
interface Props {
workspaceId: string;
open: boolean;
robot: Robot;
}
let { open = $bindable(), robot, workspaceId }: Props = $props();
let isConnecting = $state(false);
let error = $state<string | null>(null);
let showUSBCalibration = $state(false);
let pendingUSBConnection: "input" | null = $state(null);
let selectedRoomId = $state("");
let customRoomId = $state("");
let showRoomManagement = $state(true);
let hasLoadedRooms = $state(false);
// Auto-load rooms when modal opens (only once per modal session)
$effect(() => {
if (open && !hasLoadedRooms && !robotManager.roomsLoading) {
refreshRooms();
hasLoadedRooms = true;
}
// Reset when modal closes
if (!open) {
hasLoadedRooms = false;
error = null;
}
});
async function refreshRooms() {
try {
error = null;
await robotManager.refreshRooms(workspaceId);
} catch (err) {
error = err instanceof Error ? err.message : "Failed to refresh rooms";
}
}
async function createRoom() {
try {
isConnecting = true;
error = null;
const roomId = customRoomId.trim() || robot.id;
const result = await robotManager.createRoboticsRoom(workspaceId, roomId);
if (result.success) {
customRoomId = "";
await refreshRooms();
toast.success("Room Created", {
description: `Successfully created room ${result.roomId}`
});
} else {
error = result.error || "Failed to create room";
}
} catch (err) {
error = err instanceof Error ? err.message : "Failed to create room";
} finally {
isConnecting = false;
}
}
async function joinRoomAsInput() {
if (!selectedRoomId) {
error = "Please select a room";
return;
}
try {
isConnecting = true;
error = null;
await robotManager.connectConsumerToRoom(workspaceId, robot.id, selectedRoomId);
toast.success("Joined Room as Input", {
description: `Successfully joined room ${selectedRoomId} - now receiving commands`
});
} catch (err) {
error = err instanceof Error ? err.message : "Failed to join room as input";
} finally {
isConnecting = false;
}
}
async function createRoomAndJoinAsInput() {
try {
isConnecting = true;
error = null;
const roomId = customRoomId.trim() || robot.id;
const result = await robotManager.createRoboticsRoom(workspaceId, roomId);
if (result.success) {
await robotManager.connectConsumerToRoom(workspaceId, robot.id, result.roomId!);
customRoomId = "";
await refreshRooms();
toast.success("Room Created & Joined", {
description: `Successfully created and joined room ${result.roomId} - ready to receive commands`
});
} else {
error = result.error || "Failed to create room and join as input";
}
} catch (err) {
error = err instanceof Error ? err.message : "Failed to create room and join as input";
} finally {
isConnecting = false;
}
}
async function connectUSBInput() {
try {
isConnecting = true;
error = null;
// Create USB consumer first, which will handle calibration internally
await robot.setConsumer({
type: "usb",
baudRate: 1000000
});
// Check if the new consumer needs calibration
const uncalibratedDrivers = robot.getUncalibratedUSBDrivers();
if (uncalibratedDrivers.length > 0) {
pendingUSBConnection = "input";
showUSBCalibration = true;
return;
}
toast.success("USB Input Connected", {
description: "Successfully connected to physical robot hardware"
});
} catch (err) {
error = err instanceof Error ? err.message : "Unknown error";
toast.error("Failed to Connect USB Input", {
description: `Could not connect to robot hardware: ${error}`
});
} finally {
isConnecting = false;
}
}
async function disconnectInput() {
try {
isConnecting = true;
error = null;
await robot.removeConsumer();
toast.success("Input Disconnected", {
description: "Successfully disconnected input source"
});
} catch (err) {
error = err instanceof Error ? err.message : "Unknown error";
toast.error("Failed to Disconnect Input", {
description: `Could not disconnect input: ${error}`
});
} finally {
isConnecting = false;
}
}
async function onCalibrationComplete() {
showUSBCalibration = false;
pendingUSBConnection = null;
toast.success("Calibration Complete", {
description: "Hardware calibrated and ready for use"
});
}
function onCalibrationCancel() {
showUSBCalibration = false;
pendingUSBConnection = null;
isConnecting = false;
// Clean up the uncalibrated USB consumer
robot.removeConsumer().catch(err => {
console.error("Failed to clean up USB consumer after calibration cancel:", err);
});
}
</script>
<Dialog.Root bind:open>
<Dialog.Content
class="max-h-[85vh] max-w-4xl overflow-hidden border-slate-300 bg-slate-100 text-slate-900 dark:border-slate-600 dark:bg-slate-900 dark:text-slate-100"
>
<Dialog.Header class="pb-3">
<Dialog.Title
class="flex items-center gap-2 text-lg font-bold text-slate-900 dark:text-slate-100"
>
<span class="icon-[mdi--account-supervisor] size-5 text-green-500 dark:text-green-400"
></span>
Input Connection - Robot {robot.id}
</Dialog.Title>
<Dialog.Description class="text-sm text-slate-600 dark:text-slate-400">
Configure how this robot receives commands. Choose between direct hardware control or remote
collaboration.
</Dialog.Description>
</Dialog.Header>
<div class="max-h-[calc(85vh-10rem)] overflow-y-auto">
<div class="space-y-4 pb-4">
<!-- Error display -->
{#if error}
<Alert.Root
class="border-red-300/30 bg-red-100/20 dark:border-red-500/30 dark:bg-red-900/20"
>
<span class="icon-[mdi--alert-circle] size-4 text-red-500 dark:text-red-400"></span>
<Alert.Title class="text-red-700 dark:text-red-300">Connection Error</Alert.Title>
<Alert.Description class="text-sm text-red-600 dark:text-red-400">
{error}
</Alert.Description>
</Alert.Root>
{/if}
<!-- USB Calibration Panel -->
{#if showUSBCalibration}
<Card.Root
class="border-orange-300/30 bg-orange-100/20 dark:border-orange-500/30 dark:bg-orange-900/20"
>
<Card.Header>
<div class="flex items-center justify-between">
<Card.Title class="text-lg font-semibold text-orange-700 dark:text-orange-200">
Hardware Calibration Required
</Card.Title>
<button
onclick={onCalibrationCancel}
class="text-slate-600 hover:text-slate-900 dark:text-gray-400 dark:hover:text-white"
>
</button>
</div>
</Card.Header>
<Card.Content class="space-y-4">
<Alert.Root
class="border-orange-300/30 bg-orange-100/10 dark:border-orange-500/30 dark:bg-orange-500/10"
>
<span class="icon-[mdi--information] size-4 text-orange-500 dark:text-orange-400"
></span>
<Alert.Description class="text-sm text-orange-700 dark:text-orange-200">
Before connecting to the physical robot, calibration is required to map the servo
positions to software values. This ensures accurate control.
</Alert.Description>
</Alert.Root>
<!-- Show calibration panels for each uncalibrated USB driver -->
{#each robot.getUncalibratedUSBDrivers() as usbDriver}
<USBCalibrationPanel
calibrationManager={usbDriver}
connectionType="consumer"
{onCalibrationComplete}
onCancel={onCalibrationCancel}
/>
{:else}
<div class="text-center text-slate-400">
No USB drivers require calibration
</div>
{/each}
</Card.Content>
</Card.Root>
{:else}
<!-- Current Status Overview -->
<Card.Root
class="border-green-300/30 bg-green-100/20 dark:border-green-500/30 dark:bg-green-900/20"
>
<Card.Content class="p-4">
<div class="flex items-center justify-between">
<div class="flex items-center gap-2">
<span class="icon-[mdi--connection] size-4 text-green-500 dark:text-green-400"
></span>
<span class="text-sm font-medium text-green-700 dark:text-green-300"
>Current Input Source</span
>
</div>
{#if robot.hasConsumer}
<Badge variant="default" class="bg-green-500 text-xs dark:bg-green-600">
{robot.consumer?.name || "Connected"}
</Badge>
{:else}
<Badge variant="secondary" class="text-xs text-slate-600 dark:text-slate-400"
>No Input Connected</Badge
>
{/if}
</div>
{#if robot.hasConsumer}
<div class="mt-2 text-xs text-green-600/70 dark:text-green-400/70">
Status: {robot.consumer?.status.isConnected ? "Connected" : "Disconnected"}
</div>
{/if}
</Card.Content>
</Card.Root>
<!-- Local Hardware Connection -->
<Card.Root
class="border-blue-300/30 bg-blue-100/5 dark:border-blue-500/30 dark:bg-blue-500/5"
>
<Card.Header>
<Card.Title
class="flex items-center gap-2 text-base text-blue-700 dark:text-blue-200"
>
<span class="icon-[mdi--usb-port] size-4"></span>
Local Hardware (USB)
</Card.Title>
<Card.Description class="text-xs text-blue-600/70 dark:text-blue-300/70">
Read physical robot movements in real-time
</Card.Description>
</Card.Header>
<Card.Content class="space-y-3">
{#if robot.hasConsumer && robot.consumer?.name === "USB Consumer"}
<!-- USB Connected State -->
<div
class="rounded-lg border border-blue-300/30 bg-blue-100/20 p-3 dark:border-blue-500/30 dark:bg-blue-900/20"
>
<div class="flex items-center justify-between">
<div>
<p class="text-sm font-medium text-blue-700 dark:text-blue-300">
Hardware Connected
</p>
<p class="text-xs text-blue-600/70 dark:text-blue-400/70">
Reading physical servo positions
</p>
</div>
<Button
variant="destructive"
size="sm"
onclick={disconnectInput}
disabled={isConnecting}
class="h-7 px-2 text-xs"
>
<span class="icon-[mdi--close-circle] mr-1 size-3"></span>
{isConnecting ? "Disconnecting..." : "Disconnect"}
</Button>
</div>
</div>
{:else}
<!-- USB Connection Button -->
<Button
variant="secondary"
onclick={connectUSBInput}
disabled={isConnecting || robot.hasConsumer}
class="w-full bg-blue-500 text-sm text-white hover:bg-blue-600 disabled:opacity-50 dark:bg-blue-600 dark:hover:bg-blue-700"
>
<span class="icon-[mdi--usb] mr-2 size-4"></span>
{isConnecting ? "Connecting..." : "Connect to Hardware"}
</Button>
{#if robot.hasConsumer}
<p class="text-xs text-slate-600 dark:text-slate-500">
Disconnect current input to connect USB hardware
</p>
{/if}
{/if}
</Card.Content>
</Card.Root>
<!-- Remote Collaboration -->
<Card.Root
class="border-purple-300/30 bg-purple-100/5 dark:border-purple-500/30 dark:bg-purple-500/5"
>
<Card.Header>
<div class="flex items-center justify-between">
<div>
<Card.Title
class="flex items-center gap-2 text-base text-purple-700 dark:text-purple-200"
>
<span class="icon-[mdi--cloud-sync] size-4"></span>
Remote Collaboration (Rooms)
</Card.Title>
<Card.Description class="text-xs text-purple-600/70 dark:text-purple-300/70">
Receive commands from AI systems, remote users, or other software
</Card.Description>
</div>
<Button
variant="ghost"
size="sm"
onclick={refreshRooms}
disabled={robotManager.roomsLoading || isConnecting}
class="h-7 px-2 text-xs text-purple-700 hover:bg-purple-200/20 hover:text-purple-800 dark:text-purple-300 dark:hover:bg-purple-500/20 dark:hover:text-purple-200"
>
{#if robotManager.roomsLoading}
<span class="icon-[mdi--loading] mr-1 size-3 animate-spin"></span>
Refreshing
{:else}
<span class="icon-[mdi--refresh] mr-1 size-3"></span>
Refresh
{/if}
</Button>
</div>
</Card.Header>
<Card.Content class="space-y-4">
{#if robot.hasConsumer && robot.consumer?.name?.includes("Remote Consumer")}
<!-- Remote Connected State -->
<div
class="rounded-lg border border-purple-300/30 bg-purple-100/20 p-3 dark:border-purple-500/30 dark:bg-purple-900/20"
>
<div class="flex items-center justify-between">
<div>
<p class="text-sm font-medium text-purple-700 dark:text-purple-300">
Room Connected
</p>
<p class="text-xs text-purple-600/70 dark:text-purple-400/70">
Receiving remote commands
</p>
</div>
<Button
variant="destructive"
size="sm"
onclick={disconnectInput}
disabled={isConnecting}
class="h-7 px-2 text-xs"
>
<span class="icon-[mdi--close-circle] mr-1 size-3"></span>
{isConnecting ? "Leaving..." : "Leave Room"}
</Button>
</div>
</div>
{:else}
<!-- Create New Room -->
<div
class="rounded border-2 border-dashed border-green-400/50 bg-green-100/5 p-3 dark:border-green-500/50 dark:bg-green-500/5"
>
<div class="space-y-2">
<div class="flex items-center gap-2">
<span
class="icon-[mdi--plus-circle] size-4 text-green-500 dark:text-green-400"
></span>
<p class="text-sm font-medium text-green-700 dark:text-green-300">
Create New Room
</p>
</div>
<p class="text-xs text-green-600/70 dark:text-green-400/70">
Create a room where others can send commands to this robot
</p>
<input
bind:value={customRoomId}
placeholder={`Room ID (default: ${robot.id})`}
disabled={isConnecting || robot.hasConsumer}
class="w-full rounded border border-slate-300 bg-slate-50 px-2 py-1 text-xs text-slate-900 disabled:opacity-50 dark:border-slate-600 dark:bg-slate-700 dark:text-slate-100"
/>
<div class="flex gap-1">
<Button
variant="secondary"
size="sm"
onclick={createRoom}
disabled={isConnecting || robot.hasConsumer}
class="h-6 bg-green-500 px-2 text-xs hover:bg-green-600 disabled:opacity-50 dark:bg-green-600 dark:hover:bg-green-700"
>
Create Only
</Button>
<Button
variant="secondary"
size="sm"
onclick={createRoomAndJoinAsInput}
disabled={isConnecting || robot.hasConsumer}
class="h-6 bg-green-500 px-2 text-xs hover:bg-green-600 disabled:opacity-50 dark:bg-green-600 dark:hover:bg-green-700"
>
Create & Join as Input
</Button>
</div>
</div>
</div>
<!-- Existing Rooms -->
<div class="space-y-2">
<div class="flex items-center justify-between">
<span class="text-xs font-medium text-purple-700 dark:text-purple-300"
>Join Existing Room:</span
>
<span class="text-xs text-slate-600 dark:text-slate-400">
{robotManager.rooms.length} room{robotManager.rooms.length !== 1 ? "s" : ""} available
</span>
</div>
<div class="max-h-40 space-y-2 overflow-y-auto">
{#if robotManager.rooms.length === 0}
<div class="py-3 text-center text-xs text-slate-600 dark:text-slate-400">
{robotManager.roomsLoading
? "Loading rooms..."
: "No rooms available. Create one to get started."}
</div>
{:else}
{#each robotManager.rooms as room}
<div
class="rounded border border-slate-300 bg-slate-50/50 p-2 dark:border-slate-600 dark:bg-slate-800/50"
>
<div class="flex items-start justify-between gap-3">
<div class="min-w-0 flex-1">
<p
class="truncate text-xs font-medium text-slate-800 dark:text-slate-200"
>
{room.id}
</p>
<div class="flex gap-3 text-xs text-slate-600 dark:text-slate-400">
<span>{room.has_producer ? "📤 Has Output" : "📥 No Output"}</span>
<span>👥 {room.participants?.total || 0} users</span>
</div>
</div>
<Button
variant="secondary"
size="sm"
onclick={() => {
selectedRoomId = room.id;
joinRoomAsInput();
}}
disabled={isConnecting || robot.hasConsumer}
class="h-6 shrink-0 bg-purple-500 px-2 text-xs hover:bg-purple-600 disabled:opacity-50 dark:bg-purple-600 dark:hover:bg-purple-700"
>
<span class="icon-[mdi--login] mr-1 size-3"></span>
Join as Input
</Button>
</div>
</div>
{/each}
{/if}
</div>
</div>
{#if robot.hasConsumer}
<p class="text-xs text-slate-600 dark:text-slate-500">
Disconnect current input to join a room
</p>
{/if}
{/if}
</Card.Content>
</Card.Root>
<!-- Help Information -->
<Alert.Root
class="border-slate-300 bg-slate-100/30 dark:border-slate-700 dark:bg-slate-800/30"
>
<span class="icon-[mdi--help-circle] size-4 text-slate-600 dark:text-slate-400"></span>
<Alert.Title class="text-slate-700 dark:text-slate-300">Input Sources</Alert.Title>
<Alert.Description class="text-xs text-slate-600 dark:text-slate-400">
<strong>USB:</strong> Read physical movements • <strong>Remote:</strong> Receive network
commands • Only one active at a time
</Alert.Description>
</Alert.Root>
{/if}
</div>
</div>
</Dialog.Content>
</Dialog.Root>