95 lines
2.8 KiB
TypeScript
95 lines
2.8 KiB
TypeScript
import type { Accessor, JSX } from 'solid-js'
|
|
import { createContext, createSignal, useContext } from 'solid-js'
|
|
import type { Chat, Message, MutationCreateMessageArgs } from '../graphql/types.gen'
|
|
import { inboxClient } from '../utils/apiClient'
|
|
|
|
import { loadMessages } from '../stores/inbox'
|
|
|
|
type InboxContextType = {
|
|
chats: Accessor<Chat[]>
|
|
messages?: Accessor<Message[]>
|
|
actions: {
|
|
createChat: (members: number[], title: string) => Promise<{ chat: Chat }>
|
|
loadChats: () => Promise<void>
|
|
getMessages?: (chatId: string) => Promise<void>
|
|
sendMessage?: (args: MutationCreateMessageArgs) => void
|
|
// unsubscribe: () => void
|
|
}
|
|
}
|
|
|
|
const InboxContext = createContext<InboxContextType>()
|
|
|
|
export function useInbox() {
|
|
return useContext(InboxContext)
|
|
}
|
|
|
|
export const InboxProvider = (props: { children: JSX.Element }) => {
|
|
const [chats, setChats] = createSignal<Chat[]>([])
|
|
const [messages, setMessages] = createSignal<Message[]>([])
|
|
const eventSource = new EventSource('chat.discours.io/connect')
|
|
// TODO: call /disconnect some time
|
|
// eslint-disable-next-line unicorn/prefer-add-event-listener
|
|
eventSource.onmessage = function (event) {
|
|
const message = JSON.parse(event.data)
|
|
// TODO: Do something with the message
|
|
|
|
console.log(message)
|
|
}
|
|
|
|
eventSource.onerror = function (event) {
|
|
console.error('EventSource failed:', event)
|
|
// TODO: Implement reconnection logic if needed
|
|
}
|
|
const loadChats = async () => {
|
|
try {
|
|
const newChats = await apiClient.getChats({ limit: 50, offset: 0 })
|
|
setChats(newChats)
|
|
} catch (error) {
|
|
console.log(error)
|
|
}
|
|
}
|
|
|
|
const getMessages = async (chatId: string) => {
|
|
if (!chatId) return
|
|
try {
|
|
const response = await loadMessages({ chat: chatId })
|
|
setMessages(response as unknown as Message[])
|
|
} catch (error) {
|
|
console.error('[loadMessages]', error)
|
|
}
|
|
}
|
|
|
|
const sendMessage = async (args) => {
|
|
try {
|
|
const message = await apiClient.createMessage(args)
|
|
setMessages((prev) => [...prev, message])
|
|
const currentChat = chats().find((chat) => chat.id === args.chat)
|
|
setChats((prev) => [
|
|
...prev.filter((c) => c.id !== currentChat.id),
|
|
{ ...currentChat, updatedAt: message.createdAt }
|
|
])
|
|
} catch (error) {
|
|
console.error('[post message error]:', error)
|
|
}
|
|
}
|
|
|
|
const createChat = async (members: number[], title: string) => {
|
|
const chat = await apiClient.createChat({ members, title })
|
|
setChats((prevChats) => {
|
|
return [chat, ...prevChats]
|
|
})
|
|
return chat
|
|
}
|
|
|
|
const actions = {
|
|
createChat,
|
|
loadChats,
|
|
getMessages,
|
|
sendMessage
|
|
// unsubscribe // TODO: call unsubscribe some time!
|
|
}
|
|
|
|
const value: InboxContextType = { chats, messages, actions }
|
|
return <InboxContext.Provider value={value}>{props.children}</InboxContext.Provider>
|
|
}
|