Compare commits
6 commits
5669489dc9
...
c21d21015f
Author | SHA1 | Date | |
---|---|---|---|
Julien Oculi | c21d21015f | ||
Julien Oculi | 00c40f2569 | ||
Julien Oculi | 5716284c73 | ||
Julien Oculi | ae1b87c253 | ||
Julien Oculi | 654bc40358 | ||
Julien Oculi | 087843c800 |
13
islands/IsOnline.css
Normal file
13
islands/IsOnline.css
Normal file
|
@ -0,0 +1,13 @@
|
|||
.island__is_online {
|
||||
position: sticky;
|
||||
top: 0;
|
||||
width: 100%;
|
||||
text-align: center;
|
||||
padding: var(--_gap-half);
|
||||
/* invert accent color */
|
||||
background: hsl(from #82c91e calc(h + 180) s l / 1);
|
||||
font-family: var(--_font-family-accent);
|
||||
color: white;
|
||||
font-weight: bold;
|
||||
z-index: 9999;
|
||||
}
|
52
islands/IsOnline.tsx
Normal file
52
islands/IsOnline.tsx
Normal file
|
@ -0,0 +1,52 @@
|
|||
import { type Signal, useSignal } from '@preact/signals'
|
||||
import { useEffect } from 'preact/hooks'
|
||||
import { JSX } from 'preact'
|
||||
import { requestApi } from ':src/utils.ts'
|
||||
|
||||
type NetworkConnection = {
|
||||
addEventListener: (
|
||||
type: 'change',
|
||||
listener: (event: Event) => void | Promise<void>,
|
||||
) => void
|
||||
}
|
||||
|
||||
export default function IsOnline(
|
||||
{ online, offline }: { online?: string; offline: string },
|
||||
) {
|
||||
const status = useSignal(offline)
|
||||
const connection = 'connection' in navigator
|
||||
? navigator.connection as NetworkConnection
|
||||
: null
|
||||
|
||||
useEffect(() => {
|
||||
// Update connection status on network changes
|
||||
connection?.addEventListener('change', () => {
|
||||
updateNetworkStatus(status, online, offline)
|
||||
})
|
||||
// Update connection status on 1st load
|
||||
updateNetworkStatus(status, online, offline)
|
||||
// Update connection status on interval (10s)
|
||||
setInterval(() => updateNetworkStatus(status, online, offline), 10_000)
|
||||
})
|
||||
|
||||
return <>{status}</>
|
||||
}
|
||||
|
||||
async function updateNetworkStatus(
|
||||
status: Signal<JSX.Element>,
|
||||
online: string | undefined,
|
||||
offline: string,
|
||||
) {
|
||||
const isOnline = await requestApi<void, boolean>(
|
||||
'/serviceworker/is-online',
|
||||
'POST',
|
||||
).catch(() => false)
|
||||
|
||||
if (isOnline) {
|
||||
status.value = online === undefined
|
||||
? <span style={{ display: 'none' }}></span>
|
||||
: <span>{online}</span>
|
||||
} else {
|
||||
status.value = <span class={'island__is_online'}>{offline}</span>
|
||||
}
|
||||
}
|
|
@ -3,6 +3,7 @@ import { type PageProps } from '$fresh/server.ts'
|
|||
import { Footer } from ':components/Footer.tsx'
|
||||
import { Header } from ':components/Header.tsx'
|
||||
import { ProgressiveWebApp } from ':components/ProgressiveWebApp.tsx'
|
||||
import IsOnline from ':islands/IsOnline.tsx'
|
||||
|
||||
export default function App({ Component }: PageProps) {
|
||||
return (
|
||||
|
@ -42,6 +43,9 @@ export default function App({ Component }: PageProps) {
|
|||
</Head>
|
||||
<body>
|
||||
<Header />
|
||||
<IsOnline
|
||||
offline={'Vous êtes hors ligne / Serveur inaccessible'}
|
||||
/>
|
||||
<main f-client-nav>
|
||||
<Partial name='main'>
|
||||
<Component />
|
||||
|
|
9
routes/api/serviceworker/is-online.tsx
Normal file
9
routes/api/serviceworker/is-online.tsx
Normal file
|
@ -0,0 +1,9 @@
|
|||
import { SessionHandlers } from ':src/session/mod.ts'
|
||||
import { respondApi } from ':src/utils.ts'
|
||||
|
||||
export const handler: SessionHandlers = {
|
||||
POST() {
|
||||
// Check if server is online
|
||||
return respondApi<'success', true>('success', true)
|
||||
},
|
||||
}
|
|
@ -1,11 +1,16 @@
|
|||
import { expandGlob } from '$std/fs/mod.ts'
|
||||
import { SessionHandlers } from ':src/session/mod.ts'
|
||||
import { respondApi } from ':src/utils.ts'
|
||||
import { BUILD_ID } from '$fresh/src/server/build_id.ts'
|
||||
import { encodeBase64 } from '@std/encoding'
|
||||
|
||||
export type PrecacheResponse = { version: string; preCachedUrls: string[] }
|
||||
|
||||
// Updated only at server start
|
||||
const version = crypto.randomUUID()
|
||||
async function getVersion() {
|
||||
const versionBytes = new TextEncoder().encode(BUILD_ID)
|
||||
const versionHash = await crypto.subtle.digest('SHA-256', versionBytes)
|
||||
return encodeBase64(versionHash)
|
||||
}
|
||||
|
||||
export const handler: SessionHandlers = {
|
||||
async GET() {
|
||||
|
@ -13,6 +18,7 @@ export const handler: SessionHandlers = {
|
|||
const preCachedUrls: string[] = ['/', '/imports/markdown_css']
|
||||
const paths = ['/static/**', '/_fresh/static/**']
|
||||
const routes = '/routes/*/index.tsx'
|
||||
const version = await getVersion()
|
||||
|
||||
//Pre-cache routes
|
||||
for await (const route of expandGlob(routes, { root: '.' })) {
|
||||
|
|
|
@ -69,6 +69,7 @@ if (IS_SW) {
|
|||
})
|
||||
|
||||
self.addEventListener('push', (event) => {
|
||||
console.log('push')
|
||||
const { title, options } = (event.data?.json() ?? {}) as {
|
||||
title?: string
|
||||
options?: Partial<NotificationOptions>
|
||||
|
@ -86,11 +87,15 @@ async function fetchHandler(event: FetchEvent) {
|
|||
const method = event.request.method
|
||||
const preCachedUrls = await getPreCachedUrls()
|
||||
const cache = await getCache()
|
||||
// Cache will be updated on each request if version change
|
||||
updateCache()
|
||||
|
||||
// Cache first for "pre-cached-urls"
|
||||
if (preCachedUrls.includes(url.pathname) && method === 'GET') {
|
||||
const cached = await cache.match(event.request) ??
|
||||
await fetch(event.request).catch(() => null) ??
|
||||
await fetch(event.request).then((response) =>
|
||||
response.ok ? response : null
|
||||
).catch(() => null) ??
|
||||
await cache.match(event.request, { ignoreSearch: true })
|
||||
|
||||
if (cached === undefined) {
|
||||
|
@ -105,7 +110,12 @@ async function fetchHandler(event: FetchEvent) {
|
|||
|
||||
const response = fetch(event.request)
|
||||
.then((response) => {
|
||||
// Update cache
|
||||
if (!response.ok) {
|
||||
throw new Error(
|
||||
`failed to get request: [${response.status}] ${response.statusText}`,
|
||||
)
|
||||
}
|
||||
// Update cache if ok
|
||||
cache.put(event.request, response.clone())
|
||||
return response
|
||||
})
|
||||
|
@ -128,6 +138,29 @@ async function fetchHandler(event: FetchEvent) {
|
|||
return fetch(event.request)
|
||||
}
|
||||
|
||||
async function updateCache() {
|
||||
const serverVersion = await getServerCacheVersion()
|
||||
const clientVersion = await swStorage.getItem<string>('$sw.cache.version')
|
||||
if (clientVersion === null) return
|
||||
if (serverVersion === undefined) return
|
||||
if (clientVersion === serverVersion) return
|
||||
|
||||
// Open new pre-cache
|
||||
await openCache()
|
||||
// Delete old pre-cache
|
||||
caches.delete(clientVersion)
|
||||
}
|
||||
|
||||
async function getServerCacheVersion() {
|
||||
const response = await fetch('/api/serviceworker/precache').then(
|
||||
(response) => response.json() as Promise<ApiPayload<PrecacheResponse>>,
|
||||
)
|
||||
|
||||
if (response.kind === 'success') {
|
||||
return response.data.version
|
||||
}
|
||||
}
|
||||
|
||||
async function openCache() {
|
||||
const response = await fetch('/api/serviceworker/precache').then(
|
||||
(response) => response.json() as Promise<ApiPayload<PrecacheResponse>>,
|
||||
|
|
|
@ -13,3 +13,4 @@
|
|||
@import url('../../islands/MoreBox.css');
|
||||
@import url('../../islands/AiChatBox.css');
|
||||
@import url('../../islands/LoginForm.css');
|
||||
@import url('../../islands/IsOnline.css');
|
||||
|
|
Loading…
Reference in a new issue