blob: d972c8c6a67a046996e0d0b1183f811c849a933c (
plain) (
blame)
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
|
import React from 'react'
import {AppState} from 'react-native'
import {MessagesEventBus} from '#/state/messages/events/agent'
import {useAgent, useSession} from '#/state/session'
const MessagesEventBusContext = React.createContext<MessagesEventBus | null>(
null,
)
export function useMessagesEventBus() {
const ctx = React.useContext(MessagesEventBusContext)
if (!ctx) {
throw new Error(
'useMessagesEventBus must be used within a MessagesEventBusProvider',
)
}
return ctx
}
export function MessagesEventBusProvider({
children,
}: {
children: React.ReactNode
}) {
const {currentAccount} = useSession()
if (!currentAccount) {
return (
<MessagesEventBusContext.Provider value={null}>
{children}
</MessagesEventBusContext.Provider>
)
}
return (
<MessagesEventBusProviderInner>{children}</MessagesEventBusProviderInner>
)
}
export function MessagesEventBusProviderInner({
children,
}: {
children: React.ReactNode
}) {
const {getAgent} = useAgent()
const [bus] = React.useState(
() =>
new MessagesEventBus({
agent: getAgent(),
}),
)
React.useEffect(() => {
bus.resume()
return () => {
bus.suspend()
}
}, [bus])
React.useEffect(() => {
const handleAppStateChange = (nextAppState: string) => {
if (nextAppState === 'active') {
bus.resume()
} else {
bus.background()
}
}
const sub = AppState.addEventListener('change', handleAppStateChange)
return () => {
sub.remove()
}
}, [bus])
return (
<MessagesEventBusContext.Provider value={bus}>
{children}
</MessagesEventBusContext.Provider>
)
}
|
