discours.io/webapp
5
0
Fork 0
Code Issues Pull Requests Actions Projects Wiki Activity

no-sse

Browse Source
This commit is contained in:
tonyrewin 2022-12-16 11:30:03 +03:00
parent 6d0ae5662a
commit d9dfd61d50
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/context/inbox.tsx
View File

@ -1,10 +1,10 @@
import { Accessor, createMemo, JSX, onMount } from 'solid-js' import { Accessor, createMemo, JSX, onMount } from 'solid-js'
import { createContext, createSignal, useContext } from 'solid-js' import { createContext, createSignal, useContext } from 'solid-js'
import { createChatClient } from '../graphql/privateGraphQLClient' // import { createChatClient } from '../graphql/privateGraphQLClient'
import type { Chat, Message, MutationCreateMessageArgs } from '../graphql/types.gen' import type { Chat, Message, MutationCreateMessageArgs } from '../graphql/types.gen'
import { apiClient } from '../utils/apiClient' import { apiClient } from '../utils/apiClient'
import newMessage from '../graphql/subs/new-message' // import newMessage from '../graphql/subs/new-message'
import type { Client } from '@urql/core' // import type { Client } from '@urql/core'
import { pipe, subscribe } from 'wonka' import { pipe, subscribe } from 'wonka'
import { loadMessages } from '../stores/inbox' import { loadMessages } from '../stores/inbox'
@ -16,7 +16,7 @@ type InboxContextType = {
loadChats: () => Promise<void> loadChats: () => Promise<void>
getMessages?: (chatId: string) => Promise<void> getMessages?: (chatId: string) => Promise<void>
sendMessage?: (args: MutationCreateMessageArgs) => void sendMessage?: (args: MutationCreateMessageArgs) => void
unsubscribe: () => void // unsubscribe: () => void
} }
} }
@ -29,7 +29,7 @@ export function useInbox() {
export const InboxProvider = (props: { children: JSX.Element }) => { export const InboxProvider = (props: { children: JSX.Element }) => {
const [chats, setChats] = createSignal<Chat[]>([]) const [chats, setChats] = createSignal<Chat[]>([])
const [messages, setMessages] = createSignal<Message[]>([]) const [messages, setMessages] = createSignal<Message[]>([])
const subclient = createMemo<Client>(() => createChatClient()) // const subclient = createMemo<Client>(() => createChatClient())
const loadChats = async () => { const loadChats = async () => {
try { try {
const newChats = await apiClient.getChats({ limit: 50, offset: 0 }) const newChats = await apiClient.getChats({ limit: 50, offset: 0 })
@ -72,7 +72,7 @@ export const InboxProvider = (props: { children: JSX.Element }) => {
} }
const { unsubscribe } = pipe( const { unsubscribe } = pipe(
subclient().subscription(newMessage, {}), () => null, // subclient().subscription(newMessage, {}),
subscribe((result) => { subscribe((result) => {
console.info('[subscription]') console.info('[subscription]')
console.debug(result) console.debug(result)