Function createDeps

src/session/applyLocalQueryEvent.test.ts:28–77

(options?: {
  messages?: unknown[]
  conversationId?: string
  createConversationId?: () => string
  isFullscreen?: boolean
  onCompactBoundary?: () => void
})

}

function createDeps(options?: {
  messages?: unknown[]
  conversationId?: string
  createConversationId?: () => string
  isFullscreen?: boolean
  onCompactBoundary?: () => void
}): {
  deps: ApplyLocalQueryEventDeps
  getMessages: () => unknown[]
  getConversationId: () => string
  setConversationIdCalls: string[]
  removeTranscriptCalls: string[]
} {
  const messagesState = createState<unknown[]>(options?.messages ?? [])
  const streamModeState = createState<any>('idle')
  const streamingToolUsesState = createState<any[]>([])

  let conversationId = options?.conversationId ?? 'conversation-0'
  const setConversationIdCalls: string[] = []
  const removeTranscriptCalls: string[] = []
  let responseLength = 0

  const deps: ApplyLocalQueryEventDeps = {
    setMessages: messagesState.set,
    setConversationId: id => {
      conversationId = id
      setConversationIdCalls.push(id)
    },
    createConversationId: options?.createConversationId,
    setResponseLength: updater => {
      responseLength = updater(responseLength)
    },
    setStreamMode: streamModeState.set,
    setStreamingToolUses: streamingToolUsesState.set,
    removeTranscriptMessage: uuid => {
      removeTranscriptCalls.push(uuid)
    },
    onCompactBoundary: options?.onCompactBoundary,
    isFullscreen: options?.isFullscreen ?? false,
    streamAdapter: createTestStreamAdapter(),
  }

  return {
    deps,
    getMessages: messagesState.get,
    getConversationId: () => conversationId,
    setConversationIdCalls,
    removeTranscriptCalls,
  }
}

function createTestStreamAdapter(): LocalStreamMessageAdapter {
  return {