mercuryworkshop-mirror/scramjet
1
0
Fork 0
mirror of https://github.com/MercuryWorkshop/scramjet.git synced 2025-05-15 07:20:02 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

nuke dataworker

Browse source
This commit is contained in:
velzie 2024-10-12 15:01:11 -04:00
parent 3062db5df9
commit 0edb4fcecf
1 changed files with 1 additions and 26 deletions
Download patch file Download diff file Expand all files Collapse all files

27
src/worker/index.ts
View file

@ -17,11 +17,6 @@ export class ScramjetServiceWorker extends EventTarget {
serviceWorkers: FakeServiceWorker[] = []; serviceWorkers: FakeServiceWorker[] = [];
dataworkerpromises: Record<
string,
{ promise: Promise<string>; resolve: (v: string) => void }
> = {};
constructor() { constructor() {
super(); super();
this.client = new self.$scramjet.shared.util.BareClient(); this.client = new self.$scramjet.shared.util.BareClient();
@ -42,17 +37,6 @@ export class ScramjetServiceWorker extends EventTarget {
return; return;
} }
if (data.scramjet$type === "dataworker") {
if (this.dataworkerpromises[data.id]) {
this.dataworkerpromises[data.id].resolve(data.data);
} else {
let resolve: (v: string) => void;
const promise = new Promise<string>((res) => (resolve = res));
this.dataworkerpromises[data.id] = { promise, resolve };
resolve(data.data);
}
}
}); });
} }
@ -145,21 +129,12 @@ type CookieMessage = {
url: string; url: string;
}; };
type DataWorkerMessage = {
scramjet$type: "dataworker";
data: string;
id: string;
};
type MessageCommon = { type MessageCommon = {
scramjet$type: string; scramjet$type: string;
scramjet$token: number; scramjet$token: number;
}; };
type MessageTypeC2W = type MessageTypeC2W = RegisterServiceWorkerMessage | CookieMessage;
| RegisterServiceWorkerMessage
| CookieMessage
| DataWorkerMessage;
type MessageTypeW2C = CookieMessage; type MessageTypeW2C = CookieMessage;
// c2w: client to (service) worker // c2w: client to (service) worker