(null)
@@ -110,38 +457,25 @@ export function VisionSystem() {
}
}
- // Only update state if data has actually changed to prevent unnecessary re-renders
- setSystemStatus(prevStatus => {
- if (JSON.stringify(prevStatus) !== JSON.stringify(statusData)) {
- return statusData
+ // Batch state updates to minimize re-renders using startTransition for non-urgent updates
+ const updateTime = new Date()
+
+ // Use startTransition for non-urgent state updates to keep the UI responsive
+ startTransition(() => {
+ setSystemStatus(statusData)
+ setStorageStats(storageData)
+ setRecordings(recordingsData)
+ setLastUpdateTime(updateTime)
+
+ // Update MQTT status and events
+ if (mqttStatusData) {
+ setMqttStatus(mqttStatusData)
}
- return prevStatus
- })
- setStorageStats(prevStats => {
- if (JSON.stringify(prevStats) !== JSON.stringify(storageData)) {
- return storageData
+ if (mqttEventsData && mqttEventsData.events) {
+ setMqttEvents(mqttEventsData.events)
}
- return prevStats
})
-
- setRecordings(prevRecordings => {
- if (JSON.stringify(prevRecordings) !== JSON.stringify(recordingsData)) {
- return recordingsData
- }
- return prevRecordings
- })
-
- setLastUpdateTime(new Date())
-
- // Update MQTT status and events
- if (mqttStatusData) {
- setMqttStatus(mqttStatusData)
- }
-
- if (mqttEventsData && mqttEventsData.events) {
- setMqttEvents(mqttEventsData.events)
- }
} catch (err) {
setError(err instanceof Error ? err.message : 'Failed to fetch vision system data')
console.error('Vision system fetch error:', err)
@@ -242,8 +576,14 @@ export function VisionSystem() {
Vision System
Monitor cameras, machines, and recording status
{lastUpdateTime && (
-
+
Last updated: {lastUpdateTime.toLocaleTimeString()}
+ {refreshing && (
+
+
+ )}
{autoRefreshEnabled && !refreshing && (
Auto-refresh: {refreshInterval / 1000}s
@@ -296,227 +636,12 @@ export function VisionSystem() {
{/* System Overview */}
- {systemStatus && (
-
-
-
-
-
-
- {systemStatus.system_started ? 'Online' : 'Offline'}
-
-
-
-
-
System Status
-
- Uptime: {formatUptime(systemStatus.uptime_seconds)}
-
-
-
-
-
-
-
-
-
-
-
- {systemStatus.mqtt_connected ? 'Connected' : 'Disconnected'}
-
-
- {systemStatus.mqtt_connected && (
-
- )}
-
- {mqttStatus && (
-
-
{mqttStatus.message_count} messages
-
{mqttStatus.error_count} errors
-
- )}
-
-
-
MQTT
-
- {mqttStatus ? (
-
-
Broker: {mqttStatus.broker_host}:{mqttStatus.broker_port}
-
Last message: {new Date(mqttStatus.last_message_time).toLocaleTimeString()}
-
- ) : (
-
Last message: {new Date(systemStatus.last_mqtt_message).toLocaleTimeString()}
- )}
-
-
-
- {/* MQTT Events History */}
- {mqttEvents.length > 0 && (
-
-
-
Recent Events
- {mqttEvents.length} events
-
-
- {mqttEvents.map((event, index) => (
-
-
-
- {new Date(event.timestamp).toLocaleTimeString().slice(-8, -3)}
-
-
- {event.machine_name.replace('_', ' ')}
-
-
- {event.payload}
-
-
-
#{event.message_number}
-
- ))}
-
-
- )}
-
-
-
-
-
-
-
-
- {systemStatus.active_recordings}
-
-
-
-
-
Active Recordings
-
- Total: {systemStatus.total_recordings}
-
-
-
-
-
-
-
-
-
-
- {Object.keys(systemStatus.cameras).length}
-
-
-
-
-
Cameras
-
- Machines: {Object.keys(systemStatus.machines).length}
-
-
-
-
-
-
-
Cameras
-
- Current status of all cameras in the system
-
-
-
-
- {Object.entries(systemStatus.cameras).map(([cameraName, camera]) => {
- // Debug logging to see what data we're getting
- console.log(`Camera ${cameraName} data:`, JSON.stringify(camera, null, 2))
-
- const friendlyName = camera.device_info?.friendly_name
- const hasDeviceInfo = !!camera.device_info
- const hasSerial = !!camera.device_info?.serial_number
-
- return (
-
-
-
-
- {friendlyName ? (
-
-
{friendlyName}
-
({cameraName})
-
-
{cameraName}
-
- {hasDeviceInfo ? 'Device info available but no friendly name' : 'No device info available'}
-
-
-
-
- {camera.is_recording ? 'Recording' : camera.status}
-
-
-
-
-
- Recording:
-
- {camera.is_recording ? 'Yes' : 'No'}
-
-
-
- {camera.device_info?.serial_number && (
-
- Serial:
- {camera.device_info.serial_number}
-
- )}
-
- {/* Debug info - remove this after fixing */}
-
-
Debug Info:
-
-
Has device_info: {hasDeviceInfo ? 'Yes' : 'No'}
-
Has friendly_name: {friendlyName ? 'Yes' : 'No'}
-
Has serial: {hasSerial ? 'Yes' : 'No'}
-
Last error: {camera.last_error || 'None'}
- {camera.device_info && (
-
-
Raw device_info: {JSON.stringify(camera.device_info)}
-
- )}
-
-
-
-
- Last checked:
- {new Date(camera.last_checked).toLocaleTimeString()}
-
-
- {camera.current_recording_file && (
-
- Recording file:
- {camera.current_recording_file}
-
- )}
-
-
- )
- })}
-
-
-
-
-
Storage
-
- Storage usage and file statistics
-
-
-
-
-
-
{storageStats.total_files}
-
Total Files
-
-
-
{formatBytes(storageStats.total_size_bytes)}
-
Total Size
-
-
-
{formatBytes(storageStats.disk_usage.free)}
-
Free Space
-
-
-
- {/* Disk Usage Bar */}
-
-
- Disk Usage
- {Math.round((storageStats.disk_usage.used / storageStats.disk_usage.total) * 100)}% used
-
-
-
- {formatBytes(storageStats.disk_usage.used)} used
- {formatBytes(storageStats.disk_usage.total)} total
-
-
-
- {/* Per-Camera Statistics */}
- {Object.keys(storageStats.cameras).length > 0 && (
-
-
Files by Camera
-
- {Object.entries(storageStats.cameras).map(([cameraName, stats]) => {
- // Find the corresponding camera to get friendly name
- const camera = systemStatus?.cameras[cameraName]
- const displayName = camera?.device_info?.friendly_name || cameraName
-
- return (
-
-
- {camera?.device_info?.friendly_name ? (
- <>
- {displayName}
- ({cameraName})
-
- ) : (
- cameraName
- )}
-
-
-
- Files:
- {stats.file_count}
-
-
- Size:
- {formatBytes(stats.total_size_bytes)}
-
-
-
- )
- })}
-
-
- )}
-
-
-
-
Recent Recordings
-
- Latest recording sessions
-
-
-
-
-
-
-
-
- Camera
-
-
- Filename
-
-
- Status
-
-
- Duration
-
-
- Size
-
-
- Started
-
-
-
-
- {Object.entries(recordings).slice(0, 10).map(([recordingId, recording]) => {
- // Find the corresponding camera to get friendly name
- const camera = systemStatus?.cameras[recording.camera_name]
- const displayName = camera?.device_info?.friendly_name || recording.camera_name
-
- return (
-
-
- {camera?.device_info?.friendly_name ? (
-
-
{displayName}
-
({recording.camera_name})
-
-
- {recording.filename}
-
-
-
- {recording.state}
-
-
-
- {recording.duration_seconds ? formatDuration(recording.duration_seconds) : '-'}
-
-
- {recording.file_size_bytes ? formatBytes(recording.file_size_bytes) : '-'}
-
-
- {new Date(recording.start_time).toLocaleString()}
-
-
- )
- })}
-
-
-
-
-
+
Camera: {cameraName}
+
+ {/* Video Stream */}
+
+ {isStreaming ? (
+
setError('Stream connection lost')}
+ />
+ ) : (
+
+ No Stream Active
+
+ )}
+
+
+ {/* Controls */}
+
+
+ {loading ? 'Loading...' : 'Start Stream'}
+
+
+
+ {loading ? 'Loading...' : 'Stop Stream'}
+
+
+
+ {/* Error Display */}
+ {error && (
+
+ Error: {error}
+
+ )}
+
Loading cameras...
;
+ }
+
+ if (error) {
+ return (
+
+ Error: {error}
+
+ Retry
+
+
+ );
+ }
+
+ return (
+
+
USDA Vision Camera Dashboard
+
+
+ {Object.entries(cameras).map(([cameraName, cameraInfo]) => (
+
+
+
+ {/* Camera Status */}
+
+
Status: {cameraInfo.status}
+
Recording: {cameraInfo.is_recording ? 'Yes' : 'No'}
+
Last Checked: {new Date(cameraInfo.last_checked).toLocaleString()}
+
+
+ ))}
+
+
+
Camera: {cameraName}
+
+ {/* Stream Container */}
+
+ {isStreaming ? (
+
setError('Stream connection lost')}
+ />
+ ) : (
+
+ No Stream Active
+
+ )}
+
+
+ {/* Controls */}
+
+
+ {loading ? 'Loading...' : 'Start Stream'}
+
+
+
+ {loading ? 'Loading...' : 'Stop Stream'}
+
+
+
+ {/* Error Display */}
+ {error && (
+
+ Error: {error}
+
+ )}
+
;
+}
+
+export interface UseCameraRecordingResult {
+ isRecording: boolean;
+ loading: boolean;
+ error: string | null;
+ currentFile: string | null;
+ startRecording: (options?: StartRecordingRequest) => Promise<{ success: boolean; error?: string }>;
+ stopRecording: () => Promise<{ success: boolean; error?: string }>;
+}
+
+// =============================================================================
+// COMPONENT PROPS TYPES
+// =============================================================================
+
+export interface CameraStreamProps {
+ cameraName: string;
+ apiConfig?: ApiConfig;
+ autoStart?: boolean;
+ onStreamStart?: (cameraName: string) => void;
+ onStreamStop?: (cameraName: string) => void;
+ onError?: (error: StreamError) => void;
+ className?: string;
+ style?: React.CSSProperties;
+}
+
+export interface CameraDashboardProps {
+ apiConfig?: ApiConfig;
+ cameras?: string[]; // If provided, only show these cameras
+ showRecordingControls?: boolean;
+ showStreamingControls?: boolean;
+ refreshInterval?: number;
+ onCameraSelect?: (cameraName: string) => void;
+ className?: string;
+}
+
+export interface CameraControlsProps {
+ cameraName: string;
+ apiConfig?: ApiConfig;
+ showRecording?: boolean;
+ showStreaming?: boolean;
+ onAction?: (action: 'start-stream' | 'stop-stream' | 'start-recording' | 'stop-recording', cameraName: string) => void;
+}
+
+// =============================================================================
+// API CLIENT TYPES
+// =============================================================================
+
+export interface CameraApiClient {
+ // System endpoints
+ getHealth(): Promise;
+ getSystemStatus(): Promise;
+
+ // Camera endpoints
+ getCameras(): Promise;
+ getCameraStatus(cameraName: string): Promise;
+ testCameraConnection(cameraName: string): Promise<{ success: boolean; message: string }>;
+
+ // Streaming endpoints
+ startStream(cameraName: string): Promise;
+ stopStream(cameraName: string): Promise;
+ getStreamUrl(cameraName: string): string;
+
+ // Recording endpoints
+ startRecording(cameraName: string, options?: StartRecordingRequest): Promise;
+ stopRecording(cameraName: string): Promise;
+}
+
+// =============================================================================
+// UTILITY TYPES
+// =============================================================================
+
+export type CameraAction = 'start-stream' | 'stop-stream' | 'start-recording' | 'stop-recording' | 'test-connection';
+
+export interface CameraActionResult {
+ success: boolean;
+ message: string;
+ error?: string;
+}
+
+export interface StreamingState {
+ [cameraName: string]: {
+ isStreaming: boolean;
+ isLoading: boolean;
+ error: string | null;
+ lastStarted?: Date;
+ };
+}
+
+export interface RecordingState {
+ [cameraName: string]: {
+ isRecording: boolean;
+ isLoading: boolean;
+ error: string | null;
+ currentFile: string | null;
+ startTime?: Date;
+ };
+}
+
+// =============================================================================
+// EVENT TYPES
+// =============================================================================
+
+export interface CameraEvent {
+ type: 'stream-started' | 'stream-stopped' | 'stream-error' | 'recording-started' | 'recording-stopped' | 'recording-error';
+ cameraName: string;
+ timestamp: Date;
+ data?: any;
+}
+
+export type CameraEventHandler = (event: CameraEvent) => void;
+
+// =============================================================================
+// CONFIGURATION TYPES
+// =============================================================================
+
+export interface StreamConfig {
+ fps: number;
+ quality: number; // 1-100
+ timeout: number;
+ retryAttempts: number;
+ retryDelay: number;
+}
+
+export interface CameraStreamConfig extends StreamConfig {
+ cameraName: string;
+ autoReconnect: boolean;
+ maxReconnectAttempts: number;
+}
+
+// =============================================================================
+// CONTEXT TYPES (for React Context)
+// =============================================================================
+
+export interface CameraContextValue {
+ cameras: CameraListResponse;
+ streamingState: StreamingState;
+ recordingState: RecordingState;
+ apiClient: CameraApiClient;
+
+ // Actions
+ startStream: (cameraName: string) => Promise;
+ stopStream: (cameraName: string) => Promise;
+ startRecording: (cameraName: string, options?: StartRecordingRequest) => Promise;
+ stopRecording: (cameraName: string) => Promise;
+ refreshCameras: () => Promise;
+
+ // State
+ loading: boolean;
+ error: string | null;
+}
+
+// =============================================================================
+// EXAMPLE USAGE TYPES
+// =============================================================================
+
+/**
+ * Example usage in React component:
+ *
+ * ```typescript
+ * import { CameraStreamProps, UseCameraStreamResult } from './camera-api.types';
+ *
+ * const CameraStream: React.FC = ({
+ * cameraName,
+ * apiConfig = defaultApiConfig,
+ * autoStart = false,
+ * onStreamStart,
+ * onStreamStop,
+ * onError
+ * }) => {
+ * const {
+ * isStreaming,
+ * loading,
+ * error,
+ * startStream,
+ * stopStream,
+ * getStreamUrl
+ * }: UseCameraStreamResult = useCameraStream(cameraName, apiConfig);
+ *
+ * // Component implementation...
+ * };
+ * ```
+ */
+
+/**
+ * Example API client usage:
+ *
+ * ```typescript
+ * const apiClient: CameraApiClient = new CameraApiClientImpl(defaultApiConfig);
+ *
+ * // Start streaming
+ * const result = await apiClient.startStream('camera1');
+ * if (result.success) {
+ * const streamUrl = apiClient.getStreamUrl('camera1');
+ * // Use streamUrl in img tag
+ * }
+ * ```
+ */
+
+/**
+ * Example hook usage:
+ *
+ * ```typescript
+ * const MyComponent = () => {
+ * const { cameras, loading, error, refreshCameras } = useCameraList();
+ * const { isStreaming, startStream, stopStream } = useCameraStream('camera1');
+ *
+ * // Component logic...
+ * };
+ * ```
+ */
+
+export default {};
diff --git a/streaming/camera_preview.html b/streaming/camera_preview.html
new file mode 100644
index 0000000..0caa92d
--- /dev/null
+++ b/streaming/camera_preview.html
@@ -0,0 +1,336 @@
+
+
+
+ USDA Vision Camera Live Preview
+
+
+
+
+
๐ฅ USDA Vision Camera Live Preview
+
+
+
+
+
+
+
๐ก System Information
+
Loading system status...
+
+
๐ API Endpoints
+
+
Live Stream: GET /cameras/{camera_name}/stream
+
Start Stream: POST /cameras/{camera_name}/start-stream
+
Stop Stream: POST /cameras/{camera_name}/stop-stream
+
Camera Status: GET /cameras
+
+
+
+#
Start Stream
+# {isStreaming && (
+#
+# )}
+#
+#
+#
Start Stream
+#
+#
+#
+#
+
+### =============================================================================
+### TROUBLESHOOTING
+### =============================================================================
+
+### If streams don't start:
+# 1. Check camera status: GET /cameras
+# 2. Verify system health: GET /health
+# 3. Test camera connection: POST /cameras/{name}/test-connection
+# 4. Check if camera is already recording (shouldn't matter, but good to know)
+
+### If stream image doesn't load:
+# 1. Verify stream was started: POST /cameras/{name}/start-stream
+# 2. Check browser console for CORS errors
+# 3. Try accessing stream URL directly in browser
+# 4. Add timestamp to prevent caching: ?t=${Date.now()}
+
+### If concurrent operations fail:
+# 1. This should work - streaming and recording use separate connections
+# 2. Check system logs for resource conflicts
+# 3. Verify sufficient system resources (CPU/Memory)
+# 4. Test with one camera first, then multiple
+
+### Performance Notes:
+# - Streaming uses ~10 FPS by default (configurable)
+# - JPEG quality set to 70% (configurable)
+# - Each stream uses additional CPU/memory
+# - Multiple concurrent streams may impact performance
diff --git a/streaming/test_streaming.py b/streaming/test_streaming.py
new file mode 100644
index 0000000..47672ec
--- /dev/null
+++ b/streaming/test_streaming.py
@@ -0,0 +1,199 @@
+#!/usr/bin/env python3
+"""
+Test script for camera streaming functionality.
+
+This script tests the new streaming capabilities without interfering with recording.
+"""
+
+import sys
+import os
+import time
+import requests
+import threading
+from datetime import datetime
+
+# Add the current directory to Python path
+sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))
+
+def test_api_endpoints():
+ """Test the streaming API endpoints"""
+ base_url = "http://localhost:8000"
+
+ print("๐งช Testing Camera Streaming API Endpoints")
+ print("=" * 50)
+
+ # Test system status
+ try:
+ response = requests.get(f"{base_url}/system/status", timeout=5)
+ if response.status_code == 200:
+ print("โ
System status endpoint working")
+ data = response.json()
+ print(f" System: {data.get('status', 'Unknown')}")
+ print(f" Camera Manager: {'Running' if data.get('camera_manager_running') else 'Stopped'}")
+ else:
+ print(f"โ System status endpoint failed: {response.status_code}")
+ except Exception as e:
+ print(f"โ System status endpoint error: {e}")
+
+ # Test camera list
+ try:
+ response = requests.get(f"{base_url}/cameras", timeout=5)
+ if response.status_code == 200:
+ print("โ
Camera list endpoint working")
+ cameras = response.json()
+ print(f" Found {len(cameras)} cameras: {list(cameras.keys())}")
+
+ # Test streaming for each camera
+ for camera_name in cameras.keys():
+ test_camera_streaming(base_url, camera_name)
+
+ else:
+ print(f"โ Camera list endpoint failed: {response.status_code}")
+ except Exception as e:
+ print(f"โ Camera list endpoint error: {e}")
+
+def test_camera_streaming(base_url, camera_name):
+ """Test streaming for a specific camera"""
+ print(f"\n๐ฅ Testing streaming for {camera_name}")
+ print("-" * 30)
+
+ # Test start streaming
+ try:
+ response = requests.post(f"{base_url}/cameras/{camera_name}/start-stream", timeout=10)
+ if response.status_code == 200:
+ print(f"โ
Start stream endpoint working for {camera_name}")
+ data = response.json()
+ print(f" Response: {data.get('message', 'No message')}")
+ else:
+ print(f"โ Start stream failed for {camera_name}: {response.status_code}")
+ print(f" Error: {response.text}")
+ return
+ except Exception as e:
+ print(f"โ Start stream error for {camera_name}: {e}")
+ return
+
+ # Wait a moment for stream to initialize
+ time.sleep(2)
+
+ # Test stream endpoint (just check if it responds)
+ try:
+ response = requests.get(f"{base_url}/cameras/{camera_name}/stream", timeout=5, stream=True)
+ if response.status_code == 200:
+ print(f"โ
Stream endpoint responding for {camera_name}")
+ print(f" Content-Type: {response.headers.get('content-type', 'Unknown')}")
+
+ # Read a small amount of data to verify it's working
+ chunk_count = 0
+ for chunk in response.iter_content(chunk_size=1024):
+ chunk_count += 1
+ if chunk_count >= 3: # Read a few chunks then stop
+ break
+
+ print(f" Received {chunk_count} data chunks")
+ else:
+ print(f"โ Stream endpoint failed for {camera_name}: {response.status_code}")
+ except Exception as e:
+ print(f"โ Stream endpoint error for {camera_name}: {e}")
+
+ # Test stop streaming
+ try:
+ response = requests.post(f"{base_url}/cameras/{camera_name}/stop-stream", timeout=5)
+ if response.status_code == 200:
+ print(f"โ
Stop stream endpoint working for {camera_name}")
+ data = response.json()
+ print(f" Response: {data.get('message', 'No message')}")
+ else:
+ print(f"โ Stop stream failed for {camera_name}: {response.status_code}")
+ except Exception as e:
+ print(f"โ Stop stream error for {camera_name}: {e}")
+
+def test_concurrent_recording_and_streaming():
+ """Test that streaming doesn't interfere with recording"""
+ base_url = "http://localhost:8000"
+
+ print("\n๐ Testing Concurrent Recording and Streaming")
+ print("=" * 50)
+
+ try:
+ # Get available cameras
+ response = requests.get(f"{base_url}/cameras", timeout=5)
+ if response.status_code != 200:
+ print("โ Cannot get camera list for concurrent test")
+ return
+
+ cameras = response.json()
+ if not cameras:
+ print("โ No cameras available for concurrent test")
+ return
+
+ camera_name = list(cameras.keys())[0] # Use first camera
+ print(f"Using camera: {camera_name}")
+
+ # Start streaming
+ print("1. Starting streaming...")
+ response = requests.post(f"{base_url}/cameras/{camera_name}/start-stream", timeout=10)
+ if response.status_code != 200:
+ print(f"โ Failed to start streaming: {response.text}")
+ return
+
+ time.sleep(2)
+
+ # Start recording
+ print("2. Starting recording...")
+ response = requests.post(f"{base_url}/cameras/{camera_name}/start-recording",
+ json={"filename": "test_concurrent_recording.avi"}, timeout=10)
+ if response.status_code == 200:
+ print("โ
Recording started successfully while streaming")
+ else:
+ print(f"โ Failed to start recording while streaming: {response.text}")
+
+ # Let both run for a few seconds
+ print("3. Running both streaming and recording for 5 seconds...")
+ time.sleep(5)
+
+ # Stop recording
+ print("4. Stopping recording...")
+ response = requests.post(f"{base_url}/cameras/{camera_name}/stop-recording", timeout=5)
+ if response.status_code == 200:
+ print("โ
Recording stopped successfully")
+ else:
+ print(f"โ Failed to stop recording: {response.text}")
+
+ # Stop streaming
+ print("5. Stopping streaming...")
+ response = requests.post(f"{base_url}/cameras/{camera_name}/stop-stream", timeout=5)
+ if response.status_code == 200:
+ print("โ
Streaming stopped successfully")
+ else:
+ print(f"โ Failed to stop streaming: {response.text}")
+
+ print("โ
Concurrent test completed successfully!")
+
+ except Exception as e:
+ print(f"โ Concurrent test error: {e}")
+
+def main():
+ """Main test function"""
+ print("๐ USDA Vision Camera Streaming Test")
+ print("=" * 50)
+ print(f"Test started at: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
+ print()
+
+ # Wait for system to be ready
+ print("โณ Waiting for system to be ready...")
+ time.sleep(3)
+
+ # Run tests
+ test_api_endpoints()
+ test_concurrent_recording_and_streaming()
+
+ print("\n" + "=" * 50)
+ print("๐ Test completed!")
+ print("\n๐ Next Steps:")
+ print("1. Open camera_preview.html in your browser")
+ print("2. Click 'Start Stream' for any camera")
+ print("3. Verify live preview works without blocking recording")
+ print("4. Test concurrent recording and streaming")
+
+if __name__ == "__main__":
+ main()
diff --git a/supabase/migrations/20250724000001_experiment_repetitions_system.sql b/supabase/migrations/20250724000001_experiment_repetitions_system.sql
index dc45274..3549f71 100644
--- a/supabase/migrations/20250724000001_experiment_repetitions_system.sql
+++ b/supabase/migrations/20250724000001_experiment_repetitions_system.sql
@@ -85,15 +85,11 @@ CREATE TRIGGER trigger_experiment_repetitions_updated_at
ALTER TABLE public.experiment_repetitions ENABLE ROW LEVEL SECURITY;
-- Create RLS policies for experiment_repetitions
--- Users can view repetitions for experiments they have access to
+-- All authenticated users can view all experiment repetitions
CREATE POLICY "Users can view experiment repetitions" ON public.experiment_repetitions
- FOR SELECT USING (
- experiment_id IN (
- SELECT id FROM public.experiments
- WHERE created_by = auth.uid()
- )
- OR public.is_admin()
- );
+ FOR SELECT
+ TO authenticated
+ USING (true);
-- Users can insert repetitions for experiments they created or if they're admin
CREATE POLICY "Users can create experiment repetitions" ON public.experiment_repetitions
diff --git a/supabase/migrations/20250728000001_fix_repetitions_visibility.sql b/supabase/migrations/20250728000001_fix_repetitions_visibility.sql
new file mode 100644
index 0000000..5756ba0
--- /dev/null
+++ b/supabase/migrations/20250728000001_fix_repetitions_visibility.sql
@@ -0,0 +1,12 @@
+-- Fix experiment repetitions visibility for all users
+-- This migration updates the RLS policy to allow all authenticated users to view all experiment repetitions
+-- Previously, users could only see repetitions for experiments they created
+
+-- Drop the existing restrictive policy
+DROP POLICY IF EXISTS "Users can view experiment repetitions" ON public.experiment_repetitions;
+
+-- Create new policy that allows all authenticated users to view all repetitions
+CREATE POLICY "Users can view experiment repetitions" ON public.experiment_repetitions
+ FOR SELECT
+ TO authenticated
+ USING (true);