-
Notifications
You must be signed in to change notification settings - Fork 11
Expand file tree
/
Copy pathchat-interface.tsx
More file actions
246 lines (215 loc) · 8.31 KB
/
chat-interface.tsx
File metadata and controls
246 lines (215 loc) · 8.31 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
import { useState, useRef, FormEvent, useEffect, useMemo } from 'react'
import useWebSocket from 'react-use-websocket';
import { useAuth } from 'src/stores/auth'
import { Sidebar } from './sidebar'
import { useQuery } from '@tanstack/react-query'
import { chatQueries } from 'src/services/chat'
import { Spinner } from './spinner';
type Message = {
content: string
role: 'user' | 'assistant'
}
export const ChatInterface = () => {
const { data: chats } = useQuery(chatQueries.list())
const [messages, setMessages] = useState<Message[]>([])
const [inputMessage, setInputMessage] = useState('')
const [isSidebarOpen, setIsSidebarOpen] = useState(false)
const [isLoading, setIsLoading] = useState(false)
const [isConnectionError, setIsConnectionError] = useState(false)
const [, setStreamingContent] = useState('')
const chatHistoryRef = useRef<HTMLDivElement>(null)
const token = useAuth.use.token()
const webSocketUrl = useMemo(() => {
const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:'
const host = import.meta.env.DEV ? window.location.host : window.location.host
return `${protocol}//${host}/ws/chat/?token=${token}`
}, [token])
const {
sendJsonMessage,
lastJsonMessage,
readyState,
} = useWebSocket(webSocketUrl, {
onOpen: () => console.log('opened'),
//Will attempt to reconnect on all close events, such as server shutting down
shouldReconnect: (closeEvent) => true,
onError: (event) => {
console.error('WebSocket error:', event)
setIsConnectionError(true)
setIsLoading(false)
},
});
useEffect(() => {
if (readyState === WebSocket.OPEN) {
setIsLoading(false)
} else if (readyState === WebSocket.CLOSED) {
setIsLoading(false)
console.log('WebSocket is closed')
} else if (readyState === WebSocket.CONNECTING) {
console.log('WebSocket is connecting')
setIsLoading(true)
} else if (readyState === WebSocket.CLOSING) {
console.log('WebSocket is closing')
setIsLoading(true)
}
}, [readyState])
useEffect(() => {
if (lastJsonMessage) {
const data = lastJsonMessage as any
console.log('Last JSON message:', lastJsonMessage)
if (data.error) {
setMessages((prev) => {
const newMessages = [...prev]
const lastMessage = newMessages[newMessages.length - 1]
if (lastMessage?.role === 'assistant') {
lastMessage.content += `\nError: ${data.error}`
}
return newMessages
})
return
}
if (data.delta) {
// Handling streaming response
if (data.delta.content) {
setStreamingContent((prev) => {
const newContent = prev + data.delta.content
setMessages((messages) => {
const newMessages = [...messages]
newMessages[newMessages.length - 1].content = newContent
return newMessages
})
return newContent
})
}
} else if (data.message) {
// Handling regular response
setMessages((prev) => [...prev, { content: data.message.content, role: 'assistant' }])
}
}
}, [lastJsonMessage])
useEffect(() => {
// Scroll to bottom when messages change
chatHistoryRef.current?.scrollTo(0, chatHistoryRef.current.scrollHeight)
}, [messages])
const handleSubmit = async (e: FormEvent) => {
e.preventDefault()
const content = inputMessage.trim()
if (!content) return
// Add user message to conversation
const userMessage: Message = { content, role: 'user' }
setMessages((prev) => [...prev, userMessage])
setInputMessage('')
setStreamingContent('')
// Add empty assistant message that will be updated
setMessages((prev) => [...prev, { content: '', role: 'assistant' }])
// Send full conversation history through WebSocket
sendJsonMessage({
messages: [...messages, userMessage], // Include previous messages plus new user message
stream: true,
chat_id: chats?.results?.[0]?.id, // Use the first chat ID for now
})
}
const handleTextareaKeyDown = (e: React.KeyboardEvent<HTMLTextAreaElement>) => {
if (e.key === 'Enter' && !e.shiftKey) {
e.preventDefault()
handleSubmit(e as any)
}
}
// Add this new function to handle textarea height
const handleTextareaInput = (e: React.ChangeEvent<HTMLTextAreaElement>) => {
const textarea = e.target
setInputMessage(textarea.value)
// Reset height to auto to get the correct scrollHeight
textarea.style.height = 'auto'
// Set new height based on scrollHeight, capped at 5 lines (approximately 120px)
textarea.style.height = `${Math.min(textarea.scrollHeight, 120)}px`
}
return (
<div className="flex h-full">
<Sidebar isOpen={isSidebarOpen} onClose={() => setIsSidebarOpen(false)} />
<div className="flex flex-1 flex-col">
{/* Mobile Sidebar Toggle */}
<div className="border-b border-gray-200 p-4 lg:hidden">
<button
onClick={() => setIsSidebarOpen(true)}
className="flex items-center gap-2 text-sm text-gray-600 hover:text-primary"
>
<svg className="h-5 w-5" fill="none" stroke="currentColor" viewBox="0 0 24 24">
<path
strokeLinecap="round"
strokeLinejoin="round"
strokeWidth={2}
d="M4 6h16M4 12h16M4 18h16"
/>
</svg>
Menu
</button>
</div>
{/* Chat Loading Overlay */}
{(isLoading || isConnectionError) && (<div className="relative z-100 h-full w-full">
<div className="h-full w-full flex items-center justify-center bg-gray-100 opacity-50">
{
isLoading ? (<Spinner size='lg' />) : (
<div className="text-red-500">
<p>Connection Error</p>
<p>There is an error connecting, will retry.</p>
</div>
)
}
</div>
</div>)}
{/* Main Chat Area - Scrollable */}
<div className="flex flex-1 flex-col overflow-hidden">
<div ref={chatHistoryRef} className="flex-1 overflow-y-auto p-4">
<div className="mx-auto max-w-3xl">
{messages.map((message, index) => (
<div
key={index}
className={`mb-4 flex ${message.role === 'user' ? 'justify-end' : 'justify-start'
}`}
>
<div
className={`max-w-[80%] rounded-lg p-3 text-left ${message.role === 'user' ? 'bg-blue-50' : 'bg-gray-50'
}`}
>
{message.content}
</div>
</div>
))}
</div>
</div>
{/* Chat Input Area - Fixed at Bottom */}
<div className="border-t border-gray-200 bg-white">
<div className="mx-auto max-w-3xl">
<form onSubmit={handleSubmit} className="flex flex-col">
{/* Text Input */}
<div className="p-4 pb-2">
<textarea
value={inputMessage}
onChange={handleTextareaInput}
onKeyDown={handleTextareaKeyDown}
placeholder="Type your message..."
rows={1}
className="max-h-[120px] min-h-[40px] w-full resize-none overflow-y-auto rounded-lg border border-gray-300 px-4 py-2 focus:border-primary focus:outline-none focus:ring-1 focus:ring-primary"
required
/>
</div>
{/* Toolbar */}
<div className="flex items-center justify-between border-t border-gray-100 px-4 py-2">
<div className="flex items-center gap-2">
{/* Add more toolbar buttons here */}
</div>
<button
type="submit"
className="rounded-lg bg-primary px-6 py-2 text-white hover:bg-primaryLight focus:outline-none focus:ring-2 focus:ring-primary focus:ring-offset-2"
>
Send
</button>
</div>
</form>
</div>
</div>
</div>
</div>
</div>
)
}