forked from coracle/flotilla
Jon Staab
83 lines
2.5 KiB
Svelte
83 lines
2.5 KiB
Svelte
<script lang="ts">
|
|
import {onMount} from "svelte"
|
|
import {page} from "$app/stores"
|
|
import {ago, MONTH} from "@welshman/lib"
|
|
import {GROUPS, THREAD, COMMENT, MESSAGE, DELETE} from "@welshman/util"
|
|
import {subscribe, load} from "@welshman/app"
|
|
import Page from "@lib/components/Page.svelte"
|
|
import SecondaryNav from "@lib/components/SecondaryNav.svelte"
|
|
import MenuSpace from "@app/components/MenuSpace.svelte"
|
|
import SpaceAuthError from "@app/components/SpaceAuthError.svelte"
|
|
import {pushToast} from "@app/toast"
|
|
import {pushModal} from "@app/modal"
|
|
import {setChecked} from "@app/notifications"
|
|
import {checkRelayConnection, checkRelayAuth, checkRelayAccess} from "@app/commands"
|
|
import {decodeRelay, userRoomsByUrl} from "@app/state"
|
|
import {pullConservatively} from "@app/requests"
|
|
import {notifications} from "@app/notifications"
|
|
|
|
const url = decodeRelay($page.params.relay)
|
|
|
|
const rooms = Array.from($userRoomsByUrl.get(url) || [])
|
|
|
|
const checkConnection = async () => {
|
|
const connectionError = await checkRelayConnection(url)
|
|
|
|
if (connectionError) {
|
|
return pushToast({theme: "error", message: connectionError})
|
|
}
|
|
|
|
const [authError, accessError] = await Promise.all([checkRelayAuth(url), checkRelayAccess(url)])
|
|
|
|
const error = authError || accessError
|
|
|
|
if (error) {
|
|
pushModal(SpaceAuthError, {url, error})
|
|
}
|
|
}
|
|
|
|
// We have to watch this one, since on mobile the badge will be visible when active
|
|
$: {
|
|
if ($notifications.has($page.url.pathname)) {
|
|
setChecked($page.url.pathname)
|
|
}
|
|
}
|
|
|
|
onMount(() => {
|
|
checkConnection()
|
|
|
|
const relays = [url]
|
|
const since = ago(MONTH)
|
|
|
|
// Load all groups for this space to populate navigation. It would be nice to sync, but relay29
|
|
// is too picky about how requests are built.
|
|
load({relays, filters: [{kinds: [GROUPS]}], delay: 0})
|
|
|
|
// Load threads, comments, and recent messages for user rooms to help with a quick page transition
|
|
pullConservatively({
|
|
relays,
|
|
filters: [
|
|
{kinds: [THREAD], since},
|
|
{kinds: [COMMENT], "#K": [String(THREAD)], since},
|
|
...rooms.map(r => ({kinds: [MESSAGE], "#h": [r], since})),
|
|
],
|
|
})
|
|
|
|
// Listen for deletes that would apply to messages we already have, and new groups
|
|
const sub = subscribe({relays, filters: [{kinds: [DELETE, GROUPS], since}]})
|
|
|
|
return () => {
|
|
sub.close()
|
|
}
|
|
})
|
|
</script>
|
|
|
|
<SecondaryNav>
|
|
<MenuSpace {url} />
|
|
</SecondaryNav>
|
|
<Page>
|
|
{#key $page.url.pathname}
|
|
<slot />
|
|
{/key}
|
|
</Page>
|