File size: 1,444 Bytes
a0fcd39 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 | import { useState, useEffect, useRef, useCallback } from 'react'
export function useProcessingProgress(sessionId) {
const [progress, setProgress] = useState({})
const wsRef = useRef(null)
useEffect(() => {
if (!sessionId) return
// Connect to WebSocket
const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:'
const wsUrl = `${protocol}//${window.location.host}/api/ws/${sessionId}`
const ws = new WebSocket(wsUrl)
wsRef.current = ws
ws.onopen = () => {
console.log('WebSocket connected for session:', sessionId)
}
ws.onmessage = (event) => {
try {
const data = JSON.parse(event.data)
if (data.type === 'progress') {
setProgress(prev => ({
...prev,
[data.stem]: data.status
}))
} else if (data.type === 'complete') {
console.log('Processing complete in', data.total_time, 'seconds')
}
} catch (err) {
console.error('WebSocket message error:', err)
}
}
ws.onerror = (error) => {
console.error('WebSocket error:', error)
}
ws.onclose = () => {
console.log('WebSocket disconnected')
}
// Cleanup
return () => {
if (ws.readyState === WebSocket.OPEN) {
ws.close()
}
}
}, [sessionId])
const resetProgress = useCallback(() => {
setProgress({})
}, [])
return { progress, resetProgress }
}
|