Skip to content

Commit

Permalink
[ServiceWorker] Add debugging outputs for event traces
Browse files Browse the repository at this point in the history
  • Loading branch information
Neet-Nestor committed May 22, 2024
1 parent f228d05 commit 55ca0f6
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 2 deletions.
3 changes: 3 additions & 0 deletions .prettierrc
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
{
"trailingComma": "all"
}
11 changes: 9 additions & 2 deletions src/service_worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ export class ServiceWorkerMLCEngineHandler extends MLCEngineWorkerHandler {
>();
private initReuqestUuid?: string;

constructor(engine: MLCEngineInterface, verbose = false) {
constructor(engine: MLCEngineInterface) {
if (!self || !("addEventListener" in self)) {
throw new Error(
"ServiceWorkerGlobalScope is not defined. ServiceWorkerMLCEngineHandler must be created in service worker script.",
Expand Down Expand Up @@ -90,6 +90,9 @@ export class ServiceWorkerMLCEngineHandler extends MLCEngineWorkerHandler {
onError?: () => void,
): void {
const msg = event.data as WorkerRequest;
console.debug(
`ServiceWorker message: [${msg.kind}] ${JSON.stringify(msg.content)}`,
);

if (msg.kind === "keepAlive") {
const reply: WorkerRequest = {
Expand Down Expand Up @@ -212,7 +215,7 @@ export async function CreateServiceWorkerMLCEngine(
export class ServiceWorkerMLCEngine extends WebWorkerMLCEngine {
missedHeatbeat = 0;

constructor(worker: IServiceWorker, keepAliveMs = 10000, verbose = false) {
constructor(worker: IServiceWorker, keepAliveMs = 10000) {
if (!("serviceWorker" in navigator)) {
throw new Error("Service worker API is not available");
}
Expand All @@ -223,6 +226,9 @@ export class ServiceWorkerMLCEngine extends WebWorkerMLCEngine {
"message",
(event: MessageEvent) => {
const msg = event.data;
console.debug(
`MLC client message: [${msg.kind}] ${JSON.stringify(msg.content)}`,
);
try {
if (msg.kind === "heartbeat") {
this.missedHeatbeat = 0;
Expand All @@ -241,6 +247,7 @@ export class ServiceWorkerMLCEngine extends WebWorkerMLCEngine {
setInterval(() => {
this.worker.postMessage({ kind: "keepAlive", uuid: crypto.randomUUID() });
this.missedHeatbeat += 1;
console.debug("missedHeatbeat", this.missedHeatbeat);
}, keepAliveMs);
}

Expand Down

0 comments on commit 55ca0f6

Please sign in to comment.