feat: implement network condition simulation in NetworkSimulator

This commit is contained in:
张翔
2026-03-05 15:10:02 +08:00
parent dd9ccfe8b3
commit 01d966bed3
2 changed files with 115 additions and 13 deletions
+62 -13
View File
@@ -35,25 +35,74 @@ export class NetworkSimulator {
}
async setNetworkCondition(config: NetworkConfig): Promise<void> {
const page = this.context.pages()[0];
if (!page) throw new Error('No page available');
const cdpSession = await this.context.newCDPSession(page);
if (config.offline) {
await this.context.setOffline(true);
await cdpSession.send('Network.emulateNetworkConditions', {
offline: true,
downloadThroughput: 0,
uploadThroughput: 0,
latency: 0,
});
} else {
await this.context.setOffline(false);
if (config.downloadThroughput && config.uploadThroughput && config.latency) {
await this.context.route('**', (route) => {
route.continue({
headers: {
...route.request().headers(),
},
});
});
}
await cdpSession.send('Network.emulateNetworkConditions', {
offline: false,
downloadThroughput: config.downloadThroughput,
uploadThroughput: config.uploadThroughput,
latency: config.latency,
});
}
}
async goOffline(): Promise<void> {
const page = this.context.pages()[0];
if (!page) throw new Error('No page available');
const cdpSession = await this.context.newCDPSession(page);
await cdpSession.send('Network.emulateNetworkConditions', {
offline: true,
downloadThroughput: 0,
uploadThroughput: 0,
latency: 0,
});
}
async goOnline(): Promise<void> {
const page = this.context.pages()[0];
if (!page) throw new Error('No page available');
const cdpSession = await this.context.newCDPSession(page);
await cdpSession.send('Network.emulateNetworkConditions', {
offline: false,
downloadThroughput: -1,
uploadThroughput: -1,
latency: 0,
});
}
async simulateNetworkSwitch(fromConfig: NetworkConfig, toConfig: NetworkConfig): Promise<void> {
await this.setNetworkCondition(fromConfig);
const page = this.context.pages()[0];
if (page) {
await page.waitForTimeout(1000);
}
await this.setNetworkCondition(toConfig);
}
async resetNetworkCondition(): Promise<void> {
await this.context.setOffline(false);
await this.context.unrouteAll();
const page = this.context.pages()[0];
if (!page) throw new Error('No page available');
const cdpSession = await this.context.newCDPSession(page);
await cdpSession.send('Network.emulateNetworkConditions', {
offline: false,
downloadThroughput: -1,
uploadThroughput: -1,
latency: 0,
});
}
getRequests(): NetworkRequest[] {