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

chore: code cleanup

Browse source
This commit is contained in:
Percs 2024-11-02 17:57:26 -05:00
parent e4a0ee9ac0
commit 7de29b7cf3
2 changed files with 4 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/client/shared/requests/xmlhttprequest.ts
View file

@ -1,18 +1,11 @@
import { flagEnabled } from "../../../scramjet"; import { flagEnabled } from "../../../scramjet";
import { config, unrewriteUrl, rewriteUrl } from "../../../shared"; import { config, unrewriteUrl, rewriteUrl } from "../../../shared";
import { ScramjetClient } from "../../client"; import { ScramjetClient } from "../../client";
let nativeworker;
let postmessage;
if (self.Worker) {
nativeworker = Worker;
postmessage = Worker.prototype.postMessage;
}
export default function (client: ScramjetClient, self: Self) { export default function (client: ScramjetClient, self: Self) {
let worker; let worker;
if (self.Worker && flagEnabled("syncxhr", client.url)) { if (self.Worker && flagEnabled("syncxhr", client.url)) {
worker = new nativeworker(config.files.sync); worker = new client.natives["Worker"](config.files.sync);
} }
const ARGS = Symbol("xhr original args"); const ARGS = Symbol("xhr original args");
const HEADERS = Symbol("xhr headers"); const HEADERS = Symbol("xhr headers");
@ -50,7 +43,7 @@ export default function (client: ScramjetClient, self: Self) {
const sab = new SharedArrayBuffer(1024, { maxByteLength: 2147483647 }); const sab = new SharedArrayBuffer(1024, { maxByteLength: 2147483647 });
const view = new DataView(sab); const view = new DataView(sab);
postmessage.call(worker, { client.natives["Worker.prototype.postMessage"].call(worker, {
sab, sab,
args, args,
headers: ctx.this[HEADERS], headers: ctx.this[HEADERS],

9
src/client/shared/worker.ts
View file

@ -4,11 +4,6 @@ import { rewriteUrl } from "../../shared";
import type { MessageC2W } from "../../worker"; import type { MessageC2W } from "../../worker";
import { ScramjetClient } from "../client"; import { ScramjetClient } from "../client";
const sharedworkerpostmessage = MessagePort.prototype.postMessage;
let workerpostmessage;
if (self.Worker) {
workerpostmessage = Worker.prototype.postMessage;
}
export default function (client: ScramjetClient, self: typeof globalThis) { export default function (client: ScramjetClient, self: typeof globalThis) {
if (self.Worker) { if (self.Worker) {
client.Proxy("Worker", { client.Proxy("Worker", {
@ -26,7 +21,7 @@ export default function (client: ScramjetClient, self: typeof globalThis) {
(async () => { (async () => {
const port = await conn.getInnerPort(); const port = await conn.getInnerPort();
workerpostmessage.call( client.natives["Worker.prototype.postMessage"].call(
worker, worker,
{ {
$scramjet$type: "baremuxinit", $scramjet$type: "baremuxinit",
@ -71,7 +66,7 @@ export default function (client: ScramjetClient, self: typeof globalThis) {
(async () => { (async () => {
const port = await conn.getInnerPort(); const port = await conn.getInnerPort();
sharedworkerpostmessage.call( client.natives["MessagePort.prototype.postMessage"].call(
worker.port, worker.port,
{ {
$scramjet$type: "baremuxinit", $scramjet$type: "baremuxinit",