import { EventName, MessageStatus, ExtensionType, ThreadMessage, events, } from '@janhq/core' import { ConversationalExtension, InferenceExtension } from '@janhq/core' import { useAtomValue, useSetAtom } from 'jotai' import { RefreshCcw, Copy, Trash2Icon, StopCircle } from 'lucide-react' import { twMerge } from 'tailwind-merge' import { toaster } from '@/containers/Toast' import useSendChatMessage from '@/hooks/useSendChatMessage' import { extensionManager } from '@/extension' import { deleteMessageAtom, getCurrentChatMessagesAtom, } from '@/helpers/atoms/ChatMessage.atom' import { activeThreadAtom } from '@/helpers/atoms/Conversation.atom' const MessageToolbar = ({ message }: { message: ThreadMessage }) => { const deleteMessage = useSetAtom(deleteMessageAtom) const thread = useAtomValue(activeThreadAtom) const messages = useAtomValue(getCurrentChatMessagesAtom) const { resendChatMessage } = useSendChatMessage() const onStopInferenceClick = async () => { await extensionManager .get(ExtensionType.Inference) ?.stopInference() setTimeout(() => { events.emit(EventName.OnMessageUpdate, { ...message, status: MessageStatus.Ready, }) }, 300) } const onDeleteClick = async () => { deleteMessage(message.id ?? '') if (thread) { await extensionManager .get(ExtensionType.Conversational) ?.writeMessages( thread.id, messages.filter((msg) => msg.id !== message.id) ) } } return (
{message.status === MessageStatus.Pending && (
)} {message.status !== MessageStatus.Pending && message.id === messages[messages.length - 1]?.id && (
)}
{ navigator.clipboard.writeText(message.content[0]?.text?.value ?? '') toaster({ title: 'Copied to clipboard', }) }} >
{message.status === MessageStatus.Ready && (
)}
) } export default MessageToolbar