117 lines
3.2 KiB
TypeScript
117 lines
3.2 KiB
TypeScript
import {
|
|
Assistant,
|
|
ConversationalExtension,
|
|
ExtensionTypeEnum,
|
|
Thread,
|
|
ThreadAssistantInfo,
|
|
ThreadState,
|
|
Model,
|
|
} from '@janhq/core'
|
|
import { atom, useSetAtom } from 'jotai'
|
|
|
|
import { selectedModelAtom } from '@/containers/DropdownListSidebar'
|
|
import { fileUploadAtom } from '@/containers/Providers/Jotai'
|
|
|
|
import { generateThreadId } from '@/utils/thread'
|
|
|
|
import useRecommendedModel from './useRecommendedModel'
|
|
|
|
import useSetActiveThread from './useSetActiveThread'
|
|
|
|
import { extensionManager } from '@/extension'
|
|
import {
|
|
threadsAtom,
|
|
threadStatesAtom,
|
|
updateThreadAtom,
|
|
setThreadModelParamsAtom,
|
|
} from '@/helpers/atoms/Thread.atom'
|
|
|
|
const createNewThreadAtom = atom(null, (get, set, newThread: Thread) => {
|
|
// create thread state for this new thread
|
|
const currentState = { ...get(threadStatesAtom) }
|
|
|
|
const threadState: ThreadState = {
|
|
hasMore: false,
|
|
waitingForResponse: false,
|
|
lastMessage: undefined,
|
|
}
|
|
currentState[newThread.id] = threadState
|
|
set(threadStatesAtom, currentState)
|
|
|
|
// add the new thread on top of the thread list to the state
|
|
const threads = get(threadsAtom)
|
|
set(threadsAtom, [newThread, ...threads])
|
|
})
|
|
|
|
export const useCreateNewThread = () => {
|
|
const createNewThread = useSetAtom(createNewThreadAtom)
|
|
const { setActiveThread } = useSetActiveThread()
|
|
const updateThread = useSetAtom(updateThreadAtom)
|
|
const setFileUpload = useSetAtom(fileUploadAtom)
|
|
const setSelectedModel = useSetAtom(selectedModelAtom)
|
|
const setThreadModelParams = useSetAtom(setThreadModelParamsAtom)
|
|
|
|
const { recommendedModel, downloadedModels } = useRecommendedModel()
|
|
|
|
const requestCreateNewThread = async (
|
|
assistant: Assistant,
|
|
model?: Model | undefined
|
|
) => {
|
|
const defaultModel = model ?? recommendedModel ?? downloadedModels[0]
|
|
|
|
const createdAt = Date.now()
|
|
const assistantInfo: ThreadAssistantInfo = {
|
|
assistant_id: assistant.id,
|
|
assistant_name: assistant.name,
|
|
tools: assistant.tools,
|
|
model: {
|
|
id: defaultModel?.id ?? '*',
|
|
settings: defaultModel?.settings ?? {},
|
|
parameters: defaultModel?.parameters ?? {},
|
|
engine: defaultModel?.engine,
|
|
},
|
|
instructions: assistant.instructions,
|
|
}
|
|
|
|
const threadId = generateThreadId(assistant.id)
|
|
const thread: Thread = {
|
|
id: threadId,
|
|
object: 'thread',
|
|
title: 'New Thread',
|
|
assistants: [assistantInfo],
|
|
created: createdAt,
|
|
updated: createdAt,
|
|
}
|
|
|
|
// add the new thread on top of the thread list to the state
|
|
//TODO: Why do we have thread list then thread states? Should combine them
|
|
createNewThread(thread)
|
|
|
|
setSelectedModel(defaultModel)
|
|
setThreadModelParams(thread.id, {
|
|
...defaultModel?.settings,
|
|
...defaultModel?.parameters,
|
|
})
|
|
|
|
// Delete the file upload state
|
|
setFileUpload([])
|
|
// Update thread metadata
|
|
await updateThreadMetadata(thread)
|
|
|
|
setActiveThread(thread)
|
|
}
|
|
|
|
async function updateThreadMetadata(thread: Thread) {
|
|
updateThread(thread)
|
|
|
|
await extensionManager
|
|
.get<ConversationalExtension>(ExtensionTypeEnum.Conversational)
|
|
?.saveThread(thread)
|
|
}
|
|
|
|
return {
|
|
requestCreateNewThread,
|
|
updateThreadMetadata,
|
|
}
|
|
}
|