(threadId)
| 19 | } |
| 20 | |
| 21 | const getThreadState = (threadId) => { |
| 22 | if (!threadId) return null |
| 23 | if (!chatState.threadStates[threadId]) { |
| 24 | chatState.threadStates[threadId] = { |
| 25 | isStreaming: false, |
| 26 | runStreamAbortController: null, |
| 27 | activeRunId: null, |
| 28 | runLastSeq: '0-0', |
| 29 | lastRetryableJobTry: null, |
| 30 | replyLoadingVisible: false, |
| 31 | pendingRequestId: null, |
| 32 | pendingInterrupt: null, |
| 33 | onGoingConv: createOnGoingConvState(), |
| 34 | agentState: null |
| 35 | } |
| 36 | } |
| 37 | return chatState.threadStates[threadId] |
| 38 | } |
| 39 | |
| 40 | const stopThreadStream = (threadId) => { |
| 41 | if (!threadId) return |
no test coverage detected