(value)
| 11 | const getActiveRunStorageKey = (threadId) => `active_run:${threadId}` |
| 12 | |
| 13 | const getThreadIdFromObject = (value) => { |
| 14 | if (!value || typeof value !== 'object') return '' |
| 15 | if (typeof value.thread_id === 'string' && value.thread_id.trim()) return value.thread_id.trim() |
| 16 | const nestedSources = [value.meta, value.metadata, value.configurable, value.stream_event] |
| 17 | for (const source of nestedSources) { |
| 18 | const nestedThreadId = getThreadIdFromObject(source) |
| 19 | if (nestedThreadId) return nestedThreadId |
| 20 | } |
| 21 | return '' |
| 22 | } |
| 23 | |
| 24 | const resolveChunkThreadId = ({ envelope, payload, chunk, fallbackThreadId }) => { |
| 25 | return ( |
no outgoing calls
no test coverage detected