Some checks failed
Test examples / Test Examples (20) (push) Has been cancelled
Test examples / Test Examples (22) (push) Has been cancelled
Lock Threads / action (push) Has been cancelled
Trigger Release / start (push) Has been cancelled
Stale issue handler / stale (push) Has been cancelled
Update Font Data / create-pull-request (push) Has been cancelled
build-and-deploy / deploy-target (push) Has been cancelled
build-and-deploy / build (push) Has been cancelled
build-and-deploy / stable - aarch64-unknown-linux-musl - node@16 (push) Has been cancelled
build-and-deploy / stable - x86_64-unknown-linux-musl - node@16 (push) Has been cancelled
build-and-deploy / stable - aarch64-unknown-linux-gnu - node@16 (push) Has been cancelled
build-and-deploy / stable - x86_64-unknown-linux-gnu - node@16 (push) Has been cancelled
build-and-deploy / stable - aarch64-pc-windows-msvc - node@16 (push) Has been cancelled
build-and-deploy / stable - x86_64-pc-windows-msvc - node@16 (push) Has been cancelled
build-and-deploy / stable - aarch64-apple-darwin - node@16 (push) Has been cancelled
build-and-deploy / stable - x86_64-apple-darwin - node@16 (push) Has been cancelled
build-and-deploy / build-wasm (nodejs) (push) Has been cancelled
build-and-deploy / build-wasm (web) (push) Has been cancelled
build-and-deploy / Deploy preview tarball (push) Has been cancelled
build-and-deploy / Potentially publish release (push) Has been cancelled
build-and-deploy / publish-turbopack-npm-packages (push) Has been cancelled
build-and-deploy / Deploy examples (push) Has been cancelled
build-and-deploy / thank you, build (push) Has been cancelled
build-and-deploy / Upload Turbopack Bytesize metrics to Datadog (push) Has been cancelled
Rspack Next.js development integration tests / Rspack integration tests (push) Has been cancelled
Rspack Next.js production integration tests / Rspack integration tests (push) Has been cancelled
Turbopack Next.js development integration tests / Next.js integration tests (push) Has been cancelled
Turbopack Next.js production integration tests / Next.js integration tests (push) Has been cancelled
Update Rspack test manifest / Update and upload Rspack development test manifest (push) Has been cancelled
Update Rspack test manifest / Update and upload Rspack production test manifest (push) Has been cancelled
Upload bundler test manifests to areweturboyet.com / Upload test results (push) Has been cancelled
Update React / create-pull-request (push) Has been cancelled
test-e2e-project-reset-cron / reset-test-project (push) Has been cancelled
Notify about the top 15 issues/PRs/feature requests (most reacted) in the last 90 days / run (push) Has been cancelled
109 lines
3.0 KiB
TypeScript
109 lines
3.0 KiB
TypeScript
export function createTimeController() {
|
|
let fixedTime = Date.now()
|
|
|
|
return {
|
|
install: (browser) => {
|
|
return browser.eval(`
|
|
(() => {
|
|
const OriginalDate = Date;
|
|
const originalSetTimeout = globalThis.setTimeout;
|
|
const originalSetInterval = globalThis.setInterval;
|
|
const originalClearTimeout = globalThis.clearTimeout;
|
|
const originalClearInterval = globalThis.clearInterval;
|
|
|
|
let fixedTime = ${fixedTime};
|
|
let timerIdCounter = 1;
|
|
const timers = new Map();
|
|
|
|
// Override the Date constructor
|
|
globalThis.Date = class extends OriginalDate {
|
|
constructor(...args) {
|
|
if (args.length === 0) {
|
|
super(fixedTime);
|
|
} else {
|
|
super(...args);
|
|
}
|
|
}
|
|
|
|
static now() {
|
|
return fixedTime;
|
|
}
|
|
};
|
|
|
|
// Preserve static methods
|
|
Object.setPrototypeOf(globalThis.Date, OriginalDate);
|
|
|
|
// Override setTimeout
|
|
globalThis.setTimeout = function(callback, delay, ...args) {
|
|
const id = timerIdCounter++;
|
|
timers.set(id, {
|
|
callback,
|
|
args,
|
|
fireTime: fixedTime + (delay || 0),
|
|
interval: false
|
|
});
|
|
return id;
|
|
};
|
|
|
|
// Override setInterval
|
|
globalThis.setInterval = function(callback, delay, ...args) {
|
|
const id = timerIdCounter++;
|
|
timers.set(id, {
|
|
callback,
|
|
args,
|
|
fireTime: fixedTime + (delay || 0),
|
|
interval: true,
|
|
delay: delay || 0
|
|
});
|
|
return id;
|
|
};
|
|
|
|
// Override clearTimeout
|
|
globalThis.clearTimeout = function(id) {
|
|
timers.delete(id);
|
|
};
|
|
|
|
// Override clearInterval
|
|
globalThis.clearInterval = function(id) {
|
|
timers.delete(id);
|
|
};
|
|
|
|
// Add method to advance time
|
|
globalThis.__advanceTime = (ms) => {
|
|
fixedTime += ms;
|
|
|
|
// Fire any timers that should have fired
|
|
const toFire = [];
|
|
for (const [id, timer] of timers.entries()) {
|
|
if (timer.fireTime <= fixedTime) {
|
|
toFire.push({ id, timer });
|
|
}
|
|
}
|
|
|
|
for (const { id, timer } of toFire) {
|
|
try {
|
|
timer.callback(...timer.args);
|
|
} catch (e) {
|
|
console.error('Timer callback error:', e);
|
|
}
|
|
|
|
if (timer.interval) {
|
|
// Reschedule interval timer
|
|
timer.fireTime = fixedTime + timer.delay;
|
|
} else {
|
|
// Remove one-time timer
|
|
timers.delete(id);
|
|
}
|
|
}
|
|
};
|
|
})();
|
|
`)
|
|
},
|
|
|
|
advance: async (browser, ms: number) => {
|
|
fixedTime += ms
|
|
await browser.eval(`globalThis.__advanceTime(${ms})`)
|
|
},
|
|
}
|
|
}
|