mirror of
https://github.com/multipleof4/sune.git
synced 2026-01-14 08:38:00 +00:00
Update sw.js
This commit is contained in:
GitHub
183
public/sw.js
183
public/sw.js
@@ -1,139 +1,90 @@
|
|||||||
// /sw.js
|
// /sw.js - minimal worker that reports if it was restarted (killed)
|
||||||
// Service worker that detects if it was restarted (killed) between pings.
|
'use strict';
|
||||||
// - Uses IndexedDB to persist restartCount and lastPingRestartCount
|
|
||||||
// - Replies to message {type: 'PING'} by responding on the provided MessagePort
|
|
||||||
// with a {type:'PONG', ...} payload the sune logs already.
|
|
||||||
|
|
||||||
// Basic small IDB helper (promisified key-value store)
|
const DB_NAME = 'sune-sw-db';
|
||||||
const DB_NAME = 'sune-sw-test-db';
|
|
||||||
const STORE = 'kv';
|
const STORE = 'kv';
|
||||||
|
const KEY = 'lastSession';
|
||||||
|
|
||||||
function openDb() {
|
// tiny IndexedDB helpers
|
||||||
|
function idbOpen() {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
const req = indexedDB.open(DB_NAME, 1);
|
const r = indexedDB.open(DB_NAME, 1);
|
||||||
req.onupgradeneeded = () => {
|
r.onupgradeneeded = () => {
|
||||||
const db = req.result;
|
r.result.createObjectStore(STORE);
|
||||||
if (!db.objectStoreNames.contains(STORE)) {
|
|
||||||
db.createObjectStore(STORE, { keyPath: 'k' });
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
req.onsuccess = () => resolve(req.result);
|
r.onsuccess = () => resolve(r.result);
|
||||||
req.onerror = () => reject(req.error);
|
r.onerror = () => reject(r.error || new Error('idb open error'));
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
function idbGet(key) {
|
||||||
async function idbGet(key) {
|
return idbOpen().then(db => new Promise((res, rej) => {
|
||||||
const db = await openDb();
|
|
||||||
return new Promise((resolve, reject) => {
|
|
||||||
const tx = db.transaction(STORE, 'readonly');
|
const tx = db.transaction(STORE, 'readonly');
|
||||||
const s = tx.objectStore(STORE);
|
const req = tx.objectStore(STORE).get(key);
|
||||||
const r = s.get(key);
|
req.onsuccess = () => res(req.result);
|
||||||
r.onsuccess = () => resolve(r.result ? r.result.v : undefined);
|
req.onerror = () => rej(req.error);
|
||||||
r.onerror = () => reject(r.error);
|
}));
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
function idbSet(key, val) {
|
||||||
async function idbPut(key, value) {
|
return idbOpen().then(db => new Promise((res, rej) => {
|
||||||
const db = await openDb();
|
|
||||||
return new Promise((resolve, reject) => {
|
|
||||||
const tx = db.transaction(STORE, 'readwrite');
|
const tx = db.transaction(STORE, 'readwrite');
|
||||||
const s = tx.objectStore(STORE);
|
const req = tx.objectStore(STORE).put(val, key);
|
||||||
const r = s.put({ k: key, v: value });
|
req.onsuccess = () => res(true);
|
||||||
r.onsuccess = () => resolve();
|
req.onerror = () => rej(req.error);
|
||||||
r.onerror = () => reject(r.error);
|
}));
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Instance info set at startup
|
// lightweight session identity
|
||||||
const INSTANCE_ID = (self.crypto && self.crypto.randomUUID) ? crypto.randomUUID() : String(Math.random()).slice(2);
|
const SESSION_ID = Date.now().toString(36) + '-' + Math.floor(Math.random() * 1e9).toString(36);
|
||||||
const STARTED_AT = Date.now();
|
const STARTED_AT = Date.now();
|
||||||
const VERSION = '1.0.0'; // bump if you change behavior
|
|
||||||
|
|
||||||
// Keys used in IDB
|
self.addEventListener('install', ev => {
|
||||||
const KEY_RESTART_COUNT = 'restartCount';
|
// activate immediately so the page can become controlled quickly
|
||||||
const KEY_LAST_PING_RESTART_COUNT = 'lastPingRestartCount';
|
|
||||||
const KEY_LAST_PING_TIME = 'lastPingTime';
|
|
||||||
|
|
||||||
// On install/activate: increment persistent restart counter so we can detect restarts.
|
|
||||||
self.addEventListener('install', (ev) => {
|
|
||||||
// activate immediately so testing is easier
|
|
||||||
self.skipWaiting();
|
self.skipWaiting();
|
||||||
});
|
});
|
||||||
|
|
||||||
self.addEventListener('activate', (ev) => {
|
self.addEventListener('activate', ev => {
|
||||||
ev.waitUntil((async () => {
|
// claim clients so the page becomes controlled without reload where possible
|
||||||
// claim clients quickly
|
ev.waitUntil(self.clients.claim());
|
||||||
await self.clients.claim();
|
|
||||||
|
|
||||||
try {
|
|
||||||
const current = (await idbGet(KEY_RESTART_COUNT)) || 0;
|
|
||||||
const next = current + 1;
|
|
||||||
await idbPut(KEY_RESTART_COUNT, next);
|
|
||||||
console.log(`[sw] activated — instance=${INSTANCE_ID} start=${new Date(STARTED_AT).toISOString()} restartCount=${next}`);
|
|
||||||
} catch (err) {
|
|
||||||
console.error('[sw] activate idb error', err);
|
|
||||||
}
|
|
||||||
})());
|
|
||||||
});
|
});
|
||||||
|
|
||||||
// Helper to reply on message port or broadcast fallback
|
// respond to messages (works with MessageChannel from the sune)
|
||||||
async function replyToMessage(event, payload) {
|
self.addEventListener('message', ev => {
|
||||||
// Prefer using provided MessagePort (sune sends one)
|
const data = ev.data || {};
|
||||||
if (event.ports && event.ports[0]) {
|
// only handle PING to keep this tiny
|
||||||
|
if (data.type !== 'PING') return;
|
||||||
|
|
||||||
|
const respond = async () => {
|
||||||
try {
|
try {
|
||||||
event.ports[0].postMessage(payload);
|
const last = await idbGet(KEY); // may be undefined on first run
|
||||||
return;
|
const restarted = !!last && last !== SESSION_ID; // true if there was a previous session different than this one
|
||||||
|
// store current session id for subsequent comparisons
|
||||||
|
await idbSet(KEY, SESSION_ID);
|
||||||
|
|
||||||
|
const payload = {
|
||||||
|
type: 'PONG',
|
||||||
|
ts: Date.now(),
|
||||||
|
sessionId: SESSION_ID,
|
||||||
|
lastSessionId: last || null,
|
||||||
|
restarted: restarted,
|
||||||
|
uptimeMs: Date.now() - STARTED_AT,
|
||||||
|
ok: true
|
||||||
|
};
|
||||||
|
|
||||||
|
// prefer replying on the provided port
|
||||||
|
if (ev.ports && ev.ports[0]) {
|
||||||
|
ev.ports[0].postMessage(payload);
|
||||||
|
} else {
|
||||||
|
// fallback: postMessage to all clients
|
||||||
|
const clients = await self.clients.matchAll({includeUncontrolled: true});
|
||||||
|
clients.forEach(c => c.postMessage(payload));
|
||||||
|
}
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.warn('[sw] reply via port failed', err);
|
const errPayload = {type:'PONG', ok:false, error: String(err), ts: Date.now()};
|
||||||
|
if (ev.ports && ev.ports[0]) ev.ports[0].postMessage(errPayload);
|
||||||
}
|
}
|
||||||
}
|
};
|
||||||
|
|
||||||
// Fallback: send to the client who sent the message (if event.source) or broadcast
|
// ensure the work completes even if the worker might otherwise be stopped
|
||||||
try {
|
if (ev.waitUntil) ev.waitUntil(Promise.resolve(respond()));
|
||||||
if (event.source && typeof event.source.postMessage === 'function') {
|
else respond();
|
||||||
event.source.postMessage(payload);
|
});
|
||||||
return;
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
// ignore
|
|
||||||
}
|
|
||||||
|
|
||||||
// Last resort: broadcast to all clients
|
|
||||||
const clients = await self.clients.matchAll({ includeUncontrolled: true });
|
|
||||||
for (const c of clients) {
|
|
||||||
try { c.postMessage(payload); } catch (e) { /* ignore per-client errors */ }
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Message handler
|
|
||||||
self.addEventListener('message', (event) => {
|
|
||||||
const data = event.data || {};
|
|
||||||
if (data && data.type === 'PING') {
|
|
||||||
(async () => {
|
|
||||||
try {
|
|
||||||
const now = Date.now();
|
|
||||||
const restartCount = (await idbGet(KEY_RESTART_COUNT)) || 0;
|
|
||||||
const lastPingRestartCount = (await idbGet(KEY_LAST_PING_RESTART_COUNT));
|
|
||||||
const lastPingTime = (await idbGet(KEY_LAST_PING_TIME)) || null;
|
|
||||||
|
|
||||||
// If there was a previously-recorded lastPingRestartCount and current restartCount
|
|
||||||
// is greater, that means the worker was restarted since the last ping.
|
|
||||||
const lostConnection = (typeof lastPingRestartCount !== 'undefined') && (restartCount > lastPingRestartCount);
|
|
||||||
|
|
||||||
// Build response payload
|
|
||||||
const payload = {
|
|
||||||
type: 'PONG',
|
|
||||||
ts: data.ts || null,
|
|
||||||
now,
|
|
||||||
sw: {
|
|
||||||
version: VERSION,
|
|
||||||
instanceId: INSTANCE_ID,
|
|
||||||
startedAt: STARTED_AT,
|
|
||||||
restartCount,
|
|
||||||
},
|
|
||||||
lastPing: {
|
|
||||||
time: lastPingTime,
|
|
||||||
lastPingRestartCount: lastPingRestartCount
|
|
||||||
},
|
|
||||||
lostConnectionSinceLastPing: !!lostConnection,
|
|
||||||
note: lostConnection ? '
|
|
||||||
|
|||||||
Reference in New Issue
Block a user