Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
73 changes: 73 additions & 0 deletions frontend/src/components/chat/ChatShell.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,10 @@ export const ChatShell: React.FC<ChatShellProps> = ({
const [selectedFile, setSelectedFile] = useState<File | null>(null);
const [chatMode, setChatMode] = useState<'general' | 'marine'>('general');
const [showModeDropdown, setShowModeDropdown] = useState(false);
const [marineStatus, setMarineStatus] = useState<{
ais: 'ok' | 'degraded' | 'down' | 'unknown';
signalk: 'ok' | 'degraded' | 'down' | 'unknown';
}>({ ais: 'unknown', signalk: 'unknown' });

const messagesEndRef = useRef<HTMLDivElement>(null);
const textareaRef = useRef<HTMLTextAreaElement>(null);
Expand All @@ -72,6 +76,50 @@ export const ChatShell: React.FC<ChatShellProps> = ({
}
}, [inputText]);

// Fetch marine status when in marine mode
useEffect(() => {
if (chatMode !== 'marine') {
return;
}

const fetchMarineStatus = async () => {
// Fetch AIS status
try {
const aisRes = await api.get('/vessels/realtime/status');
const aisData = aisRes.data;
const aisStatus: 'ok' | 'degraded' | 'down' | 'unknown' =
aisData?.service_running === true ? 'ok' :
aisData?.service_running === false ? 'down' :
'unknown';
setMarineStatus((prev) => ({ ...prev, ais: aisStatus }));
} catch (err) {
setMarineStatus((prev) => ({ ...prev, ais: 'unknown' }));
}

// Fetch SignalK status (try vessels endpoint as health check)
try {
const signalkRes = await api.get('/marine/signalk/vessels');
const signalkStatus: 'ok' | 'degraded' | 'down' | 'unknown' =
signalkRes.status === 200 ? 'ok' : 'degraded';
setMarineStatus((prev) => ({ ...prev, signalk: signalkStatus }));
} catch (err: any) {
const signalkStatus: 'ok' | 'degraded' | 'down' | 'unknown' =
err.response?.status === 503 ? 'down' :
err.response?.status === 404 ? 'down' :
'unknown';
setMarineStatus((prev) => ({ ...prev, signalk: signalkStatus }));
}
};

// Fetch immediately
fetchMarineStatus();

// Poll every 30s
const interval = setInterval(fetchMarineStatus, 30000);

return () => clearInterval(interval);
}, [chatMode]);

// Transcribe audio blob to text (SSOT-compliant)
const transcribeAudio = async (audioBlob: Blob): Promise<string> => {
const formData = new FormData();
Expand Down Expand Up @@ -349,6 +397,31 @@ export const ChatShell: React.FC<ChatShellProps> = ({
</div>
)}

{/* Marine status line (when in marine mode) */}
{chatMode === 'marine' && (
<div className="border-b border-slate-800 bg-slate-900/50 px-4 py-1.5">
<div className="flex items-center gap-3 text-[10px]">
<span className="text-slate-400">Marine Status:</span>
<span className={`px-1.5 py-0.5 rounded ${
marineStatus.ais === 'ok' ? 'bg-emerald-500/20 text-emerald-300' :
marineStatus.ais === 'degraded' ? 'bg-amber-500/20 text-amber-300' :
marineStatus.ais === 'down' ? 'bg-rose-500/20 text-rose-300' :
'bg-slate-700/50 text-slate-400'
}`}>
AIS: {marineStatus.ais.toUpperCase()}
</span>
<span className={`px-1.5 py-0.5 rounded ${
marineStatus.signalk === 'ok' ? 'bg-emerald-500/20 text-emerald-300' :
marineStatus.signalk === 'degraded' ? 'bg-amber-500/20 text-amber-300' :
marineStatus.signalk === 'down' ? 'bg-rose-500/20 text-rose-300' :
'bg-slate-700/50 text-slate-400'
}`}>
SignalK: {marineStatus.signalk.toUpperCase()}
</span>
</div>
</div>
)}

{/* Messages */}
<div className="flex-1 space-y-2 overflow-y-auto px-4 py-3 text-sm">
{messages.length === 0 ? (
Expand Down