feat(offline+auth): enable those in webkit, make them a part of the core API (#346)

This commit is contained in:
Pavel Feldman 2019-12-30 14:09:54 -08:00 committed by Andrey Lushnikov
parent 654fa22cc7
commit 6a04e1f026
13 changed files with 91 additions and 67 deletions

View file

@ -144,6 +144,7 @@
* [page.$x(expression)](#pagexexpression) * [page.$x(expression)](#pagexexpression)
* [page.addScriptTag(options)](#pageaddscripttagoptions) * [page.addScriptTag(options)](#pageaddscripttagoptions)
* [page.addStyleTag(options)](#pageaddstyletagoptions) * [page.addStyleTag(options)](#pageaddstyletagoptions)
* [page.authenticate(credentials)](#pageauthenticatecredentials)
* [page.browserContext()](#pagebrowsercontext) * [page.browserContext()](#pagebrowsercontext)
* [page.click(selector[, options])](#pageclickselector-options) * [page.click(selector[, options])](#pageclickselector-options)
* [page.close([options])](#pagecloseoptions) * [page.close([options])](#pagecloseoptions)
@ -173,6 +174,7 @@
* [page.setDefaultNavigationTimeout(timeout)](#pagesetdefaultnavigationtimeouttimeout) * [page.setDefaultNavigationTimeout(timeout)](#pagesetdefaultnavigationtimeouttimeout)
* [page.setDefaultTimeout(timeout)](#pagesetdefaulttimeouttimeout) * [page.setDefaultTimeout(timeout)](#pagesetdefaulttimeouttimeout)
* [page.setExtraHTTPHeaders(headers)](#pagesetextrahttpheadersheaders) * [page.setExtraHTTPHeaders(headers)](#pagesetextrahttpheadersheaders)
* [page.setOfflineMode(enabled)](#pagesetofflinemodeenabled)
* [page.setRequestInterception(enabled)](#pagesetrequestinterceptionenabled) * [page.setRequestInterception(enabled)](#pagesetrequestinterceptionenabled)
* [page.setViewport(viewport)](#pagesetviewportviewport) * [page.setViewport(viewport)](#pagesetviewportviewport)
* [page.title()](#pagetitle) * [page.title()](#pagetitle)
@ -233,9 +235,6 @@
* [chromiumCoverage.startJSCoverage([options])](#chromiumcoveragestartjscoverageoptions) * [chromiumCoverage.startJSCoverage([options])](#chromiumcoveragestartjscoverageoptions)
* [chromiumCoverage.stopCSSCoverage()](#chromiumcoveragestopcsscoverage) * [chromiumCoverage.stopCSSCoverage()](#chromiumcoveragestopcsscoverage)
* [chromiumCoverage.stopJSCoverage()](#chromiumcoveragestopjscoverage) * [chromiumCoverage.stopJSCoverage()](#chromiumcoveragestopjscoverage)
- [class: ChromiumInterception](#class-chromiuminterception)
* [chromiumInterception.authenticate(credentials)](#chromiuminterceptionauthenticatecredentials)
* [chromiumInterception.setOfflineMode(enabled)](#chromiuminterceptionsetofflinemodeenabled)
- [class: ChromiumOverrides](#class-chromiumoverrides) - [class: ChromiumOverrides](#class-chromiumoverrides)
* [chromiumOverrides.setGeolocation(options)](#chromiumoverridessetgeolocationoptions) * [chromiumOverrides.setGeolocation(options)](#chromiumoverridessetgeolocationoptions)
- [class: ChromiumPlaywright](#class-chromiumplaywright) - [class: ChromiumPlaywright](#class-chromiumplaywright)
@ -1916,6 +1915,16 @@ Adds a `<link rel="stylesheet">` tag into the page with the desired url or a `<s
Shortcut for [page.mainFrame().addStyleTag(options)](#frameaddstyletagoptions). Shortcut for [page.mainFrame().addStyleTag(options)](#frameaddstyletagoptions).
#### page.authenticate(credentials)
- `credentials` <?[Object]>
- `username` <[string]>
- `password` <[string]>
- returns: <[Promise]>
Provide credentials for [HTTP authentication](https://developer.mozilla.org/en-US/docs/Web/HTTP/Authentication).
To disable authentication, pass `null`.
#### page.browserContext() #### page.browserContext()
- returns: <[BrowserContext]> - returns: <[BrowserContext]>
@ -2402,6 +2411,10 @@ The extra HTTP headers will be sent with every request the page initiates.
> **NOTE** page.setExtraHTTPHeaders does not guarantee the order of headers in the outgoing requests. > **NOTE** page.setExtraHTTPHeaders does not guarantee the order of headers in the outgoing requests.
#### page.setOfflineMode(enabled)
- `enabled` <[boolean]> When `true`, enables offline mode for the page.
- returns: <[Promise]>
#### page.setRequestInterception(enabled) #### page.setRequestInterception(enabled)
- `enabled` <[boolean]> Whether to enable request interception. - `enabled` <[boolean]> Whether to enable request interception.
- returns: <[Promise]> - returns: <[Promise]>
@ -3134,22 +3147,6 @@ _To output coverage in a form consumable by [Istanbul](https://github.com/istanb
> **NOTE** JavaScript Coverage doesn't include anonymous scripts by default. However, scripts with sourceURLs are > **NOTE** JavaScript Coverage doesn't include anonymous scripts by default. However, scripts with sourceURLs are
reported. reported.
### class: ChromiumInterception
#### chromiumInterception.authenticate(credentials)
- `credentials` <?[Object]>
- `username` <[string]>
- `password` <[string]>
- returns: <[Promise]>
Provide credentials for [HTTP authentication](https://developer.mozilla.org/en-US/docs/Web/HTTP/Authentication).
To disable authentication, pass `null`.
#### chromiumInterception.setOfflineMode(enabled)
- `enabled` <[boolean]> When `true`, enables offline mode for the page.
- returns: <[Promise]>
### class: ChromiumOverrides ### class: ChromiumOverrides
#### chromiumOverrides.setGeolocation(options) #### chromiumOverrides.setGeolocation(options)

View file

@ -10,7 +10,7 @@
"playwright": { "playwright": {
"chromium_revision": "724623", "chromium_revision": "724623",
"firefox_revision": "1008", "firefox_revision": "1008",
"webkit_revision": "1053" "webkit_revision": "1055"
}, },
"scripts": { "scripts": {
"unit": "node test/test.js", "unit": "node test/test.js",

View file

@ -8,6 +8,5 @@ export { CRPlaywright as ChromiumPlaywright } from './crPlaywright';
export { CRTarget as ChromiumTarget } from './crTarget'; export { CRTarget as ChromiumTarget } from './crTarget';
export { CRAccessibility as ChromiumAccessibility } from './features/crAccessibility'; export { CRAccessibility as ChromiumAccessibility } from './features/crAccessibility';
export { CRCoverage as ChromiumCoverage } from './features/crCoverage'; export { CRCoverage as ChromiumCoverage } from './features/crCoverage';
export { CRInterception as ChromiumInterception } from './features/crInterception';
export { CROverrides as ChromiumOverrides } from './features/crOverrides'; export { CROverrides as ChromiumOverrides } from './features/crOverrides';
export { CRWorker as ChromiumWorker } from './features/crWorkers'; export { CRWorker as ChromiumWorker } from './features/crWorkers';

View file

@ -21,6 +21,7 @@ import { assert, debugError, helper, RegisteredListener } from '../helper';
import { Protocol } from './protocol'; import { Protocol } from './protocol';
import * as network from '../network'; import * as network from '../network';
import * as frames from '../frames'; import * as frames from '../frames';
import { Credentials } from '../types';
export class CRNetworkManager { export class CRNetworkManager {
private _client: CRSession; private _client: CRSession;
@ -58,14 +59,12 @@ export class CRNetworkManager {
helper.removeEventListeners(this._eventListeners); helper.removeEventListeners(this._eventListeners);
} }
async authenticate(credentials: { username: string; password: string; } | null) { async authenticate(credentials: Credentials | null) {
this._credentials = credentials; this._credentials = credentials;
await this._updateProtocolRequestInterception(); await this._updateProtocolRequestInterception();
} }
async setOfflineMode(value: boolean) { async setOfflineMode(value: boolean) {
if (this._offline === value)
return;
this._offline = value; this._offline = value;
await this._client.send('Network.emulateNetworkConditions', { await this._client.send('Network.emulateNetworkConditions', {
offline: this._offline, offline: this._offline,

View file

@ -33,7 +33,6 @@ import { CRAccessibility } from './features/crAccessibility';
import { CRCoverage } from './features/crCoverage'; import { CRCoverage } from './features/crCoverage';
import { CRPDF, PDFOptions } from './features/crPdf'; import { CRPDF, PDFOptions } from './features/crPdf';
import { CRWorkers, CRWorker } from './features/crWorkers'; import { CRWorkers, CRWorker } from './features/crWorkers';
import { CRInterception } from './features/crInterception';
import { CRBrowser } from './crBrowser'; import { CRBrowser } from './crBrowser';
import { BrowserContext } from '../browserContext'; import { BrowserContext } from '../browserContext';
import * as types from '../types'; import * as types from '../types';
@ -302,6 +301,14 @@ export class CRPage implements PageDelegate {
await this._networkManager.setRequestInterception(enabled); await this._networkManager.setRequestInterception(enabled);
} }
async setOfflineMode(value: boolean) {
await this._networkManager.setOfflineMode(value);
}
async authenticate(credentials: types.Credentials | null) {
await this._networkManager.authenticate(credentials);
}
async reload(): Promise<void> { async reload(): Promise<void> {
await this._client.send('Page.reload'); await this._client.send('Page.reload');
} }
@ -456,7 +463,6 @@ export class CRPage implements PageDelegate {
export class ChromiumPage extends Page { export class ChromiumPage extends Page {
readonly accessibility: CRAccessibility; readonly accessibility: CRAccessibility;
readonly coverage: CRCoverage; readonly coverage: CRCoverage;
readonly interception: CRInterception;
private _pdf: CRPDF; private _pdf: CRPDF;
private _workers: CRWorkers; private _workers: CRWorkers;
_networkManager: CRNetworkManager; _networkManager: CRNetworkManager;
@ -468,7 +474,6 @@ export class ChromiumPage extends Page {
this._pdf = new CRPDF(client); this._pdf = new CRPDF(client);
this._workers = new CRWorkers(client, this, this._addConsoleMessage.bind(this), error => this.emit(Events.Page.PageError, error)); this._workers = new CRWorkers(client, this, this._addConsoleMessage.bind(this), error => this.emit(Events.Page.PageError, error));
this._networkManager = new CRNetworkManager(client, this); this._networkManager = new CRNetworkManager(client, this);
this.interception = new CRInterception(this._networkManager);
} }
async pdf(options?: PDFOptions): Promise<Buffer> { async pdf(options?: PDFOptions): Promise<Buffer> {

View file

@ -1,20 +0,0 @@
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
import { CRNetworkManager } from '../crNetworkManager';
export class CRInterception {
private _networkManager: CRNetworkManager;
constructor(networkManager: CRNetworkManager) {
this._networkManager = networkManager;
}
setOfflineMode(enabled: boolean) {
return this._networkManager.setOfflineMode(enabled);
}
async authenticate(credentials: { username: string; password: string; } | null) {
return this._networkManager.authenticate(credentials);
}
}

View file

@ -216,6 +216,14 @@ export class FFPage implements PageDelegate {
await this._networkManager.setRequestInterception(enabled); await this._networkManager.setRequestInterception(enabled);
} }
async setOfflineMode(enabled: boolean): Promise<void> {
throw new Error('Offline mode not implemented in Firefox');
}
async authenticate(credentials: types.Credentials): Promise<void> {
throw new Error('Offline mode not implemented in Firefox');
}
async reload(): Promise<void> { async reload(): Promise<void> {
await this._session.send('Page.reload', { frameId: this._page.mainFrame()._id }); await this._session.send('Page.reload', { frameId: this._page.mainFrame()._id });
} }

View file

@ -49,6 +49,8 @@ export interface PageDelegate {
setEmulateMedia(mediaType: input.MediaType | null, colorScheme: input.ColorScheme | null): Promise<void>; setEmulateMedia(mediaType: input.MediaType | null, colorScheme: input.ColorScheme | null): Promise<void>;
setCacheEnabled(enabled: boolean): Promise<void>; setCacheEnabled(enabled: boolean): Promise<void>;
setRequestInterception(enabled: boolean): Promise<void>; setRequestInterception(enabled: boolean): Promise<void>;
setOfflineMode(enabled: boolean): Promise<void>;
authenticate(credentials: types.Credentials | null): Promise<void>;
getBoundingBoxForScreenshot(handle: dom.ElementHandle<Node>): Promise<types.Rect | null>; getBoundingBoxForScreenshot(handle: dom.ElementHandle<Node>): Promise<types.Rect | null>;
canScreenshotOutsideViewport(): boolean; canScreenshotOutsideViewport(): boolean;
@ -73,6 +75,8 @@ type PageState = {
extraHTTPHeaders: network.Headers | null; extraHTTPHeaders: network.Headers | null;
cacheEnabled: boolean | null; cacheEnabled: boolean | null;
interceptNetwork: boolean | null; interceptNetwork: boolean | null;
offlineMode: boolean | null;
credentials: types.Credentials | null;
}; };
export type FileChooser = { export type FileChooser = {
@ -109,7 +113,9 @@ export class Page extends EventEmitter {
colorScheme: browserContext._options.colorScheme || null, colorScheme: browserContext._options.colorScheme || null,
extraHTTPHeaders: null, extraHTTPHeaders: null,
cacheEnabled: null, cacheEnabled: null,
interceptNetwork: null interceptNetwork: null,
offlineMode: null,
credentials: null
}; };
this.keyboard = new input.Keyboard(delegate.rawKeyboard); this.keyboard = new input.Keyboard(delegate.rawKeyboard);
this.mouse = new input.Mouse(delegate.rawMouse, this.keyboard); this.mouse = new input.Mouse(delegate.rawMouse, this.keyboard);
@ -401,6 +407,18 @@ export class Page extends EventEmitter {
await this._delegate.setRequestInterception(enabled); await this._delegate.setRequestInterception(enabled);
} }
async setOfflineMode(enabled: boolean) {
if (this._state.offlineMode === enabled)
return;
this._state.offlineMode = enabled;
await this._delegate.setOfflineMode(enabled);
}
async authenticate(credentials: types.Credentials | null) {
this._state.credentials = credentials;
await this._delegate.authenticate(credentials);
}
async screenshot(options?: types.ScreenshotOptions): Promise<Buffer> { async screenshot(options?: types.ScreenshotOptions): Promise<Buffer> {
return this._screenshotter.screenshotPage(options); return this._screenshotter.screenshotPage(options);
} }

View file

@ -51,3 +51,8 @@ export type Viewport = {
}; };
export type URLMatch = string | RegExp | ((url: kurl.URL) => boolean); export type URLMatch = string | RegExp | ((url: kurl.URL) => boolean);
export type Credentials = {
username: string;
password: string;
}

View file

@ -21,6 +21,7 @@ import { helper, RegisteredListener, assert } from '../helper';
import { Protocol } from './protocol'; import { Protocol } from './protocol';
import * as network from '../network'; import * as network from '../network';
import * as frames from '../frames'; import * as frames from '../frames';
import * as types from '../types';
export class WKNetworkManager { export class WKNetworkManager {
private _session: WKTargetSession; private _session: WKTargetSession;
@ -45,11 +46,15 @@ export class WKNetworkManager {
]; ];
} }
async initializeSession(session: WKTargetSession, enableInterception: boolean) { async initializeSession(session: WKTargetSession, interceptNetwork: boolean | null, offlineMode: boolean | null, credentials: types.Credentials | null) {
const promises = []; const promises = [];
promises.push(session.send('Network.enable')); promises.push(session.send('Network.enable'));
if (enableInterception) if (interceptNetwork)
promises.push(session.send('Network.setInterceptionEnabled', { enabled: true })); promises.push(session.send('Network.setInterceptionEnabled', { enabled: true }));
if (offlineMode)
promises.push(session.send('Network.setEmulateOfflineState', { offline: true }));
if (credentials)
promises.push(session.send('Emulation.setAuthCredentials', { ...credentials }));
await Promise.all(promises); await Promise.all(promises);
} }
@ -151,12 +156,12 @@ export class WKNetworkManager {
this._page._frameManager.requestFailed(request.request, event.errorText.includes('cancelled')); this._page._frameManager.requestFailed(request.request, event.errorText.includes('cancelled'));
} }
authenticate(credentials: { username: string; password: string; }) { async authenticate(credentials: types.Credentials | null) {
throw new Error('Not implemented'); await this._session.send('Emulation.setAuthCredentials', { ...(credentials || {}) });
} }
setOfflineMode(enabled: boolean) { async setOfflineMode(value: boolean): Promise<void> {
throw new Error('Not implemented'); await this._session.send('Network.setEmulateOfflineState', { offline: value });
} }
} }

View file

@ -85,7 +85,7 @@ export class WKPage implements PageDelegate {
session.send('Runtime.enable').then(() => this._ensureIsolatedWorld(UTILITY_WORLD_NAME)), session.send('Runtime.enable').then(() => this._ensureIsolatedWorld(UTILITY_WORLD_NAME)),
session.send('Console.enable'), session.send('Console.enable'),
session.send('Page.setInterceptFileChooserDialog', { enabled: true }), session.send('Page.setInterceptFileChooserDialog', { enabled: true }),
this._networkManager.initializeSession(session, this._page._state.interceptNetwork), this._networkManager.initializeSession(session, this._page._state.interceptNetwork, this._page._state.offlineMode, this._page._state.credentials),
]; ];
if (!session.isProvisional()) { if (!session.isProvisional()) {
// FIXME: move dialog agent to web process. // FIXME: move dialog agent to web process.
@ -309,6 +309,14 @@ export class WKPage implements PageDelegate {
return this._networkManager.setRequestInterception(enabled); return this._networkManager.setRequestInterception(enabled);
} }
async setOfflineMode(value: boolean) {
await this._networkManager.setOfflineMode(value);
}
async authenticate(credentials: types.Credentials | null) {
await this._networkManager.authenticate(credentials);
}
async reload(): Promise<void> { async reload(): Promise<void> {
await this._session.send('Page.reload'); await this._session.send('Page.reload');
} }

View file

@ -495,12 +495,12 @@ module.exports.describe = function({testRunner, expect, defaultBrowserOptions, p
}); });
}); });
describe.skip(FFOX || WEBKIT)('Interception.authenticate', function() { describe.skip(FFOX)('Interception.authenticate', function() {
it('should work', async({page, server}) => { it('should work', async({page, server}) => {
server.setAuth('/empty.html', 'user', 'pass'); server.setAuth('/empty.html', 'user', 'pass');
let response = await page.goto(server.EMPTY_PAGE); let response = await page.goto(server.EMPTY_PAGE);
expect(response.status()).toBe(401); expect(response.status()).toBe(401);
await page.interception.authenticate({ await page.authenticate({
username: 'user', username: 'user',
password: 'pass' password: 'pass'
}); });
@ -510,7 +510,7 @@ module.exports.describe = function({testRunner, expect, defaultBrowserOptions, p
it('should fail if wrong credentials', async({page, server}) => { it('should fail if wrong credentials', async({page, server}) => {
// Use unique user/password since Chrome caches credentials per origin. // Use unique user/password since Chrome caches credentials per origin.
server.setAuth('/empty.html', 'user2', 'pass2'); server.setAuth('/empty.html', 'user2', 'pass2');
await page.interception.authenticate({ await page.authenticate({
username: 'foo', username: 'foo',
password: 'bar' password: 'bar'
}); });
@ -520,34 +520,34 @@ module.exports.describe = function({testRunner, expect, defaultBrowserOptions, p
it('should allow disable authentication', async({page, server}) => { it('should allow disable authentication', async({page, server}) => {
// Use unique user/password since Chrome caches credentials per origin. // Use unique user/password since Chrome caches credentials per origin.
server.setAuth('/empty.html', 'user3', 'pass3'); server.setAuth('/empty.html', 'user3', 'pass3');
await page.interception.authenticate({ await page.authenticate({
username: 'user3', username: 'user3',
password: 'pass3' password: 'pass3'
}); });
let response = await page.goto(server.EMPTY_PAGE); let response = await page.goto(server.EMPTY_PAGE);
expect(response.status()).toBe(200); expect(response.status()).toBe(200);
await page.interception.authenticate(null); await page.authenticate(null);
// Navigate to a different origin to bust Chrome's credential caching. // Navigate to a different origin to bust Chrome's credential caching.
response = await page.goto(server.CROSS_PROCESS_PREFIX + '/empty.html'); response = await page.goto(server.CROSS_PROCESS_PREFIX + '/empty.html');
expect(response.status()).toBe(401); expect(response.status()).toBe(401);
}); });
}); });
describe.skip(FFOX || WEBKIT)('Interception.setOfflineMode', function() { describe.skip(FFOX)('Interception.setOfflineMode', function() {
it('should work', async({page, server}) => { it('should work', async({page, server}) => {
await page.interception.setOfflineMode(true); await page.setOfflineMode(true);
let error = null; let error = null;
await page.goto(server.EMPTY_PAGE).catch(e => error = e); await page.goto(server.EMPTY_PAGE).catch(e => error = e);
expect(error).toBeTruthy(); expect(error).toBeTruthy();
await page.interception.setOfflineMode(false); await page.setOfflineMode(false);
const response = await page.reload(); const response = await page.goto(server.EMPTY_PAGE);
expect(response.status()).toBe(200); expect(response.status()).toBe(200);
}); });
it('should emulate navigator.onLine', async({page, server}) => { it('should emulate navigator.onLine', async({page, server}) => {
expect(await page.evaluate(() => window.navigator.onLine)).toBe(true); expect(await page.evaluate(() => window.navigator.onLine)).toBe(true);
await page.interception.setOfflineMode(true); await page.setOfflineMode(true);
expect(await page.evaluate(() => window.navigator.onLine)).toBe(false); expect(await page.evaluate(() => window.navigator.onLine)).toBe(false);
await page.interception.setOfflineMode(false); await page.setOfflineMode(false);
expect(await page.evaluate(() => window.navigator.onLine)).toBe(true); expect(await page.evaluate(() => window.navigator.onLine)).toBe(true);
}); });
}); });

View file

@ -201,7 +201,7 @@ module.exports.describe = function({testRunner, expect, product, FFOX, CHROME, W
expect(await page.evaluate(() => ({ w: window.innerWidth, h: window.innerHeight }))).toEqual({ w: 500, h: 500 }); expect(await page.evaluate(() => ({ w: window.innerWidth, h: window.innerHeight }))).toEqual({ w: 500, h: 500 });
}); });
// Fails on GTK due to async setViewport. // Fails on GTK due to async setViewport.
it.skip(WEBKIT)('should capture full element when larger than viewport', async({page, server}) => { it('should capture full element when larger than viewport', async({page, server}) => {
await page.setViewport({width: 500, height: 500}); await page.setViewport({width: 500, height: 500});
await page.setContent(` await page.setContent(`