83 lines
3.1 KiB
TypeScript
83 lines
3.1 KiB
TypeScript
 
|
/** Esegue il worker reale senza pagina, DOM, rete o stato lasciato dall'app. */
|
||
|
|
import assert from "node:assert/strict";
|
||
|
|
import { readFileSync } from "node:fs";
|
||
|
|
import { runInNewContext } from "node:vm";
|
||
|
|
|
||
|
|
const codice = readFileSync(new URL("../../public/push-sw.js", import.meta.url), "utf8");
|
||
|
|
type Evento = { data?: { json: () => unknown } | null; waitUntil: (p: Promise<unknown>) => void };
|
||
|
|
|
||
|
|
function avviaWorker() {
|
||
|
|
const listener = new Map<string, (event: Evento) => void>();
|
||
|
|
const notifiche: Array<{ titolo: string; opzioni: NotificationOptions }> = [];
|
||
|
|
let completa: (() => void) | undefined;
|
||
|
|
const mostrata = new Promise<void>((resolve) => (completa = resolve));
|
||
|
|
const installata = Promise.resolve();
|
||
|
|
const attivata = Promise.resolve();
|
||
|
|
runInNewContext(codice, {
|
||
|
|
self: {
|
||
|
|
addEventListener: (nome: string, callback: (event: Evento) => void) =>
|
||
|
|
listener.set(nome, callback),
|
||
|
|
skipWaiting: () => installata,
|
||
|
|
clients: {
|
||
|
|
claim: () => attivata,
|
||
|
|
matchAll: () => assert.fail("la push deve funzionare senza consultare finestre aperte"),
|
||
|
|
},
|
||
|
|
registration: {
|
||
|
|
showNotification(titolo: string, opzioni: NotificationOptions) {
|
||
|
|
notifiche.push({ titolo, opzioni });
|
||
|
|
return mostrata;
|
||
|
|
},
|
||
|
|
},
|
||
|
|
},
|
||
|
|
fetch: () => assert.fail("nessuna rete per mostrare la notifica"),
|
||
|
|
});
|
||
|
|
return { listener, notifiche, mostrata, completa: completa!, installata, attivata };
|
||
|
|
}
|
||
|
|
|
||
|
|
// L'installazione e l'attivazione tengono vivo il worker fino al completamento.
|
||
|
|
const avvio = avviaWorker();
|
||
|
|
for (const [nome, promessa] of [
|
||
|
|
["install", avvio.installata],
|
||
|
|
["activate", avvio.attivata],
|
||
|
|
] as const) {
|
||
|
|
let attesa: Promise<unknown> | undefined;
|
||
|
|
avvio.listener.get(nome)!({ waitUntil: (p) => (attesa = p) });
|
||
|
|
assert.equal(attesa, promessa, `${nome}: la promessa è collegata a waitUntil`);
|
||
|
|
await attesa;
|
||
|
|
}
|
||
|
|
|
||
|
|
const casi: Array<{ data: Evento["data"]; titolo: string; testo: string }> = [
|
||
|
|
{
|
||
|
|
data: { json: () => ({ title: "🏐 Palloni", body: "Sabato tocca a te." }) },
|
||
|
|
titolo: "🏐 Palloni",
|
||
|
|
testo: "Sabato tocca a te.",
|
||
|
|
},
|
||
|
|
{ data: null, titolo: "CrAPP", testo: "Apri l'app per i dettagli." },
|
||
|
|
{
|
||
|
|
data: {
|
||
|
|
json: () => {
|
||
|
|
throw new SyntaxError("payload non JSON");
|
||
|
|
},
|
||
|
|
},
|
||
|
|
titolo: "CrAPP",
|
||
|
|
testo: "Apri l'app per i dettagli.",
|
||
|
|
},
|
||
|
|
];
|
||
|
|
for (const { data, titolo, testo } of casi) {
|
||
|
|
// Nuovo contesto a ogni consegna: simula il risveglio dopo la terminazione del worker.
|
||
|
|
const worker = avviaWorker();
|
||
|
|
let attesa: Promise<unknown> | undefined;
|
||
|
|
worker.listener.get("push")!({ data, waitUntil: (p) => (attesa = p) });
|
||
|
|
assert.equal(worker.notifiche.length, 1, "mostra subito una notifica anche senza l'app");
|
||
|
|
assert.equal(attesa, worker.mostrata, "waitUntil copre tutta showNotification");
|
||
|
|
const notifica = worker.notifiche[0]!;
|
||
|
|
assert.equal(notifica.titolo, titolo);
|
||
|
|
assert.equal(notifica.opzioni.body, testo);
|
||
|
|
assert.ok(notifica.opzioni.tag, "il tag permette di sostituire la notifica precedente");
|
||
|
|
assert.equal(notifica.opzioni.renotify, true, "anche una sostituzione avvisa l'utente");
|
||
|
|
worker.completa();
|
||
|
|
await attesa;
|
||
|
|
}
|
||
|
|
|
||
|
|
console.log("push-sw: ok");
|